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/federation/transaction_queue.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/federation/transaction_queue.py')
| -rw-r--r-- | synapse/federation/transaction_queue.py | 10 |
1 files changed, 9 insertions, 1 deletions
diff --git a/synapse/federation/transaction_queue.py b/synapse/federation/transaction_queue.py index 78f9d40a3a..f603c8a368 100644 --- a/synapse/federation/transaction_queue.py +++ b/synapse/federation/transaction_queue.py @@ -26,6 +26,8 @@ from synapse.api.errors import FederationDeniedError, HttpResponseException from synapse.handlers.presence import format_user_presence_state, get_interested_remotes from synapse.metrics import ( LaterGauge, + event_processing_loop_counter, + event_processing_loop_room_count, events_processed_counter, sent_edus_counter, sent_transactions_counter, @@ -253,7 +255,13 @@ class TransactionQueue(object): synapse.metrics.event_processing_last_ts.labels( "federation_sender").set(ts) - events_processed_counter.inc(len(events)) + events_processed_counter.inc(len(events)) + + event_processing_loop_room_count.labels( + "federation_sender" + ).inc(len(events_by_room)) + + event_processing_loop_counter.labels("federation_sender").inc() synapse.metrics.event_processing_positions.labels( "federation_sender").set(next_token) |