]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
msg: Move public_addr use outside ->bind()
authorTommi Virtanen <tv@eagain.net>
Mon, 21 Nov 2011 18:12:29 +0000 (10:12 -0800)
committerTommi Virtanen <tv@eagain.net>
Mon, 21 Nov 2011 21:37:39 +0000 (13:37 -0800)
src/ceph_mds.cc
src/ceph_syn.cc
src/msg/SimpleMessenger.h
src/testmsgr.cc

index 35150db24c0f8bcbde269e160dee2139bc810e3f..1ba4389453730a2f83b28d9c7309a797172ee112 100644 (file)
@@ -63,7 +63,7 @@ static int do_cmds_special_action(const std::string &action,
                                  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;
@@ -206,7 +206,7 @@ int main(int argc, const char **argv)
   }
 
   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));
index 7879dcfefd5a5bf1e64270fe6d5159657f94060b..09ab7db1c28a8ac776b3f98206be5b420d7c72ca 100644 (file)
@@ -67,7 +67,7 @@ int main(int argc, const char **argv, char *envp[])
   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]);
index 10583501e89a1bc7277fd9f1289c763f039d7915..4b52b2dc11f1522d386febe638a4fdc8769d8c66 100644 (file)
@@ -577,9 +577,6 @@ public:
   //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);
index 823b176a02fa04da05c5ec2fae9252e8d961fd62..313d4a5596a7e71eca80c05d0907c0b94186d5d1 100644 (file)
@@ -97,7 +97,7 @@ int main(int argc, const char **argv, const char *envp[]) {
   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;