diff options
author | Jorik Schellekens <joriks@matrix.org> | 2019-07-02 17:34:48 +0100 |
---|---|---|
committer | Jorik Schellekens <joriks@matrix.org> | 2019-07-23 16:04:02 +0100 |
commit | 21940cadf05d6c1fa55c30b7bda07bc6643b7bf2 (patch) | |
tree | dfaccd4fdb9e7e77365b54d9d106a9fb46ed4974 /synapse/handlers/devicemessage.py | |
parent | Trace device messages. (diff) | |
download | synapse-21940cadf05d6c1fa55c30b7bda07bc6643b7bf2.tar.xz |
Update to new access pattern
Diffstat (limited to 'synapse/handlers/devicemessage.py')
-rw-r--r-- | synapse/handlers/devicemessage.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/synapse/handlers/devicemessage.py b/synapse/handlers/devicemessage.py index c999805184..de22b37b9e 100644 --- a/synapse/handlers/devicemessage.py +++ b/synapse/handlers/devicemessage.py @@ -20,7 +20,7 @@ from twisted.internet import defer from synapse.api.errors import SynapseError from synapse.types import UserID, get_domain_from_id from synapse.util.stringutils import random_string -from synapse.util.tracerutils import TracerUtil, trace_defered_function +import synapse.util.tracerutils as tracerutils logger = logging.getLogger(__name__) @@ -77,7 +77,7 @@ class DeviceMessageHandler(object): "to_device_key", stream_id, users=local_messages.keys() ) - @trace_defered_function + @tracerutils.trace_defered_function @defer.inlineCallbacks def send_device_message(self, sender_user_id, message_type, messages): @@ -111,7 +111,7 @@ class DeviceMessageHandler(object): "message_id": message_id, } - TracerUtil.log_kv(local_messages) + tracerutils.log_kv(local_messages) stream_id = yield self.store.add_messages_to_device_inbox( local_messages, remote_edu_contents ) @@ -120,7 +120,7 @@ class DeviceMessageHandler(object): "to_device_key", stream_id, users=local_messages.keys() ) - TracerUtil.log_kv(remote_messages) + tracerutils.log_kv(remote_messages) for destination in remote_messages.keys(): # Enqueue a new federation transaction to send the new # device messages to each remote destination. |