diff options
| author | Richard van der Hoff <richard@matrix.org> | 2018-06-04 16:23:05 +0100 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2018-06-04 16:23:05 +0100 |
| commit | b7e7fd2d0edd4d46aaf9d6afc8df14cf3de911f9 (patch) | |
| tree | 9c22e901448613dbcc2b82a84902bd920feeda57 /synapse/replication | |
| parent | Hopefully, fix LaterGuage error handling (diff) | |
| download | synapse-b7e7fd2d0edd4d46aaf9d6afc8df14cf3de911f9.tar.xz | |
Fix replication metrics
fix bug introduced in #3256
Diffstat (limited to 'synapse/replication')
| -rw-r--r-- | synapse/replication/tcp/protocol.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py index a6280aae70..c870475cd1 100644 --- a/synapse/replication/tcp/protocol.py +++ b/synapse/replication/tcp/protocol.py @@ -622,7 +622,7 @@ tcp_inbound_commands = LaterGauge( lambda: { (k[0], p.name, p.conn_id): count for p in connected_connections - for k, count in iteritems(p.inbound_commands_counter.counts) + for k, count in iteritems(p.inbound_commands_counter) }) tcp_outbound_commands = LaterGauge( @@ -630,7 +630,7 @@ tcp_outbound_commands = LaterGauge( lambda: { (k[0], p.name, p.conn_id): count for p in connected_connections - for k, count in iteritems(p.outbound_commands_counter.counts) + for k, count in iteritems(p.outbound_commands_counter) }) # number of updates received for each RDATA stream |