summaryrefslogtreecommitdiffstats
path: root/resource
diff options
context:
space:
mode:
Diffstat (limited to 'resource')
-rw-r--r--resource/listener.cpp16
-rw-r--r--resource/listener.h5
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
179void Listener::updateClientsWithRevision() 179void 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
8class Client 10class Client
9{ 11{
10public: 12public:
@@ -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};