diff options
| author | Gordon Sim <gsim@apache.org> | 2014-09-30 15:02:05 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2014-09-30 15:02:05 +0000 |
| commit | 0da097bf2a32489bb770544ab56ed0a18852cb21 (patch) | |
| tree | 45064291ddee451015ddcef98bb03b2cf1f1a7e1 /qpid | |
| parent | fc3f14861d3f78994813a6dd83a0497e73203445 (diff) | |
| download | qpid-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.cpp | 10 |
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)); } } } |
