summaryrefslogtreecommitdiffstats
path: root/synchronizer/listener.h
diff options
context:
space:
mode:
authorAaron Seigo <aseigo@kde.org>2014-12-16 22:40:44 +0100
committerAaron Seigo <aseigo@kde.org>2014-12-16 22:40:44 +0100
commit77944384d24b5005d6b8648572a31a3ae84dd946 (patch)
tree8726831773b4182cb6177d6c72a723e08a6c15aa /synchronizer/listener.h
parent66b21fd2e3c53e4a820e3343b192be7b043da110 (diff)
downloadsink-77944384d24b5005d6b8648572a31a3ae84dd946.tar.gz
sink-77944384d24b5005d6b8648572a31a3ae84dd946.zip
add pipelines (as a sketch only), message ids and message responses
Diffstat (limited to 'synchronizer/listener.h')
-rw-r--r--synchronizer/listener.h5
1 files changed, 5 insertions, 0 deletions
diff --git a/synchronizer/listener.h b/synchronizer/listener.h
index 053fac3..b294277 100644
--- a/synchronizer/listener.h
+++ b/synchronizer/listener.h
@@ -25,6 +25,8 @@
25 25
26#include <flatbuffers/flatbuffers.h> 26#include <flatbuffers/flatbuffers.h>
27 27
28#include "common/pipeline.h"
29
28namespace Akonadi2 30namespace Akonadi2
29{ 31{
30 class Resource; 32 class Resource;
@@ -78,6 +80,7 @@ private Q_SLOTS:
78private: 80private:
79 bool processClientBuffer(Client &client); 81 bool processClientBuffer(Client &client);
80 void sendCurrentRevision(Client &client); 82 void sendCurrentRevision(Client &client);
83 void sendCommandCompleted(Client &client, uint messageId);
81 void updateClientsWithRevision(); 84 void updateClientsWithRevision();
82 void loadResource(); 85 void loadResource();
83 86
@@ -87,5 +90,7 @@ private:
87 flatbuffers::FlatBufferBuilder m_fbb; 90 flatbuffers::FlatBufferBuilder m_fbb;
88 const QString m_resourceName; 91 const QString m_resourceName;
89 Akonadi2::Resource *m_resource; 92 Akonadi2::Resource *m_resource;
93 Akonadi2::Pipeline *m_pipeline;
90 QTimer *m_clientBufferProcessesTimer; 94 QTimer *m_clientBufferProcessesTimer;
95 int m_messageId;
91}; 96};