diff options
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(); |