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

Wait for a POSITION on the right connection before accepting RDATA

Browse source 
... otherwise we can believe we're up to date when we're not.
This commit is contained in:
Richard van der Hoff 2020-05-05 19:32:35 +01:00
parent d78265af0c
commit 7f7eedbebb
2 changed files with 39 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

2
synapse/replication/tcp/redis.py
View file

@ -144,7 +144,7 @@ class RedisSubscriber(txredisapi.SubscriberProtocol, AbstractConnection):
Args:
cmd (Command)
"""
run_as_background_process("send-cmd", self._send_command, cmd)
run_as_background_process("send-cmd", self._async_send_command, cmd)
async def _async_send_command(self, cmd: Command):
"""Encode a replication command and send it over our outbound connection"""