diff options
-rw-r--r-- | common/changereplay.cpp | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/common/changereplay.cpp b/common/changereplay.cpp index a17fc88..51443e8 100644 --- a/common/changereplay.cpp +++ b/common/changereplay.cpp | |||
@@ -96,7 +96,6 @@ KAsync::Job<void> ChangeReplay::replayNextRevision() | |||
96 | [&lastReplayedRevision, type, this, &replayJob](const QByteArray &key, const QByteArray &value) -> bool { | 96 | [&lastReplayedRevision, type, this, &replayJob](const QByteArray &key, const QByteArray &value) -> bool { |
97 | Trace() << "Replaying " << key; | 97 | Trace() << "Replaying " << key; |
98 | replayJob = replay(type, key, value); | 98 | replayJob = replay(type, key, value); |
99 | // TODO make for loop async, and pass to async replay function together with type | ||
100 | return false; | 99 | return false; |
101 | }, | 100 | }, |
102 | [key](const Storage::Error &) { ErrorMsg() << "Failed to replay change " << key; }); | 101 | [key](const Storage::Error &) { ErrorMsg() << "Failed to replay change " << key; }); |
@@ -108,9 +107,9 @@ KAsync::Job<void> ChangeReplay::replayNextRevision() | |||
108 | }, | 107 | }, |
109 | [this, revision, recordReplayedRevision](int, QString) { | 108 | [this, revision, recordReplayedRevision](int, QString) { |
110 | Trace() << "Change replay failed" << revision; | 109 | Trace() << "Change replay failed" << revision; |
111 | recordReplayedRevision(revision); | 110 | //We're probably not online or so, so postpone retrying |
112 | //replay until we're done | 111 | mReplayInProgress = false; |
113 | replayNextRevision().exec(); | 112 | emit changesReplayed(); |
114 | }); | 113 | }); |
115 | } else { | 114 | } else { |
116 | Trace() << "No changes to replay"; | 115 | Trace() << "No changes to replay"; |