From 26e48f4234c051edeeac6e7ba739f911d9454b9a Mon Sep 17 00:00:00 2001 From: Greg Farnum Date: Thu, 1 Mar 2012 18:31:49 -0800 Subject: msgr: Require that init functions are called before bind() and start(). Fix up callers to handle these constraints. Signed-off-by: Greg Farnum --- src/ceph_osd.cc | 30 +++++++++++++++--------------- 1 file changed, 15 insertions(+), 15 deletions(-) (limited to 'src/ceph_osd.cc') diff --git a/src/ceph_osd.cc b/src/ceph_osd.cc index 98a998d906c..3bf1cbaf286 100644 --- a/src/ceph_osd.cc +++ b/src/ceph_osd.cc @@ -312,21 +312,6 @@ int main(int argc, const char **argv) messenger_hbin->set_cluster_protocol(CEPH_OSD_PROTOCOL); messenger_hbout->set_cluster_protocol(CEPH_OSD_PROTOCOL); - r = client_messenger->bind(g_conf->public_addr); - if (r < 0) - exit(1); - r = cluster_messenger->bind(g_conf->cluster_addr); - if (r < 0) - exit(1); - - // hb should bind to same ip as cluster_addr (if specified) - entity_addr_t hb_addr = g_conf->cluster_addr; - if (!hb_addr.is_blank_ip()) - hb_addr.set_port(0); - r = messenger_hbout->bind(hb_addr); - if (r < 0) - exit(1); - global_print_banner(); cout << "starting osd." << whoami @@ -366,6 +351,21 @@ int main(int argc, const char **argv) cluster_messenger->set_policy(entity_name_t::TYPE_CLIENT, Messenger::Policy::stateless_server(0, 0)); + r = client_messenger->bind(g_conf->public_addr); + if (r < 0) + exit(1); + r = cluster_messenger->bind(g_conf->cluster_addr); + if (r < 0) + exit(1); + + // hb should bind to same ip as cluster_addr (if specified) + entity_addr_t hb_addr = g_conf->cluster_addr; + if (!hb_addr.is_blank_ip()) + hb_addr.set_port(0); + r = messenger_hbout->bind(hb_addr); + if (r < 0) + exit(1); + // Set up crypto, daemonize, etc. // Leave stderr open in case we need to report errors. global_init_daemonize(g_ceph_context, CINIT_FLAG_NO_CLOSE_STDERR); -- cgit v1.2.1