diff options
author | Richard van der Hoff <richard@matrix.org> | 2019-03-04 18:31:18 +0000 |
---|---|---|
committer | Richard van der Hoff <richard@matrix.org> | 2019-03-04 18:31:18 +0000 |
commit | c7325776a7a02354657c519eb5169c1f2f3e0872 (patch) | |
tree | 90c5d24a5ab7bf71a8acc2e23a36bd7e80d6de7a /synapse/notifier.py | |
parent | Remove unused `wait_for_replication` method (diff) | |
download | synapse-c7325776a7a02354657c519eb5169c1f2f3e0872.tar.xz |
Remove redundant PreserveLoggingContext
Both (!) things that register as replication listeners do the right thing wrt logcontexts, so this is redundant.
Diffstat (limited to 'synapse/notifier.py')
-rw-r--r-- | synapse/notifier.py | 15 |
1 files changed, 5 insertions, 10 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py index 2505202e98..ff589660da 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -203,7 +203,9 @@ class Notifier(object): def add_replication_callback(self, cb): """Add a callback that will be called when some new data is available. - Callback is not given any arguments. + Callback is not given any arguments. It should *not* return a Deferred - if + it needs to do any asynchronous work, a background thread should be started and + wrapped with run_as_background_process. """ self.replication_callbacks.append(cb) @@ -515,12 +517,5 @@ class Notifier(object): def notify_replication(self): """Notify the any replication listeners that there's a new event""" - with PreserveLoggingContext(): - # the callbacks may well outlast the current request, so we run - # them in the sentinel logcontext. - # - # (ideally it would be up to the callbacks to know if they were - # starting off background processes and drop the logcontext - # accordingly, but that requires more changes) - for cb in self.replication_callbacks: - cb() + for cb in self.replication_callbacks: + cb() |