summaryrefslogtreecommitdiffstats
path: root/common/synchronizer.cpp
diff options
context:
space:
mode:
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 ed493dc..df36ef0 100644
--- a/common/synchronizer.cpp
+++ b/common/synchronizer.cpp
@@ -293,6 +293,7 @@ KAsync::Job<void> Synchronizer::processSyncQueue()
293 n.message = "Synchronization has started."; 293 n.message = "Synchronization has started.";
294 n.code = ApplicationDomain::BusyStatus; 294 n.code = ApplicationDomain::BusyStatus;
295 emit notify(n); 295 emit notify(n);
296 SinkLogCtx(mLogCtx) << "Synchronizing " << request.query.type();
296 }).then(synchronizeWithSource(request.query)).syncThen<void>([this] { 297 }).then(synchronizeWithSource(request.query)).syncThen<void>([this] {
297 //Commit after every request, so implementations only have to commit more if they add a lot of data. 298 //Commit after every request, so implementations only have to commit more if they add a lot of data.
298 commit(); 299 commit();
@@ -367,7 +368,7 @@ void Synchronizer::commit()
367Sink::Storage::DataStore::DataStore::Transaction &Synchronizer::syncTransaction() 368Sink::Storage::DataStore::DataStore::Transaction &Synchronizer::syncTransaction()
368{ 369{
369 if (!mSyncTransaction) { 370 if (!mSyncTransaction) {
370 SinkTrace() << "Starting transaction"; 371 SinkTrace() << "Starting transaction on sync store.";
371 mSyncTransaction = mSyncStorage.createTransaction(Sink::Storage::DataStore::DataStore::ReadWrite); 372 mSyncTransaction = mSyncStorage.createTransaction(Sink::Storage::DataStore::DataStore::ReadWrite);
372 } 373 }
373 return mSyncTransaction; 374 return mSyncTransaction;