summary refs log tree commit diff
path: root/synapse/federation/transaction_queue.py
diff options
context:
space:
mode:
authorRichard van der Hoff <richard@matrix.org>2019-02-24 22:24:36 +0000
committerRichard van der Hoff <richard@matrix.org>2019-02-24 22:24:36 +0000
commit4d07dc0d18ee5506ba3664a9387645a973814f54 (patch)
treecdc745f7799cf4a4158dcfd7a4261bfb4a1e0a14 /synapse/federation/transaction_queue.py
parentMerge branch 'develop' of github.com:matrix-org/synapse into matrix-org-hotfixes (diff)
downloadsynapse-4d07dc0d18ee5506ba3664a9387645a973814f54.tar.xz
Add a delay to the federation loop for EDUs
Diffstat (limited to 'synapse/federation/transaction_queue.py')
-rw-r--r--synapse/federation/transaction_queue.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py

index 30941f5ad6..2969c83ac5 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py
@@ -380,7 +380,9 @@ class TransactionQueue(object): else: self.pending_edus_by_dest.setdefault(destination, []).append(edu) - self._attempt_new_transaction(destination) + # this is a bit of a hack, but we delay starting the transmission loop + # in an effort to batch up outgoing EDUs a bit. + self.clock.call_later(5.0, self._attempt_new_transaction, destination) def send_device_messages(self, destination): if destination == self.server_name: