diff options
author | Gordon Sim <gsim@apache.org> | 2008-11-27 18:48:18 +0000 |
---|---|---|
committer | Gordon Sim <gsim@apache.org> | 2008-11-27 18:48:18 +0000 |
commit | f7536e37883be4982b7c8b92e4a95913367c3ff0 (patch) | |
tree | 48a8ff26513259b81bbd49a62e2f1e9efcc16bbd /qpid/cpp/src/tests/IncompleteMessageList.cpp | |
parent | 55317569afa36d78d1ebe95a409f1c725acf524d (diff) | |
download | qpid-python-f7536e37883be4982b7c8b92e4a95913367c3ff0.tar.gz |
Backed out last change; not sure it actually makes sense.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@721258 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/IncompleteMessageList.cpp')
-rw-r--r-- | qpid/cpp/src/tests/IncompleteMessageList.cpp | 37 |
1 files changed, 1 insertions, 36 deletions
diff --git a/qpid/cpp/src/tests/IncompleteMessageList.cpp b/qpid/cpp/src/tests/IncompleteMessageList.cpp index d9ea70f815..925cdbf43e 100644 --- a/qpid/cpp/src/tests/IncompleteMessageList.cpp +++ b/qpid/cpp/src/tests/IncompleteMessageList.cpp @@ -24,8 +24,6 @@ #include "qpid/broker/NullMessageStore.h" #include "qpid/broker/Queue.h" #include "qpid/broker/IncompleteMessageList.h" -#include "qpid/sys/Runnable.h" -#include "qpid/sys/Thread.h" #include "unit_test.h" @@ -95,6 +93,7 @@ QPID_AUTO_TEST_CASE(testProcessWithIncomplete) list.process(Checker(3, 5), false); } + struct MockStore : public NullMessageStore { Queue::shared_ptr queue; @@ -126,38 +125,4 @@ QPID_AUTO_TEST_CASE(testSyncProcessWithIncomplete) list.process(Checker(1, 5), true); } -struct AsyncProcessor : qpid::sys::Runnable -{ - Checker checker; - IncompleteMessageList& list; - - AsyncProcessor(uint start, uint end, IncompleteMessageList& list_) : checker(start, end), list(list_) {} - - void run() - { - list.process(checker, true); - } -}; - -QPID_AUTO_TEST_CASE(testSyncProcessInterruptedOnClose) -{ - IncompleteMessageList list; - SequenceNumber counter(1); - NullMessageStore store; - Queue::shared_ptr queue(new Queue("mock-queue")); - //fill up list with messages - for (int i = 0; i < 5; i++) { - boost::intrusive_ptr<Message> msg(new Message(counter++)); - list.add(msg); - if (i == 2) { - //mark a message in the middle as incomplete - msg->enqueueAsync(queue, &store); - } - } - AsyncProcessor ap(1, 2, list); - qpid::sys::Thread thread(ap); - list.close(); - thread.join(); -} - QPID_AUTO_TEST_SUITE_END() |