Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2025-01-06 09:17:55 -05:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'release-v1.13.0' into rav/fix_dropped_messages

Browse Source
This commit is contained in:
Richard van der Hoff 2020-05-05 23:01:12 +01:00
commit a8c17da245
2 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
changelog.d/7421.misc Normal file
View File

@ -0,0 +1 @@
Move catchup of replication streams logic to worker.

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

@ -265,7 +265,7 @@ class ReplicationCommandHandler:
if not sbc or stream_name not in sbc: if not sbc or stream_name not in sbc:
# 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.info( logger.debug(
"Discarding RDATA for unconnected stream %s -> %s", "Discarding RDATA for unconnected stream %s -> %s",
stream_name, stream_name,
cmd.token, cmd.token,