summary refs log tree commit diff
diff options
context:
space:
mode:
-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