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

gah, fix it yet again

pull/7374/head
Richard van der Hoff 2020-04-30 18:26:17 +01:00
parent 645efd7c18
commit 9bfea9e42b
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
synapse/replication/tcp/streams/federation.py
View File

@ -41,10 +41,11 @@ class FederationStream(Stream):
def __init__(self, hs):
if hs.config.worker_app is None:
# master process: get updates from the FederationRemoteSendQueue
# master process: get updates from the FederationRemoteSendQueue.
# (if the master is configured to send federation itself, federation_sender
# will be a real FederationSender, which has stubs for current_token and
# get_replication_rows.)
federation_sender = hs.get_federation_sender()
assert isinstance(federation_sender, FederationRemoteSendQueue)
current_token = federation_sender.get_current_token
update_function = db_query_to_update_function(
federation_sender.get_replication_rows