}
bufferlist::iterator p = object_data.begin();
::decode(*object_size, p);
- ::decode(*op_size, p);
::decode(*num_objects, p);
::decode(*prevPid, p);
+ if (!p.end()) {
+ ::decode(*op_size, p);
+ } else {
+ *op_size = *object_size;
+ }
return 0;
}
}
//write object size/number data for read benchmarks
::encode(data.object_size, b_write);
- ::encode(data.op_size, b_write);
num_objects = (data.finished + writes_per_object - 1) / writes_per_object;
::encode(num_objects, b_write);
::encode(getpid(), b_write);
+ ::encode(data.op_size, b_write);
// persist meta-data for further cleanup or read
sync_write(run_name_meta, b_write, sizeof(int)*3);