RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-11 02:39:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

AsyncConnection: Discard all prefetch buffer when replacing

Browse Source 
Signed-off-by: Haomai Wang <haomaiwang@gmail.com>
This commit is contained in:
Haomai Wang 2015-04-12 15:01:50 +08:00
parent ea2edf36e1
commit 190ec03b83
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -1752,7 +1752,9 @@ int AsyncConnection::handle_connect_msg(ceph_msg_connect &connect, bufferlist &a
existing->replacing = true; existing->replacing = true;
existing->state_offset = 0; existing->state_offset = 0;
existing->state = STATE_ACCEPTING_WAIT_CONNECT_MSG; existing->state = STATE_ACCEPTING_WAIT_CONNECT_MSG;
// there should exist any buffer // Discard existing prefetch buffer in `recv_buf`
existing->recv_start = existing->recv_end = 0;
// there shouldn't exist any buffer
assert(recv_start == recv_end); assert(recv_start == recv_end);
if (existing->_reply_accept(CEPH_MSGR_TAG_RETRY_GLOBAL, connect, reply, authorizer_reply) < 0) { if (existing->_reply_accept(CEPH_MSGR_TAG_RETRY_GLOBAL, connect, reply, authorizer_reply) < 0) {