Method write_commit

src/runtime/rpc/rpc_message.cpp:426–437

}

void message_ex::write_commit(size_t size)
{
    // printf("%p %s\n", this, __FUNCTION__);
    CHECK(!this->_rw_committed,
          "there are no pending msg write to be committed"
          ", please invoke dsn_msg_write_next and dsn_msg_write_commit in pairs");

    this->_rw_offset += (int)size;
    *this->buffers.rbegin() = this->buffers.rbegin()->range(0, (int)this->_rw_offset);
    this->_rw_committed = true;
    this->header->body_length += (int)size;
}

bool message_ex::read_next(void **ptr, size_t *size)
{