diff options
| author | Erik Johnston <erikj@matrix.org> | 2023-09-13 10:51:50 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-09-13 09:51:50 +0000 |
| commit | ab13fb08bf7c20a992ec2796c72d0fbb2a06545c (patch) | |
| tree | 57bc91c2614914198fec579692cdd3d968f4345c /synapse/replication | |
| parent | Update changelog (diff) | |
| download | synapse-ab13fb08bf7c20a992ec2796c72d0fbb2a06545c.tar.xz | |
Improve logging of replication (#16309)
Diffstat (limited to '')
| -rw-r--r-- | synapse/replication/tcp/handler.py | 2 | ||||
| -rw-r--r-- | synapse/replication/tcp/resource.py | 7 |
2 files changed, 7 insertions, 2 deletions
diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py index d9045d7b73..5642666411 100644 --- a/synapse/replication/tcp/handler.py +++ b/synapse/replication/tcp/handler.py @@ -644,7 +644,7 @@ class ReplicationCommandHandler: [stream.parse_row(row) for row in rows], ) - logger.info("Caught up with stream '%s' to %i", stream_name, cmd.new_token) + logger.info("Caught up with stream '%s' to %i", stream_name, cmd.new_token) # We've now caught up to position sent to us, notify handler. await self._replication_data_handler.on_position( diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py index 347467d863..1d9a29d22e 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -191,7 +191,12 @@ class ReplicationStreamer: if updates: logger.info( - "Streaming: %s -> %s", stream.NAME, updates[-1][0] + "Streaming: %s -> %s (limited: %s, updates: %s, max token: %s)", + stream.NAME, + updates[-1][0], + limited, + len(updates), + current_token, ) stream_updates_counter.labels(stream.NAME).inc(len(updates)) |