summary refs log tree commit diff
path: root/synapse/storage/devices.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2020-02-25 10:10:45 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2020-02-25 10:10:45 +0000
commit2b3f54ae90044f6512f967c8dfc82fa3a756395c (patch)
treecb2dbcb16143c5bca0d88c50d40a9410b4ce5904 /synapse/storage/devices.py
parentRemove unused methods from c/s api v1 in register.py (#5963) (diff)
parentOpentrace device lists (#5853) (diff)
downloadsynapse-2b3f54ae90044f6512f967c8dfc82fa3a756395c.tar.xz
Opentrace device lists (#5853)
Diffstat (limited to 'synapse/storage/devices.py')
-rw-r--r--synapse/storage/devices.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/storage/devices.py b/synapse/storage/devices.py

index 410d4d76f8..cc2852026f 100644 --- a/synapse/storage/devices.py +++ b/synapse/storage/devices.py
@@ -25,6 +25,7 @@ from twisted.internet import defer from synapse.api.errors import Codes, StoreError from synapse.logging.opentracing import ( get_active_span_text_map, + set_tag, trace, whitelisted_homeserver, ) @@ -325,6 +326,7 @@ class DeviceWorkerStore(SQLBaseStore): def get_device_stream_token(self): return self._device_list_id_gen.get_current_token() + @trace @defer.inlineCallbacks def get_user_devices_from_cache(self, query_list): """Get the devices (and keys if any) for remote users from the cache. @@ -356,6 +358,9 @@ class DeviceWorkerStore(SQLBaseStore): else: results[user_id] = yield self._get_cached_devices_for_user(user_id) + set_tag("in_cache", results) + set_tag("not_in_cache", user_ids_not_in_cache) + return user_ids_not_in_cache, results @cachedInlineCallbacks(num_args=2, tree=True)