diff options
Diffstat (limited to 'resource')
-rw-r--r-- | resource/listener.cpp | 16 | ||||
-rw-r--r-- | resource/listener.h | 5 |
2 files changed, 12 insertions, 9 deletions
diff --git a/resource/listener.cpp b/resource/listener.cpp index 4b3e4ff..23a5a70 100644 --- a/resource/listener.cpp +++ b/resource/listener.cpp | |||
@@ -170,23 +170,23 @@ void Listener::sendCurrentRevision(Client &client) | |||
170 | return; | 170 | return; |
171 | } | 171 | } |
172 | 172 | ||
173 | flatbuffers::FlatBufferBuilder fbb; | 173 | auto command = Akonadi::CreateRevisionUpdate(m_fbb, m_revision); |
174 | auto command = Akonadi::CreateRevisionUpdate(fbb, m_revision); | 174 | Akonadi::FinishRevisionUpdateBuffer(m_fbb, command); |
175 | Akonadi::FinishRevisionUpdateBuffer(fbb, command); | 175 | Commands::write(client.socket, Commands::RevisionUpdateCommand, m_fbb); |
176 | Commands::write(client.socket, Commands::RevisionUpdateCommand, fbb); | 176 | m_fbb.Clear(); |
177 | } | 177 | } |
178 | 178 | ||
179 | void Listener::updateClientsWithRevision() | 179 | void Listener::updateClientsWithRevision() |
180 | { | 180 | { |
181 | flatbuffers::FlatBufferBuilder fbb; | 181 | auto command = Akonadi::CreateRevisionUpdate(m_fbb, m_revision); |
182 | auto command = Akonadi::CreateRevisionUpdate(fbb, m_revision); | 182 | Akonadi::FinishRevisionUpdateBuffer(m_fbb, command); |
183 | Akonadi::FinishRevisionUpdateBuffer(fbb, command); | ||
184 | 183 | ||
185 | for (const Client &client: m_connections) { | 184 | for (const Client &client: m_connections) { |
186 | if (!client.socket || !client.socket->isValid()) { | 185 | if (!client.socket || !client.socket->isValid()) { |
187 | continue; | 186 | continue; |
188 | } | 187 | } |
189 | 188 | ||
190 | Commands::write(client.socket, Commands::RevisionUpdateCommand, fbb); | 189 | Commands::write(client.socket, Commands::RevisionUpdateCommand, m_fbb); |
191 | } | 190 | } |
191 | m_fbb.Clear(); | ||
192 | } | 192 | } |
diff --git a/resource/listener.h b/resource/listener.h index 0d8f388..dcc3818 100644 --- a/resource/listener.h +++ b/resource/listener.h | |||
@@ -5,6 +5,8 @@ | |||
5 | #include <QList> | 5 | #include <QList> |
6 | #include <QObject> | 6 | #include <QObject> |
7 | 7 | ||
8 | #include <flatbuffers/flatbuffers.h> | ||
9 | |||
8 | class Client | 10 | class Client |
9 | { | 11 | { |
10 | public: | 12 | public: |
@@ -57,4 +59,5 @@ private: | |||
57 | QLocalServer *m_server; | 59 | QLocalServer *m_server; |
58 | QVector<Client> m_connections; | 60 | QVector<Client> m_connections; |
59 | unsigned long long m_revision; | 61 | unsigned long long m_revision; |
60 | }; \ No newline at end of file | 62 | flatbuffers::FlatBufferBuilder m_fbb; |
63 | }; | ||