diff options
author | Mark Haines <mark.haines@matrix.org> | 2016-03-24 18:02:10 +0000 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2016-03-24 18:02:10 +0000 |
commit | 54a546091abdf70c740d1e59b025e79c44df7455 (patch) | |
tree | e7c648c718ee6f56f8bdf8b3955b0fc2026362fd | |
parent | Deduplicate identical /sync requests (diff) | |
download | synapse-54a546091abdf70c740d1e59b025e79c44df7455.tar.xz |
Add a response cache for getting the public room list
-rw-r--r-- | synapse/handlers/room.py | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/synapse/handlers/room.py b/synapse/handlers/room.py index d5c56ce0d6..133183a257 100644 --- a/synapse/handlers/room.py +++ b/synapse/handlers/room.py @@ -25,6 +25,7 @@ from synapse.api.constants import ( from synapse.api.errors import AuthError, StoreError, SynapseError, Codes from synapse.util import stringutils, unwrapFirstError from synapse.util.logcontext import preserve_context_over_fn +from synapse.util.caches.response_cache import ResponseCache from signedjson.sign import verify_signed_json from signedjson.key import decode_verify_key_bytes @@ -939,9 +940,18 @@ class RoomMemberHandler(BaseHandler): class RoomListHandler(BaseHandler): + def __init__(self, hs): + super(RoomListHandler, self).__init__(hs) + self.response_cache = ResponseCache() - @defer.inlineCallbacks def get_public_room_list(self): + result = self.response_cache.get(()) + if not result: + result = self.response_cache.set((), self._get_public_room_list()) + return result + + @defer.inlineCallbacks + def _get_public_room_list(self): room_ids = yield self.store.get_public_room_ids() @defer.inlineCallbacks |