mirror of
https://git.anonymousland.org/anonymousland/synapse-product.git
synced 2024-09-08 12:41:53 +00:00
Fix new metric where we used ms instead of seconds (#7771)
Introduced in #7755, not yet released.
This commit is contained in:
parent
8718021469
commit
1e03513f9a
1
changelog.d/7771.misc
Normal file
1
changelog.d/7771.misc
Normal file
@ -0,0 +1 @@
|
|||||||
|
Add some metrics for inbound and outbound federation latencies: `synapse_federation_server_pdu_process_time` and `synapse_event_processing_lag_by_event`.
|
@ -209,7 +209,7 @@ class FederationSender(object):
|
|||||||
|
|
||||||
synapse.metrics.event_processing_lag_by_event.labels(
|
synapse.metrics.event_processing_lag_by_event.labels(
|
||||||
"federation_sender"
|
"federation_sender"
|
||||||
).observe(now - ts)
|
).observe((now - ts) / 1000)
|
||||||
|
|
||||||
async def handle_room_events(events: Iterable[EventBase]) -> None:
|
async def handle_room_events(events: Iterable[EventBase]) -> None:
|
||||||
with Measure(self.clock, "handle_room_events"):
|
with Measure(self.clock, "handle_room_events"):
|
||||||
|
@ -118,7 +118,7 @@ class ApplicationServicesHandler(object):
|
|||||||
ts = yield self.store.get_received_ts(event.event_id)
|
ts = yield self.store.get_received_ts(event.event_id)
|
||||||
synapse.metrics.event_processing_lag_by_event.labels(
|
synapse.metrics.event_processing_lag_by_event.labels(
|
||||||
"appservice_sender"
|
"appservice_sender"
|
||||||
).observe(now - ts)
|
).observe((now - ts) / 1000)
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def handle_room_events(events):
|
def handle_room_events(events):
|
||||||
|
Loading…
Reference in New Issue
Block a user