aboutsummaryrefslogtreecommitdiffstats
path: root/messagebus/src/tests/sequencer
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-12-03 21:45:53 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2019-12-04 18:26:06 +0000
commitb8e151a435ccec1ecc03d98bac5b59f4f14514be (patch)
tree140efda301a7e5adc407c44061ba5b0bb41dd212 /messagebus/src/tests/sequencer
parent7700f411ea6f4a3e7c0599fae239ec84c18c0038 (diff)
timeout as duration
Conflicts: messagebus/src/vespa/messagebus/testlib/testserver.cpp
Diffstat (limited to 'messagebus/src/tests/sequencer')
-rw-r--r--messagebus/src/tests/sequencer/sequencer.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/messagebus/src/tests/sequencer/sequencer.cpp b/messagebus/src/tests/sequencer/sequencer.cpp
index 218c1e43929..d347c3855cb 100644
--- a/messagebus/src/tests/sequencer/sequencer.cpp
+++ b/messagebus/src/tests/sequencer/sequencer.cpp
@@ -21,7 +21,7 @@ struct MyQueue : public RoutableQueue {
virtual ~MyQueue() {
while (size() > 0) {
- Routable::UP obj = dequeue(0);
+ Routable::UP obj = dequeue();
obj->getCallStack().discard();
}
}
@@ -31,14 +31,14 @@ struct MyQueue : public RoutableQueue {
LOG(error, "checkReply(): No reply in queue.");
return false;
}
- Routable::UP obj = dequeue(0);
+ Routable::UP obj = dequeue();
if (!obj->isReply()) {
LOG(error, "checkReply(): Got message when expecting reply.");
return false;
}
Reply::UP reply(static_cast<Reply*>(obj.release()));
Message::UP msg = reply->getMessage();
- if (msg.get() == NULL) {
+ if ( ! msg) {
LOG(error, "checkReply(): Reply has no message attached.");
return false;
}
@@ -64,7 +64,7 @@ struct MyQueue : public RoutableQueue {
}
void replyNext() {
- Routable::UP obj = dequeue(0);
+ Routable::UP obj = dequeue();
Message::UP msg(static_cast<Message*>(obj.release()));
Reply::UP reply(new EmptyReply());