summary refs log tree commit diff
path: root/synapse/replication/tcp/handler.py
diff options
context:
space:
mode:
authorRichard van der Hoff <richard@matrix.org>2020-05-05 18:53:38 +0100
committerRichard van der Hoff <richard@matrix.org>2020-05-05 19:31:37 +0100
commitd78265af0c77b7d75bc5fd013515b53b01a2ac23 (patch)
treedd8368c5874a72c83e292278b8e20952eea4d600 /synapse/replication/tcp/handler.py
parentWorkaround for assertion errors from db_query_to_update_function (#7378) (diff)
downloadsynapse-d78265af0c77b7d75bc5fd013515b53b01a2ac23.tar.xz
Wait to subscribe before sending REPLICATE
Diffstat (limited to 'synapse/replication/tcp/handler.py')
-rw-r--r--synapse/replication/tcp/handler.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/synapse/replication/tcp/handler.py b/synapse/replication/tcp/handler.py
index 6f7054d5af..0e8a38fd80 100644
--- a/synapse/replication/tcp/handler.py
+++ b/synapse/replication/tcp/handler.py
@@ -99,7 +99,8 @@ class ReplicationCommandHandler:
         # The factory used to create connections.
         self._factory = None  # type: Optional[ReconnectingClientFactory]
 
-        # The currently connected connections.
+        # The currently connected connections. (The list of places we need to send
+        # outgoing replication commands to.)
         self._connections = []  # type: List[AbstractConnection]
 
         LaterGauge(