reifydb_codec/encoded/
i16.rs1use std::ptr;
5
6use reifydb_value::{reifydb_assertions, value::value_type::ValueType};
7
8use crate::encoded::{row::EncodedRow, shape::RowShape};
9
10impl RowShape {
11 pub fn set_i16(&self, row: &mut EncodedRow, index: usize, value: impl Into<i16>) {
12 let field = &self.fields()[index];
13 reifydb_assertions! {
14 assert!(
15 row.len() >= self.total_static_size(),
16 "row/shape size mismatch: row.len()={} < total_static_size()={}",
17 row.len(),
18 self.total_static_size()
19 );
20 assert_eq!(*field.constraint.get_type().inner_type(), ValueType::Int2);
21 }
22 row.set_valid(index, true);
23 unsafe {
24 ptr::write_unaligned(
25 row.make_mut().as_mut_ptr().add(field.offset as usize) as *mut i16,
26 value.into(),
27 )
28 }
29 }
30
31 pub fn get_i16(&self, row: &EncodedRow, index: usize) -> i16 {
32 let field = &self.fields()[index];
33 reifydb_assertions! {
34 assert!(
35 row.len() >= self.total_static_size(),
36 "row/shape size mismatch: row.len()={} < total_static_size()={}",
37 row.len(),
38 self.total_static_size()
39 );
40 assert_eq!(*field.constraint.get_type().inner_type(), ValueType::Int2);
41 }
42 unsafe { (row.as_ptr().add(field.offset as usize) as *const i16).read_unaligned() }
43 }
44
45 pub fn try_get_i16(&self, row: &EncodedRow, index: usize) -> Option<i16> {
46 if row.is_defined(index) && self.fields()[index].constraint.get_type() == ValueType::Int2 {
47 Some(self.get_i16(row, index))
48 } else {
49 None
50 }
51 }
52}
53
54#[cfg(test)]
55pub mod tests {
56 use reifydb_value::value::value_type::ValueType;
57
58 use crate::encoded::shape::RowShape;
59
60 #[test]
61 fn test_set_get_i16() {
62 let shape = RowShape::testing(&[ValueType::Int2]);
63 let mut row = shape.allocate();
64 shape.set_i16(&mut row, 0, -1234i16);
65 assert_eq!(shape.get_i16(&row, 0), -1234i16);
66 }
67
68 #[test]
69 fn test_try_get_i16() {
70 let shape = RowShape::testing(&[ValueType::Int2]);
71 let mut row = shape.allocate();
72
73 assert_eq!(shape.try_get_i16(&row, 0), None);
74
75 shape.set_i16(&mut row, 0, -1234i16);
76 assert_eq!(shape.try_get_i16(&row, 0), Some(-1234i16));
77 }
78
79 #[test]
80 fn test_extremes() {
81 let shape = RowShape::testing(&[ValueType::Int2]);
82 let mut row = shape.allocate();
83
84 shape.set_i16(&mut row, 0, i16::MAX);
85 assert_eq!(shape.get_i16(&row, 0), i16::MAX);
86
87 let mut row2 = shape.allocate();
88 shape.set_i16(&mut row2, 0, i16::MIN);
89 assert_eq!(shape.get_i16(&row2, 0), i16::MIN);
90
91 let mut row3 = shape.allocate();
92 shape.set_i16(&mut row3, 0, 0i16);
93 assert_eq!(shape.get_i16(&row3, 0), 0i16);
94 }
95
96 #[test]
97 fn test_various_values() {
98 let shape = RowShape::testing(&[ValueType::Int2]);
99
100 let test_values = [-32768i16, -10000i16, -1i16, 0i16, 1i16, 10000i16, 32767i16];
101
102 for value in test_values {
103 let mut row = shape.allocate();
104 shape.set_i16(&mut row, 0, value);
105 assert_eq!(shape.get_i16(&row, 0), value);
106 }
107 }
108
109 #[test]
110 fn test_mixed_with_other_types() {
111 let shape = RowShape::testing(&[ValueType::Int2, ValueType::Int1, ValueType::Int2]);
112 let mut row = shape.allocate();
113
114 shape.set_i16(&mut row, 0, -30000i16);
115 shape.set_i8(&mut row, 1, 100i8);
116 shape.set_i16(&mut row, 2, 25000i16);
117
118 assert_eq!(shape.get_i16(&row, 0), -30000i16);
119 assert_eq!(shape.get_i8(&row, 1), 100i8);
120 assert_eq!(shape.get_i16(&row, 2), 25000i16);
121 }
122
123 #[test]
124 fn test_undefined_handling() {
125 let shape = RowShape::testing(&[ValueType::Int2, ValueType::Int2]);
126 let mut row = shape.allocate();
127
128 shape.set_i16(&mut row, 0, 1234i16);
129
130 assert_eq!(shape.try_get_i16(&row, 0), Some(1234));
131 assert_eq!(shape.try_get_i16(&row, 1), None);
132
133 shape.set_none(&mut row, 0);
134 assert_eq!(shape.try_get_i16(&row, 0), None);
135 }
136
137 #[test]
138 fn test_try_get_i16_wrong_type() {
139 let shape = RowShape::testing(&[ValueType::Boolean]);
140 let mut row = shape.allocate();
141
142 shape.set_bool(&mut row, 0, true);
143
144 assert_eq!(shape.try_get_i16(&row, 0), None);
145 }
146}