diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-01-31 19:41:08 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-02-01 21:51:45 +0000 |
commit | 79487ed8e135b5948248db91974148d80f2692dc (patch) | |
tree | ef1db9dc8979bd21ca3818d59548b2d39bf1d7e2 /messagebus/src/tests/sourcesession | |
parent | 5d4c62ac6a6cc32c9c0893126c603d9428a5dab7 (diff) |
- Deinline destructor.
- Move instead of copy = > noexcept move construtors.
- make_unique/make_shared.
- c++11 for loops
Diffstat (limited to 'messagebus/src/tests/sourcesession')
-rw-r--r-- | messagebus/src/tests/sourcesession/sourcesession.cpp | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/messagebus/src/tests/sourcesession/sourcesession.cpp b/messagebus/src/tests/sourcesession/sourcesession.cpp index 6ebbc68f965..a91c128b0b0 100644 --- a/messagebus/src/tests/sourcesession/sourcesession.cpp +++ b/messagebus/src/tests/sourcesession/sourcesession.cpp @@ -13,7 +13,6 @@ #include <vespa/messagebus/routing/routingspec.h> #include <vespa/messagebus/testlib/simplemessage.h> #include <vespa/messagebus/testlib/simpleprotocol.h> -#include <vespa/messagebus/testlib/simplereply.h> #include <vespa/messagebus/testlib/slobrok.h> #include <vespa/messagebus/testlib/testserver.h> #include <vespa/vespalib/testkit/testapp.h> @@ -29,7 +28,7 @@ struct DelayedHandler : public IMessageHandler DelayedHandler(MessageBus &mb, uint32_t d) : session(), delay(d) { session = mb.createDestinationSession("session", true, *this); } - ~DelayedHandler() { + ~DelayedHandler() override { session.reset(); } void handleMessage(Message::UP msg) override { @@ -45,14 +44,14 @@ RoutingSpec getRouting() { return RoutingSpec() .addTable(RoutingTableSpec("Simple") .addHop(HopSpec("dst", "dst/session")) - .addRoute(RouteSpec("dst").addHop("dst"))); + .addRoute(std::move(RouteSpec("dst").addHop("dst")))); } RoutingSpec getBadRouting() { return RoutingSpec() .addTable(RoutingTableSpec("Simple") .addHop(HopSpec("dst", "dst/session")) - .addRoute(RouteSpec("dst").addHop("dst"))); + .addRoute(std::move(RouteSpec("dst").addHop("dst")))); } bool waitQueueSize(RoutableQueue &queue, uint32_t size) { @@ -183,8 +182,8 @@ Test::testResendConnDown() RPCNetworkParams(slobrok.config())); src.mb.setupRouting(RoutingSpec().addTable(RoutingTableSpec(SimpleProtocol::NAME) .addHop(HopSpec("dst", "dst2/session")) - .addHop(HopSpec("pxy", "[All]").addRecipient("dst")) - .addRoute(RouteSpec("dst").addHop("pxy")))); + .addHop(std::move(HopSpec("pxy", "[All]").addRecipient("dst"))) + .addRoute(std::move(RouteSpec("dst").addHop("pxy"))))); RoutableQueue srcQ; SourceSession::UP ss = src.mb.createSourceSession(srcQ); @@ -243,7 +242,7 @@ Test::testIllegalRoute() while (srcQ.size() > 0) { Routable::UP routable = srcQ.dequeue(); ASSERT_TRUE(routable->isReply()); - Reply::UP r(static_cast<Reply*>(routable.release())); + Reply::UP r(dynamic_cast<Reply*>(routable.release())); EXPECT_EQUAL(1u, r->getNumErrors()); EXPECT_EQUAL((uint32_t)ErrorCode::NO_ADDRESS_FOR_SERVICE, r->getError(0).getCode()); string trace = r->getTrace().toString(); @@ -275,7 +274,7 @@ Test::testNoServices() while (srcQ.size() > 0) { Routable::UP routable = srcQ.dequeue(); ASSERT_TRUE(routable->isReply()); - Reply::UP r(static_cast<Reply*>(routable.release())); + Reply::UP r(dynamic_cast<Reply*>(routable.release())); EXPECT_TRUE(r->getNumErrors() == 1); EXPECT_TRUE(r->getError(0).getCode() == ErrorCode::NO_ADDRESS_FOR_SERVICE); string trace = r->getTrace().toString(); |