]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/net: use parameter tag in handle_connect_reply()
authorYingxin <yingxin.cheng@intel.com>
Thu, 30 Aug 2018 10:04:51 +0000 (18:04 +0800)
committerYingxin <yingxin.cheng@intel.com>
Tue, 4 Sep 2018 10:39:03 +0000 (18:39 +0800)
Signed-off-by: Yingxin <yingxin.cheng@intel.com>
src/crimson/net/SocketConnection.cc

index e695e0ac61a3ef44a0942d82519c1f35e36ddff8..24fcd6fab99a460b088af66c34bf47b70a19e6b2 100644 (file)
@@ -691,7 +691,7 @@ seastar::future<> SocketConnection::handle_connect_reply(msgr_tag_t tag)
       missing) {
     return fault();
   }
-  if (h.reply.tag == CEPH_MSGR_TAG_SEQ) {
+  if (tag == CEPH_MSGR_TAG_SEQ) {
     return in.read_exactly(sizeof(seq_num_t))
       .then([this] (auto buf) {
         auto acked_seq = reinterpret_cast<const seq_num_t*>(buf.get());
@@ -704,7 +704,7 @@ seastar::future<> SocketConnection::handle_connect_reply(msgr_tag_t tag)
         return handle_connect_reply(CEPH_MSGR_TAG_READY);
       });
   }
-  if (h.reply.tag == CEPH_MSGR_TAG_READY) {
+  if (tag == CEPH_MSGR_TAG_READY) {
     // hooray!
     h.peer_global_seq = h.reply.global_seq;
     policy.lossy = h.reply.flags & CEPH_MSG_CONNECT_LOSSY;