diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-03-20 09:24:06 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-03-20 09:24:06 +0100 |
commit | cd5ecf7b381ebc76196931e213c92664c3443be8 (patch) | |
tree | 0f8beca5b6e7c62ff503c0b8fcfcd12bcc91a1be /common/synchronizer.cpp | |
parent | 9e8d4bac334e727368ada48676a21d52030b97cc (diff) | |
download | sink-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.cpp | 3 |
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(); |