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

Address review comments

pull/7226/head
Erik Johnston 2020-04-06 18:20:13 +01:00
parent a2e0bb9512
commit 55eccdc094
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
synapse/replication/tcp/handler.py
View File

@ -104,7 +104,7 @@ class ReplicationCommandHandler:
# Let's drop the row for now, on the assumption we'll receive a # Let's drop the row for now, on the assumption we'll receive a
# `POSITION` soon and we'll catch up correctly then. # `POSITION` soon and we'll catch up correctly then.
logger.warning( logger.warning(
"Discarding RDATA for unconnected stream %s -> ", "Discarding RDATA for unconnected stream %s -> %s",
stream_name, stream_name,
cmd.token, cmd.token,
) )
@ -146,8 +146,8 @@ class ReplicationCommandHandler:
# of connected streams. # of connected streams.
self._streams_connected.discard(cmd.stream_name) self._streams_connected.discard(cmd.stream_name)
# We clear the pending batches for the stream as the fetching # We clear the pending batches for the stream as the fetching of the
# updates below will fetch all rows in the batch. # missing updates below will fetch all rows in the batch.
self._pending_batches.pop(cmd.stream_name, []) self._pending_batches.pop(cmd.stream_name, [])
# Find where we previously streamed up to. # Find where we previously streamed up to.