OpenFPM_data  0.1.0
Project that contain the implementation and interfaces for basic structure like vectors, grids, graph ... .
 All Data Structures Namespaces Functions Variables Typedefs Friends
Packer_unit_tests.hpp
1 /*
2  * Packer_unit_tests.hpp
3  *
4  * Created on: Jul 15, 2015
5  * Author: Pietro Incardona
6  */
7 
8 #ifndef SRC_PACKER_UNIT_TESTS_HPP_
9 #define SRC_PACKER_UNIT_TESTS_HPP_
10 
11 #include "Pack_selector.hpp"
12 #include "Packer.hpp"
13 #include "Unpacker.hpp"
14 #include "Grid/grid_util_test.hpp"
15 #include <iostream>
16 #include "Vector/vector_test_util.hpp"
17 
18 BOOST_AUTO_TEST_SUITE( packer_unpacker )
19 
20 BOOST_AUTO_TEST_CASE ( packer_unpacker_test )
21 {
23 
24  int val = Pack_selector<unsigned char>::value;
25  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
26  val = Pack_selector<char>::value;
27  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
28  val = Pack_selector<short>::value;
29  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
30  val = Pack_selector<unsigned short>::value;
31  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
32  val = Pack_selector<int>::value;
33  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
34  val = Pack_selector<unsigned int>::value;
35  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
36  val = Pack_selector<long int>::value;
37  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
38  val = Pack_selector<unsigned long int>::value;
39  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
40  val = Pack_selector<float>::value;
41  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
42  val = Pack_selector<double>::value;
43  BOOST_REQUIRE_EQUAL(val,PACKER_PRIMITIVE);
44 
45  val = Pack_selector<Point_test<float>>::value;
46  BOOST_REQUIRE_EQUAL(val,PACKER_OBJECTS_WITH_POINTER_CHECK);
47 
48 
49  val = Pack_selector< openfpm::vector<Point_test<float>> >::value;
50  BOOST_REQUIRE_EQUAL(val,PACKER_VECTOR);
51  val = Pack_selector< grid_cpu<3,Point_test<float>> >::value;
52  BOOST_REQUIRE_EQUAL(val,PACKER_GRID);
53  val = Pack_selector< encapc<3,Point_test<float>, memory_traits_lin<Point_test<float>> > >::value;
54  BOOST_REQUIRE_EQUAL(val,PACKER_ENCAP_OBJECTS);
55 
56  struct test_s
57  {
58  float a;
59  float b;
60 
61  static bool noPointers() {return true;}
62  };
63 
64  val = Pack_selector< test_s >::value;
65  BOOST_REQUIRE_EQUAL(val,PACKER_OBJECTS_WITH_POINTER_CHECK);
66 
68 
69  {
70 
72 
73  typedef Point_test<float> pt;
74 
75  // Create all the objects we want to pack
76  unsigned char uc = 1;
77  char c = 2;
78  short s = 3;
79  unsigned short us = 4;
80  int i = 5;
81  unsigned int ui = 6;
82  long int li = 7;
83  unsigned long int uli = 8;
84  float f = 9;
85  double d = 10;
86 
87  openfpm::vector<Point_test<float>> v = allocate_openfpm(1024);
88 
89  Point_test<float> p;
90  p.fill();
91 
92  size_t sz[] = {16,16,16};
93  grid_cpu<3,Point_test<float>> g(sz);
94  g.setMemory();
95  fill_grid<3>(g);
96  grid_key_dx_iterator_sub<3> sub(g.getGrid(),{1,2,3},{5,6,7});
97 
98  // Here we start to push all the allocations required to pack all the data
99 
100  std::vector<size_t> pap_prp;
101 
102  Packer<unsigned char,HeapMemory>::packRequest(pap_prp);
103  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(unsigned char));
104  Packer<char,HeapMemory>::packRequest(pap_prp);
105  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(char));
106  Packer<short,HeapMemory>::packRequest(pap_prp);
107  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(short));
108  Packer<unsigned short,HeapMemory>::packRequest(pap_prp);
109  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(unsigned short));
110  Packer<int,HeapMemory>::packRequest(pap_prp);
111  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(int));
112  Packer<unsigned int,HeapMemory>::packRequest(pap_prp);
113  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(unsigned int));
114  Packer<long int,HeapMemory>::packRequest(pap_prp);
115  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(long int));
116  Packer<long unsigned int,HeapMemory>::packRequest(pap_prp);
117  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(long unsigned int));
118  Packer<float,HeapMemory>::packRequest(pap_prp);
119  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(float));
120  Packer<double,HeapMemory>::packRequest(pap_prp);
121  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],sizeof(double));
122  Packer<Point_test<float>,HeapMemory>::packRequest(pap_prp);
123  Packer<openfpm::vector<Point_test<float>>,HeapMemory>::packRequest<pt::x,pt::v>(v,pap_prp);
124  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],(sizeof(float) + sizeof(float[3])) * v.size());
125  Packer<grid_cpu<3,Point_test<float>>,HeapMemory>::packRequest<pt::x,pt::v>(g,sub,pap_prp);
126  BOOST_REQUIRE_EQUAL(pap_prp[pap_prp.size()-1],(sizeof(float) + sizeof(float[3])) * sub.getVolume());
127 
128  // Calculate how much preallocated memory we need to pack all the objects
129  size_t req = ExtPreAlloc<HeapMemory>::calculateMem(pap_prp);
130 
131  // allocate the memory
132  HeapMemory pmem;
133  pmem.allocate(req);
134  ExtPreAlloc<HeapMemory> & mem = *(new ExtPreAlloc<HeapMemory>(pap_prp,pmem));
135  mem.incRef();
136 
137  Pack_stat sts;
138 
139  // try to pack
140  Packer<unsigned char,HeapMemory>::pack(mem,1,sts);
141  Packer<char,HeapMemory>::pack(mem,2,sts);
142  Packer<short,HeapMemory>::pack(mem,3,sts);
143  Packer<unsigned short,HeapMemory>::pack(mem,4,sts);
144  Packer<int,HeapMemory>::pack(mem,5,sts);
145  Packer<unsigned int, HeapMemory>::pack(mem,6,sts);
146  Packer<long int,HeapMemory>::pack(mem,7,sts);
147  Packer<long unsigned int,HeapMemory>::pack(mem,8,sts);
148  Packer<float,HeapMemory>::pack(mem,9,sts);
149  Packer<double,HeapMemory>::pack(mem,10,sts);
150  Packer<Point_test<float>,HeapMemory>::pack(mem,p,sts);
151  Packer<openfpm::vector<Point_test<float>>,HeapMemory>::pack<pt::x,pt::v>(mem,v,sts);
152  Packer<grid_cpu<3,Point_test<float>>,HeapMemory>::pack<pt::x,pt::v>(mem,g,sub,sts);
153 
155 
157 
158  Unpack_stat ps;
159 
160  unsigned char uc2;
161  Unpacker<unsigned char,HeapMemory>::unpack(mem,uc2,ps);
162  char c2;
163  Unpacker<char,HeapMemory>::unpack(mem,c2,ps);
164  short s2;
165  Unpacker<short,HeapMemory>::unpack(mem,s2,ps);
166  unsigned short us2;
167  Unpacker<unsigned short,HeapMemory>::unpack(mem,us2,ps);
168  int i2;
169  Unpacker<int,HeapMemory>::unpack(mem,i2,ps);
170  unsigned int ui2;
171  Unpacker<unsigned int,HeapMemory>::unpack(mem,ui2,ps);
172  long int li2;
173  Unpacker<long int,HeapMemory>::unpack(mem,li2,ps);
174  unsigned long int uli2;
175  Unpacker<unsigned long int,HeapMemory>::unpack(mem,uli2,ps);
176  float f2;
177  Unpacker<float,HeapMemory>::unpack(mem,f2,ps);
178  double d2;
179  Unpacker<double,HeapMemory>::unpack(mem,d2,ps);
180 
181  // Unpack the point and check
182  Point_test<float> p_test;
183  Unpacker<Point_test<float>,HeapMemory>::unpack(mem,p_test,ps);
184 
185  // Unpack the vector and check
186  openfpm::vector<Point_test<float>> v_test;
187  v_test.resize(v.size());
188  Unpacker<openfpm::vector<Point_test<float>>,HeapMemory>::unpack<pt::x,pt::v>(mem,v_test,ps);
189 
191 
192  BOOST_REQUIRE_EQUAL(uc2,uc);
193  BOOST_REQUIRE_EQUAL(c2,c);
194  BOOST_REQUIRE_EQUAL(s2,s);
195  BOOST_REQUIRE_EQUAL(us2,us);
196  BOOST_REQUIRE_EQUAL(i2,i);
197  BOOST_REQUIRE_EQUAL(ui2,ui);
198  BOOST_REQUIRE_EQUAL(li2,li);
199  BOOST_REQUIRE_EQUAL(uli2,uli);
200  BOOST_REQUIRE_EQUAL(f2,f);
201  BOOST_REQUIRE_EQUAL(d2,d);
202 
203  bool val = (p_test == p);
204  BOOST_REQUIRE_EQUAL(true,val);
205 
206  auto it = v_test.getIterator();
207 
208  while (it.isNext())
209  {
210  float f1 = v_test.template get<pt::x>(it.get());
211  float f2 = v.template get<pt::x>(it.get());
212 
213  BOOST_REQUIRE_EQUAL(f1,f2);
214 
215  for (size_t i = 0 ; i < 3 ; i++)
216  {
217  f1 = v_test.template get<pt::v>(it.get())[i];
218  f2 = v.template get<pt::v>(it.get())[i];
219 
220  BOOST_REQUIRE_EQUAL(f1,f2);
221  }
222 
223  ++it;
224  }
225 
226  // Unpack the grid and check
227 
228  size_t sz2[] = {16,16,16};
229  grid_cpu<3,Point_test<float>> g_test(sz2);
230  g_test.setMemory();
231  grid_key_dx_iterator_sub<3> sub2(g_test.getGrid(),{1,2,3},{5,6,7});
232 
233  Unpacker<grid_cpu<3,Point_test<float>>,HeapMemory>::unpack<pt::x,pt::v>(mem,sub2,g_test,ps);
234 
235  // Check the unpacked grid
236  sub2.reset();
237 
238  while (sub2.isNext())
239  {
240  float f1 = g_test.template get<pt::x>(sub2.get());
241  float f2 = g.template get<pt::x>(sub2.get());
242 
243  BOOST_REQUIRE_EQUAL(f1,f2);
244 
245  for (size_t i = 0 ; i < 3 ; i++)
246  {
247  f1 = g_test.template get<pt::v>(sub2.get())[i];
248  f2 = g.template get<pt::v>(sub2.get())[i];
249 
250  BOOST_REQUIRE_EQUAL(f1,f2);
251  }
252 
253  ++sub2;
254  }
255 
256  // destroy the packed memory
257  mem.decRef();
258  delete &mem;
259 
261 
262  }
263 }
264 
265 BOOST_AUTO_TEST_SUITE_END()
266 
267 
268 
269 #endif /* SRC_PACKER_UNIT_TESTS_HPP_ */
grid_cpu
Definition: map_grid.hpp:98
memory_traits_lin
Transform the boost::fusion::vector into memory specification (memory_traits)
Definition: memory_conf.hpp:71
Unpacker
Unpacker class.
Definition: Unpacker.hpp:28
Pack_selector
Pack selector.
Definition: Pack_selector.hpp:131
grid_key_dx_iterator_sub::isNext
bool isNext()
Check if there is the next element.
Definition: grid_key_dx_iterator_sub.hpp:303
Point_test::fill
void fill()
fill
Definition: Point_test.hpp:227
Packer::packRequest
static size_t packRequest(std::vector< size_t > &req)
Error, no implementation.
Definition: Packer.hpp:61
grid_key_dx_iterator_sub::get
grid_key_dx< dim > get()
Return the actual grid key iterator.
Definition: grid_key_dx_iterator_sub.hpp:324
Packer
Packing class.
Definition: Packer.hpp:46
Unpack_stat
Unpacking status object.
Definition: Pack_stat.hpp:15
grid_key_dx_iterator_sub::reset
void reset()
Reset the iterator (it restart from the beginning)
Definition: grid_key_dx_iterator_sub.hpp:384
Unpacker::unpack
static void unpack(ExtPreAlloc< Mem >, T &obj)
Error, no implementation.
Definition: Unpacker.hpp:35
grid_key_dx_iterator_sub
Definition: grid_sm.hpp:71
Point_test
Test structure used for several test.
Definition: Point_test.hpp:72
openfpm::vector
Implementation of 1-D std::vector like structure.
Definition: map_grid.hpp:94
Pack_stat
Packing status object.
Definition: Pack_stat.hpp:49
Packer::pack
static void pack(ExtPreAlloc< Mem >, const T &obj)
Error, no implementation.
Definition: Packer.hpp:53