You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ac...@apache.org on 2011/12/14 22:46:05 UTC
svn commit: r1214492 -
/qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/MessageDeque.cpp
Author: aconway
Date: Wed Dec 14 21:46:05 2011
New Revision: 1214492
URL: http://svn.apache.org/viewvc?rev=1214492&view=rev
Log:
QPID-3603: Fix bug in MessageDeque::acquire.
Acquire was returning incorrect results if the acquired position was
before the first availble index.
Modified:
qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/MessageDeque.cpp
Modified: qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/MessageDeque.cpp
URL: http://svn.apache.org/viewvc/qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/MessageDeque.cpp?rev=1214492&r1=1214491&r2=1214492&view=diff
==============================================================================
--- qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/MessageDeque.cpp (original)
+++ qpid/branches/qpid-3603/qpid/cpp/src/qpid/broker/MessageDeque.cpp Wed Dec 14 21:46:05 2011
@@ -70,6 +70,7 @@ void MessageDeque::release(const QueuedM
bool MessageDeque::acquire(const framing::SequenceNumber& position, QueuedMessage& message)
{
+ if (position < messages.front().position) return false;
size_t i = index(position);
if (i < messages.size()) {
QueuedMessage& temp = messages[i];
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org