diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-28 23:18:44 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2016-11-28 23:18:44 +0100 |
commit | 2b9295f8d078081c9aecfe6047cb331ab0cd0129 (patch) | |
tree | e06637948675def73f6591829e7d37852760f244 /common/genericresource.h | |
parent | 3e7b8fe8b8cca75b546c8cac2c09ce231861f21b (diff) | |
download | sink-2b9295f8d078081c9aecfe6047cb331ab0cd0129.tar.gz sink-2b9295f8d078081c9aecfe6047cb331ab0cd0129.zip |
Cleanup
Diffstat (limited to 'common/genericresource.h')
-rw-r--r-- | common/genericresource.h | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/common/genericresource.h b/common/genericresource.h index cc73f50..558145c 100644 --- a/common/genericresource.h +++ b/common/genericresource.h | |||
@@ -21,13 +21,8 @@ | |||
21 | 21 | ||
22 | #include "sink_export.h" | 22 | #include "sink_export.h" |
23 | #include <resource.h> | 23 | #include <resource.h> |
24 | #include <messagequeue.h> | ||
25 | #include <flatbuffers/flatbuffers.h> | ||
26 | #include <domainadaptor.h> | ||
27 | #include <resourcecontext.h> | 24 | #include <resourcecontext.h> |
28 | 25 | ||
29 | #include <QTimer> | ||
30 | |||
31 | namespace Sink { | 26 | namespace Sink { |
32 | class Pipeline; | 27 | class Pipeline; |
33 | class Preprocessor; | 28 | class Preprocessor; |
@@ -54,7 +49,9 @@ public: | |||
54 | static void removeFromDisk(const QByteArray &instanceIdentifier); | 49 | static void removeFromDisk(const QByteArray &instanceIdentifier); |
55 | static qint64 diskUsage(const QByteArray &instanceIdentifier); | 50 | static qint64 diskUsage(const QByteArray &instanceIdentifier); |
56 | 51 | ||
52 | //TODO Remove this API, it's only used in tests | ||
57 | KAsync::Job<void> synchronizeWithSource(const Sink::QueryBase &query); | 53 | KAsync::Job<void> synchronizeWithSource(const Sink::QueryBase &query); |
54 | //TODO Remove this API, it's only used in tests | ||
58 | KAsync::Job<void> processAllMessages(); | 55 | KAsync::Job<void> processAllMessages(); |
59 | 56 | ||
60 | private slots: | 57 | private slots: |
@@ -65,12 +62,11 @@ protected: | |||
65 | void setupSynchronizer(const QSharedPointer<Synchronizer> &synchronizer); | 62 | void setupSynchronizer(const QSharedPointer<Synchronizer> &synchronizer); |
66 | void setupInspector(const QSharedPointer<Inspector> &inspector); | 63 | void setupInspector(const QSharedPointer<Inspector> &inspector); |
67 | 64 | ||
68 | void onProcessorError(int errorCode, const QString &errorMessage); | ||
69 | void enqueueCommand(MessageQueue &mq, int commandId, const QByteArray &data); | ||
70 | |||
71 | ResourceContext mResourceContext; | 65 | ResourceContext mResourceContext; |
72 | 66 | ||
73 | private: | 67 | private: |
68 | void onProcessorError(int errorCode, const QString &errorMessage); | ||
69 | |||
74 | QSharedPointer<Pipeline> mPipeline; | 70 | QSharedPointer<Pipeline> mPipeline; |
75 | QSharedPointer<CommandProcessor> mProcessor; | 71 | QSharedPointer<CommandProcessor> mProcessor; |
76 | QSharedPointer<Synchronizer> mSynchronizer; | 72 | QSharedPointer<Synchronizer> mSynchronizer; |