summary refs log tree commit diff
path: root/synapse/replication/tcp/protocol.py
diff options
context:
space:
mode:
authorRichard van der Hoff <richard@matrix.org>2018-06-06 07:02:02 +0100
committerRichard van der Hoff <richard@matrix.org>2018-06-06 07:02:02 +0100
commit592ee217a3d0622ace35743dd4bb48fe5560b3ac (patch)
tree0bdf92e711d6d9e1fe52d653821c88bee834dbb1 /synapse/replication/tcp/protocol.py
parentbump version and changelog (diff)
parentFix replication metrics (diff)
downloadsynapse-592ee217a3d0622ace35743dd4bb48fe5560b3ac.tar.xz
Merge commit 'b7e7fd2' into release-v0.31.0
Diffstat (limited to 'synapse/replication/tcp/protocol.py')
-rw-r--r--synapse/replication/tcp/protocol.py4
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