Skip to content
This repository has been archived by the owner on Apr 26, 2024. It is now read-only.

Commit

Permalink
Fix replication metrics
Browse files Browse the repository at this point in the history
fix bug introduced in #3256
  • Loading branch information
richvdh committed Jun 4, 2018
1 parent 694968f commit b7e7fd2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions synapse/replication/tcp/protocol.py
Original file line number Diff line number Diff line change
Expand Up @@ -622,15 +622,15 @@ def transport_kernel_read_buffer_size(protocol, read=True):
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(
"synapse_replication_tcp_outbound_commands", "", ["command", "name", "conn_id"],
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
Expand Down

0 comments on commit b7e7fd2

Please sign in to comment.