| 10 | namespace FBE { |
| 11 | |
| 12 | size_t Sender::send_serialized(size_t serialized) |
| 13 | { |
| 14 | assert((serialized > 0) && "Invalid size of the serialized buffer!"); |
| 15 | if (serialized == 0) |
| 16 | return 0; |
| 17 | |
| 18 | // Shift the send buffer |
| 19 | this->_buffer->shift(serialized); |
| 20 | |
| 21 | // Send the value |
| 22 | size_t sent = onSend(this->_buffer->data(), this->_buffer->size()); |
| 23 | this->_buffer->remove(0, sent); |
| 24 | return sent; |
| 25 | } |
| 26 | |
| 27 | void Receiver::receive(const void* data, size_t size) |
| 28 | { |