summary refs log tree commit diff
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2019-03-05 14:50:37 +0000
committerhera <matrix@hera.matrix.org>2019-03-05 14:50:37 +0000
commita6e2546980fd3c80f31f391b0eefb48c497250c4 (patch)
tree1e0cbc5d07d6a722386287b0a7a45c8bb74111d5
parentMerge branch 'develop' of github.com:matrix-org/synapse into matrix-org-hotfixes (diff)
downloadsynapse-a6e2546980fd3c80f31f391b0eefb48c497250c4.tar.xz
Fix outbound federation
-rw-r--r--synapse/federation/transaction_queue.py2
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py

index cf1759f422..549bc944a6 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py
@@ -406,6 +406,8 @@ class TransactionQueue(object): else: self.pending_edus_by_dest.setdefault(edu.destination, []).append(edu) + destination = edu.destination + if destination not in self.edu_tx_time_by_dest: txtime = self.clock.time() + EDU_BATCH_TIME * 1000 self.edu_tx_time_by_dest[destination] = txtime