global_print_banner();
SimpleMessenger *messenger = new SimpleMessenger(g_ceph_context);
- messenger->bind(g_conf->public_addr, getpid());
+ messenger->set_cluster_protocol(CEPH_MDS_PROTOCOL);
+
+ int r = messenger->bind(g_conf->public_addr, getpid());
+ if (r < 0)
+ exit(1);
++
cout << "starting " << g_conf->name << " at " << messenger->get_ms_addr()
<< std::endl;
messenger->register_entity(entity_name_t::MDS(-1));
SimpleMessenger *cluster_messenger = new SimpleMessenger(g_ceph_context);
SimpleMessenger *messenger_hbin = new SimpleMessenger(g_ceph_context);
SimpleMessenger *messenger_hbout = new SimpleMessenger(g_ceph_context);
-
+ cluster_messenger->set_cluster_protocol(CEPH_OSD_PROTOCOL);
+ messenger_hbin->set_cluster_protocol(CEPH_OSD_PROTOCOL);
+ messenger_hbout->set_cluster_protocol(CEPH_OSD_PROTOCOL);
- client_messenger->bind(g_conf->public_addr, getpid());
- cluster_messenger->bind(g_conf->cluster_addr, getpid());
+ r = client_messenger->bind(g_conf->public_addr, getpid());
+ if (r < 0)
+ exit(1);
+ r = cluster_messenger->bind(g_conf->cluster_addr, getpid());
+ 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;