diff options
| author | Carl C. Trieloff <cctrieloff@apache.org> | 2007-08-16 20:57:43 +0000 |
|---|---|---|
| committer | Carl C. Trieloff <cctrieloff@apache.org> | 2007-08-16 20:57:43 +0000 |
| commit | c47ffec9b9e4608e511c03ed597a6c988460703f (patch) | |
| tree | bac0c12a88c63c02be820dcf2758ae15cdfd80c2 /cpp/src/qpid/broker/RecoveryManagerImpl.cpp | |
| parent | d146e757b26e03349db432c8732f0067aecb4e7b (diff) | |
| download | qpid-python-c47ffec9b9e4608e511c03ed597a6c988460703f.tar.gz | |
- Fix for asyncIO for store
- Fix for dtx async IO recover
- Temp patch for Tx commit ( existing bug uncovered )
- All store tests should be working again
Know issues:
- If a msg is sent to more than one queue, then the
io complete is signaled on the first record written, not
the last
- Open issues for tx begin then commit with no prepare using
duarble msgs and async IO. async complete bit not set on
recovery. will be fixed with next commit.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@566846 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/RecoveryManagerImpl.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/RecoveryManagerImpl.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/RecoveryManagerImpl.cpp b/cpp/src/qpid/broker/RecoveryManagerImpl.cpp index 2daf3b2d0a..954c50faee 100644 --- a/cpp/src/qpid/broker/RecoveryManagerImpl.cpp +++ b/cpp/src/qpid/broker/RecoveryManagerImpl.cpp @@ -194,6 +194,7 @@ void RecoverableMessageImpl::dequeue(DtxBuffer::shared_ptr buffer, Queue::shared void RecoverableMessageImpl::enqueue(DtxBuffer::shared_ptr buffer, Queue::shared_ptr queue) { + msg->enqueueComplete(); // recoved nmessage to enqueued in store already buffer->enlist(TxOp::shared_ptr(new RecoveredEnqueue(queue, msg))); } |