Change MPI setup to communicate TPR as buffer
[alexxy/gromacs.git] / src / gromacs / utility / inmemoryserializer.cpp
1 /*
2  * This file is part of the GROMACS molecular simulation package.
3  *
4  * Copyright (c) 2016,2017,2018,2019, by the GROMACS development team, led by
5  * Mark Abraham, David van der Spoel, Berk Hess, and Erik Lindahl,
6  * and including many others, as listed in the AUTHORS file in the
7  * top-level source directory and at http://www.gromacs.org.
8  *
9  * GROMACS is free software; you can redistribute it and/or
10  * modify it under the terms of the GNU Lesser General Public License
11  * as published by the Free Software Foundation; either version 2.1
12  * of the License, or (at your option) any later version.
13  *
14  * GROMACS is distributed in the hope that it will be useful,
15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
17  * Lesser General Public License for more details.
18  *
19  * You should have received a copy of the GNU Lesser General Public
20  * License along with GROMACS; if not, see
21  * http://www.gnu.org/licenses, or write to the Free Software Foundation,
22  * Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA.
23  *
24  * If you want to redistribute modifications to GROMACS, please
25  * consider that scientific software is very special. Version
26  * control is crucial - bugs must be traceable. We will be happy to
27  * consider code for inclusion in the official distribution, but
28  * derived work must not be called official GROMACS. Details are found
29  * in the README & COPYING files - if they are missing, get the
30  * official version at http://www.gromacs.org.
31  *
32  * To help us fund GROMACS development, we humbly ask that you cite
33  * the research papers on the package. Check out http://www.gromacs.org.
34  */
35 #include "gmxpre.h"
36
37 #include "inmemoryserializer.h"
38
39 #include <algorithm>
40 #include <vector>
41
42 #include "gromacs/utility/gmxassert.h"
43
44 namespace gmx
45 {
46
47 namespace
48 {
49
50 template <typename T>
51 class CharBuffer
52 {
53     public:
54         static const size_t ValueSize = sizeof(T);
55
56         explicit CharBuffer(T value)
57         {
58             u.v = value;
59         }
60         explicit CharBuffer(const char buffer[])
61         {
62             std::copy(buffer, buffer + ValueSize, u.c);
63         }
64
65         T value() const { return u.v; }
66
67         void appendTo(std::vector<char> *buffer)
68         {
69             buffer->insert(buffer->end(), u.c, u.c + ValueSize);
70         }
71
72     private:
73         union {
74             char c[ValueSize];
75             T    v;
76         } u;
77 };
78
79 }   // namespace
80
81 /********************************************************************
82  * InMemorySerializer
83  */
84
85 class InMemorySerializer::Impl
86 {
87     public:
88         template <typename T>
89         void doValue(T value)
90         {
91             CharBuffer<T>(value).appendTo(&buffer_);
92         }
93         void doString(const std::string &value)
94         {
95             doValue<size_t>(value.size());
96             buffer_.insert(buffer_.end(), value.begin(), value.end());
97         }
98
99         std::vector<char> buffer_;
100 };
101
102 InMemorySerializer::InMemorySerializer()
103     : impl_(new Impl)
104 {
105 }
106
107 InMemorySerializer::~InMemorySerializer()
108 {
109 }
110
111 std::vector<char> InMemorySerializer::finishAndGetBuffer()
112 {
113     return std::move(impl_->buffer_);
114 }
115
116 void InMemorySerializer::doBool(bool *value)
117 {
118     impl_->doValue(*value);
119 }
120
121 void InMemorySerializer::doUChar(unsigned char *value)
122 {
123     impl_->doValue(*value);
124 }
125
126 void InMemorySerializer::doChar(char *value)
127 {
128     impl_->doValue(*value);
129 }
130
131 void InMemorySerializer::doUShort(unsigned short *value)
132 {
133     impl_->doValue(*value);
134 }
135
136 void InMemorySerializer::doInt(int *value)
137 {
138     impl_->doValue(*value);
139 }
140
141 void InMemorySerializer::doInt32(int32_t *value)
142 {
143     impl_->doValue(*value);
144 }
145
146 void InMemorySerializer::doInt64(int64_t *value)
147 {
148     impl_->doValue(*value);
149 }
150
151 void InMemorySerializer::doFloat(float *value)
152 {
153     impl_->doValue(*value);
154 }
155
156 void InMemorySerializer::doDouble(double *value)
157 {
158     impl_->doValue(*value);
159 }
160
161 void InMemorySerializer::doReal(real *value)
162 {
163     impl_->doValue(*value);
164 }
165
166 void InMemorySerializer::doRvec(rvec *value)
167 {
168     for (int d = 0; d < DIM; d++)
169     {
170         doReal(&(*value)[d]);
171     }
172 }
173
174 void InMemorySerializer::doIvec(ivec *value)
175 {
176     for (int d = 0; d < DIM; d++)
177     {
178         doInt(&(*value)[d]);
179     }
180 }
181
182 void InMemorySerializer::doString(std::string *value)
183 {
184     impl_->doString(*value);
185 }
186
187 /********************************************************************
188  * InMemoryDeserializer
189  */
190
191 class InMemoryDeserializer::Impl
192 {
193     public:
194         explicit Impl(ArrayRef<const char> buffer, bool sourceIsDouble)
195             : buffer_(buffer), sourceIsDouble_(sourceIsDouble), pos_(0)
196         {
197         }
198
199         template <typename T>
200         void doValue(T *value)
201         {
202             *value = CharBuffer<T>(&buffer_[pos_]).value();
203             pos_  += CharBuffer<T>::ValueSize;
204         }
205         void doString(std::string *value)
206         {
207             size_t size;
208             doValue<size_t>(&size);
209             *value = std::string(&buffer_[pos_], size);
210             pos_  += size;
211         }
212
213         ArrayRef<const char>     buffer_;
214         bool                     sourceIsDouble_;
215         size_t                   pos_;
216 };
217
218 InMemoryDeserializer::InMemoryDeserializer(ArrayRef<const char> buffer, bool sourceIsDouble)
219     : impl_(new Impl(buffer, sourceIsDouble))
220 {
221 }
222
223 InMemoryDeserializer::~InMemoryDeserializer()
224 {
225 }
226
227 bool InMemoryDeserializer::sourceIsDouble() const
228 {
229     return impl_->sourceIsDouble_;
230 }
231
232 void InMemoryDeserializer::doBool(bool *value)
233 {
234     impl_->doValue(value);
235 }
236
237 void InMemoryDeserializer::doUChar(unsigned char *value)
238 {
239     impl_->doValue(value);
240 }
241
242 void InMemoryDeserializer::doChar(char *value)
243 {
244     impl_->doValue(value);
245 }
246
247 void InMemoryDeserializer::doUShort(unsigned short *value)
248 {
249     impl_->doValue(value);
250 }
251
252 void InMemoryDeserializer::doInt(int *value)
253 {
254     impl_->doValue(value);
255 }
256
257 void InMemoryDeserializer::doInt32(int32_t *value)
258 {
259     impl_->doValue(value);
260 }
261
262 void InMemoryDeserializer::doInt64(int64_t *value)
263 {
264     impl_->doValue(value);
265 }
266
267 void InMemoryDeserializer::doFloat(float *value)
268 {
269     impl_->doValue(value);
270 }
271
272 void InMemoryDeserializer::doDouble(double *value)
273 {
274     impl_->doValue(value);
275 }
276
277 void InMemoryDeserializer::doReal(real *value)
278 {
279     if (sourceIsDouble())
280     {
281         double temp = 0.0;
282         doDouble(&temp);
283         *value = temp;
284     }
285     else
286     {
287         float temp = 0.0;
288         doFloat(&temp);
289         *value = temp;
290     }
291 }
292
293 void InMemoryDeserializer::doRvec(rvec *value)
294 {
295     for (int d = 0; d < DIM; d++)
296     {
297         doReal(&(*value)[d]);
298     }
299 }
300
301 void InMemoryDeserializer::doIvec(ivec *value)
302 {
303     for (int d = 0; d < DIM; d++)
304     {
305         doInt(&(*value)[d]);
306     }
307 }
308
309 void InMemoryDeserializer::doString(std::string *value)
310 {
311     impl_->doString(value);
312 }
313
314 } // namespace gmx