mirror of
https://github.com/ceph/ceph
synced 2025-02-07 19:03:18 +00:00
msgr: small cleanup; hexdump code (disabled)
This commit is contained in:
parent
217533cc19
commit
52be66c1eb
@ -1635,6 +1635,41 @@ int SimpleMessenger::Pipe::do_sendmsg(int sd, struct msghdr *msg, int len)
|
||||
errno = EINTR;
|
||||
return -1; // close enough
|
||||
}
|
||||
|
||||
if (0) {
|
||||
// hex dump
|
||||
struct iovec *v = msg->msg_iov;
|
||||
size_t left = r;
|
||||
size_t vpos = 0;
|
||||
dout(0) << "do_sendmsg wrote " << r << " bytes, hexdump:\n";
|
||||
int pos = 0;
|
||||
int col = 0;
|
||||
char buf[20];
|
||||
while (left > 0) {
|
||||
if (col == 0) {
|
||||
sprintf(buf, "%05x : ", pos);
|
||||
*_dout << buf;
|
||||
}
|
||||
sprintf(buf, " %02x", ((unsigned char*)v->iov_base)[vpos]);
|
||||
*_dout << buf;
|
||||
left--;
|
||||
if (!left)
|
||||
break;
|
||||
vpos++;
|
||||
pos++;
|
||||
if (vpos == v->iov_len) {
|
||||
v++;
|
||||
vpos = 0;
|
||||
}
|
||||
col++;
|
||||
if (col == 16) {
|
||||
*_dout << "\n";
|
||||
col = 0;
|
||||
}
|
||||
}
|
||||
*_dout << dendl;
|
||||
}
|
||||
|
||||
len -= r;
|
||||
if (len == 0) break;
|
||||
|
||||
@ -1650,7 +1685,7 @@ int SimpleMessenger::Pipe::do_sendmsg(int sd, struct msghdr *msg, int len)
|
||||
} else {
|
||||
// partial!
|
||||
//dout(30) << "adjusting " << msg->msg_iov[0].iov_len << ", " << msg->msg_iovlen << " v, " << r << " left" << dendl;
|
||||
msg->msg_iov[0].iov_base = (void*)((long)msg->msg_iov[0].iov_base + r);
|
||||
msg->msg_iov[0].iov_base = (char *)msg->msg_iov[0].iov_base + r;
|
||||
msg->msg_iov[0].iov_len -= r;
|
||||
break;
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user