From bb1b238d6982abe1e640fbf424234b2c5389642b Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Wed, 28 Oct 2015 18:28:23 +0100 Subject: Cleanup changereplay, and replay revision 1 as the first --- common/genericresource.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'common') 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: { auto mainStoreTransaction = mStorage.createTransaction(Storage::ReadOnly); auto replayStoreTransaction = mChangeReplayStore.createTransaction(Storage::ReadWrite); - qint64 lastReplayedRevision = 0; + qint64 lastReplayedRevision = 1; replayStoreTransaction.openDatabase().scan("lastReplayedRevision", [&lastReplayedRevision](const QByteArray &key, const QByteArray &value) -> bool { lastReplayedRevision = value.toLongLong(); return false; @@ -290,6 +290,7 @@ void GenericResource::removeFromDisk(const QByteArray &instanceIdentifier) Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier, Akonadi2::Storage::ReadWrite).removeFromDisk(); Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".userqueue", Akonadi2::Storage::ReadWrite).removeFromDisk(); Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".synchronizerqueue", Akonadi2::Storage::ReadWrite).removeFromDisk(); + Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier + ".changereplay", Akonadi2::Storage::ReadWrite).removeFromDisk(); } void GenericResource::onProcessorError(int errorCode, const QString &errorMessage) -- cgit v1.2.3