diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-12-15 13:41:29 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2015-12-15 13:41:29 +0100 |
commit | ef492409892eedb85d7555002eebebe3f046b873 (patch) | |
tree | a5dea6c76fbe3a21641d9ddf91c3ce2c677fd690 /common/genericresource.h | |
parent | 2f504b6f264c90ded6b0226a565301da97d3918f (diff) | |
download | sink-ef492409892eedb85d7555002eebebe3f046b873.tar.gz sink-ef492409892eedb85d7555002eebebe3f046b873.zip |
Avoid duplication accross resource implementations
Diffstat (limited to 'common/genericresource.h')
-rw-r--r-- | common/genericresource.h | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/common/genericresource.h b/common/genericresource.h index f756273..82c8a49 100644 --- a/common/genericresource.h +++ b/common/genericresource.h | |||
@@ -23,6 +23,7 @@ | |||
23 | #include <resource.h> | 23 | #include <resource.h> |
24 | #include <messagequeue.h> | 24 | #include <messagequeue.h> |
25 | #include <flatbuffers/flatbuffers.h> | 25 | #include <flatbuffers/flatbuffers.h> |
26 | #include <domainadaptor.h> | ||
26 | #include <QTimer> | 27 | #include <QTimer> |
27 | 28 | ||
28 | class Processor; | 29 | class Processor; |
@@ -31,6 +32,7 @@ class ChangeReplay; | |||
31 | namespace Akonadi2 | 32 | namespace Akonadi2 |
32 | { | 33 | { |
33 | class Pipeline; | 34 | class Pipeline; |
35 | class Preprocessor; | ||
34 | 36 | ||
35 | /** | 37 | /** |
36 | * Generic Resource implementation. | 38 | * Generic Resource implementation. |
@@ -54,6 +56,7 @@ private Q_SLOTS: | |||
54 | void updateLowerBoundRevision(); | 56 | void updateLowerBoundRevision(); |
55 | 57 | ||
56 | protected: | 58 | protected: |
59 | void addType(const QByteArray &type, DomainTypeAdaptorFactoryInterface::Ptr factory, const QVector<Akonadi2::Preprocessor*> &preprocessors); | ||
57 | virtual KAsync::Job<void> replay(const QByteArray &type, const QByteArray &key, const QByteArray &value); | 60 | virtual KAsync::Job<void> replay(const QByteArray &type, const QByteArray &key, const QByteArray &value); |
58 | void onProcessorError(int errorCode, const QString &errorMessage); | 61 | void onProcessorError(int errorCode, const QString &errorMessage); |
59 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); | 62 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); |