summaryrefslogtreecommitdiffstats
path: root/common/synchronizer.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2017-01-06 15:15:22 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2017-01-06 15:15:22 +0100
commit470203f1c09fa1811ae2859520c168901d5fa6cd (patch)
tree6e520109547313cc7a6d5672c46699e78f4fb825 /common/synchronizer.cpp
parent02219fb46fff9312ec2bf3896fdee6dd537aaa0d (diff)
downloadsink-470203f1c09fa1811ae2859520c168901d5fa6cd.tar.gz
sink-470203f1c09fa1811ae2859520c168901d5fa6cd.zip
Debug output
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;