diff options
| author | reivilibre <oliverw@matrix.org> | 2022-03-11 14:00:15 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-03-11 14:00:15 +0000 |
| commit | 4a53f357379c2dc407617a3d39e6da4790dec9aa (patch) | |
| tree | e73c980ce59d8c8735d36a55faf192488951fc31 /synapse/replication/tcp/resource.py | |
| parent | Add an additional HTTP pusher + push rule tests. (#12188) (diff) | |
| download | synapse-4a53f357379c2dc407617a3d39e6da4790dec9aa.tar.xz | |
Improve code documentation for the typing stream over replication. (#12211)
Diffstat (limited to 'synapse/replication/tcp/resource.py')
| -rw-r--r-- | synapse/replication/tcp/resource.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/replication/tcp/resource.py b/synapse/replication/tcp/resource.py index ab829040cd..c6870df8f9 100644 --- a/synapse/replication/tcp/resource.py +++ b/synapse/replication/tcp/resource.py @@ -67,8 +67,8 @@ class ReplicationStreamProtocolFactory(ServerFactory): class ReplicationStreamer: """Handles replication connections. - This needs to be poked when new replication data may be available. When new - data is available it will propagate to all connected clients. + This needs to be poked when new replication data may be available. + When new data is available it will propagate to all Redis subscribers. """ def __init__(self, hs: "HomeServer"): @@ -109,7 +109,7 @@ class ReplicationStreamer: def on_notifier_poke(self) -> None: """Checks if there is actually any new data and sends it to the - connections if there are. + Redis subscribers if there are. This should get called each time new data is available, even if it is currently being executed, so that nothing gets missed |