diff options
| author | Erik Johnston <erik@matrix.org> | 2017-04-04 15:22:54 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2017-04-04 15:22:54 +0100 |
| commit | ac66e11f2b1235f801195ad0065008cdca2f1b0b (patch) | |
| tree | be58241935d8c7361788e247abc19dae6d8648d3 /synapse/app/appservice.py | |
| parent | Remove unused worker config option (diff) | |
| download | synapse-ac66e11f2b1235f801195ad0065008cdca2f1b0b.tar.xz | |
Add the appropriate amount of preserve_fn
Diffstat (limited to 'synapse/app/appservice.py')
| -rw-r--r-- | synapse/app/appservice.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/synapse/app/appservice.py b/synapse/app/appservice.py index 13b69d8dee..9a476efa63 100644 --- a/synapse/app/appservice.py +++ b/synapse/app/appservice.py @@ -29,7 +29,7 @@ from synapse.replication.slave.storage.registration import SlavedRegistrationSto from synapse.replication.tcp.client import ReplicationClientHandler from synapse.storage.engines import create_engine 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 @@ -136,7 +136,9 @@ class ASReplicationHandler(ReplicationClientHandler): if stream_name == "events": max_stream_id = self.store.get_room_max_stream_ordering() - self.appservice_handler.notify_interested_services(max_stream_id) + preserve_fn( + self.appservice_handler.notify_interested_services + )(max_stream_id) def start(config_options): |