diff options
| author | Erik Johnston <erik@matrix.org> | 2021-04-01 17:08:21 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-04-01 17:08:21 +0100 |
| commit | 33548f37aa7858c4d9ce01bf3ec931cc3f08833a (patch) | |
| tree | a301076b73976909451029fa1fdb53ef3d03a6ae /synapse/handlers/typing.py | |
| parent | Add `order_by` to list user admin API (#9691) (diff) | |
| download | synapse-33548f37aa7858c4d9ce01bf3ec931cc3f08833a.tar.xz | |
Improve tracing for to device messages (#9686)
Diffstat (limited to 'synapse/handlers/typing.py')
| -rw-r--r-- | synapse/handlers/typing.py | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/synapse/handlers/typing.py b/synapse/handlers/typing.py index 096d199f4c..bb35af099d 100644 --- a/synapse/handlers/typing.py +++ b/synapse/handlers/typing.py @@ -19,7 +19,10 @@ from typing import TYPE_CHECKING, Dict, Iterable, List, Optional, Set, Tuple from synapse.api.errors import AuthError, ShadowBanError, SynapseError from synapse.appservice import ApplicationService -from synapse.metrics.background_process_metrics import run_as_background_process +from synapse.metrics.background_process_metrics import ( + run_as_background_process, + wrap_as_background_process, +) from synapse.replication.tcp.streams import TypingStream from synapse.types import JsonDict, Requester, UserID, get_domain_from_id from synapse.util.caches.stream_change_cache import StreamChangeCache @@ -86,6 +89,7 @@ class FollowerTypingHandler: self._member_last_federation_poke = {} self.wheel_timer = WheelTimer(bucket_size=5000) + @wrap_as_background_process("typing._handle_timeouts") def _handle_timeouts(self) -> None: logger.debug("Checking for typing timeouts") |