summaryrefslogtreecommitdiffstats
path: root/synchronizer/listener.h
diff options
context:
space:
mode:
authorChristian Mollekopf <chrigi_1@fastmail.fm>2014-12-28 14:44:50 +0100
committerChristian Mollekopf <chrigi_1@fastmail.fm>2014-12-28 14:44:50 +0100
commit9b2257d680a5e4fa2fda8cf3302f25054a06710e (patch)
tree9abaf141018eb83d26ce07f5bd0e9436003ce732 /synchronizer/listener.h
parentc83c2ef64b5a1e4b1dc0102df36687caebb96ff0 (diff)
downloadsink-9b2257d680a5e4fa2fda8cf3302f25054a06710e.tar.gz
sink-9b2257d680a5e4fa2fda8cf3302f25054a06710e.zip
Buffers wrapped into entity buffer, async command progress tracking.
Diffstat (limited to 'synchronizer/listener.h')
-rw-r--r--synchronizer/listener.h6
1 files changed, 2 insertions, 4 deletions
diff --git a/synchronizer/listener.h b/synchronizer/listener.h
index 357ae37..4c35191 100644
--- a/synchronizer/listener.h
+++ b/synchronizer/listener.h
@@ -61,9 +61,6 @@ public:
61 Listener(const QString &resourceName, QObject *parent = 0); 61 Listener(const QString &resourceName, QObject *parent = 0);
62 ~Listener(); 62 ~Listener();
63 63
64 void setRevision(unsigned long long revision);
65 unsigned long long revision() const;
66
67Q_SIGNALS: 64Q_SIGNALS:
68 void noClients(); 65 void noClients();
69 66
@@ -79,15 +76,16 @@ private Q_SLOTS:
79 void refreshRevision(); 76 void refreshRevision();
80 77
81private: 78private:
79 void processCommand(int commandId, uint messageId, Client &client, uint size, const std::function<void()> &callback);
82 bool processClientBuffer(Client &client); 80 bool processClientBuffer(Client &client);
83 void sendCurrentRevision(Client &client); 81 void sendCurrentRevision(Client &client);
84 void sendCommandCompleted(Client &client, uint messageId); 82 void sendCommandCompleted(Client &client, uint messageId);
85 void updateClientsWithRevision(); 83 void updateClientsWithRevision();
86 void loadResource(); 84 void loadResource();
85 void log(const QString &);
87 86
88 QLocalServer *m_server; 87 QLocalServer *m_server;
89 QVector<Client> m_connections; 88 QVector<Client> m_connections;
90 unsigned long long m_revision;
91 flatbuffers::FlatBufferBuilder m_fbb; 89 flatbuffers::FlatBufferBuilder m_fbb;
92 const QString m_resourceName; 90 const QString m_resourceName;
93 Akonadi2::Resource *m_resource; 91 Akonadi2::Resource *m_resource;