diff options
author | Johannes Löthberg <johannes@kyriasis.com> | 2016-12-12 16:19:54 +0100 |
---|---|---|
committer | Johannes Löthberg <johannes@kyriasis.com> | 2016-12-12 16:32:47 +0100 |
commit | d3bd94805f6ef68e75d8c2e39b8c97ea5ce88286 (patch) | |
tree | d297f3abc3c58a1c2bdb23268abb7f56db32daa0 /synapse/http/endpoint.py | |
parent | IPv6 support for endpoint.py (diff) | |
download | synapse-d3bd94805f6ef68e75d8c2e39b8c97ea5ce88286.tar.xz |
Fixup for #1689 and #1690
Signed-off-by: Johannes Löthberg <johannes@kyriasis.com>
Diffstat (limited to '')
-rw-r--r-- | synapse/http/endpoint.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/synapse/http/endpoint.py b/synapse/http/endpoint.py index 5e2e428dbf..1c17a28406 100644 --- a/synapse/http/endpoint.py +++ b/synapse/http/endpoint.py @@ -61,8 +61,10 @@ def matrix_federation_endpoint(reactor, destination, ssl_context_factory=None, transport_endpoint = HostnameEndpoint default_port = 8008 else: - def transport_endpoint(reactor, host, port): - return wrapClientTLS(ssl_context_factory, HostnameEndpoint(reactor, host, port)) + def transport_endpoint(reactor, host, port, timeout): + return wrapClientTLS( + ssl_context_factory, + HostnameEndpoint(reactor, host, port, timeout=timeout)) default_port = 8448 if port is None: @@ -80,7 +82,7 @@ class SpiderEndpoint(object): Implements twisted.internet.interfaces.IStreamClientEndpoint. """ def __init__(self, reactor, host, port, blacklist, whitelist, - endpoint=TCP4ClientEndpoint, endpoint_kw_args={}): + endpoint=HostnameEndpoint, endpoint_kw_args={}): self.reactor = reactor self.host = host self.port = port @@ -118,7 +120,7 @@ class SRVClientEndpoint(object): """ def __init__(self, reactor, service, domain, protocol="tcp", - default_port=None, endpoint=TCP4ClientEndpoint, + default_port=None, endpoint=HostnameEndpoint, endpoint_kw_args={}): self.reactor = reactor self.service_name = "_%s._%s.%s" % (service, protocol, domain) |