- flush async IO if present on sync for 0-10

- notify, for ack from sync for 0-10
- use of raw pointer, to avoid recursive fre



git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@587332 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 0 deletions

diff --git a/cpp/src/qpid/broker/IncomingExecutionContext.cpp b/cpp/src/qpid/broker/IncomingExecutionContext.cpp
index 7cf1179fcb..4747c71033 100644
--- a/cpp/src/qpid/broker/IncomingExecutionContext.cpp
+++ b/cpp/src/qpid/broker/IncomingExecutionContext.cpp
@@ -112,6 +112,10 @@ SequenceNumberSet IncomingExecutionContext::getRange()
 void IncomingExecutionContext::wait()
 {
     check();
+	// for IO flush on the store
+    for (Messages::iterator i = incomplete.begin(); i != incomplete.end(); i++) {
+        (*i)->flush();
+    }
     incomplete.front()->waitForEnqueueComplete();
     flush();
 }