summaryrefslogtreecommitdiffstats
path: root/common/synchronizer.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2017-03-14 11:41:32 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2017-03-14 11:41:32 +0100
commit6f3f86f9617486e1d30f263189fedafa1fedd62e (patch)
treef9f2bea723c2be293ef4e4788215fa237dc1a089 /common/synchronizer.cpp
parentec79366d96f7376b758fb41a50d3096518be4333 (diff)
downloadsink-6f3f86f9617486e1d30f263189fedafa1fedd62e.tar.gz
sink-6f3f86f9617486e1d30f263189fedafa1fedd62e.zip
Debug output
Diffstat (limited to 'common/synchronizer.cpp')
-rw-r--r--common/synchronizer.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp
index e722f57..c7c0af5 100644
--- a/common/synchronizer.cpp
+++ b/common/synchronizer.cpp
@@ -353,7 +353,7 @@ KAsync::Job<void> Synchronizer::processRequest(const SyncRequest &request)
353 Q_ASSERT(!request.requestId.isEmpty()); 353 Q_ASSERT(!request.requestId.isEmpty());
354 //FIXME it looks like this is emitted before the replay actually finishes 354 //FIXME it looks like this is emitted before the replay actually finishes
355 if (request.flushType == Flush::FlushReplayQueue) { 355 if (request.flushType == Flush::FlushReplayQueue) {
356 SinkTraceCtx(mLogCtx) << "Emitting flush completion."; 356 SinkTraceCtx(mLogCtx) << "Emitting flush completion: " << request.requestId;
357 Sink::Notification n; 357 Sink::Notification n;
358 n.type = Sink::Notification::FlushCompletion; 358 n.type = Sink::Notification::FlushCompletion;
359 n.id = request.requestId; 359 n.id = request.requestId;
@@ -410,7 +410,7 @@ KAsync::Job<void> Synchronizer::processSyncQueue()
410 emit changesReplayed(); 410 emit changesReplayed();
411 } 411 }
412 if (error) { 412 if (error) {
413 SinkWarningCtx(mLogCtx) << "Error during sync: " << error.errorMessage; 413 SinkWarningCtx(mLogCtx) << "Error during sync: " << error;
414 } 414 }
415 //In case we got more requests meanwhile. 415 //In case we got more requests meanwhile.
416 return processSyncQueue(); 416 return processSyncQueue();