diff options
author | Erik Johnston <erik@matrix.org> | 2016-08-26 11:15:40 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2016-08-26 11:15:40 +0100 |
commit | 11faa4296d1109ff6370cedf5c9e3bd688266792 (patch) | |
tree | 4004fe203cb4ed698b955b9b93067ef8eb68c986 | |
parent | Don't pull out full state for _filter_events_for_server (diff) | |
download | synapse-11faa4296d1109ff6370cedf5c9e3bd688266792.tar.xz |
Measure _filter_events_for_server
-rw-r--r-- | synapse/handlers/federation.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/synapse/handlers/federation.py b/synapse/handlers/federation.py index c9deb52280..a7ea8fb98f 100644 --- a/synapse/handlers/federation.py +++ b/synapse/handlers/federation.py @@ -29,6 +29,7 @@ from synapse.util import unwrapFirstError from synapse.util.logcontext import ( PreserveLoggingContext, preserve_fn, preserve_context_over_deferred ) +from synapse.util.metrics import measure_func from synapse.util.logutils import log_function from synapse.util.async import run_on_reactor from synapse.util.frozenutils import unfreeze @@ -235,6 +236,7 @@ class FederationHandler(BaseHandler): user = UserID.from_string(event.state_key) yield user_joined_room(self.distributor, user, event.room_id) + @measure_func("_filter_events_for_server") @defer.inlineCallbacks def _filter_events_for_server(self, server_name, room_id, events): event_to_state_ids = yield self.store.get_state_ids_for_events( |