diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-22 10:26:11 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-22 10:26:11 +0100 |
commit | b6981d94fb5fb12024738b639f9e389dd04578da (patch) | |
tree | f13e16f84ba9cf33782af7a0b0dbd82c5d65afd4 /common/changereplay.h | |
parent | 1d713d9e2dbaf27de9da087f9270d260dfc40c31 (diff) | |
download | sink-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.h | 4 |
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 | ||
51 | public slots: | 51 | public slots: |
52 | void revisionChanged(); | 52 | virtual void revisionChanged(); |
53 | 53 | ||
54 | protected: | 54 | protected: |
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 | ||
59 | private: | 60 | private: |
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; |