summaryrefslogtreecommitdiffstats
path: root/common/changereplay.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-22 10:26:11 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-22 10:26:11 +0100
commitb6981d94fb5fb12024738b639f9e389dd04578da (patch)
treef13e16f84ba9cf33782af7a0b0dbd82c5d65afd4 /common/changereplay.h
parent1d713d9e2dbaf27de9da087f9270d260dfc40c31 (diff)
downloadsink-b6981d94fb5fb12024738b639f9e389dd04578da.tar.gz
sink-b6981d94fb5fb12024738b639f9e389dd04578da.zip
Process change replays as part of the synchronization queue
Diffstat (limited to 'common/changereplay.h')
-rw-r--r--common/changereplay.h4
1 files changed, 2 insertions, 2 deletions
diff --git a/common/changereplay.h b/common/changereplay.h
index e86c4f2..4894806 100644
--- a/common/changereplay.h
+++ b/common/changereplay.h
@@ -49,16 +49,16 @@ signals:
49 void replayingChanges(); 49 void replayingChanges();
50 50
51public slots: 51public slots:
52 void revisionChanged(); 52 virtual void revisionChanged();
53 53
54protected: 54protected:
55 virtual KAsync::Job<void> replay(const QByteArray &type, const QByteArray &key, const QByteArray &value) = 0; 55 virtual KAsync::Job<void> replay(const QByteArray &type, const QByteArray &key, const QByteArray &value) = 0;
56 virtual bool canReplay(const QByteArray &type, const QByteArray &key, const QByteArray &value) = 0; 56 virtual bool canReplay(const QByteArray &type, const QByteArray &key, const QByteArray &value) = 0;
57 Sink::Storage::DataStore mStorage; 57 Sink::Storage::DataStore mStorage;
58 KAsync::Job<void> replayNextRevision();
58 59
59private: 60private:
60 void recordReplayedRevision(qint64 revision); 61 void recordReplayedRevision(qint64 revision);
61 KAsync::Job<void> replayNextRevision();
62 Sink::Storage::DataStore mChangeReplayStore; 62 Sink::Storage::DataStore mChangeReplayStore;
63 bool mReplayInProgress; 63 bool mReplayInProgress;
64 Sink::Storage::DataStore::Transaction mMainStoreTransaction; 64 Sink::Storage::DataStore::Transaction mMainStoreTransaction;