Use `listen_tcp` for the replication listener

Fixes the "can't listen on 0.0.0.0" error. Also makes it more consistent with
what we do elsewhere.
pull/4636/head
Richard van der Hoff 2019-02-13 11:59:04 +00:00
parent 2a5a15aff8
commit 767686af48
1 changed files with 7 additions and 7 deletions

View File

@ -266,14 +266,14 @@ class SynapseHomeServer(HomeServer):
)
)
elif listener["type"] == "replication":
bind_addresses = listener["bind_addresses"]
for address in bind_addresses:
factory = ReplicationStreamProtocolFactory(self)
server_listener = reactor.listenTCP(
listener["port"], factory, interface=address
)
services = listen_tcp(
listener["bind_addresses"],
listener["port"],
ReplicationStreamProtocolFactory(self),
)
for s in services:
reactor.addSystemEventTrigger(
"before", "shutdown", server_listener.stopListening,
"before", "shutdown", s.stopListening,
)
elif listener["type"] == "metrics":
if not self.get_config().enable_metrics: