diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-21 14:21:16 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-21 14:21:16 +0200 |
commit | 12cc3f612c3ebe9522f98c808f9d7115d8e222ce (patch) | |
tree | 8dd53dd441d8577b9d72289748a72cf76acd4cca /common/genericresource.cpp | |
parent | 264fb692ccd122e53c7592a26447ed8281179c8b (diff) | |
download | sink-12cc3f612c3ebe9522f98c808f9d7115d8e222ce.tar.gz sink-12cc3f612c3ebe9522f98c808f9d7115d8e222ce.zip |
Cleanup
Diffstat (limited to 'common/genericresource.cpp')
-rw-r--r-- | common/genericresource.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/common/genericresource.cpp b/common/genericresource.cpp index 8ae20ed..dcae43d 100644 --- a/common/genericresource.cpp +++ b/common/genericresource.cpp | |||
@@ -26,7 +26,7 @@ public: | |||
26 | 26 | ||
27 | typedef std::function<KAsync::Job<void>(const QByteArray &type, const QByteArray &key, const QByteArray &value)> ReplayFunction; | 27 | typedef std::function<KAsync::Job<void>(const QByteArray &type, const QByteArray &key, const QByteArray &value)> ReplayFunction; |
28 | 28 | ||
29 | ChangeReplay(const QString &resourceName, const ReplayFunction replayFunction) | 29 | ChangeReplay(const QString &resourceName, const ReplayFunction &replayFunction) |
30 | : mStorage(storageLocation(), resourceName, Storage::ReadOnly), | 30 | : mStorage(storageLocation(), resourceName, Storage::ReadOnly), |
31 | mChangeReplayStore(storageLocation(), resourceName + ".changereplay", Storage::ReadWrite), | 31 | mChangeReplayStore(storageLocation(), resourceName + ".changereplay", Storage::ReadWrite), |
32 | mReplayFunction(replayFunction) | 32 | mReplayFunction(replayFunction) |
@@ -224,6 +224,7 @@ private slots: | |||
224 | KAsync::Job<void> processPipeline() | 224 | KAsync::Job<void> processPipeline() |
225 | { | 225 | { |
226 | mPipeline->startTransaction(); | 226 | mPipeline->startTransaction(); |
227 | Trace() << "Cleaning up from " << mPipeline->cleanedUpRevision() + 1 << " to " << mLowerBoundRevision; | ||
227 | for (qint64 revision = mPipeline->cleanedUpRevision() + 1; revision <= mLowerBoundRevision; revision++) { | 228 | for (qint64 revision = mPipeline->cleanedUpRevision() + 1; revision <= mLowerBoundRevision; revision++) { |
228 | mPipeline->cleanupRevision(revision); | 229 | mPipeline->cleanupRevision(revision); |
229 | } | 230 | } |