summary refs log tree commit diff
path: root/synapse/app/federation_sender.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2017-04-04 15:22:54 +0100
committerErik Johnston <erik@matrix.org>2017-04-04 15:22:54 +0100
commitac66e11f2b1235f801195ad0065008cdca2f1b0b (patch)
treebe58241935d8c7361788e247abc19dae6d8648d3 /synapse/app/federation_sender.py
parentRemove unused worker config option (diff)
downloadsynapse-ac66e11f2b1235f801195ad0065008cdca2f1b0b.tar.xz
Add the appropriate amount of preserve_fn
Diffstat (limited to '')
-rw-r--r--synapse/app/federation_sender.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/app/federation_sender.py b/synapse/app/federation_sender.py
index 705fe5e3df..fa7b19e53a 100644
--- a/synapse/app/federation_sender.py
+++ b/synapse/app/federation_sender.py
@@ -36,7 +36,7 @@ from synapse.storage.engines import create_engine
 from synapse.storage.presence import UserPresenceState
 from synapse.util.async import Linearizer
 from synapse.util.httpresourcetree import create_resource_tree
-from synapse.util.logcontext import LoggingContext, PreserveLoggingContext
+from synapse.util.logcontext import LoggingContext, PreserveLoggingContext, preserve_fn
 from synapse.util.manhole import manhole
 from synapse.util.rlimit import change_resource_limit
 from synapse.util.versionstring import get_version_string
@@ -337,7 +337,7 @@ class FederationSenderHandler(object):
             for destination in device_destinations:
                 self.federation_sender.send_device_messages(destination)
 
-            self.update_token(token)
+            preserve_fn(self.update_token)(token)
 
         # We also need to poke the federation sender when new events happen
         elif stream_name == "events":