summaryrefslogtreecommitdiffstats
path: root/common/synchronizer.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2017-03-20 09:24:06 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2017-03-20 09:24:06 +0100
commitcd5ecf7b381ebc76196931e213c92664c3443be8 (patch)
tree0f8beca5b6e7c62ff503c0b8fcfcd12bcc91a1be /common/synchronizer.cpp
parent9e8d4bac334e727368ada48676a21d52030b97cc (diff)
downloadsink-cd5ecf7b381ebc76196931e213c92664c3443be8.tar.gz
sink-cd5ecf7b381ebc76196931e213c92664c3443be8.zip
Make error codes part of the applicationdomain interface
Diffstat (limited to 'common/synchronizer.cpp')
-rw-r--r--common/synchronizer.cpp3
1 files changed, 2 insertions, 1 deletions
diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp
index ff13783..4ed6e3a 100644
--- a/common/synchronizer.cpp
+++ b/common/synchronizer.cpp
@@ -391,7 +391,7 @@ KAsync::Job<void> Synchronizer::processSyncQueue()
391 mSyncInProgress = true; 391 mSyncInProgress = true;
392 }) 392 })
393 .then(processRequest(request)) 393 .then(processRequest(request))
394 .then<void>([this](const KAsync::Error &error) { 394 .then<void>([this, request](const KAsync::Error &error) {
395 SinkTraceCtx(mLogCtx) << "Sync request processed"; 395 SinkTraceCtx(mLogCtx) << "Sync request processed";
396 mEntityStore->abortTransaction(); 396 mEntityStore->abortTransaction();
397 mSyncTransaction.abort(); 397 mSyncTransaction.abort();
@@ -403,6 +403,7 @@ KAsync::Job<void> Synchronizer::processSyncQueue()
403 } 403 }
404 if (error) { 404 if (error) {
405 SinkWarningCtx(mLogCtx) << "Error during sync: " << error; 405 SinkWarningCtx(mLogCtx) << "Error during sync: " << error;
406 emitNotification(Notification::Error, error.errorCode, error.errorMessage, request.requestId);
406 } 407 }
407 //In case we got more requests meanwhile. 408 //In case we got more requests meanwhile.
408 return processSyncQueue(); 409 return processSyncQueue();