Populate synapse_federation_client_sent_pdu_destinations:count again (#3386)
parent
99b77aa829
commit
c2eff937ac
|
@ -41,8 +41,11 @@ import logging
|
||||||
|
|
||||||
logger = logging.getLogger(__name__)
|
logger = logging.getLogger(__name__)
|
||||||
|
|
||||||
sent_pdus_destination_dist = Counter(
|
sent_pdus_destination_dist_count = Counter(
|
||||||
"synapse_federation_transaction_queue_sent_pdu_destinations", ""
|
"synapse_federation_client_sent_pdu_destinations:count", ""
|
||||||
|
)
|
||||||
|
sent_pdus_destination_dist_total = Counter(
|
||||||
|
"synapse_federation_client_sent_pdu_destinations:total", ""
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
|
@ -279,7 +282,8 @@ class TransactionQueue(object):
|
||||||
if not destinations:
|
if not destinations:
|
||||||
return
|
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:
|
for destination in destinations:
|
||||||
self.pending_pdus_by_dest.setdefault(destination, []).append(
|
self.pending_pdus_by_dest.setdefault(destination, []).append(
|
||||||
|
|
Loading…
Reference in New Issue