aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests/sourcesession
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/sourcesession
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/sourcesession')
-rw-r--r--messagebus/src/tests/sourcesession/sourcesession.cpp15
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();