diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-07 21:48:44 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-07 21:48:44 +0100 |
commit | 89b6f63bab839ab0504cd3067f0389afe4dc47e3 (patch) | |
tree | 62c527983d63827bb722010ea8c59d5af0e5a879 /common/synchronizer.cpp | |
parent | 438c74630e5f8c9a46d00b991f5cb8ecd479dafe (diff) | |
download | sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.tar.gz sink-89b6f63bab839ab0504cd3067f0389afe4dc47e3.zip |
Implement debug stream operators for query.
Diffstat (limited to 'common/synchronizer.cpp')
-rw-r--r-- | common/synchronizer.cpp | 4 |
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 | ||
231 | KAsync::Job<void> Synchronizer::synchronize() | 231 | KAsync::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; |