summaryrefslogtreecommitdiffstats
path: root/common/genericresource.cpp
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2015-10-28 18:28:23 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2015-10-28 18:28:23 +0100
commitbb1b238d6982abe1e640fbf424234b2c5389642b (patch)
tree4fd4b44be533720f2804e8fd5f5434991138eb80 /common/genericresource.cpp
parent043cd5c9e1c90ba04659b67000b974cf8c35f7ba (diff)
downloadsink-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.cpp3
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
295void GenericResource::onProcessorError(int errorCode, const QString &errorMessage) 296void GenericResource::onProcessorError(int errorCode, const QString &errorMessage)