diff options
| author | Mathieu Velten <mathieuv@matrix.org> | 2023-03-30 12:51:35 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-03-30 12:51:35 +0200 |
| commit | 9228ae633f209212ed55de7943d1a8aee3645b57 (patch) | |
| tree | aef07f993238dc5806ee86b9a281227837bef5c5 /synapse/replication/tcp/streams | |
| parent | Fix missing app variable in mail subject for password resets (#15352) (diff) | |
| download | synapse-9228ae633f209212ed55de7943d1a8aee3645b57.tar.xz | |
Add some clarification to the doc/comments regarding TCP replication (#15354)
Diffstat (limited to 'synapse/replication/tcp/streams')
| -rw-r--r-- | synapse/replication/tcp/streams/_base.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py index a4bdb48c0c..c6088a0f99 100644 --- a/synapse/replication/tcp/streams/_base.py +++ b/synapse/replication/tcp/streams/_base.py @@ -152,8 +152,8 @@ class Stream: Returns: A triplet `(updates, new_last_token, limited)`, where `updates` is a list of `(token, row)` entries, `new_last_token` is the new - position in stream, and `limited` is whether there are more updates - to fetch. + position in stream (ie the highest token returned in the updates), + and `limited` is whether there are more updates to fetch. """ current_token = self.current_token(self.local_instance_name) updates, current_token, limited = await self.get_updates_since( |