summaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests/serviceaddress/serviceaddress.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus/src/tests/serviceaddress/serviceaddress.cpp')
-rw-r--r--messagebus/src/tests/serviceaddress/serviceaddress.cpp107
1 files changed, 40 insertions, 67 deletions
diff --git a/messagebus/src/tests/serviceaddress/serviceaddress.cpp b/messagebus/src/tests/serviceaddress/serviceaddress.cpp
index 441da5a80ac..770cac620a9 100644
--- a/messagebus/src/tests/serviceaddress/serviceaddress.cpp
+++ b/messagebus/src/tests/serviceaddress/serviceaddress.cpp
@@ -7,34 +7,49 @@
using namespace mbus;
-class Test : public vespalib::TestApp {
-public:
- int Main() override;
- void testAddrServiceAddress();
- void testNameServiceAddress();
-
-private:
- bool waitSlobrok(RPCNetwork &network, const string &pattern, size_t num);
- bool testAddress(RPCNetwork& network, const string &pattern,
- const string &expectedSpec, const string &expectedSession);
- bool testNullAddress(RPCNetwork &network, const string &pattern);
-};
-
-int
-Test::Main()
+bool
+waitSlobrok(RPCNetwork &network, const string &pattern, size_t num)
{
- TEST_INIT("serviceaddress_test");
-
- testAddrServiceAddress(); TEST_FLUSH();
- testNameServiceAddress(); TEST_FLUSH();
+ for (int i = 0; i < 1000; i++) {
+ slobrok::api::IMirrorAPI::SpecList res = network.getMirror().lookup(pattern);
+ if (res.size() == num) {
+ return true;
+ }
+ std::this_thread::sleep_for(10ms);
+ }
+ return false;
+}
- TEST_DONE();
+bool
+testNullAddress(RPCNetwork &network, const string &pattern)
+{
+ RPCService service(network.getMirror(), pattern);
+ RPCServiceAddress::UP obj = service.resolve();
+ if ( ! EXPECT_FALSE(obj)) {
+ return false;
+ }
+ return true;
}
-TEST_APPHOOK(Test);
+bool
+testAddress(RPCNetwork &network, const string &pattern,
+ const string &expectedSpec, const string &expectedSession)
+{
+ RPCService service(network.getMirror(), pattern);
+ RPCServiceAddress::UP obj = service.resolve();
+ if (!EXPECT_TRUE(obj)) {
+ return false;
+ }
+ if (!EXPECT_EQUAL(expectedSpec, obj->getConnectionSpec())) {
+ return false;
+ }
+ if (!EXPECT_EQUAL(expectedSession, obj->getSessionName())) {
+ return false;
+ }
+ return true;
+}
-void
-Test::testAddrServiceAddress()
+TEST("testAddrServiceAddress")
{
Slobrok slobrok;
RPCNetwork network(RPCNetworkParams(slobrok.config())
@@ -55,8 +70,7 @@ Test::testAddrServiceAddress()
network.shutdown();
}
-void
-Test::testNameServiceAddress()
+TEST("testNameServiceAddress")
{
Slobrok slobrok;
RPCNetwork network(RPCNetworkParams(slobrok.config())
@@ -74,45 +88,4 @@ Test::testNameServiceAddress()
network.shutdown();
}
-bool
-Test::waitSlobrok(RPCNetwork &network, const string &pattern, size_t num)
-{
- for (int i = 0; i < 1000; i++) {
- slobrok::api::IMirrorAPI::SpecList res = network.getMirror().lookup(pattern);
- if (res.size() == num) {
- return true;
- }
- std::this_thread::sleep_for(10ms);
- }
- return false;
-}
-
-bool
-Test::testNullAddress(RPCNetwork &network, const string &pattern)
-{
- RPCService service(network.getMirror(), pattern);
- RPCServiceAddress::UP obj = service.resolve();
- if (!EXPECT_TRUE(obj.get() == NULL)) {
- return false;
- }
- return true;
-}
-
-bool
-Test::testAddress(RPCNetwork &network, const string &pattern,
- const string &expectedSpec, const string &expectedSession)
-{
- RPCService service(network.getMirror(), pattern);
- RPCServiceAddress::UP obj = service.resolve();
- if (!EXPECT_TRUE(obj.get() != NULL)) {
- return false;
- }
- if (!EXPECT_EQUAL(expectedSpec, obj->getConnectionSpec())) {
- return false;
- }
- if (!EXPECT_EQUAL(expectedSession, obj->getSessionName())) {
- return false;
- }
- return true;
-}
-
+TEST_MAIN() { TEST_RUN_ALL(); } \ No newline at end of file