diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-05-29 15:19:21 +0200 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-05-29 15:19:21 +0200 |
commit | dabd408dcd372f16c7934597db30346869cd8ad8 (patch) | |
tree | 0d6513204b7fa6e34cf50733ad0472866ea05e2a /common/genericresource.h | |
parent | b441386c4e138d19bbd79d578e0a2ff1b3f54a93 (diff) | |
download | sink-dabd408dcd372f16c7934597db30346869cd8ad8.tar.gz sink-dabd408dcd372f16c7934597db30346869cd8ad8.zip |
Fixed genericresource so it works with the maildirresourcetest
Diffstat (limited to 'common/genericresource.h')
-rw-r--r-- | common/genericresource.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/common/genericresource.h b/common/genericresource.h index 4ed408d..0878968 100644 --- a/common/genericresource.h +++ b/common/genericresource.h | |||
@@ -41,12 +41,11 @@ class Synchronizer; | |||
41 | class SINK_EXPORT GenericResource : public Resource | 41 | class SINK_EXPORT GenericResource : public Resource |
42 | { | 42 | { |
43 | public: | 43 | public: |
44 | GenericResource(const QByteArray &resourceType, const QByteArray &resourceInstanceIdentifier, const QSharedPointer<Pipeline> &pipeline, const QSharedPointer<ChangeReplay> &changeReplay, const QSharedPointer<Synchronizer> &synchronizer); | 44 | GenericResource(const QByteArray &resourceType, const QByteArray &resourceInstanceIdentifier, const QSharedPointer<Pipeline> &pipeline); |
45 | virtual ~GenericResource(); | 45 | virtual ~GenericResource(); |
46 | 46 | ||
47 | virtual void processCommand(int commandId, const QByteArray &data) Q_DECL_OVERRIDE; | 47 | virtual void processCommand(int commandId, const QByteArray &data) Q_DECL_OVERRIDE; |
48 | virtual KAsync::Job<void> synchronizeWithSource() Q_DECL_OVERRIDE; | 48 | virtual KAsync::Job<void> synchronizeWithSource() Q_DECL_OVERRIDE; |
49 | virtual KAsync::Job<void> synchronizeWithSource(Sink::Storage &mainStore, Sink::Storage &synchronizationStore); | ||
50 | virtual KAsync::Job<void> processAllMessages() Q_DECL_OVERRIDE; | 49 | virtual KAsync::Job<void> processAllMessages() Q_DECL_OVERRIDE; |
51 | virtual void setLowerBoundRevision(qint64 revision) Q_DECL_OVERRIDE; | 50 | virtual void setLowerBoundRevision(qint64 revision) Q_DECL_OVERRIDE; |
52 | virtual KAsync::Job<void> | 51 | virtual KAsync::Job<void> |
@@ -64,7 +63,9 @@ private slots: | |||
64 | protected: | 63 | protected: |
65 | void enableChangeReplay(bool); | 64 | void enableChangeReplay(bool); |
66 | 65 | ||
67 | void addType(const QByteArray &type, DomainTypeAdaptorFactoryInterface::Ptr factory, const QVector<Sink::Preprocessor *> &preprocessors); | 66 | void setupPreprocessors(const QByteArray &type, const QVector<Sink::Preprocessor *> &preprocessors); |
67 | void setupSynchronizer(const QSharedPointer<Synchronizer> &synchronizer); | ||
68 | void setupChangereplay(const QSharedPointer<ChangeReplay> &changeReplay); | ||
68 | 69 | ||
69 | void onProcessorError(int errorCode, const QString &errorMessage); | 70 | void onProcessorError(int errorCode, const QString &errorMessage); |
70 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); | 71 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); |