diff options
author | Mark Haines <mark.haines@matrix.org> | 2014-10-13 10:58:36 +0100 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2014-10-13 10:58:50 +0100 |
commit | 984e207b5982df26bec37223cd07b4044dcacdd2 (patch) | |
tree | 9b7cd2052ab91b4365bb43f46d2509b389bf1bab /synapse/federation | |
parent | Merge branch 'develop' into server2server_signing (diff) | |
parent | remove wishlist in favour of jira (diff) | |
download | synapse-984e207b5982df26bec37223cd07b4044dcacdd2.tar.xz |
Merge branch develop into server2server_signing
Conflicts: synapse/app/homeserver.py
Diffstat (limited to 'synapse/federation')
-rw-r--r-- | synapse/federation/replication.py | 7 | ||||
-rw-r--r-- | synapse/federation/transport.py | 5 |
2 files changed, 8 insertions, 4 deletions
diff --git a/synapse/federation/replication.py b/synapse/federation/replication.py index a8dd038b0b..b4235585a3 100644 --- a/synapse/federation/replication.py +++ b/synapse/federation/replication.py @@ -163,7 +163,8 @@ class ReplicationLayer(object): return defer.succeed(None) @log_function - def make_query(self, destination, query_type, args): + def make_query(self, destination, query_type, args, + retry_on_dns_fail=True): """Sends a federation Query to a remote homeserver of the given type and arguments. @@ -178,7 +179,9 @@ class ReplicationLayer(object): a Deferred which will eventually yield a JSON object from the response """ - return self.transport_layer.make_query(destination, query_type, args) + return self.transport_layer.make_query( + destination, query_type, args, retry_on_dns_fail=retry_on_dns_fail + ) @defer.inlineCallbacks @log_function diff --git a/synapse/federation/transport.py b/synapse/federation/transport.py index 5d595b7433..1f864f5fa7 100644 --- a/synapse/federation/transport.py +++ b/synapse/federation/transport.py @@ -195,13 +195,14 @@ class TransportLayer(object): @defer.inlineCallbacks @log_function - def make_query(self, destination, query_type, args): + def make_query(self, destination, query_type, args, retry_on_dns_fail): path = PREFIX + "/query/%s" % query_type response = yield self.client.get_json( destination=destination, path=path, - args=args + args=args, + retry_on_dns_fail=retry_on_dns_fail, ) defer.returnValue(response) |