msgr: handle keepalive

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 195f4389bf31136db0810787f9034812ee1e0e73..554bc9a1231756fddd40b819159961bd1c674581 100644 (file)
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -1199,6 +1199,12 @@ void SimpleMessenger::Pipe::reader()
       continue;
     }
 
+    if (tag == CEPH_MSGR_TAG_KEEPALIVE) {
+      dout(20) << "reader got KEEPALIVE" << dendl;
+      lock.Lock();
+      continue;
+    }
+
     // open ...
     if (tag == CEPH_MSGR_TAG_ACK) {
       dout(20) << "reader got ACK" << dendl;