diff options
author | Christian Mollekopf <chrigi_1@fastmail.fm> | 2014-12-28 14:44:50 +0100 |
---|---|---|
committer | Christian Mollekopf <chrigi_1@fastmail.fm> | 2014-12-28 14:44:50 +0100 |
commit | 9b2257d680a5e4fa2fda8cf3302f25054a06710e (patch) | |
tree | 9abaf141018eb83d26ce07f5bd0e9436003ce732 /synchronizer/listener.h | |
parent | c83c2ef64b5a1e4b1dc0102df36687caebb96ff0 (diff) | |
download | sink-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.h | 6 |
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 | |||
67 | Q_SIGNALS: | 64 | Q_SIGNALS: |
68 | void noClients(); | 65 | void noClients(); |
69 | 66 | ||
@@ -79,15 +76,16 @@ private Q_SLOTS: | |||
79 | void refreshRevision(); | 76 | void refreshRevision(); |
80 | 77 | ||
81 | private: | 78 | private: |
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; |