From 80786d5cafe3bfe7637116c2208455384f65e97b Mon Sep 17 00:00:00 2001 From: Richard van der Hoff Date: Wed, 4 Apr 2018 17:30:02 +0100 Subject: [PATCH] Logging for get_users_in_room --- synapse/storage/roommember.py | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/synapse/storage/roommember.py b/synapse/storage/roommember.py index 829cc4a207..3032f10185 100644 --- a/synapse/storage/roommember.py +++ b/synapse/storage/roommember.py @@ -68,6 +68,7 @@ class RoomMemberWorkerStore(EventsWorkerStore): defer.returnValue(hosts) @cached(max_entries=100000, iterable=True) + @defer.inlineCallbacks def get_users_in_room(self, room_id): def f(txn): sql = ( @@ -81,7 +82,14 @@ class RoomMemberWorkerStore(EventsWorkerStore): txn.execute(sql, (room_id, Membership.JOIN,)) return [to_ascii(r[0]) for r in txn] - return self.runInteraction("get_users_in_room", f) + start_time = self._clock.time_msec() + result = yield self.runInteraction("get_users_in_room", f) + end_time = self._clock.time_msec() + logger.info( + "Fetched room membership for %s (%i users) in %i ms", + room_id, len(result), end_time - start_time, + ) + defer.returnValue(result) @cached() def get_invited_rooms_for_user(self, user_id):