Commit 1a064725 authored by Julien Muchembled's avatar Julien Muchembled

fixup! storage: speed up replication by sending bigger network packets

parent 156da51c
...@@ -78,6 +78,7 @@ class SocketConnector(object): ...@@ -78,6 +78,7 @@ class SocketConnector(object):
def queue(self, data): def queue(self, data):
was_empty = not self.queued was_empty = not self.queued
self.queued += data self.queued += data
for data in data:
self.queue_size += len(data) self.queue_size += len(data)
return was_empty return was_empty
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment