diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-07-08 12:32:04 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-07-08 12:32:04 +0200 |
commit | d099ece17c6707af477b91dee9ced13b0f7e962a (patch) | |
tree | 8a564f6c6de279e985cf9f74d0ccae542d2115b3 /common/changereplay.cpp | |
parent | ac67eb1a3baa93cfd494ee5461b1b9bb9b304aa8 (diff) | |
download | sink-d099ece17c6707af477b91dee9ced13b0f7e962a.tar.gz sink-d099ece17c6707af477b91dee9ced13b0f7e962a.zip |
Only change the status once per batch, instead of every revision.
Diffstat (limited to 'common/changereplay.cpp')
-rw-r--r-- | common/changereplay.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/common/changereplay.cpp b/common/changereplay.cpp index 99bbaab..4b7d593 100644 --- a/common/changereplay.cpp +++ b/common/changereplay.cpp | |||
@@ -85,7 +85,6 @@ KAsync::Job<void> ChangeReplay::replayNextRevision() | |||
85 | 85 | ||
86 | if (lastReplayedRevision < topRevision) { | 86 | if (lastReplayedRevision < topRevision) { |
87 | SinkTrace() << "Changereplay from " << lastReplayedRevision << " to " << topRevision; | 87 | SinkTrace() << "Changereplay from " << lastReplayedRevision << " to " << topRevision; |
88 | emit replayingChanges(); | ||
89 | qint64 revision = lastReplayedRevision + 1; | 88 | qint64 revision = lastReplayedRevision + 1; |
90 | const auto uid = Storage::getUidFromRevision(mainStoreTransaction, revision); | 89 | const auto uid = Storage::getUidFromRevision(mainStoreTransaction, revision); |
91 | const auto type = Storage::getTypeFromRevision(mainStoreTransaction, revision); | 90 | const auto type = Storage::getTypeFromRevision(mainStoreTransaction, revision); |
@@ -122,6 +121,7 @@ KAsync::Job<void> ChangeReplay::replayNextRevision() | |||
122 | void ChangeReplay::revisionChanged() | 121 | void ChangeReplay::revisionChanged() |
123 | { | 122 | { |
124 | if (!mReplayInProgress) { | 123 | if (!mReplayInProgress) { |
124 | emit replayingChanges(); | ||
125 | replayNextRevision().exec(); | 125 | replayNextRevision().exec(); |
126 | } | 126 | } |
127 | } | 127 | } |