Commit all databases in the same interval

1 files changed, 6 insertions, 4 deletions

diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp
index cf50b0b..1374d00 100644
--- a/common/synchronizer.cpp
+++ b/common/synchronizer.cpp
@@ -240,24 +240,26 @@ void Synchronizer::modify(const DomainType &entity)
 KAsync::Job<void> Synchronizer::synchronize()
 {
     Trace() << "Synchronizing";
+    mSyncInProgress = true;
     mMessageQueue->startTransaction();
     return synchronizeWithSource().then<void>([this]() {
         mSyncStore.clear();
         mEntityStore.clear();
         mMessageQueue->commit();
+        mSyncInProgress = false;
     });
 }
 
 void Synchronizer::commit()
 {
+    mMessageQueue->commit();
     mTransaction.abort();
     mEntityStore.clear();
-}
-
-void Synchronizer::commitSync()
-{
     mSyncTransaction.commit();
     mSyncStore.clear();
+    if (mSyncInProgress) {
+        mMessageQueue->startTransaction();
+    }
 }
 
 Sink::Storage::Transaction &Synchronizer::transaction()