From: Sage Weil Date: Fri, 3 Mar 2017 18:56:21 +0000 (-0600) Subject: msg/Messenger: drop useless 'supported' arg to Policy ctor X-Git-Tag: v12.0.1~123^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=e0a01ecc4f79ad972e78379040af2dd82366ea38;p=ceph-ci.git msg/Messenger: drop useless 'supported' arg to Policy ctor We always use CEPH_FEATURES_DEFAULT_SUPPORTED (= CEPH_FEATURES_ALL) here. Signed-off-by: Sage Weil --- diff --git a/src/ceph_fuse.cc b/src/ceph_fuse.cc index 824be1272d5..935c5f7e039 100644 --- a/src/ceph_fuse.cc +++ b/src/ceph_fuse.cc @@ -209,9 +209,9 @@ int main(int argc, const char **argv, const char *envp[]) { // start up network messenger = Messenger::create_client_messenger(g_ceph_context, "client"); - messenger->set_default_policy(Messenger::Policy::lossy_client(0, 0)); + messenger->set_default_policy(Messenger::Policy::lossy_client(0)); messenger->set_policy(entity_name_t::TYPE_MDS, - Messenger::Policy::lossless_client(0, 0)); + Messenger::Policy::lossless_client(0)); client = new Client(messenger, mc); if (filer_flags) { diff --git a/src/ceph_mds.cc b/src/ceph_mds.cc index 7bde9ee10e8..95fa6d8a151 100644 --- a/src/ceph_mds.cc +++ b/src/ceph_mds.cc @@ -156,16 +156,14 @@ int main(int argc, const char **argv) uint64_t required = CEPH_FEATURE_OSDREPLYMUX; - msgr->set_default_policy(Messenger::Policy::lossy_client(0, required)); + msgr->set_default_policy(Messenger::Policy::lossy_client(required)); msgr->set_policy(entity_name_t::TYPE_MON, - Messenger::Policy::lossy_client(0, - CEPH_FEATURE_UID | + Messenger::Policy::lossy_client(CEPH_FEATURE_UID | CEPH_FEATURE_PGID64)); msgr->set_policy(entity_name_t::TYPE_MDS, - Messenger::Policy::lossless_peer(0, - CEPH_FEATURE_UID)); + Messenger::Policy::lossless_peer(CEPH_FEATURE_UID)); msgr->set_policy(entity_name_t::TYPE_CLIENT, - Messenger::Policy::stateful_server(0, 0)); + Messenger::Policy::stateful_server(0)); int r = msgr->bind(g_conf->public_addr); if (r < 0) diff --git a/src/ceph_mon.cc b/src/ceph_mon.cc index 818171478b2..9c9460cc2b8 100644 --- a/src/ceph_mon.cc +++ b/src/ceph_mon.cc @@ -660,22 +660,20 @@ int main(int argc, const char **argv) msgr->set_cluster_protocol(CEPH_MON_PROTOCOL); msgr->set_default_send_priority(CEPH_MSG_PRIO_HIGH); - msgr->set_default_policy(Messenger::Policy::stateless_server(0, 0)); + msgr->set_default_policy(Messenger::Policy::stateless_server(0)); msgr->set_policy(entity_name_t::TYPE_MON, Messenger::Policy::lossless_peer_reuse( - 0, CEPH_FEATURE_UID | CEPH_FEATURE_PGID64 | CEPH_FEATURE_MON_SINGLE_PAXOS)); msgr->set_policy(entity_name_t::TYPE_OSD, Messenger::Policy::stateless_server( - 0, CEPH_FEATURE_PGID64 | CEPH_FEATURE_OSDENC)); msgr->set_policy(entity_name_t::TYPE_CLIENT, - Messenger::Policy::stateless_server(0, 0)); + Messenger::Policy::stateless_server(0)); msgr->set_policy(entity_name_t::TYPE_MDS, - Messenger::Policy::stateless_server(0, 0)); + Messenger::Policy::stateless_server(0)); // throttle client traffic Throttle *client_throttler = new Throttle(g_ceph_context, "mon_client_bytes", diff --git a/src/ceph_osd.cc b/src/ceph_osd.cc index 7f49d00883e..d405de23e21 100644 --- a/src/ceph_osd.cc +++ b/src/ceph_osd.cc @@ -497,42 +497,40 @@ flushjournal_out: CEPH_FEATURE_PGID64 | CEPH_FEATURE_OSDENC; - ms_public->set_default_policy(Messenger::Policy::stateless_server(0, 0)); + ms_public->set_default_policy(Messenger::Policy::stateless_server(0)); ms_public->set_policy_throttlers(entity_name_t::TYPE_CLIENT, client_byte_throttler.get(), client_msg_throttler.get()); ms_public->set_policy(entity_name_t::TYPE_MON, - Messenger::Policy::lossy_client(0, - CEPH_FEATURE_UID | + Messenger::Policy::lossy_client(CEPH_FEATURE_UID | CEPH_FEATURE_PGID64 | CEPH_FEATURE_OSDENC)); ms_public->set_policy(entity_name_t::TYPE_MGR, - Messenger::Policy::lossy_client(0, - CEPH_FEATURE_UID | + Messenger::Policy::lossy_client(CEPH_FEATURE_UID | CEPH_FEATURE_PGID64 | CEPH_FEATURE_OSDENC)); //try to poison pill any OSD connections on the wrong address ms_public->set_policy(entity_name_t::TYPE_OSD, - Messenger::Policy::stateless_server(0,0)); + Messenger::Policy::stateless_server(0)); - ms_cluster->set_default_policy(Messenger::Policy::stateless_server(0, 0)); - ms_cluster->set_policy(entity_name_t::TYPE_MON, Messenger::Policy::lossy_client(0,0)); + ms_cluster->set_default_policy(Messenger::Policy::stateless_server(0)); + ms_cluster->set_policy(entity_name_t::TYPE_MON, Messenger::Policy::lossy_client(0)); ms_cluster->set_policy(entity_name_t::TYPE_OSD, - Messenger::Policy::lossless_peer(0, osd_required)); + Messenger::Policy::lossless_peer(osd_required)); ms_cluster->set_policy(entity_name_t::TYPE_CLIENT, - Messenger::Policy::stateless_server(0, 0)); + Messenger::Policy::stateless_server(0)); ms_hb_front_client->set_policy(entity_name_t::TYPE_OSD, - Messenger::Policy::lossy_client(0, 0)); + Messenger::Policy::lossy_client(0)); ms_hb_back_client->set_policy(entity_name_t::TYPE_OSD, - Messenger::Policy::lossy_client(0, 0)); + Messenger::Policy::lossy_client(0)); ms_hb_back_server->set_policy(entity_name_t::TYPE_OSD, - Messenger::Policy::stateless_server(0, 0)); + Messenger::Policy::stateless_server(0)); ms_hb_front_server->set_policy(entity_name_t::TYPE_OSD, - Messenger::Policy::stateless_server(0, 0)); + Messenger::Policy::stateless_server(0)); - ms_objecter->set_default_policy(Messenger::Policy::lossy_client(0, CEPH_FEATURE_OSDREPLYMUX)); + ms_objecter->set_default_policy(Messenger::Policy::lossy_client(CEPH_FEATURE_OSDREPLYMUX)); r = ms_public->bind(g_conf->public_addr); if (r < 0) diff --git a/src/librados/RadosClient.cc b/src/librados/RadosClient.cc index 789de968c0c..8950a900cf2 100644 --- a/src/librados/RadosClient.cc +++ b/src/librados/RadosClient.cc @@ -260,7 +260,7 @@ int librados::RadosClient::connect() // require OSDREPLYMUX feature. this means we will fail to talk to // old servers. this is necessary because otherwise we won't know // how to decompose the reply data into its constituent pieces. - messenger->set_default_policy(Messenger::Policy::lossy_client(0, CEPH_FEATURE_OSDREPLYMUX)); + messenger->set_default_policy(Messenger::Policy::lossy_client(CEPH_FEATURE_OSDREPLYMUX)); ldout(cct, 1) << "starting msgr at " << messenger->get_myaddr() << dendl; diff --git a/src/msg/Messenger.h b/src/msg/Messenger.h index 6331fcf0e42..c4df379939a 100644 --- a/src/msg/Messenger.h +++ b/src/msg/Messenger.h @@ -102,31 +102,31 @@ public: features_supported(CEPH_FEATURES_SUPPORTED_DEFAULT), features_required(0) {} private: - Policy(bool l, bool s, bool st, bool r, uint64_t sup, uint64_t req) + Policy(bool l, bool s, bool st, bool r, uint64_t req) : lossy(l), server(s), standby(st), resetcheck(r), throttler_bytes(NULL), throttler_messages(NULL), - features_supported(sup | CEPH_FEATURES_SUPPORTED_DEFAULT), + features_supported(CEPH_FEATURES_SUPPORTED_DEFAULT), features_required(req) {} public: - static Policy stateful_server(uint64_t sup, uint64_t req) { - return Policy(false, true, true, true, sup, req); + static Policy stateful_server(uint64_t req) { + return Policy(false, true, true, true, req); } - static Policy stateless_server(uint64_t sup, uint64_t req) { - return Policy(true, true, false, false, sup, req); + static Policy stateless_server(uint64_t req) { + return Policy(true, true, false, false, req); } - static Policy lossless_peer(uint64_t sup, uint64_t req) { - return Policy(false, false, true, false, sup, req); + static Policy lossless_peer(uint64_t req) { + return Policy(false, false, true, false, req); } - static Policy lossless_peer_reuse(uint64_t sup, uint64_t req) { - return Policy(false, false, true, true, sup, req); + static Policy lossless_peer_reuse(uint64_t req) { + return Policy(false, false, true, true, req); } - static Policy lossy_client(uint64_t sup, uint64_t req) { - return Policy(true, false, false, false, sup, req); + static Policy lossy_client(uint64_t req) { + return Policy(true, false, false, false, req); } - static Policy lossless_client(uint64_t sup, uint64_t req) { - return Policy(false, false, false, true, sup, req); + static Policy lossless_client(uint64_t req) { + return Policy(false, false, false, true, req); } }; diff --git a/src/test/messenger/simple_client.cc b/src/test/messenger/simple_client.cc index 6fb01e9a9eb..7b37921b04f 100644 --- a/src/test/messenger/simple_client.cc +++ b/src/test/messenger/simple_client.cc @@ -110,7 +110,7 @@ int main(int argc, const char **argv) // enable timing prints messenger->set_magic(MSG_MAGIC_TRACE_CTR); - messenger->set_default_policy(Messenger::Policy::lossy_client(0, 0)); + messenger->set_default_policy(Messenger::Policy::lossy_client(0)); string dest_str = "tcp://"; dest_str += addr; diff --git a/src/test/messenger/simple_server.cc b/src/test/messenger/simple_server.cc index df94701e535..a10cdc5472c 100644 --- a/src/test/messenger/simple_server.cc +++ b/src/test/messenger/simple_server.cc @@ -82,7 +82,7 @@ int main(int argc, const char **argv) // enable timing prints messenger->set_magic(MSG_MAGIC_TRACE_CTR); messenger->set_default_policy( - Messenger::Policy::stateless_server(CEPH_FEATURES_ALL, 0)); + Messenger::Policy::stateless_server(0)); r = messenger->bind(bind_addr); if (r < 0) diff --git a/src/test/messenger/xio_client.cc b/src/test/messenger/xio_client.cc index da132060dc8..35218cbb258 100644 --- a/src/test/messenger/xio_client.cc +++ b/src/test/messenger/xio_client.cc @@ -131,7 +131,7 @@ int main(int argc, const char **argv) if (n_dsize) (void) static_cast(messenger)->pool_hint(n_dsize); - messenger->set_default_policy(Messenger::Policy::lossy_client(0, 0)); + messenger->set_default_policy(Messenger::Policy::lossy_client(0)); string dest_str = "tcp://"; dest_str += addr; diff --git a/src/test/messenger/xio_server.cc b/src/test/messenger/xio_server.cc index a5459a55e20..d50737b924b 100644 --- a/src/test/messenger/xio_server.cc +++ b/src/test/messenger/xio_server.cc @@ -97,7 +97,7 @@ int main(int argc, const char **argv) MSG_MAGIC_TRACE_CTR /* timing prints */); messenger->set_default_policy( - Messenger::Policy::stateless_server(CEPH_FEATURES_ALL, 0)); + Messenger::Policy::stateless_server(0)); r = messenger->bind(bind_addr); if (r < 0) diff --git a/src/test/mon/test-mon-msg.cc b/src/test/mon/test-mon-msg.cc index b4b7c0e8dc9..922abea87ce 100644 --- a/src/test/mon/test-mon-msg.cc +++ b/src/test/mon/test-mon-msg.cc @@ -83,7 +83,7 @@ public: msg = Messenger::create(cct, public_msgr_type, entity_name_t::CLIENT(-1), "test-mon-msg", 0, 0); assert(msg != NULL); - msg->set_default_policy(Messenger::Policy::lossy_client(0,0)); + msg->set_default_policy(Messenger::Policy::lossy_client(0)); dout(0) << __func__ << " starting messenger at " << msg->get_myaddr() << dendl; msg->start(); diff --git a/src/test/mon/test_mon_workloadgen.cc b/src/test/mon/test_mon_workloadgen.cc index baffc5faf71..c9cba519659 100644 --- a/src/test/mon/test_mon_workloadgen.cc +++ b/src/test/mon/test_mon_workloadgen.cc @@ -253,7 +253,7 @@ class ClientStub : public TestStub assert(messenger.get() != NULL); messenger->set_default_policy( - Messenger::Policy::lossy_client(0, CEPH_FEATURE_OSDREPLYMUX)); + Messenger::Policy::lossy_client(CEPH_FEATURE_OSDREPLYMUX)); dout(10) << "ClientStub::" << __func__ << " starting messenger at " << messenger->get_myaddr() << dendl; @@ -369,15 +369,16 @@ class OSDStub : public TestStub g_conf->osd_client_message_size_cap); messenger->set_default_policy( - Messenger::Policy::stateless_server(0, 0)); + Messenger::Policy::stateless_server(0)); messenger->set_policy_throttlers(entity_name_t::TYPE_CLIENT, &throttler, NULL); messenger->set_policy(entity_name_t::TYPE_MON, - Messenger::Policy::lossy_client(0, CEPH_FEATURE_UID | + Messenger::Policy::lossy_client( + CEPH_FEATURE_UID | CEPH_FEATURE_PGID64 | CEPH_FEATURE_OSDENC)); messenger->set_policy(entity_name_t::TYPE_OSD, - Messenger::Policy::stateless_server(0,0)); + Messenger::Policy::stateless_server(0)); dout(10) << __func__ << " public addr " << g_conf->public_addr << dendl; int err = messenger->bind(g_conf->public_addr); diff --git a/src/test/msgr/perf_msgr_client.cc b/src/test/msgr/perf_msgr_client.cc index 8da71c5ad04..96488507661 100644 --- a/src/test/msgr/perf_msgr_client.cc +++ b/src/test/msgr/perf_msgr_client.cc @@ -134,7 +134,7 @@ class MessengerClient { addr.set_nonce(0); for (int i = 0; i < jobs; ++i) { Messenger *msgr = Messenger::create(g_ceph_context, type, entity_name_t::CLIENT(0), "client", getpid()+i, 0); - msgr->set_default_policy(Messenger::Policy::lossless_client(0, 0)); + msgr->set_default_policy(Messenger::Policy::lossless_client(0)); entity_inst_t inst(entity_name_t::OSD(0), addr); ConnectionRef conn = msgr->get_connection(inst); ClientThread *t = new ClientThread(msgr, c, conn, msg_len, ops, think_time_us); diff --git a/src/test/msgr/perf_msgr_server.cc b/src/test/msgr/perf_msgr_server.cc index 2d428386ecb..46f28e39416 100644 --- a/src/test/msgr/perf_msgr_server.cc +++ b/src/test/msgr/perf_msgr_server.cc @@ -117,7 +117,7 @@ class MessengerServer { MessengerServer(string t, string addr, int threads, int delay): msgr(NULL), type(t), bindaddr(addr), dispatcher(threads, delay) { msgr = Messenger::create(g_ceph_context, type, entity_name_t::OSD(0), "server", 0, 0); - msgr->set_default_policy(Messenger::Policy::stateless_server(0, 0)); + msgr->set_default_policy(Messenger::Policy::stateless_server(0)); } ~MessengerServer() { msgr->shutdown(); diff --git a/src/test/msgr/test_msgr.cc b/src/test/msgr/test_msgr.cc index fdda005e267..572b8d578b2 100644 --- a/src/test/msgr/test_msgr.cc +++ b/src/test/msgr/test_msgr.cc @@ -67,8 +67,8 @@ class MessengerTest : public ::testing::TestWithParam { lderr(g_ceph_context) << __func__ << " start set up " << GetParam() << dendl; server_msgr = Messenger::create(g_ceph_context, string(GetParam()), entity_name_t::OSD(0), "server", getpid(), 0); client_msgr = Messenger::create(g_ceph_context, string(GetParam()), entity_name_t::CLIENT(-1), "client", getpid(), 0); - server_msgr->set_default_policy(Messenger::Policy::stateless_server(0, 0)); - client_msgr->set_default_policy(Messenger::Policy::lossy_client(0, 0)); + server_msgr->set_default_policy(Messenger::Policy::stateless_server(0)); + client_msgr->set_default_policy(Messenger::Policy::lossy_client(0)); } void TearDown() override { ASSERT_EQ(server_msgr->get_dispatch_queue_len(), 0); @@ -423,9 +423,9 @@ TEST_P(MessengerTest, StatefulTest) { FakeDispatcher cli_dispatcher(false), srv_dispatcher(true); entity_addr_t bind_addr; bind_addr.parse("127.0.0.1"); - Messenger::Policy p = Messenger::Policy::stateful_server(0, 0); + Messenger::Policy p = Messenger::Policy::stateful_server(0); server_msgr->set_policy(entity_name_t::TYPE_CLIENT, p); - p = Messenger::Policy::lossless_client(0, 0); + p = Messenger::Policy::lossless_client(0); client_msgr->set_policy(entity_name_t::TYPE_OSD, p); server_msgr->bind(bind_addr); @@ -518,9 +518,9 @@ TEST_P(MessengerTest, StatelessTest) { FakeDispatcher cli_dispatcher(false), srv_dispatcher(true); entity_addr_t bind_addr; bind_addr.parse("127.0.0.1"); - Messenger::Policy p = Messenger::Policy::stateless_server(0, 0); + Messenger::Policy p = Messenger::Policy::stateless_server(0); server_msgr->set_policy(entity_name_t::TYPE_CLIENT, p); - p = Messenger::Policy::lossy_client(0, 0); + p = Messenger::Policy::lossy_client(0); client_msgr->set_policy(entity_name_t::TYPE_OSD, p); server_msgr->bind(bind_addr); @@ -591,9 +591,9 @@ TEST_P(MessengerTest, ClientStandbyTest) { FakeDispatcher cli_dispatcher(false), srv_dispatcher(true); entity_addr_t bind_addr; bind_addr.parse("127.0.0.1"); - Messenger::Policy p = Messenger::Policy::stateful_server(0, 0); + Messenger::Policy p = Messenger::Policy::stateful_server(0); server_msgr->set_policy(entity_name_t::TYPE_CLIENT, p); - p = Messenger::Policy::lossless_peer(0, 0); + p = Messenger::Policy::lossless_peer(0); client_msgr->set_policy(entity_name_t::TYPE_OSD, p); server_msgr->bind(bind_addr); @@ -708,9 +708,9 @@ TEST_P(MessengerTest, MessageTest) { FakeDispatcher cli_dispatcher(false), srv_dispatcher(true); entity_addr_t bind_addr; bind_addr.parse("127.0.0.1"); - Messenger::Policy p = Messenger::Policy::stateful_server(0, 0); + Messenger::Policy p = Messenger::Policy::stateful_server(0); server_msgr->set_policy(entity_name_t::TYPE_CLIENT, p); - p = Messenger::Policy::lossless_peer(0, 0); + p = Messenger::Policy::lossless_peer(0); client_msgr->set_policy(entity_name_t::TYPE_OSD, p); server_msgr->bind(bind_addr); @@ -1164,8 +1164,8 @@ bool SyntheticDispatcher::ms_handle_reset(Connection *con) { TEST_P(MessengerTest, SyntheticStressTest) { SyntheticWorkload test_msg(8, 32, GetParam(), 100, - Messenger::Policy::stateful_server(0, 0), - Messenger::Policy::lossless_client(0, 0)); + Messenger::Policy::stateful_server(0), + Messenger::Policy::lossless_client(0)); for (int i = 0; i < 100; ++i) { if (!(i % 10)) lderr(g_ceph_context) << "seeding connection " << i << dendl; test_msg.generate_connection(); @@ -1193,8 +1193,8 @@ TEST_P(MessengerTest, SyntheticStressTest) { TEST_P(MessengerTest, SyntheticStressTest1) { SyntheticWorkload test_msg(16, 32, GetParam(), 100, - Messenger::Policy::lossless_peer_reuse(0, 0), - Messenger::Policy::lossless_peer_reuse(0, 0)); + Messenger::Policy::lossless_peer_reuse(0), + Messenger::Policy::lossless_peer_reuse(0)); for (int i = 0; i < 10; ++i) { if (!(i % 10)) lderr(g_ceph_context) << "seeding connection " << i << dendl; test_msg.generate_connection(); @@ -1227,8 +1227,8 @@ TEST_P(MessengerTest, SyntheticInjectTest) { g_ceph_context->_conf->set_val("ms_inject_internal_delays", "0.1"); g_ceph_context->_conf->set_val("ms_dispatch_throttle_bytes", "16777216"); SyntheticWorkload test_msg(8, 32, GetParam(), 100, - Messenger::Policy::stateful_server(0, 0), - Messenger::Policy::lossless_client(0, 0)); + Messenger::Policy::stateful_server(0), + Messenger::Policy::lossless_client(0)); for (int i = 0; i < 100; ++i) { if (!(i % 10)) lderr(g_ceph_context) << "seeding connection " << i << dendl; test_msg.generate_connection(); @@ -1262,8 +1262,8 @@ TEST_P(MessengerTest, SyntheticInjectTest2) { g_ceph_context->_conf->set_val("ms_inject_socket_failures", "30"); g_ceph_context->_conf->set_val("ms_inject_internal_delays", "0.1"); SyntheticWorkload test_msg(8, 16, GetParam(), 100, - Messenger::Policy::lossless_peer_reuse(0, 0), - Messenger::Policy::lossless_peer_reuse(0, 0)); + Messenger::Policy::lossless_peer_reuse(0), + Messenger::Policy::lossless_peer_reuse(0)); for (int i = 0; i < 100; ++i) { if (!(i % 10)) lderr(g_ceph_context) << "seeding connection " << i << dendl; test_msg.generate_connection(); @@ -1295,8 +1295,8 @@ TEST_P(MessengerTest, SyntheticInjectTest3) { g_ceph_context->_conf->set_val("ms_inject_socket_failures", "600"); g_ceph_context->_conf->set_val("ms_inject_internal_delays", "0.1"); SyntheticWorkload test_msg(8, 16, GetParam(), 100, - Messenger::Policy::stateless_server(0, 0), - Messenger::Policy::lossy_client(0, 0)); + Messenger::Policy::stateless_server(0), + Messenger::Policy::lossy_client(0)); for (int i = 0; i < 100; ++i) { if (!(i % 10)) lderr(g_ceph_context) << "seeding connection " << i << dendl; test_msg.generate_connection(); @@ -1332,8 +1332,8 @@ TEST_P(MessengerTest, SyntheticInjectTest4) { g_ceph_context->_conf->set_val("ms_inject_delay_type", "client osd", false, false); g_ceph_context->_conf->set_val("ms_inject_delay_max", "5"); SyntheticWorkload test_msg(16, 32, GetParam(), 100, - Messenger::Policy::lossless_peer(0, 0), - Messenger::Policy::lossless_peer(0, 0)); + Messenger::Policy::lossless_peer(0), + Messenger::Policy::lossless_peer(0)); for (int i = 0; i < 100; ++i) { if (!(i % 10)) lderr(g_ceph_context) << "seeding connection " << i << dendl; test_msg.generate_connection(); diff --git a/src/test/osd/TestOSDScrub.cc b/src/test/osd/TestOSDScrub.cc index 9c0a2f2503b..c39ce96cc09 100644 --- a/src/test/osd/TestOSDScrub.cc +++ b/src/test/osd/TestOSDScrub.cc @@ -61,7 +61,7 @@ TEST(TestOSDScrub, scrub_time_permit) { entity_name_t::OSD(0), "make_checker", getpid(), 0); ms->set_cluster_protocol(CEPH_OSD_PROTOCOL); - ms->set_default_policy(Messenger::Policy::stateless_server(0, 0)); + ms->set_default_policy(Messenger::Policy::stateless_server(0)); ms->bind(g_conf->public_addr); MonClient mc(g_ceph_context); mc.build_initial_monmap();