diff options
| author | Olivier 'reivilibre <oliverw@matrix.org> | 2024-07-30 18:07:35 +0100 |
|---|---|---|
| committer | Olivier 'reivilibre <oliverw@matrix.org> | 2024-07-30 18:07:35 +0100 |
| commit | ed583d9c815520f94a7267e7ef0dbb7977e57189 (patch) | |
| tree | 123e3d6a8ffa77a12f7bf219fb63c8b801b0f5e9 /synapse/notifier.py | |
| parent | Add bold emphasis to some parts of the changelog (diff) | |
| parent | 1.112.0 (diff) | |
| download | synapse-master.tar.xz | |
Merge branch 'release-v1.112' master
Diffstat (limited to '')
| -rw-r--r-- | synapse/notifier.py | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/synapse/notifier.py b/synapse/notifier.py index c3ecf86ec4..7a2b54036c 100644 --- a/synapse/notifier.py +++ b/synapse/notifier.py @@ -773,6 +773,7 @@ class Notifier: stream_token = await self.event_sources.bound_future_token(stream_token) start = self.clock.time_msec() + logged = False while True: current_token = self.event_sources.get_current_token() if stream_token.is_before_or_eq(current_token): @@ -783,11 +784,13 @@ class Notifier: if now - start > 10_000: return False - logger.info( - "Waiting for current token to reach %s; currently at %s", - stream_token, - current_token, - ) + if not logged: + logger.info( + "Waiting for current token to reach %s; currently at %s", + stream_token, + current_token, + ) + logged = True # TODO: be better await self.clock.sleep(0.5) |