RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-04-01 23:02:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

AsyncConnection: Upper read_until log level

Browse Source 
Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
This commit is contained in:
Haomai Wang 2015-02-11 17:39:29 +08:00
parent a640ca9330
commit a70c1111d3
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/msg/async/AsyncConnection.cc
View File

@ -379,7 +379,7 @@ int AsyncConnection::_try_send(bufferlist send_bl, bool send)
int AsyncConnection::read_until(uint64_t len, char *p) int AsyncConnection::read_until(uint64_t len, char *p)
{ {
assert(len); assert(len);
ldout(async_msgr->cct, 20) << __func__ << " len is " << len << " state_offset is " ldout(async_msgr->cct, 25) << __func__ << " len is " << len << " state_offset is "
<< state_offset << dendl; << state_offset << dendl;
if (async_msgr->cct->_conf->ms_inject_socket_failures && sd >= 0) { if (async_msgr->cct->_conf->ms_inject_socket_failures && sd >= 0) {
@ -397,7 +397,7 @@ int AsyncConnection::read_until(uint64_t len, char *p)
memcpy(p, recv_buf+recv_start, to_read); memcpy(p, recv_buf+recv_start, to_read);
recv_start += to_read; recv_start += to_read;
left -= to_read; left -= to_read;
ldout(async_msgr->cct, 20) << __func__ << " got " << to_read << " in buffer " ldout(async_msgr->cct, 25) << __func__ << " got " << to_read << " in buffer "
<< " left is " << left << " buffer still has " << " left is " << left << " buffer still has "
<< recv_end - recv_start << dendl; << recv_end - recv_start << dendl;
if (left == 0) { if (left == 0) {
@ -413,7 +413,7 @@ int AsyncConnection::read_until(uint64_t len, char *p)
/* this was a large read, we don't prefetch for these */ /* this was a large read, we don't prefetch for these */
do { do {
r = read_bulk(sd, p+state_offset, left); r = read_bulk(sd, p+state_offset, left);
ldout(async_msgr->cct, 20) << __func__ << " read_bulk left is " << left << " got " << r << dendl; ldout(async_msgr->cct, 25) << __func__ << " read_bulk left is " << left << " got " << r << dendl;
if (r < 0) { if (r < 0) {
ldout(async_msgr->cct, 1) << __func__ << " read failed, state is " << get_state_name(state) << dendl; ldout(async_msgr->cct, 1) << __func__ << " read failed, state is " << get_state_name(state) << dendl;
return -1; return -1;
@ -427,7 +427,7 @@ int AsyncConnection::read_until(uint64_t len, char *p)
} else { } else {
do { do {
r = read_bulk(sd, recv_buf+recv_end, recv_max_prefetch); r = read_bulk(sd, recv_buf+recv_end, recv_max_prefetch);
ldout(async_msgr->cct, 20) << __func__ << " read_bulk recv_end is " << recv_end ldout(async_msgr->cct, 25) << __func__ << " read_bulk recv_end is " << recv_end
<< " left is " << left << " got " << r << dendl; << " left is " << left << " got " << r << dendl;
if (r < 0) { if (r < 0) {
ldout(async_msgr->cct, 1) << __func__ << " read failed, state is " << get_state_name(state) << dendl; ldout(async_msgr->cct, 1) << __func__ << " read failed, state is " << get_state_name(state) << dendl;
@ -446,7 +446,7 @@ int AsyncConnection::read_until(uint64_t len, char *p)
state_offset += (recv_end - recv_start); state_offset += (recv_end - recv_start);
recv_end = recv_start = 0; recv_end = recv_start = 0;
} }
ldout(async_msgr->cct, 20) << __func__ << " need len " << len << " remaining " ldout(async_msgr->cct, 25) << __func__ << " need len " << len << " remaining "
<< len - state_offset << " bytes, state is " << len - state_offset << " bytes, state is "
<< get_state_name(state) << dendl; << get_state_name(state) << dendl;
return len - state_offset; return len - state_offset;