diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-28 19:33:01 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-28 19:33:01 +0100 |
commit | 938554f267193b652478fc12343819fa45d76034 (patch) | |
tree | 1c027f97f3209571740377f1d4b7e6721d8de777 /common/genericresource.h | |
parent | 885f185f55249a2e97e9c7c238f89a5d0d99d1df (diff) | |
download | sink-938554f267193b652478fc12343819fa45d76034.tar.gz sink-938554f267193b652478fc12343819fa45d76034.zip |
Moved inspection commands to a separate inspector.
Diffstat (limited to 'common/genericresource.h')
-rw-r--r-- | common/genericresource.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/common/genericresource.h b/common/genericresource.h index 12f15f3..0bc47da 100644 --- a/common/genericresource.h +++ b/common/genericresource.h | |||
@@ -32,6 +32,7 @@ namespace Sink { | |||
32 | class Pipeline; | 32 | class Pipeline; |
33 | class Preprocessor; | 33 | class Preprocessor; |
34 | class Synchronizer; | 34 | class Synchronizer; |
35 | class Inspector; | ||
35 | class CommandProcessor; | 36 | class CommandProcessor; |
36 | 37 | ||
37 | /** | 38 | /** |
@@ -50,8 +51,6 @@ public: | |||
50 | virtual KAsync::Job<void> synchronizeWithSource(const Sink::QueryBase &query) Q_DECL_OVERRIDE; | 51 | virtual KAsync::Job<void> synchronizeWithSource(const Sink::QueryBase &query) Q_DECL_OVERRIDE; |
51 | virtual KAsync::Job<void> processAllMessages() Q_DECL_OVERRIDE; | 52 | virtual KAsync::Job<void> processAllMessages() Q_DECL_OVERRIDE; |
52 | virtual void setLowerBoundRevision(qint64 revision) Q_DECL_OVERRIDE; | 53 | virtual void setLowerBoundRevision(qint64 revision) Q_DECL_OVERRIDE; |
53 | virtual KAsync::Job<void> | ||
54 | inspect(int inspectionType, const QByteArray &inspectionId, const QByteArray &domainType, const QByteArray &entityId, const QByteArray &property, const QVariant &expectedValue); | ||
55 | 54 | ||
56 | int error() const; | 55 | int error() const; |
57 | 56 | ||
@@ -64,6 +63,7 @@ private slots: | |||
64 | protected: | 63 | protected: |
65 | void setupPreprocessors(const QByteArray &type, const QVector<Sink::Preprocessor *> &preprocessors); | 64 | void setupPreprocessors(const QByteArray &type, const QVector<Sink::Preprocessor *> &preprocessors); |
66 | void setupSynchronizer(const QSharedPointer<Synchronizer> &synchronizer); | 65 | void setupSynchronizer(const QSharedPointer<Synchronizer> &synchronizer); |
66 | void setupInspector(const QSharedPointer<Inspector> &inspector); | ||
67 | 67 | ||
68 | void onProcessorError(int errorCode, const QString &errorMessage); | 68 | void onProcessorError(int errorCode, const QString &errorMessage); |
69 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); | 69 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); |