diff options
author | Erik Johnston <erik@matrix.org> | 2022-02-15 15:01:00 +0000 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-02-15 15:01:00 +0000 |
commit | 2b5643b3afa4cddc7809c8b51fe813d2f0987235 (patch) | |
tree | 9ff32427ebf0249a81e94e0f8b3e608efd1fd8b6 /synapse/storage/databases/main/devices.py | |
parent | `_auth_and_persist_outliers`: drop events we have already seen (#11994) (diff) | |
download | synapse-2b5643b3afa4cddc7809c8b51fe813d2f0987235.tar.xz |
Optimise calculating device_list changes in `/sync`. (#11974)
For users with large accounts it is inefficient to calculate the set of users they share a room with (and takes a lot of space in the cache). Instead we can look at users whose devices have changed since the last sync and check if they share a room with the syncing user.
Diffstat (limited to 'synapse/storage/databases/main/devices.py')
-rw-r--r-- | synapse/storage/databases/main/devices.py | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/synapse/storage/databases/main/devices.py b/synapse/storage/databases/main/devices.py index 8d845fe951..3b3a089b76 100644 --- a/synapse/storage/databases/main/devices.py +++ b/synapse/storage/databases/main/devices.py @@ -670,6 +670,16 @@ class DeviceWorkerStore(SQLBaseStore): device["device_id"]: db_to_json(device["content"]) for device in devices } + def get_cached_device_list_changes( + self, + from_key: int, + ) -> Optional[Set[str]]: + """Get set of users whose devices have changed since `from_key`, or None + if that information is not in our cache. + """ + + return self._device_list_stream_cache.get_all_entities_changed(from_key) + async def get_users_whose_devices_changed( self, from_key: int, user_ids: Iterable[str] ) -> Set[str]: |