diff options
Diffstat (limited to 'common')
-rw-r--r-- | common/synchronizer.cpp | 6 |
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( | |||
381 | 381 | ||
382 | void Synchronizer::revisionChanged() | 382 | void Synchronizer::revisionChanged() |
383 | { | 383 | { |
384 | //One replay request is enough | ||
385 | for (const auto &r : mSyncRequestQueue) { | ||
386 | if (r.requestType == Synchronizer::SyncRequest::ChangeReplay) { | ||
387 | return; | ||
388 | } | ||
389 | } | ||
384 | mSyncRequestQueue << Synchronizer::SyncRequest{Synchronizer::SyncRequest::ChangeReplay}; | 390 | mSyncRequestQueue << Synchronizer::SyncRequest{Synchronizer::SyncRequest::ChangeReplay}; |
385 | processSyncQueue().exec(); | 391 | processSyncQueue().exec(); |
386 | } | 392 | } |