Support dependencies between sync requests.

If one sync task depends on the previous sync task we want to flush in
between, so we can query for the results of the previous sync request
locally.

If we detect such a dependency we temporarily halt all processing of
synchronization requests until the flush completes, so we can continue
processing.

1 files changed, 1 insertions, 0 deletions

diff --git a/common/commandprocessor.cpp b/common/commandprocessor.cpp
index a6371be..5d5261f 100644
--- a/common/commandprocessor.cpp
+++ b/common/commandprocessor.cpp
@@ -331,6 +331,7 @@ KAsync::Job<void> CommandProcessor::flush(void const *command, size_t size)
             mSynchronizer->flush(flushType, flushId);
         } else {
             SinkTraceCtx(mLogCtx) << "Emitting flush completion" << flushId;
+            mSynchronizer->flushComplete(flushId);
             Sink::Notification n;
             n.type = Sink::Notification::FlushCompletion;
             n.id = flushId;