summaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests/targetpool/targetpool.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus/src/tests/targetpool/targetpool.cpp')
-rw-r--r--messagebus/src/tests/targetpool/targetpool.cpp31
1 files changed, 13 insertions, 18 deletions
diff --git a/messagebus/src/tests/targetpool/targetpool.cpp b/messagebus/src/tests/targetpool/targetpool.cpp
index 0e0e566f2be..9259f992d6c 100644
--- a/messagebus/src/tests/targetpool/targetpool.cpp
+++ b/messagebus/src/tests/targetpool/targetpool.cpp
@@ -22,12 +22,7 @@ public:
}
};
-TEST_SETUP(Test);
-
-int
-Test::Main()
-{
- TEST_INIT("targetpool_test");
+TEST("targetpool_test") {
// Necessary setup to be able to resolve targets.
Slobrok slobrok;
@@ -46,9 +41,9 @@ Test::Main()
// Assert that all connections expire.
RPCTarget::SP target;
- ASSERT_TRUE((target = pool.getTarget(orb, adr1)).get() != NULL); target.reset();
- ASSERT_TRUE((target = pool.getTarget(orb, adr2)).get() != NULL); target.reset();
- ASSERT_TRUE((target = pool.getTarget(orb, adr3)).get() != NULL); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr1))); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr2))); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr3))); target.reset();
EXPECT_EQUAL(3u, pool.size());
for (uint32_t i = 0; i < 10; ++i) {
pool.flushTargets(false);
@@ -59,19 +54,19 @@ Test::Main()
EXPECT_EQUAL(0u, pool.size());
// Assert that only idle connections expire.
- ASSERT_TRUE((target = pool.getTarget(orb, adr1)).get() != NULL); target.reset();
- ASSERT_TRUE((target = pool.getTarget(orb, adr2)).get() != NULL); target.reset();
- ASSERT_TRUE((target = pool.getTarget(orb, adr3)).get() != NULL); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr1))); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr2))); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr3))); target.reset();
EXPECT_EQUAL(3u, pool.size());
timer.millis += 444;
pool.flushTargets(false);
EXPECT_EQUAL(3u, pool.size());
- ASSERT_TRUE((target = pool.getTarget(orb, adr2)).get() != NULL); target.reset();
- ASSERT_TRUE((target = pool.getTarget(orb, adr3)).get() != NULL); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr2))); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr3))); target.reset();
timer.millis += 444;
pool.flushTargets(false);
EXPECT_EQUAL(2u, pool.size());
- ASSERT_TRUE((target = pool.getTarget(orb, adr3)).get() != NULL); target.reset();
+ ASSERT_TRUE((target = pool.getTarget(orb, adr3))); target.reset();
timer.millis += 444;
pool.flushTargets(false);
EXPECT_EQUAL(1u, pool.size());
@@ -80,7 +75,7 @@ Test::Main()
EXPECT_EQUAL(0u, pool.size());
// Assert that connections never expire while they are referenced.
- ASSERT_TRUE((target = pool.getTarget(orb, adr1)).get() != NULL);
+ ASSERT_TRUE((target = pool.getTarget(orb, adr1)));
EXPECT_EQUAL(1u, pool.size());
for (int i = 0; i < 10; ++i) {
timer.millis += 999;
@@ -91,6 +86,6 @@ Test::Main()
timer.millis += 999;
pool.flushTargets(false);
EXPECT_EQUAL(0u, pool.size());
-
- TEST_DONE();
}
+
+TEST_MAIN() { TEST_RUN_ALL(); } \ No newline at end of file