if (wpdu_.solong == wpdu_.buf.size())
return true;
- if (wpdu_.solong == 0) {
- rpc_sz_t sz = hton((rpc_sz_t)(wpdu_.buf.size() - sizeof(uint32_t)));
- copy((const char *)&sz, (const char *)(&sz+1), &wpdu_.buf[0]);
- }
ssize_t n = write(fd_, &wpdu_.buf[wpdu_.solong], (wpdu_.buf.size()-wpdu_.solong));
if (n < 0) {
if (errno != EAGAIN) {
VERIFY(rpdu_.buf.size() == 0);
rpdu_.buf = string(sz+sizeof(sz1), 0);
- copy((const char *)&sz1, (const char *)(&sz1 + 1), &rpdu_.buf[0]);
rpdu_.solong = sizeof(sz1);
}