From a1753902dc3ab24a3cb63924041d92325b7e194e Mon Sep 17 00:00:00 2001 From: Haomai Wang Date: Mon, 12 Jan 2015 22:34:59 +0800 Subject: [PATCH] AsyncConnection: set state_offset=0 in case of reuse this connection Signed-off-by: Haomai Wang --- src/msg/async/AsyncConnection.cc | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc index 48c425d48d3dd..5673c179e16fc 100644 --- a/src/msg/async/AsyncConnection.cc +++ b/src/msg/async/AsyncConnection.cc @@ -1118,6 +1118,7 @@ int AsyncConnection::_process_connection() bufferlist authorizer_reply; if (connect_reply.authorizer_len) { ldout(async_msgr->cct, 10) << __func__ << " reply.authorizer_len=" << connect_reply.authorizer_len << dendl; + assert(connect_reply.authorizer_len < 4096); r = read_until(connect_reply.authorizer_len, state_buffer); if (r < 0) { ldout(async_msgr->cct, 1) << __func__ << " read connect reply authorizer failed" << dendl; @@ -1966,6 +1967,7 @@ void AsyncConnection::_stop() shutdown_socket(); discard_out_queue(); open_write = false; + state_offset = 0; state = STATE_CLOSED; if (sd > 0) ::close(sd); -- 2.39.5