Fix sending server up commands from workers

matrix-org · Jan 30, 2020 · f2c8ef8 · f2c8ef8
1 parent 8ca12a7
commit f2c8ef8
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py
@@ -31,6 +31,7 @@
     Command,
     FederationAckCommand,
     InvalidateCacheCommand,
+    RemoteServerUpCommand,
     RemovePusherCommand,
     UserIpCommand,
     UserSyncCommand,
@@ -210,6 +211,9 @@ def send_user_ip(self, user_id, access_token, ip, user_agent, device_id, last_se
         cmd = UserIpCommand(user_id, access_token, ip, user_agent, device_id, last_seen)
         self.send_command(cmd)
 
+    def send_remote_server_up(self, server: str):
+        self.send_command(RemoteServerUpCommand(server))
+
     def await_sync(self, data):
         """Returns a deferred that is resolved when we receive a SYNC command
         with given data.