diff options
Diffstat (limited to 'src/test/mon/test_mon_workloadgen.cc')
| -rw-r--r-- | src/test/mon/test_mon_workloadgen.cc | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/src/test/mon/test_mon_workloadgen.cc b/src/test/mon/test_mon_workloadgen.cc index 613a18f247e..15792a63af5 100644 --- a/src/test/mon/test_mon_workloadgen.cc +++ b/src/test/mon/test_mon_workloadgen.cc @@ -39,7 +39,6 @@ #include "mon/MonClient.h" #include "msg/Dispatcher.h" #include "msg/Messenger.h" -#include "common/async/context_pool.h" #include "common/Timer.h" #include "common/ceph_argparse.h" #include "global/global_init.h" @@ -83,7 +82,6 @@ class TestStub : public Dispatcher { protected: MessengerRef messenger; - ceph::async::io_context_pool poolctx; MonClient monc; ceph::mutex lock; @@ -165,7 +163,6 @@ class TestStub : public Dispatcher monc.shutdown(); timer.shutdown(); messenger->shutdown(); - poolctx.finish(); return 0; } @@ -180,7 +177,7 @@ class TestStub : public Dispatcher TestStub(CephContext *cct, string who) : Dispatcher(cct), - monc(cct, poolctx), + monc(cct), lock(ceph::make_mutex(who.append("::lock"))), timer(cct, lock), do_shutdown(false), @@ -247,7 +244,6 @@ class ClientStub : public TestStub int init() override { int err; - poolctx.start(1); err = monc.build_initial_monmap(); if (err < 0) { derr << "ClientStub::" << __func__ << " ERROR: build initial monmap: " @@ -263,7 +259,7 @@ class ClientStub : public TestStub dout(10) << "ClientStub::" << __func__ << " starting messenger at " << messenger->get_myaddrs() << dendl; - objecter.reset(new Objecter(cct, messenger.get(), &monc, poolctx, 0, 0)); + objecter.reset(new Objecter(cct, messenger.get(), &monc, NULL, 0, 0)); ceph_assert(objecter.get() != NULL); objecter->set_balanced_budget(); |