OpenCloud
/
MatrixSynapse
mirror of https://github.com/matrix-org/synapse
1
0
Fork 0
Code Issues Releases Wiki Activity

Fixup old style class constructors

pull/7187/head
Erik Johnston 2020-04-06 14:44:01 +01:00
parent 984c959f38
commit 9cc569857d
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
synapse/replication/tcp/protocol.py
View File

@ -423,13 +423,13 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol):
def __init__( def __init__(
self, server_name: str, clock: Clock, handler: "ReplicationCommandHandler" self, server_name: str, clock: Clock, handler: "ReplicationCommandHandler"
): ):
BaseReplicationStreamProtocol.__init__(self, clock, handler) # Old style class super().__init__(clock, handler)
self.server_name = server_name self.server_name = server_name
def connectionMade(self): def connectionMade(self):
self.send_command(ServerCommand(self.server_name)) self.send_command(ServerCommand(self.server_name))
BaseReplicationStreamProtocol.connectionMade(self) super().connectionMade()
async def on_NAME(self, cmd): async def on_NAME(self, cmd):
logger.info("[%s] Renamed to %r", self.id(), cmd.data) logger.info("[%s] Renamed to %r", self.id(), cmd.data)
@ -448,7 +448,7 @@ class ClientReplicationStreamProtocol(BaseReplicationStreamProtocol):
clock: Clock, clock: Clock,
command_handler: "ReplicationCommandHandler", command_handler: "ReplicationCommandHandler",
): ):
BaseReplicationStreamProtocol.__init__(self, clock, command_handler) super().__init__(clock, command_handler)
self.instance_id = hs.get_instance_id() self.instance_id = hs.get_instance_id()
@ -457,7 +457,7 @@ class ClientReplicationStreamProtocol(BaseReplicationStreamProtocol):
def connectionMade(self): def connectionMade(self):
self.send_command(NameCommand(self.client_name)) self.send_command(NameCommand(self.client_name))
BaseReplicationStreamProtocol.connectionMade(self) super().connectionMade()
# Once we've connected subscribe to the necessary streams # Once we've connected subscribe to the necessary streams
self.replicate() self.replicate()