const std::string &dump_file, int rank)
{
SimpleMessenger *messenger = new SimpleMessenger(g_ceph_context);
- messenger->bind(getpid());
+ messenger->bind(g_conf->public_addr, getpid());
MonClient mc(g_ceph_context);
if (mc.build_initial_monmap() < 0)
return -1;
}
SimpleMessenger *messenger = new SimpleMessenger(g_ceph_context);
- messenger->bind(getpid());
+ messenger->bind(g_conf->public_addr, getpid());
cout << "starting " << g_conf->name << " at " << messenger->get_ms_addr()
<< std::endl;
messenger->register_entity(entity_name_t::MDS(-1));
for (int i=0; i<g_conf->num_client; i++) {
messengers[i] = new SimpleMessenger(g_ceph_context);
messengers[i]->register_entity(entity_name_t(entity_name_t::TYPE_CLIENT,-1));
- messengers[i]->bind(i * 1000000 + getpid());
+ messengers[i]->bind(g_conf->public_addr, i * 1000000 + getpid());
mclients[i] = new MonClient(g_ceph_context);
mclients[i]->build_initial_monmap();
Client *client = new Client(messengers[i], mclients[i]);
//void set_listen_addr(tcpaddr_t& a);
int bind(entity_addr_t bind_addr, int64_t nonce);
- int bind(uint64_t nonce) {
- return bind(cct->_conf->public_addr, nonce);
- }
int start_with_nonce(uint64_t nonce); // if we didn't bind
int start() { // if we did
assert(did_bind);
g_ceph_context->_conf->set_val("public_addr", sss.c_str());
g_ceph_context->_conf->apply_changes(NULL);
SimpleMessenger *rank = new SimpleMessenger(g_ceph_context);
- int err = rank->bind(getpid());
+ int err = rank->bind(g_ceph_context->_conf->public_addr, getpid());
if (err < 0)
return 1;