mirrors/synapse
1
0
Fork 0
mirror of https://github.com/element-hq/synapse.git synced 2024-12-22 20:50:23 +03:00
Code Issues Projects Releases Packages Wiki Activity

fixup! Thread through instance name to replication client

Browse source
This commit is contained in:
Erik Johnston 2020-03-25 11:41:38 +00:00
parent b6f6f5c399
commit 092b62ee7b
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
synapse/replication/tcp/streams/_base.py
View file

@ -69,6 +69,8 @@ class Stream(object):
# The token from which we last asked for updates # The token from which we last asked for updates
self.last_token = self.current_token() self.last_token = self.current_token()
self.local_instance_name = hs.config.worker_name or "master"
def discard_updates_and_advance(self): def discard_updates_and_advance(self):
"""Called when the stream should advance but the updates would be discarded, """Called when the stream should advance but the updates would be discarded,
e.g. when there are no currently connected workers. e.g. when there are no currently connected workers.
@ -87,7 +89,7 @@ class Stream(object):
""" """
current_token = self.current_token() current_token = self.current_token()
updates, current_token, limited = await self.get_updates_since( updates, current_token, limited = await self.get_updates_since(
"master", self.last_token, current_token self.local_instance_name, self.last_token, current_token
) )
self.last_token = current_token self.last_token = current_token