diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-06 15:15:22 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2017-01-06 15:15:22 +0100 |
commit | 470203f1c09fa1811ae2859520c168901d5fa6cd (patch) | |
tree | 6e520109547313cc7a6d5672c46699e78f4fb825 /common/synchronizer.cpp | |
parent | 02219fb46fff9312ec2bf3896fdee6dd537aaa0d (diff) | |
download | sink-470203f1c09fa1811ae2859520c168901d5fa6cd.tar.gz sink-470203f1c09fa1811ae2859520c168901d5fa6cd.zip |
Debug output
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 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() | |||
367 | Sink::Storage::DataStore::DataStore::Transaction &Synchronizer::syncTransaction() | 368 | Sink::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; |