diff options
| author | Brendan Abolivier <babolivier@matrix.org> | 2019-11-26 10:53:48 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-11-26 10:53:48 +0000 |
| commit | 4c1b799e1b9f8e04f6cd86a0977e28685ac20aea (patch) | |
| tree | fcaea2671bf38721520191c13bb37adf18ef84c5 /synapse/logging/_structured.py | |
| parent | Format changelog (diff) | |
| parent | Make sure that we close cursors before returning from a query (#6408) (diff) | |
| download | synapse-4c1b799e1b9f8e04f6cd86a0977e28685ac20aea.tar.xz | |
Merge branch 'develop' into babolivier/context_filters
Diffstat (limited to 'synapse/logging/_structured.py')
| -rw-r--r-- | synapse/logging/_structured.py | 14 |
1 files changed, 13 insertions, 1 deletions
diff --git a/synapse/logging/_structured.py b/synapse/logging/_structured.py index 334ddaf39a..ffa7b20ca8 100644 --- a/synapse/logging/_structured.py +++ b/synapse/logging/_structured.py @@ -261,6 +261,18 @@ def parse_drain_configs( ) +class StoppableLogPublisher(LogPublisher): + """ + A log publisher that can tell its observers to shut down any external + communications. + """ + + def stop(self): + for obs in self._observers: + if hasattr(obs, "stop"): + obs.stop() + + def setup_structured_logging( hs, config, @@ -336,7 +348,7 @@ def setup_structured_logging( # We should never get here, but, just in case, throw an error. raise ConfigError("%s drain type cannot be configured" % (observer.type,)) - publisher = LogPublisher(*observers) + publisher = StoppableLogPublisher(*observers) log_filter = LogLevelFilterPredicate() for namespace, namespace_config in log_config.get( |