aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2023-01-31 19:41:08 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2023-02-01 21:51:45 +0000
commit79487ed8e135b5948248db91974148d80f2692dc (patch)
treeef1db9dc8979bd21ca3818d59548b2d39bf1d7e2 /messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp
parent5d4c62ac6a6cc32c9c0893126c603d9428a5dab7 (diff)
- Deinline destructor.
- Move instead of copy = > noexcept move construtors. - make_unique/make_shared. - c++11 for loops
Diffstat (limited to 'messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp')
-rw-r--r--messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp28
1 files changed, 13 insertions, 15 deletions
diff --git a/messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp b/messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp
index d3736f067c9..911c3d38e5e 100644
--- a/messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp
+++ b/messagebus/src/tests/simple-roundtrip/simple-roundtrip.cpp
@@ -18,9 +18,7 @@ RoutingSpec getRouting() {
.addTable(RoutingTableSpec("Simple")
.addHop(HopSpec("pxy", "test/pxy/session"))
.addHop(HopSpec("dst", "test/dst/session"))
- .addRoute(RouteSpec("test")
- .addHop("pxy")
- .addHop("dst")));
+ .addRoute(std::move(RouteSpec("test").addHop("pxy").addHop("dst"))));
}
int
@@ -47,47 +45,47 @@ Test::Main()
ASSERT_TRUE(pxyNet.waitSlobrok("test/dst/session"));
// send message on client
- ss->send(SimpleMessage::UP(new SimpleMessage("test message")), "test");
+ ss->send(std::make_unique<SimpleMessage>("test message"), "test");
// check message on proxy
Message::UP msg = pxy.getMessage();
- ASSERT_TRUE(msg.get() != 0);
+ ASSERT_TRUE(msg);
EXPECT_TRUE(msg->getProtocol() == SimpleProtocol::NAME);
EXPECT_TRUE(msg->getType() == SimpleProtocol::MESSAGE);
- EXPECT_TRUE(static_cast<SimpleMessage&>(*msg).getValue() == "test message");
+ EXPECT_TRUE(dynamic_cast<SimpleMessage&>(*msg).getValue() == "test message");
// forward message on proxy
- static_cast<SimpleMessage&>(*msg).setValue("test message pxy");
+ dynamic_cast<SimpleMessage&>(*msg).setValue("test message pxy");
is->forward(std::move(msg));
// check message on server
msg = dst.getMessage();
- ASSERT_TRUE(msg.get() != 0);
+ ASSERT_TRUE(msg);
EXPECT_TRUE(msg->getProtocol() == SimpleProtocol::NAME);
EXPECT_TRUE(msg->getType() == SimpleProtocol::MESSAGE);
- EXPECT_TRUE(static_cast<SimpleMessage&>(*msg).getValue() == "test message pxy");
+ EXPECT_TRUE(dynamic_cast<SimpleMessage&>(*msg).getValue() == "test message pxy");
// send reply on server
- SimpleReply::UP sr(new SimpleReply("test reply"));
+ auto sr = std::make_unique<SimpleReply>("test reply");
msg->swapState(*sr);
ds->reply(Reply::UP(sr.release()));
// check reply on proxy
Reply::UP reply = pxy.getReply();
- ASSERT_TRUE(reply.get() != 0);
+ ASSERT_TRUE(reply);
EXPECT_TRUE(reply->getProtocol() == SimpleProtocol::NAME);
EXPECT_TRUE(reply->getType() == SimpleProtocol::REPLY);
- EXPECT_TRUE(static_cast<SimpleReply&>(*reply).getValue() == "test reply");
+ EXPECT_TRUE(dynamic_cast<SimpleReply&>(*reply).getValue() == "test reply");
// forward reply on proxy
- static_cast<SimpleReply&>(*reply).setValue("test reply pxy");
+ dynamic_cast<SimpleReply&>(*reply).setValue("test reply pxy");
is->forward(std::move(reply));
// check reply on client
reply = src.getReply();
- ASSERT_TRUE(reply.get() != 0);
+ ASSERT_TRUE(reply);
EXPECT_TRUE(reply->getProtocol() == SimpleProtocol::NAME);
EXPECT_TRUE(reply->getType() == SimpleProtocol::REPLY);
- EXPECT_TRUE(static_cast<SimpleReply&>(*reply).getValue() == "test reply pxy");
+ EXPECT_TRUE(dynamic_cast<SimpleReply&>(*reply).getValue() == "test reply pxy");
TEST_DONE();
}