summaryrefslogtreecommitdiff
path: root/src/ceph_osd.cc
diff options
context:
space:
mode:
authorGreg Farnum <gregory.farnum@dreamhost.com>2012-03-01 17:12:28 -0800
committerGreg Farnum <gregory.farnum@dreamhost.com>2012-03-02 11:20:27 -0800
commitef244773ee6bd8d1b8c7b0a5a06e9c082eefa472 (patch)
treeddf0080687bf0447ab34ed367b64c615b432c376 /src/ceph_osd.cc
parentffa595598d5b49ac2d30a16e4a2f9ae24e518a33 (diff)
downloadceph-ef244773ee6bd8d1b8c7b0a5a06e9c082eefa472.tar.gz
msgr: Remove the SimpleMessenger start/start_with_nonce distinction.
Instead, have a settable nonce value that you can fill in any time after construction and that it uses during regular start(). Signed-off-by: Greg Farnum <gregory.farnum@dreamhost.com>
Diffstat (limited to 'src/ceph_osd.cc')
-rw-r--r--src/ceph_osd.cc5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/ceph_osd.cc b/src/ceph_osd.cc
index 8896d443f73..9e8b9676218 100644
--- a/src/ceph_osd.cc
+++ b/src/ceph_osd.cc
@@ -302,10 +302,11 @@ int main(int argc, const char **argv)
SimpleMessenger *client_messenger = new SimpleMessenger(g_ceph_context, entity_name_t::OSD(whoami));
SimpleMessenger *cluster_messenger = new SimpleMessenger(g_ceph_context, entity_name_t::OSD(whoami));
- SimpleMessenger *messenger_hbin = new SimpleMessenger(g_ceph_context, entity_name_t::OSD(whoami));
+ SimpleMessenger *messenger_hbin = new SimpleMessenger(g_ceph_context,entity_name_t::OSD(whoami));
SimpleMessenger *messenger_hbout = new SimpleMessenger(g_ceph_context, entity_name_t::OSD(whoami));
cluster_messenger->set_cluster_protocol(CEPH_OSD_PROTOCOL);
messenger_hbin->set_cluster_protocol(CEPH_OSD_PROTOCOL);
+ messenger_hbin->set_nonce(getpid());
messenger_hbout->set_cluster_protocol(CEPH_OSD_PROTOCOL);
r = client_messenger->bind(g_conf->public_addr, getpid());
@@ -394,7 +395,7 @@ int main(int argc, const char **argv)
global_init_shutdown_stderr(g_ceph_context);
client_messenger->start();
- messenger_hbin->start_with_nonce(getpid());
+ messenger_hbin->start();
messenger_hbout->start();
cluster_messenger->start();