summaryrefslogtreecommitdiffstats
path: root/common/synchronizer.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2017-01-18 15:55:28 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2017-01-18 15:55:28 +0100
commit47412280397d66950abd9582048ce8e465fc2844 (patch)
treeba4cbea4d2baaee01e33154a4335ade1d0b02370 /common/synchronizer.cpp
parentefe439ae932d221816f5c24283022d494bcb9796 (diff)
downloadsink-47412280397d66950abd9582048ce8e465fc2844.tar.gz
sink-47412280397d66950abd9582048ce8e465fc2844.zip
Don't overwrite the first job with the continuation
Diffstat (limited to 'common/synchronizer.cpp')
-rw-r--r--common/synchronizer.cpp2
1 files changed, 1 insertions, 1 deletions
diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp
index cfd2c10..d86b027 100644
--- a/common/synchronizer.cpp
+++ b/common/synchronizer.cpp
@@ -336,7 +336,7 @@ KAsync::Job<void> Synchronizer::processSyncQueue()
336 enqueueCommand(Sink::Commands::FlushCommand, BufferUtils::extractBuffer(fbb)); 336 enqueueCommand(Sink::Commands::FlushCommand, BufferUtils::extractBuffer(fbb));
337 } 337 }
338 } else if (request.requestType == Synchronizer::SyncRequest::ChangeReplay) { 338 } else if (request.requestType == Synchronizer::SyncRequest::ChangeReplay) {
339 job = replayNextRevision(); 339 job = job.then(replayNextRevision());
340 } else { 340 } else {
341 SinkWarning() << "Unknown request type: " << request.requestType; 341 SinkWarning() << "Unknown request type: " << request.requestType;
342 return KAsync::error(KAsync::Error{"Unknown request type."}); 342 return KAsync::error(KAsync::Error{"Unknown request type."});