From 7fdcc36a1a352bb869020ade8a8aa697c3e8b80c Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Mon, 28 Nov 2016 19:43:23 +0100
Subject: Moved the flush command to the command processor.

---
 common/commandprocessor.h | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

(limited to 'common/commandprocessor.h')

diff --git a/common/commandprocessor.h b/common/commandprocessor.h
index 75ae37a..d00cf43 100644
--- a/common/commandprocessor.h
+++ b/common/commandprocessor.h
@@ -42,7 +42,6 @@ namespace Sink {
 class CommandProcessor : public QObject
 {
     Q_OBJECT
-    typedef std::function<KAsync::Job<void>(void const *, size_t)> FlushFunction;
     SINK_DEBUG_AREA("commandprocessor")
 
 public:
@@ -50,8 +49,6 @@ public:
 
     void setOldestUsedRevision(qint64 revision);
 
-    void setFlushCommand(const FlushFunction &f);
-
     void setInspector(const QSharedPointer<Inspector> &inspector);
     void setSynchronizer(const QSharedPointer<Synchronizer> &synchronizer);
 
@@ -71,13 +68,14 @@ private slots:
     KAsync::Job<void> processPipeline();
 
 private:
+    KAsync::Job<void> flush(void const *command, size_t size);
+
     Sink::Pipeline *mPipeline;
     // Ordered by priority
     QList<MessageQueue *> mCommandQueues;
     bool mProcessingLock;
     // The lowest revision we no longer need
     qint64 mLowerBoundRevision;
-    FlushFunction mFlush;
     QSharedPointer<Synchronizer> mSynchronizer;
     QSharedPointer<Inspector> mInspector;
 };
-- 
cgit v1.2.3