summaryrefslogtreecommitdiffstats
path: root/common/genericresource.h
diff options
context:
space:
mode:
Diffstat (limited to 'common/genericresource.h')
-rw-r--r--common/genericresource.h7
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;
41class SINK_EXPORT GenericResource : public Resource 41class SINK_EXPORT GenericResource : public Resource
42{ 42{
43public: 43public:
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:
64protected: 63protected:
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);