From 382150ca27b03b912b43ad07956231497d35cfe8 Mon Sep 17 00:00:00 2001 From: Christian Mollekopf Date: Thu, 10 Dec 2015 11:14:04 +0100 Subject: A change-replay function --- common/genericresource.cpp | 9 +++++++-- common/genericresource.h | 1 + 2 files changed, 8 insertions(+), 2 deletions(-) (limited to 'common') diff --git a/common/genericresource.cpp b/common/genericresource.cpp index 66f5dcf..7b8d9bb 100644 --- a/common/genericresource.cpp +++ b/common/genericresource.cpp @@ -266,8 +266,8 @@ GenericResource::GenericResource(const QByteArray &resourceInstanceIdentifier, c mProcessor = new Processor(mPipeline.data(), QList() << &mUserQueue << &mSynchronizerQueue); QObject::connect(mProcessor, &Processor::error, [this](int errorCode, const QString &msg) { onProcessorError(errorCode, msg); }); QObject::connect(mPipeline.data(), &Pipeline::revisionUpdated, this, &Resource::revisionUpdated); - mSourceChangeReplay = new ChangeReplay(resourceInstanceIdentifier, [](const QByteArray &type, const QByteArray &key, const QByteArray &value) { - return KAsync::null(); + mSourceChangeReplay = new ChangeReplay(resourceInstanceIdentifier, [this](const QByteArray &type, const QByteArray &key, const QByteArray &value) { + return this->replay(type, key, value); }); QObject::connect(mPipeline.data(), &Pipeline::revisionUpdated, mSourceChangeReplay, &ChangeReplay::revisionChanged); QObject::connect(mSourceChangeReplay, &ChangeReplay::changesReplayed, this, &GenericResource::updateLowerBoundRevision); @@ -285,6 +285,11 @@ GenericResource::~GenericResource() delete mSourceChangeReplay; } +KAsync::Job GenericResource::replay(const QByteArray &type, const QByteArray &key, const QByteArray &value) +{ + return KAsync::null(); +} + void GenericResource::removeFromDisk(const QByteArray &instanceIdentifier) { Akonadi2::Storage(Akonadi2::storageLocation(), instanceIdentifier, Akonadi2::Storage::ReadWrite).removeFromDisk(); diff --git a/common/genericresource.h b/common/genericresource.h index 33de0e7..97251a9 100644 --- a/common/genericresource.h +++ b/common/genericresource.h @@ -53,6 +53,7 @@ private Q_SLOTS: void updateLowerBoundRevision(); protected: + virtual KAsync::Job replay(const QByteArray &type, const QByteArray &key, const QByteArray &value); void onProcessorError(int errorCode, const QString &errorMessage); void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); flatbuffers::FlatBufferBuilder m_fbb; -- cgit v1.2.3