tileradotorg/synapse
1
0
Fork 0
forked from MirrorHub/synapse
Code Pull requests Activity

Remove vestigal references to SYNC replication command

Browse source 
We've ripped pretty much all of this out: let's remove the remains.
This commit is contained in:
Richard van der Hoff 2020-04-07 16:59:40 +01:00
parent 2e105c156b
commit 6a519a0ca0
2 changed files with 0 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
synapse/replication/tcp/commands.py
View file

@ -289,14 +289,6 @@ class FederationAckCommand(Command):
return str(self.token) return str(self.token)
class SyncCommand(Command):
"""Used for testing. The client protocol implementation allows waiting
on a SYNC command with a specified data.
"""
NAME = "SYNC"
class RemovePusherCommand(Command): class RemovePusherCommand(Command):
"""Sent by the client to request the master remove the given pusher. """Sent by the client to request the master remove the given pusher.
@ -419,7 +411,6 @@ _COMMANDS = (
ReplicateCommand, ReplicateCommand,
UserSyncCommand, UserSyncCommand,
FederationAckCommand, FederationAckCommand,
SyncCommand,
RemovePusherCommand, RemovePusherCommand,
InvalidateCacheCommand, InvalidateCacheCommand,
UserIpCommand, UserIpCommand,
@ -437,7 +428,6 @@ VALID_SERVER_COMMANDS = (
PositionCommand.NAME, PositionCommand.NAME,
ErrorCommand.NAME, ErrorCommand.NAME,
PingCommand.NAME, PingCommand.NAME,
SyncCommand.NAME,
RemoteServerUpCommand.NAME, RemoteServerUpCommand.NAME,
) )

4
synapse/replication/tcp/handler.py
View file

@ -31,7 +31,6 @@ from synapse.replication.tcp.commands import (
RemoteServerUpCommand, RemoteServerUpCommand,
RemovePusherCommand, RemovePusherCommand,
ReplicateCommand, ReplicateCommand,
SyncCommand,
UserIpCommand, UserIpCommand,
UserSyncCommand, UserSyncCommand,
) )
@ -281,9 +280,6 @@ class ReplicationCommandHandler:
self._streams_connected.add(cmd.stream_name) self._streams_connected.add(cmd.stream_name)
async def on_SYNC(self, cmd: SyncCommand):
pass
async def on_REMOTE_SERVER_UP(self, cmd: RemoteServerUpCommand): async def on_REMOTE_SERVER_UP(self, cmd: RemoteServerUpCommand):
""""Called when get a new REMOTE_SERVER_UP command.""" """"Called when get a new REMOTE_SERVER_UP command."""
self._replication_data_handler.on_remote_server_up(cmd.data) self._replication_data_handler.on_remote_server_up(cmd.data)