OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Fix outbound federation

pull/4812/head
Erik Johnston 2019-03-05 14:50:37 +00:00 committed by hera
parent dc510e0e43
commit a6e2546980
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
synapse/federation/transaction_queue.py
View File

@ -406,6 +406,8 @@ class TransactionQueue(object):
else: else:
self.pending_edus_by_dest.setdefault(edu.destination, []).append(edu) self.pending_edus_by_dest.setdefault(edu.destination, []).append(edu)
destination = edu.destination
if destination not in self.edu_tx_time_by_dest: if destination not in self.edu_tx_time_by_dest:
txtime = self.clock.time() + EDU_BATCH_TIME * 1000 txtime = self.clock.time() + EDU_BATCH_TIME * 1000
self.edu_tx_time_by_dest[destination] = txtime self.edu_tx_time_by_dest[destination] = txtime