aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorGeir Storli <geirst@vespa.ai>2024-03-12 15:05:38 +0100
committerGitHub <noreply@github.com>2024-03-12 15:05:38 +0100
commit84bf457b193f3cbd5fc481334e2f8c83103c9d80 (patch)
treed5a3e622703b0fd70510dfa0de7ea27bc24ce433
parentb29166aab15033cb89dd90af25de4524228808ee (diff)
parent5278744c64c426a195476a98a79afc78d11c46c2 (diff)
Merge pull request #30595 from vespa-engine/toregge/rewrite-messagebus-sequencer-unit-test-to-gtest
Rewrite messagebus sequencer unit test to gtest.
-rw-r--r--messagebus/src/tests/sequencer/CMakeLists.txt1
-rw-r--r--messagebus/src/tests/sequencer/sequencer.cpp60
2 files changed, 22 insertions, 39 deletions
diff --git a/messagebus/src/tests/sequencer/CMakeLists.txt b/messagebus/src/tests/sequencer/CMakeLists.txt
index bdcd4d1b2da..0c00209f3c7 100644
--- a/messagebus/src/tests/sequencer/CMakeLists.txt
+++ b/messagebus/src/tests/sequencer/CMakeLists.txt
@@ -5,5 +5,6 @@ vespa_add_executable(messagebus_sequencer_test_app TEST
DEPENDS
messagebus_messagebus-test
messagebus
+ GTest::gtest
)
vespa_add_test(NAME messagebus_sequencer_test_app COMMAND messagebus_sequencer_test_app)
diff --git a/messagebus/src/tests/sequencer/sequencer.cpp b/messagebus/src/tests/sequencer/sequencer.cpp
index 3fb905bce7a..8814ff45f1d 100644
--- a/messagebus/src/tests/sequencer/sequencer.cpp
+++ b/messagebus/src/tests/sequencer/sequencer.cpp
@@ -4,7 +4,7 @@
#include <vespa/messagebus/sequencer.h>
#include <vespa/messagebus/routablequeue.h>
#include <vespa/messagebus/emptyreply.h>
-#include <vespa/vespalib/testkit/testapp.h>
+#include <vespa/vespalib/gtest/gtest.h>
#include <cinttypes>
#include <vespa/log/log.h>
@@ -82,32 +82,13 @@ struct MyQueue : public RoutableQueue {
}
};
-class Test : public vespalib::TestApp {
-private:
- void testSyncNone();
- void testSyncId();
-
-public:
- int Main() override {
- TEST_INIT("sequencer_test");
-
- testSyncNone(); TEST_FLUSH();
- testSyncId(); TEST_FLUSH();
-
- TEST_DONE();
- }
-};
-
-TEST_APPHOOK(Test);
-
// --------------------------------------------------------------------------------
//
// Tests.
//
// --------------------------------------------------------------------------------
-void
-Test::testSyncNone()
+TEST(SequencerTest, test_sync_none)
{
MyQueue src;
MyQueue dst;
@@ -118,28 +99,27 @@ Test::testSyncNone()
seq.handleMessage(src.createMessage(false, 0));
seq.handleMessage(src.createMessage(false, 0));
seq.handleMessage(src.createMessage(false, 0));
- EXPECT_EQUAL(0u, src.size());
- EXPECT_EQUAL(5u, dst.size());
+ EXPECT_EQ(0u, src.size());
+ EXPECT_EQ(5u, dst.size());
dst.replyNext();
dst.replyNext();
dst.replyNext();
dst.replyNext();
dst.replyNext();
- EXPECT_EQUAL(5u, src.size());
- EXPECT_EQUAL(0u, dst.size());
+ EXPECT_EQ(5u, src.size());
+ EXPECT_EQ(0u, dst.size());
EXPECT_TRUE(src.checkReply(false, 0));
EXPECT_TRUE(src.checkReply(false, 0));
EXPECT_TRUE(src.checkReply(false, 0));
EXPECT_TRUE(src.checkReply(false, 0));
EXPECT_TRUE(src.checkReply(false, 0));
- EXPECT_EQUAL(0u, src.size());
- EXPECT_EQUAL(0u, dst.size());
+ EXPECT_EQ(0u, src.size());
+ EXPECT_EQ(0u, dst.size());
}
-void
-Test::testSyncId()
+TEST(SequencerTest, test_sync_id)
{
MyQueue src;
MyQueue dst;
@@ -150,8 +130,8 @@ Test::testSyncId()
seq.handleMessage(src.createMessage(true, 3));
seq.handleMessage(src.createMessage(true, 4));
seq.handleMessage(src.createMessage(true, 5));
- EXPECT_EQUAL(0u, src.size());
- EXPECT_EQUAL(5u, dst.size());
+ EXPECT_EQ(0u, src.size());
+ EXPECT_EQ(5u, dst.size());
seq.handleMessage(src.createMessage(true, 1));
seq.handleMessage(src.createMessage(true, 5));
@@ -159,16 +139,16 @@ Test::testSyncId()
seq.handleMessage(src.createMessage(true, 10));
seq.handleMessage(src.createMessage(true, 4));
seq.handleMessage(src.createMessage(true, 3));
- EXPECT_EQUAL(0u, src.size());
- EXPECT_EQUAL(6u, dst.size());
+ EXPECT_EQ(0u, src.size());
+ EXPECT_EQ(6u, dst.size());
dst.replyNext();
dst.replyNext();
dst.replyNext();
dst.replyNext();
dst.replyNext();
- EXPECT_EQUAL(5u, src.size());
- EXPECT_EQUAL(6u, dst.size());
+ EXPECT_EQ(5u, src.size());
+ EXPECT_EQ(6u, dst.size());
dst.replyNext();
dst.replyNext();
@@ -176,8 +156,8 @@ Test::testSyncId()
dst.replyNext();
dst.replyNext();
dst.replyNext();
- EXPECT_EQUAL(11u, src.size());
- EXPECT_EQUAL(0u, dst.size());
+ EXPECT_EQ(11u, src.size());
+ EXPECT_EQ(0u, dst.size());
EXPECT_TRUE(src.checkReply(true, 1));
EXPECT_TRUE(src.checkReply(true, 2));
@@ -190,6 +170,8 @@ Test::testSyncId()
EXPECT_TRUE(src.checkReply(true, 3));
EXPECT_TRUE(src.checkReply(true, 4));
EXPECT_TRUE(src.checkReply(true, 5));
- EXPECT_EQUAL(0u, src.size());
- EXPECT_EQUAL(0u, dst.size());
+ EXPECT_EQ(0u, src.size());
+ EXPECT_EQ(0u, dst.size());
}
+
+GTEST_MAIN_RUN_ALL_TESTS()