From: Yingxin Cheng Date: Thu, 20 Oct 2022 02:56:16 +0000 (+0800) Subject: crimson/net: set global_seq when get from Messenger X-Git-Tag: v18.1.0~967^2~5 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=207b010400ffaa7b5ccb6026b3336e3fe30d3e2b;p=ceph.git crimson/net: set global_seq when get from Messenger Signed-off-by: Yingxin Cheng --- diff --git a/src/crimson/net/ProtocolV2.cc b/src/crimson/net/ProtocolV2.cc index 7a4e3030f863..4df78bc2dcbc 100644 --- a/src/crimson/net/ProtocolV2.cc +++ b/src/crimson/net/ProtocolV2.cc @@ -1623,6 +1623,7 @@ ProtocolV2::send_server_ident() // refered to async-conn v2: not assign gs to global_seq return messenger.get_global_seq().then([this] (auto gs) { + global_seq = gs; logger().debug("{} UPDATE: gs={} for server ident", conn, global_seq); // this is required for the case when this connection is being replaced @@ -1641,7 +1642,7 @@ ProtocolV2::send_server_ident() auto server_ident = ServerIdentFrame::Encode( messenger.get_myaddrs(), messenger.get_myname().num(), - gs, + global_seq, conn.policy.features_supported, conn.policy.features_required | msgr2_required, flags, @@ -1651,7 +1652,7 @@ ProtocolV2::send_server_ident() " gs={}, features_supported={}, features_required={}," " flags={}, cookie={}", conn, messenger.get_myaddrs(), messenger.get_myname().num(), - gs, conn.policy.features_supported, + global_seq, conn.policy.features_supported, conn.policy.features_required | msgr2_required, flags, server_cookie);