summaryrefslogtreecommitdiffstats
path: root/common/synchronizer.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-07 21:48:44 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-07 21:48:44 +0100
commit89b6f63bab839ab0504cd3067f0389afe4dc47e3 (patch)
tree62c527983d63827bb722010ea8c59d5af0e5a879 /common/synchronizer.cpp
parent438c74630e5f8c9a46d00b991f5cb8ecd479dafe (diff)
downloadsink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.tar.gz
sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.zip
Implement debug stream operators for query.
Diffstat (limited to 'common/synchronizer.cpp')
-rw-r--r--common/synchronizer.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp
index 206cf5e..85c68e4 100644
--- a/common/synchronizer.cpp
+++ b/common/synchronizer.cpp
@@ -228,12 +228,12 @@ void Synchronizer::modify(const DomainType &entity)
228 modifyEntity(entity.identifier(), entity.revision(), ApplicationDomain::getTypeName<DomainType>(), entity); 228 modifyEntity(entity.identifier(), entity.revision(), ApplicationDomain::getTypeName<DomainType>(), entity);
229} 229}
230 230
231KAsync::Job<void> Synchronizer::synchronize() 231KAsync::Job<void> Synchronizer::synchronize(const Sink::QueryBase &query)
232{ 232{
233 SinkTrace() << "Synchronizing"; 233 SinkTrace() << "Synchronizing";
234 mSyncInProgress = true; 234 mSyncInProgress = true;
235 mMessageQueue->startTransaction(); 235 mMessageQueue->startTransaction();
236 return synchronizeWithSource().syncThen<void>([this]() { 236 return synchronizeWithSource(query).syncThen<void>([this]() {
237 mSyncStore.clear(); 237 mSyncStore.clear();
238 mMessageQueue->commit(); 238 mMessageQueue->commit();
239 mSyncInProgress = false; 239 mSyncInProgress = false;