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

Commit

Permalink
Populate synapse_federation_client_sent_pdu_destinations:count again (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
hawkowl authored Jun 21, 2018
1 parent 99b77aa commit c2eff93
Showing 1 changed file with 7 additions and 3 deletions.
10 changes: 7 additions & 3 deletions synapse/federation/transaction_queue.py
Original file line number Diff line number Diff line change
Expand Up @@ -41,8 +41,11 @@

logger = logging.getLogger(__name__)

sent_pdus_destination_dist = Counter(
"synapse_federation_transaction_queue_sent_pdu_destinations", ""
sent_pdus_destination_dist_count = Counter(
"synapse_federation_client_sent_pdu_destinations:count", ""
)
sent_pdus_destination_dist_total = Counter(
"synapse_federation_client_sent_pdu_destinations:total", ""
)


Expand Down Expand Up @@ -279,7 +282,8 @@ def _send_pdu(self, pdu, destinations):
if not destinations:
return

sent_pdus_destination_dist.inc(len(destinations))
sent_pdus_destination_dist_total.inc(len(destinations))
sent_pdus_destination_dist_count.inc()

for destination in destinations:
self.pending_pdus_by_dest.setdefault(destination, []).append(
Expand Down

0 comments on commit c2eff93

Please sign in to comment.