From cb1b7e7ef24ad7bf59cc7e2fec681e0df574ca9f Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Tue, 22 Sep 2009 13:09:09 -0700 Subject: [PATCH] librados: fix dispatch --- src/librados.cc | 3 +++ 1 file changed, 3 insertions(+) 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; -- 2.39.5