summaryrefslogtreecommitdiff
path: root/cpp/src/tests/QueueTest.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2008-10-11 18:24:50 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2008-10-11 18:24:50 +0000
commit493993c4b8851ba1a1170abb928d2f37d8060e83 (patch)
tree6e7e3caf48995fdc5055dd83e1cc60d735a680a2 /cpp/src/tests/QueueTest.cpp
parent7a4f554f249787b7de06d1bf6e61d5c587a28f1a (diff)
downloadqpid-python-493993c4b8851ba1a1170abb928d2f37d8060e83.tar.gz
QPID-1306
- Added aquire safety check + test. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703704 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/tests/QueueTest.cpp')
-rw-r--r--cpp/src/tests/QueueTest.cpp9
1 files changed, 6 insertions, 3 deletions
diff --git a/cpp/src/tests/QueueTest.cpp b/cpp/src/tests/QueueTest.cpp
index a189dc1f15..ccc2fc2391 100644
--- a/cpp/src/tests/QueueTest.cpp
+++ b/cpp/src/tests/QueueTest.cpp
@@ -423,9 +423,12 @@ QPID_AUTO_TEST_CASE(testLVQAcquire){
BOOST_CHECK_EQUAL(queue->getMessageCount(), 3u);
- framing::SequenceNumber sequence;
- QueuedMessage qmsg(queue.get(), msg2, ++sequence);
- queue->acquire(qmsg);
+ framing::SequenceNumber sequence(1);
+ QueuedMessage qmsg(queue.get(), msg1, sequence);
+ QueuedMessage qmsg2(queue.get(), msg2, ++sequence);
+
+ BOOST_CHECK(!queue->acquire(qmsg));
+ BOOST_CHECK(queue->acquire(qmsg2));
BOOST_CHECK_EQUAL(queue->getMessageCount(), 2u);