summaryrefslogtreecommitdiffstats
path: root/resource/listener.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'resource/listener.cpp')
-rw-r--r--resource/listener.cpp16
1 files changed, 8 insertions, 8 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}