xio: fix to work with commit 626360aa

Fix xio to work with commit 626360aa
"msg, ceph_osd: Support feature bits for all message type's local connection"

Signed-off-by: Vu Pham <vu@mellanox.com>

diff --git a/src/msg/xio/XioConnection.cc b/src/msg/xio/XioConnection.cc
index 6a2ae2e1270bc4e2c870fde10032a5e3b5797b07..b8b62e24bbc26323b605a555a0732718be79448a 100644 (file)
--- a/src/msg/xio/XioConnection.cc
+++ b/src/msg/xio/XioConnection.cc
@@ -142,7 +142,7 @@ XioConnection::XioConnection(XioMessenger *m, XioConnection::type _type,
         " throttle_msgs: " << xopt << " throttle_bytes: " << bytes_opt << dendl;
 
   /* XXXX fake features, aieee! */
-  set_features(XIO_ALL_FEATURES);
+  set_features(m->local_features);
 }
 
 int XioConnection::send_message(Message *m)

diff --git a/src/msg/xio/XioMessenger.cc b/src/msg/xio/XioMessenger.cc
index ad87af181298e2342de8a146790b2eee50e6003e..24278e5466fd76fac9874bf44375f28f8422b2b8 100644 (file)
--- a/src/msg/xio/XioMessenger.cc
+++ b/src/msg/xio/XioMessenger.cc
@@ -250,8 +250,8 @@ static string xio_uri_from_entity(const string &type,
 
 /* XioMessenger */
 XioMessenger::XioMessenger(CephContext *cct, entity_name_t name,
-                          string mname, uint64_t _nonce,
-                          DispatchStrategy *ds, uint64_t features)
+                          string mname, uint64_t _nonce, uint64_t features,
+                          DispatchStrategy *ds)
   : SimplePolicyMessenger(cct, name, mname, _nonce),
     nsessions(0),
     shutdown_called(false),
@@ -379,7 +379,8 @@ XioMessenger::XioMessenger(CephContext *cct, entity_name_t name,
   /* update class instance count */
   nInstances.inc();
 
-  loop_con.set_features(features);
+  local_features = features;
+  loop_con->set_features(features);
 
 } /* ctor */
 

diff --git a/src/msg/xio/XioMessenger.h b/src/msg/xio/XioMessenger.h
index e1bfe9c334b8e89a71dd34228938205bdfaad6b0..d6bb5b5d22d9764ad643bdc2d340514d073bff81 100644 (file)
--- a/src/msg/xio/XioMessenger.h
+++ b/src/msg/xio/XioMessenger.h
@@ -53,8 +53,8 @@ private:
 
 public:
   XioMessenger(CephContext *cct, entity_name_t name,
-              string mname, uint64_t nonce,
-              DispatchStrategy* ds = new QueueStrategy(1), uint64_t features);
+              string mname, uint64_t nonce, uint64_t features,
+              DispatchStrategy* ds = new QueueStrategy(1));
 
   virtual ~XioMessenger();
 
@@ -151,6 +151,7 @@ protected:
     { }
 
 public:
+  uint64_t local_features;
 };
 
 #endif /* XIO_MESSENGER_H */

diff --git a/src/test/messenger/xio_client.cc b/src/test/messenger/xio_client.cc
index 29f807f9c25e159f22274f041f0aac9ef4baf579..414668f37e882e79cc1a2d2079b8b042e11dd763 100644 (file)
--- a/src/test/messenger/xio_client.cc
+++ b/src/test/messenger/xio_client.cc
@@ -117,7 +117,7 @@ int main(int argc, const char **argv)
        messenger = new XioMessenger(g_ceph_context,
                                     entity_name_t::MON(-1),
                                     "xio_client",
-                                    0 /* nonce */,
+                                    0 /* nonce */, XIO_ALL_FEATURES,
                                     dstrategy);
 
        // enable timing prints

diff --git a/src/test/messenger/xio_server.cc b/src/test/messenger/xio_server.cc
index ee74b791a61f8ef9aae1a7235912c459babcdd63..039aa7b1b70a8e2a426132e84360980c699879e2 100644 (file)
--- a/src/test/messenger/xio_server.cc
+++ b/src/test/messenger/xio_server.cc
@@ -88,7 +88,7 @@ int main(int argc, const char **argv)
        messenger = new XioMessenger(g_ceph_context,
                                     entity_name_t::MON(-1),
                                     "xio_server",
-                                    0 /* nonce */,
+                                    0 /* nonce */, XIO_ALL_FEATURES,
                                     dstrategy);
 
        static_cast<XioMessenger*>(messenger)->set_magic(