diff options
author | Erik Johnston <erik@matrix.org> | 2017-03-30 13:31:10 +0100 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2017-03-30 13:31:10 +0100 |
commit | 3ba2859e0c1fb30a22b70c25de89eb4242d14d6e (patch) | |
tree | 4a807de8e99d8a534548018c59b27532e3123da0 /synapse/app | |
parent | Add functions to presence to support remote syncs (diff) | |
download | synapse-3ba2859e0c1fb30a22b70c25de89eb4242d14d6e.tar.xz |
Add tcp replication listener type and hook it up
Diffstat (limited to '')
-rwxr-xr-x | synapse/app/homeserver.py | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/synapse/app/homeserver.py b/synapse/app/homeserver.py index 2cdd2d39ff..990eb477e5 100755 --- a/synapse/app/homeserver.py +++ b/synapse/app/homeserver.py @@ -56,6 +56,7 @@ from synapse.util.logcontext import LoggingContext, PreserveLoggingContext from synapse.metrics import register_memory_metrics, get_metrics_for from synapse.metrics.resource import MetricsResource, METRICS_PREFIX from synapse.replication.resource import ReplicationResource, REPLICATION_PREFIX +from synapse.replication.tcp.resource import ReplicationStreamProtocolFactory from synapse.federation.transport.server import TransportLayerServer from synapse.util.rlimit import change_resource_limit @@ -222,6 +223,16 @@ class SynapseHomeServer(HomeServer): ), interface=address ) + 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 + ) + reactor.addSystemEventTrigger( + "before", "shutdown", server_listener.stopListening, + ) else: logger.warn("Unrecognized listener type: %s", listener["type"]) |