diff options
| author | Erik Johnston <erik@matrix.org> | 2020-03-23 16:13:12 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-03-23 16:13:12 +0000 |
| commit | ba1a8be9300595104c580e2c8e652ba2c58afff3 (patch) | |
| tree | dbf0cac65e06fe601c1d565b24072502b2fda9f9 /synapse/replication/tcp/protocol.py | |
| parent | Remove unused 'stream' param of REPLICATE and update docs (diff) | |
| download | synapse-ba1a8be9300595104c580e2c8e652ba2c58afff3.tar.xz | |
Review comments
Diffstat (limited to '')
| -rw-r--r-- | synapse/replication/tcp/protocol.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py index 13e5fa9b12..8aa749265c 100644 --- a/synapse/replication/tcp/protocol.py +++ b/synapse/replication/tcp/protocol.py @@ -638,8 +638,7 @@ class ClientReplicationStreamProtocol(BaseReplicationStreamProtocol): # We've now caught up to position sent to us, notify handler. await self.handler.on_position(cmd.stream_name, cmd.token) - # When we get a `POSITION` command it means we've finished getting - # missing updates for the given stream, and are now up to date. + # We're now up to date wit the stream self.streams_connecting.discard(cmd.stream_name) if not self.streams_connecting: self.handler.finished_connecting() |