From 9c31df56c894892f20a30dc336cfe608b14679e0 Mon Sep 17 00:00:00 2001 From: Aaron Seigo Date: Tue, 2 Dec 2014 15:19:48 +0100 Subject: consolidate command writing to avoid duplicating those 4 lines everywhere --- resource/listener.cpp | 13 +++---------- 1 file changed, 3 insertions(+), 10 deletions(-) (limited to 'resource') diff --git a/resource/listener.cpp b/resource/listener.cpp index 038b3fa..4b3e4ff 100644 --- a/resource/listener.cpp +++ b/resource/listener.cpp @@ -173,11 +173,7 @@ void Listener::sendCurrentRevision(Client &client) flatbuffers::FlatBufferBuilder fbb; auto command = Akonadi::CreateRevisionUpdate(fbb, m_revision); Akonadi::FinishRevisionUpdateBuffer(fbb, command); - const int commandId = Commands::RevisionUpdateCommand; - const int dataSize = fbb.GetSize(); - client.socket->write((const char*)&commandId, sizeof(int)); - client.socket->write((const char*)&dataSize, sizeof(int)); - client.socket->write((const char*)fbb.GetBufferPointer(), dataSize); + Commands::write(client.socket, Commands::RevisionUpdateCommand, fbb); } void Listener::updateClientsWithRevision() @@ -185,15 +181,12 @@ void Listener::updateClientsWithRevision() flatbuffers::FlatBufferBuilder fbb; auto command = Akonadi::CreateRevisionUpdate(fbb, m_revision); Akonadi::FinishRevisionUpdateBuffer(fbb, command); - const int commandId = Commands::RevisionUpdateCommand; - const int dataSize = fbb.GetSize(); for (const Client &client: m_connections) { if (!client.socket || !client.socket->isValid()) { continue; } - client.socket->write((const char*)&commandId, sizeof(int)); - client.socket->write((const char*)&dataSize, sizeof(int)); - client.socket->write((const char*)fbb.GetBufferPointer(), dataSize); + + Commands::write(client.socket, Commands::RevisionUpdateCommand, fbb); } } -- cgit v1.2.3