Avoid unnecessary replay requests.

A single request will replay until the latest revision.

1 files changed, 6 insertions, 0 deletions

diff --git a/common/synchronizer.cpp b/common/synchronizer.cpp
index cfe1f09..cfd2c10 100644
--- a/common/synchronizer.cpp
+++ b/common/synchronizer.cpp
@@ -381,6 +381,12 @@ Sink::Storage::DataStore::DataStore::Transaction &Synchronizer::syncTransaction(
 
 void Synchronizer::revisionChanged()
 {
+    //One replay request is enough
+    for (const auto &r : mSyncRequestQueue) {
+        if (r.requestType == Synchronizer::SyncRequest::ChangeReplay) {
+            return;
+        }
+    }
     mSyncRequestQueue << Synchronizer::SyncRequest{Synchronizer::SyncRequest::ChangeReplay};
     processSyncQueue().exec();
 }