@@ -220,11 +220,11 @@ struct SnapMessageBase {
220
220
tv_t received;
221
221
uint32_t size;
222
222
223
- int serialize (char *data, uint32_t size ) {
223
+ int serialize (char *data, uint32_t reqSize ) {
224
224
SnapWriteBuffer buffer;
225
225
int result = 0 ;
226
226
227
- buffer.begin (data, size );
227
+ buffer.begin (data, reqSize );
228
228
229
229
result |= buffer.write_uint16 (this ->type );
230
230
result |= buffer.write_uint16 (this ->id );
@@ -238,11 +238,11 @@ struct SnapMessageBase {
238
238
return result;
239
239
}
240
240
241
- int deserialize (const char *data, uint32_t size ) {
241
+ int deserialize (const char *data, uint32_t reqSize ) {
242
242
SnapReadBuffer buffer;
243
243
int result = 0 ;
244
244
245
- buffer.begin (data, size );
245
+ buffer.begin (data, reqSize );
246
246
247
247
result |= buffer.read_uint16 (&(this ->type ));
248
248
result |= buffer.read_uint16 (&(this ->id ));
@@ -359,12 +359,12 @@ struct SnapMessageCodecHeader {
359
359
char *payload () { return &v_payload[0 ]; }
360
360
char *codec () { return &v_codec[0 ]; }
361
361
362
- int deserialize (const char *data, uint32_t size ) {
362
+ int deserialize (const char *data, uint32_t reqSize ) {
363
363
SnapReadBuffer buffer;
364
364
uint32_t string_size;
365
365
int result = 0 ;
366
-
367
- buffer.begin (data, size );
366
+
367
+ buffer.begin (data, reqSize );
368
368
369
369
result |= buffer.read_uint32 (&string_size);
370
370
if (result) {
@@ -388,8 +388,8 @@ struct SnapMessageCodecHeader {
388
388
return 1 ;
389
389
}
390
390
391
- if (v_payload.size () < size )
392
- v_payload.resize (size );
391
+ if (v_payload.size () < reqSize )
392
+ v_payload.resize (reqSize );
393
393
394
394
result |= buffer.read (payload (), this ->size );
395
395
return result;
@@ -402,11 +402,11 @@ struct SnapMessageWireChunk {
402
402
uint32_t size;
403
403
char *payload = nullptr ;
404
404
405
- int deserialize (const char *data, uint32_t size ) {
405
+ int deserialize (const char *data, uint32_t reqSize ) {
406
406
SnapReadBuffer buffer;
407
407
int result = 0 ;
408
408
409
- buffer.begin (data, size );
409
+ buffer.begin (data, reqSize );
410
410
411
411
result |= buffer.read_int32 (&(this ->timestamp .sec ));
412
412
result |= buffer.read_int32 (&(this ->timestamp .usec ));
0 commit comments