From e513ee41adb6061aa72de8bfe49d117f47c1545b Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Sun, 22 Jan 2017 18:25:31 +0100
Subject: 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.
---
 common/commandprocessor.cpp | 1 +
 1 file changed, 1 insertion(+)

(limited to 'common/commandprocessor.cpp')

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;
-- 
cgit v1.2.3