summaryrefslogtreecommitdiff
path: root/qpid
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2014-09-30 15:02:05 +0000
committerGordon Sim <gsim@apache.org>2014-09-30 15:02:05 +0000
commit0da097bf2a32489bb770544ab56ed0a18852cb21 (patch)
tree45064291ddee451015ddcef98bb03b2cf1f1a7e1 /qpid
parentfc3f14861d3f78994813a6dd83a0497e73203445 (diff)
downloadqpid-python-0da097bf2a32489bb770544ab56ed0a18852cb21.tar.gz
QPID-6127: slight refactoring of previous solution for brevity; suggested by Andrew Stitcher.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1628462 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid')
-rw-r--r--qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp10
1 files changed, 2 insertions, 8 deletions
diff --git a/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp b/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
index e8f36ae8ea..e300ddae8b 100644
--- a/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
+++ b/qpid/cpp/src/qpid/client/amqp0_10/IncomingMessages.cpp
@@ -34,6 +34,7 @@
#include "qpid/framing/MessageProperties.h"
#include "qpid/framing/MessageTransferBody.h"
#include "qpid/framing/enum.h"
+#include <algorithm>
namespace qpid {
namespace client {
@@ -131,15 +132,8 @@ qpid::sys::Duration get_duration(qpid::sys::Duration timeout, qpid::sys::AbsTime
{
if (timeout == qpid::sys::TIME_INFINITE) {
return qpid::sys::TIME_INFINITE;
- } else if (timeout == 0) {
- return 0;
} else {
- qpid::sys::AbsTime n = AbsTime::now();
- if (n < deadline) {
- return qpid::sys::Duration(n, deadline);
- } else {
- return 0;
- }
+ return std::max(qpid::sys::Duration(0), qpid::sys::Duration(AbsTime::now(), deadline));
}
}
}