diff options
| author | Richard van der Hoff <richard@matrix.org> | 2020-05-05 19:32:35 +0100 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2020-05-05 22:38:16 +0100 |
| commit | 7f7eedbebba561771f39c22c78d1dfa1412283a5 (patch) | |
| tree | 8609497af062fc86fbd4d0488cbf418c7db99d92 /synapse/replication/tcp/redis.py | |
| parent | Wait to subscribe before sending REPLICATE (diff) | |
| download | synapse-7f7eedbebba561771f39c22c78d1dfa1412283a5.tar.xz | |
Wait for a POSITION on the right connection before accepting RDATA
... otherwise we can believe we're up to date when we're not.
Diffstat (limited to 'synapse/replication/tcp/redis.py')
| -rw-r--r-- | synapse/replication/tcp/redis.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/tcp/redis.py b/synapse/replication/tcp/redis.py index 61dbf4ddbe..b3ae9f401c 100644 --- a/synapse/replication/tcp/redis.py +++ b/synapse/replication/tcp/redis.py @@ -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""" |