diff options
| author | Sage Weil <sage@inktank.com> | 2012-07-31 23:46:13 +0200 |
|---|---|---|
| committer | Sage Weil <sage@inktank.com> | 2012-08-13 17:45:48 +0200 |
| commit | ee206a52b69b77615fc83c6660936729e3b906ef (patch) | |
| tree | ff8d06065421a1f60638dc6ac59905235dcc45bc /src/tools/common.cc | |
| parent | cephtool: fix deadlock on fault when waiting for osdmap (diff) | |
| download | ceph-ee206a52b69b77615fc83c6660936729e3b906ef.tar.xz ceph-ee206a52b69b77615fc83c6660936729e3b906ef.zip | |
cephtool: set messenger policy
Signed-off-by: Sage Weil <sage@inktank.com>
Diffstat (limited to 'src/tools/common.cc')
| -rw-r--r-- | src/tools/common.cc | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/tools/common.cc b/src/tools/common.cc index 183cdf15cd4..78ab62b5081 100644 --- a/src/tools/common.cc +++ b/src/tools/common.cc @@ -439,11 +439,14 @@ CephToolCtx* ceph_tool_common_init(ceph_tool_mode_t mode, bool concise) // start up network messenger = new SimpleMessenger(g_ceph_context, entity_name_t::CLIENT(), "client", getpid()); + messenger->set_default_policy(Messenger::Policy::lossy_client(0, 0)); messenger->start(); + + ctx->mc.set_messenger(messenger); + ctx->dispatcher = new Admin(ctx.get()); messenger->add_dispatcher_head(ctx->dispatcher); - ctx->mc.set_messenger(messenger); int r = ctx->mc.init(); if (r < 0) return NULL; |