From 8960e42ae07acce1bdbc79d3523fe76f3b64d3ef Mon Sep 17 00:00:00 2001 From: Jianpeng Ma Date: Thu, 26 Oct 2017 00:03:36 +0800 Subject: [PATCH] msg/async: batch handle out_seq. Signed-off-by: Jianpeng Ma --- src/msg/async/AsyncConnection.cc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/msg/async/AsyncConnection.cc b/src/msg/async/AsyncConnection.cc index 4c98bbe9e8587..3f09648d05783 100644 --- a/src/msg/async/AsyncConnection.cc +++ b/src/msg/async/AsyncConnection.cc @@ -1940,13 +1940,13 @@ void AsyncConnection::requeue_sent() return; list >& rq = out_q[CEPH_MSG_PRIO_HIGHEST]; + out_seq -= sent.size(); while (!sent.empty()) { Message* m = sent.back(); sent.pop_back(); ldout(async_msgr->cct, 10) << __func__ << " " << *m << " for resend " << " (" << m->get_seq() << ")" << dendl; rq.push_front(make_pair(bufferlist(), m)); - out_seq--; } } -- 2.39.5