diff options
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; |