summaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-05-10 11:25:48 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2019-05-10 12:25:38 +0000
commit4412aace869986be3a1060f78f367841353d3384 (patch)
treef4b5e1f6da5eaf1563f3b2fd64779800acfd5796 /messagebus/src/tests
parent840d4e0578dc627b75bcd0050f1b253e84cc30ed (diff)
Simplify the supervisor responsibility
Diffstat (limited to 'messagebus/src/tests')
-rw-r--r--messagebus/src/tests/shutdown/shutdown.cpp11
-rw-r--r--messagebus/src/tests/targetpool/targetpool.cpp6
2 files changed, 6 insertions, 11 deletions
diff --git a/messagebus/src/tests/shutdown/shutdown.cpp b/messagebus/src/tests/shutdown/shutdown.cpp
index 46a8a6518f0..1706da3b55f 100644
--- a/messagebus/src/tests/shutdown/shutdown.cpp
+++ b/messagebus/src/tests/shutdown/shutdown.cpp
@@ -37,21 +37,18 @@ TEST_APPHOOK(Test);
void
Test::requireThatListenFailedIsExceptionSafe()
{
- FRT_Supervisor orb;
- ASSERT_TRUE(orb.Listen(0));
- ASSERT_TRUE(orb.Start());
+ fnet::frt::StandaloneFRT orb;
+ ASSERT_TRUE(orb.supervisor().Listen(0));
Slobrok slobrok;
try {
TestServer bar(MessageBusParams(),
RPCNetworkParams(slobrok.config())
- .setListenPort(orb.GetListenPort()));
+ .setListenPort(orb.supervisor().GetListenPort()));
EXPECT_TRUE(false);
} catch (vespalib::Exception &e) {
- EXPECT_EQUAL("Failed to start network.",
- e.getMessage());
+ EXPECT_EQUAL("Failed to start network.", e.getMessage());
}
- orb.ShutDown(true);
}
void
diff --git a/messagebus/src/tests/targetpool/targetpool.cpp b/messagebus/src/tests/targetpool/targetpool.cpp
index 0ae70daf489..0e0e566f2be 100644
--- a/messagebus/src/tests/targetpool/targetpool.cpp
+++ b/messagebus/src/tests/targetpool/targetpool.cpp
@@ -38,8 +38,8 @@ Test::Main()
TestServer srv3(Identity("srv3"), RoutingSpec(), slobrok);
RPCServiceAddress adr3("", srv3.mb.getConnectionSpec());
- FRT_Supervisor orb(1024u, 1);
- ASSERT_TRUE(orb.Start());
+ fnet::frt::StandaloneFRT server;
+ FRT_Supervisor & orb = server.supervisor();
std::unique_ptr<PoolTimer> ptr(new PoolTimer());
PoolTimer &timer = *ptr;
RPCTargetPool pool(std::move(ptr), 0.666);
@@ -92,7 +92,5 @@ Test::Main()
pool.flushTargets(false);
EXPECT_EQUAL(0u, pool.size());
- orb.ShutDown(true);
-
TEST_DONE();
}