From 7eb4227cfcda1cbcf066c37d5e6679ef350d518c Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Mon, 12 Oct 2015 13:14:41 +0200 Subject: Cleanup revisions with a delay --- common/pipeline.cpp | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) (limited to 'common/pipeline.cpp') diff --git a/common/pipeline.cpp b/common/pipeline.cpp index b05cb2f..9816129 100644 --- a/common/pipeline.cpp +++ b/common/pipeline.cpp @@ -313,7 +313,6 @@ KAsync::Job Pipeline::deletedEntity(void const *command, size_t size) const QByteArray bufferType = QByteArray(reinterpret_cast(deleteEntity->domainType()->Data()), deleteEntity->domainType()->size()); const QByteArray key = QByteArray(reinterpret_cast(deleteEntity->entityId()->Data()), deleteEntity->entityId()->size()); - const qint64 baseRevision = deleteEntity->revision(); const qint64 newRevision = Akonadi2::Storage::maxRevision(d->transaction) + 1; @@ -365,6 +364,12 @@ void Pipeline::cleanupRevision(qint64 revision) }, [](const Akonadi2::Storage::Error &error) { Warning() << "Error while reading: " << error.message; }, true); + Akonadi2::Storage::setCleanedUpRevision(d->transaction, revision); +} + +qint64 Pipeline::cleanedUpRevision() +{ + return Akonadi2::Storage::cleanedUpRevision(d->transaction); } void Pipeline::pipelineStepped(const PipelineState &state) -- cgit v1.2.3