diff options
Diffstat (limited to 'resource/listener.cpp')
-rw-r--r-- | resource/listener.cpp | 16 |
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 | ||
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 | } |