Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-12 04:24:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

fixes

Browse Source
This commit is contained in:
Amber Brown 2018-05-23 13:03:51 -05:00
parent b6063631c3
commit e987079037
3 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
synapse/federation/transaction_queue.py
View File

@ -41,7 +41,7 @@ import logging
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
sent_pdus_destination_dist = Counter( sent_pdus_destination_dist = Counter(
"synapse_federation_client_sent_pdu_destinations", "" "synapse_federation_transaction_queue_sent_pdu_destinations", ""
) )
@ -70,7 +70,7 @@ class TransactionQueue(object):
self.pending_transactions = {} self.pending_transactions = {}
LaterGauge( LaterGauge(
"synapse_federation_client_pending_destinations", "synapse_federation_transaction_queue_pending_destinations",
"", "",
[], [],
lambda: len(self.pending_transactions), lambda: len(self.pending_transactions),
@ -97,13 +97,13 @@ class TransactionQueue(object):
self.pending_edus_keyed_by_dest = edus_keyed = {} self.pending_edus_keyed_by_dest = edus_keyed = {}
LaterGauge( LaterGauge(
"synapse_federation_client_pending_pdus", "synapse_federation_transaction_queue_pending_pdus",
"", "",
[], [],
lambda: sum(map(len, pdus.values())), lambda: sum(map(len, pdus.values())),
) )
LaterGauge( LaterGauge(
"synapse_federation_client_pending_edus", "synapse_federation_transaction_queue_pending_edus",
"", "",
[], [],
lambda: ( lambda: (

14
synapse/http/request_metrics.py
View File

@ -63,46 +63,46 @@ response_db_txn_duration = Counter(
# seconds spent waiting for a db connection, when processing this request # seconds spent waiting for a db connection, when processing this request
response_db_sched_duration = Counter( response_db_sched_duration = Counter(
"synapse_http_request_response_db_sched_duration_seconds", "synapse_http_server_response_db_sched_duration_seconds",
"", "",
["method", "servlet", "tag"], ["method", "servlet", "tag"],
) )
# size in bytes of the response written # size in bytes of the response written
response_size = Counter( response_size = Counter(
"synapse_http_request_response_size", "", ["method", "servlet", "tag"] "synapse_http_server_response_size", "", ["method", "servlet", "tag"]
) )
# In flight metrics are incremented while the requests are in flight, rather # In flight metrics are incremented while the requests are in flight, rather
# than when the response was written. # than when the response was written.
in_flight_requests_ru_utime = Counter( in_flight_requests_ru_utime = Counter(
"synapse_http_request_in_flight_requests_ru_utime_seconds", "synapse_http_server_in_flight_requests_ru_utime_seconds",
"", "",
["method", "servlet"], ["method", "servlet"],
) )
in_flight_requests_ru_stime = Counter( in_flight_requests_ru_stime = Counter(
"synapse_http_request_in_flight_requests_ru_stime_seconds", "synapse_http_server_in_flight_requests_ru_stime_seconds",
"", "",
["method", "servlet"], ["method", "servlet"],
) )
in_flight_requests_db_txn_count = Counter( in_flight_requests_db_txn_count = Counter(
"synapse_http_request_in_flight_requests_db_txn_count", "", ["method", "servlet"] "synapse_http_server_in_flight_requests_db_txn_count", "", ["method", "servlet"]
) )
# seconds spent waiting for db txns, excluding scheduling time, when processing # seconds spent waiting for db txns, excluding scheduling time, when processing
# this request # this request
in_flight_requests_db_txn_duration = Counter( in_flight_requests_db_txn_duration = Counter(
"synapse_http_request_in_flight_requests_db_txn_duration_seconds", "synapse_http_server_in_flight_requests_db_txn_duration_seconds",
"", "",
["method", "servlet"], ["method", "servlet"],
) )
# seconds spent waiting for a db connection, when processing this request # seconds spent waiting for a db connection, when processing this request
in_flight_requests_db_sched_duration = Counter( in_flight_requests_db_sched_duration = Counter(
"synapse_http_request_in_flight_requests_db_sched_duration_seconds", "synapse_http_server_in_flight_requests_db_sched_duration_seconds",
"", "",
["method", "servlet"], ["method", "servlet"],
) )

4
synapse/push/bulk_push_rule_evaluator.py
View File

@ -37,9 +37,9 @@ rules_by_room = {}
push_rules_invalidation_counter = Counter( push_rules_invalidation_counter = Counter(
"synapse_push_bulk_push_role_evaluator_push_rules_invalidation_counter", "") "synapse_push_bulk_push_rule_evaluator_push_rules_invalidation_counter", "")
push_rules_state_size_counter = Counter( push_rules_state_size_counter = Counter(
"synapse_push_bulk_push_role_evaluator_push_rules_state_size_counter", "") "synapse_push_bulk_push_rule_evaluator_push_rules_state_size_counter", "")
# Measures whether we use the fast path of using state deltas, or if we have to # Measures whether we use the fast path of using state deltas, or if we have to
# recalculate from scratch # recalculate from scratch