summaryrefslogtreecommitdiffstats
path: root/common/genericresource.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-28 23:18:44 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2016-11-28 23:18:44 +0100
commit2b9295f8d078081c9aecfe6047cb331ab0cd0129 (patch)
treee06637948675def73f6591829e7d37852760f244 /common/genericresource.h
parent3e7b8fe8b8cca75b546c8cac2c09ce231861f21b (diff)
downloadsink-2b9295f8d078081c9aecfe6047cb331ab0cd0129.tar.gz
sink-2b9295f8d078081c9aecfe6047cb331ab0cd0129.zip
Cleanup
Diffstat (limited to 'common/genericresource.h')
-rw-r--r--common/genericresource.h12
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
31namespace Sink { 26namespace Sink {
32class Pipeline; 27class Pipeline;
33class Preprocessor; 28class 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
60private slots: 57private 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
73private: 67private:
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;