diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-28 18:28:23 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-10-28 18:28:23 +0100 |
commit | bb1b238d6982abe1e640fbf424234b2c5389642b (patch) | |
tree | 4fd4b44be533720f2804e8fd5f5434991138eb80 /common/genericresource.cpp | |
parent | 043cd5c9e1c90ba04659b67000b974cf8c35f7ba (diff) | |
download | sink-bb1b238d6982abe1e640fbf424234b2c5389642b.tar.gz sink-bb1b238d6982abe1e640fbf424234b2c5389642b.zip |
Cleanup changereplay, and replay revision 1 as the first
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 ec68f33..652154d 100644 --- a/common/genericresource.cpp +++ b/common/genericresource.cpp | |||
@@ -54,7 +54,7 @@ public Q_SLOTS: | |||
54 | { | 54 | { |
55 | auto mainStoreTransaction = mStorage.createTransaction(Storage::ReadOnly); | 55 | auto mainStoreTransaction = mStorage.createTransaction(Storage::ReadOnly); |
56 | auto replayStoreTransaction = mChangeReplayStore.createTransaction(Storage::ReadWrite); | 56 | auto replayStoreTransaction = mChangeReplayStore.createTransaction(Storage::ReadWrite); |
57 | qint64 lastReplayedRevision = 0; | 57 | qint64 lastReplayedRevision = 1; |
58 | replayStoreTransaction.openDatabase().scan("lastReplayedRevision", [&lastReplayedRevision](const QByteArray &key, const QByteArray &value) -> bool { | 58 | replayStoreTransaction.openDatabase().scan("lastReplayedRevision", [&lastReplayedRevision](const QByteArray &key, const QByteArray &value) -> bool { |
59 | lastReplayedRevision = value.toLongLong(); | 59 | lastReplayedRevision = value.toLongLong(); |
60 | return false; | 60 | return false; |
@@ -290,6 +290,7 @@ void GenericResource::removeFromDisk(const QByteArray &instanceIdentifier) | |||
290 | Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier, Akonadi2::Storage::ReadWrite).removeFromDisk(); | 290 | Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier, Akonadi2::Storage::ReadWrite).removeFromDisk(); |
291 | Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".userqueue", Akonadi2::Storage::ReadWrite).removeFromDisk(); | 291 | Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".userqueue", Akonadi2::Storage::ReadWrite).removeFromDisk(); |
292 | Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".synchronizerqueue", Akonadi2::Storage::ReadWrite).removeFromDisk(); | 292 | Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".synchronizerqueue", Akonadi2::Storage::ReadWrite).removeFromDisk(); |
293 | Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".changereplay", Akonadi2::Storage::ReadWrite).removeFromDisk(); | ||
293 | } | 294 | } |
294 | 295 | ||
295 | void GenericResource::onProcessorError(int errorCode, const QString &errorMessage) | 296 | void GenericResource::onProcessorError(int errorCode, const QString &errorMessage) |