Matrix-Mirrors/anonymousland-synapse
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse.git synced 2025-05-02 11:06:07 -04:00
Code Issues Projects Releases Packages Wiki Activity

Split up replication_layer module into client, server and transaction queue

Browse source
This commit is contained in:
Erik Johnston 2015-01-26 10:45:24 +00:00
parent 9b1e552b51
commit 7b88619241
5 changed files with 654 additions and 603 deletions
Download patch file Download diff file Expand all files Collapse all files

9
synapse/federation/transaction_queue.py
View file

@ -16,6 +16,7 @@
from twisted.internet import defer
from .persistence import TransactionActions
from .units import Transaction
from synapse.util.logutils import log_function
@ -34,13 +35,15 @@ class TransactionQueue(object):
It batches pending PDUs into single transactions.
"""
def __init__(self, hs, transaction_actions, transport_layer):
def __init__(self, hs, transport_layer):
self.server_name = hs.hostname
self.transaction_actions = transaction_actions
self.store = hs.get_datastore()
self.transaction_actions = TransactionActions(self.store)
self.transport_layer = transport_layer
self._clock = hs.get_clock()
self.store = hs.get_datastore()
# Is a mapping from destinations -> deferreds. Used to keep track
# of which destinations have transactions in flight and when they are