diff options
| author | Erik Johnston <erik@matrix.org> | 2020-01-30 16:42:11 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-01-30 16:42:11 +0000 |
| commit | c3d4ad8afdbe181707451410100dec4817c2c01a (patch) | |
| tree | 0aa1cb23234419e1857918f2c8e5edb75949b9cf /synapse/replication/tcp/client.py | |
| parent | When server leaves room check for stale device lists. (#6801) (diff) | |
| download | synapse-c3d4ad8afdbe181707451410100dec4817c2c01a.tar.xz | |
Fix sending server up commands from workers (#6811)
Co-authored-by: Andrew Morgan <1342360+anoadragon453@users.noreply.github.com>
Diffstat (limited to 'synapse/replication/tcp/client.py')
| -rw-r--r-- | synapse/replication/tcp/client.py | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index fc06a7b053..02ab5b66ea 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -31,6 +31,7 @@ from .commands import ( Command, FederationAckCommand, InvalidateCacheCommand, + RemoteServerUpCommand, RemovePusherCommand, UserIpCommand, UserSyncCommand, @@ -210,6 +211,9 @@ class ReplicationClientHandler(AbstractReplicationClientHandler): 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. |