From: Sage Weil <sage@newdream.net>
Date: Tue, 22 Sep 2009 20:09:09 +0000 (-0700)
Subject: librados: fix dispatch
X-Git-Tag: v0.16~96
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=cb1b7e7ef24ad7bf59cc7e2fec681e0df574ca9f;p=ceph.git

librados: fix dispatch
---

diff --git a/src/librados.cc b/src/librados.cc
index a4d4cfce21b40..5013bab965d00 100644
--- 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;