librados: fix dispatch

diff --git a/src/librados.cc b/src/librados.cc
index a4d4cfce21b40fa98968c2275e4496dd3dfa3090..5013bab965d009cd160a239e9d5f052e76365c79 100644 (file)
--- a/src/librados.cc
+++ b/src/librados.cc
@@ -290,6 +290,8 @@ bool RadosClient::init()
     return false;
 
   monclient.set_messenger(messenger);
+  
+  messenger->add_dispatcher_head(this);
 
   rank.set_policy(entity_name_t::TYPE_MON, SimpleMessenger::Policy::lossy_fail_after(1.0));
   rank.set_policy(entity_name_t::TYPE_MDS, SimpleMessenger::Policy::lossless());
@@ -309,6 +311,7 @@ bool RadosClient::init()
 
   objecter->set_client_incarnation(0);
   objecter->init();
+  monclient.renew_subs();
 
   while (osdmap.get_epoch() == 0) {
     dout(1) << "waiting for osdmap" << dendl;