diff options
author | Neil Johnson <neil@matrix.org> | 2018-08-09 11:40:37 +0100 |
---|---|---|
committer | Neil Johnson <neil@matrix.org> | 2018-08-09 11:40:37 +0100 |
commit | a5ef1107490a8f581e8baf8a29d509826b8d2490 (patch) | |
tree | 24dcb2ae7813a421d04b6faa3a00c8ec646a7bef /synapse/handlers/appservice.py | |
parent | sync auth blocking (diff) | |
parent | Merge branch 'master' into develop (diff) | |
download | synapse-a5ef1107490a8f581e8baf8a29d509826b8d2490.tar.xz |
Merge branch 'develop' of github.com:matrix-org/synapse into neilj/mau_sync_block
Diffstat (limited to 'synapse/handlers/appservice.py')
-rw-r--r-- | synapse/handlers/appservice.py | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/synapse/handlers/appservice.py b/synapse/handlers/appservice.py index ee41aed69e..f0f89af7dc 100644 --- a/synapse/handlers/appservice.py +++ b/synapse/handlers/appservice.py @@ -23,6 +23,10 @@ from twisted.internet import defer import synapse from synapse.api.constants import EventTypes +from synapse.metrics import ( + event_processing_loop_counter, + event_processing_loop_room_count, +) from synapse.metrics.background_process_metrics import run_as_background_process from synapse.util.logcontext import make_deferred_yieldable, run_in_background from synapse.util.metrics import Measure @@ -136,6 +140,12 @@ class ApplicationServicesHandler(object): events_processed_counter.inc(len(events)) + event_processing_loop_room_count.labels( + "appservice_sender" + ).inc(len(events_by_room)) + + event_processing_loop_counter.labels("appservice_sender").inc() + synapse.metrics.event_processing_lag.labels( "appservice_sender").set(now - ts) synapse.metrics.event_processing_last_ts.labels( |