diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-12-03 21:45:53 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-12-04 18:26:06 +0000 |
commit | b8e151a435ccec1ecc03d98bac5b59f4f14514be (patch) | |
tree | 140efda301a7e5adc407c44061ba5b0bb41dd212 /messagebus/src/tests/sequencer | |
parent | 7700f411ea6f4a3e7c0599fae239ec84c18c0038 (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.cpp | 8 |
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()); |