summary refs log tree commit diff
path: root/synapse/federation
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2019-03-08 18:22:47 +0000
committerAndrew Morgan <andrew@amorgan.xyz>2019-03-08 18:22:47 +0000
commit64ff11019e11a712278fdb4fbc0a5f8307f83ddb (patch)
treef83770944a0640bbbee485c3a2b64754c9fc2a69 /synapse/federation
parentRemove trailing slashes from outbound federation requests (diff)
downloadsynapse-64ff11019e11a712278fdb4fbc0a5f8307f83ddb.tar.xz
Retry certain federation requests on 404
Diffstat (limited to 'synapse/federation')
-rw-r--r--synapse/federation/transport/client.py10
1 files changed, 5 insertions, 5 deletions
diff --git a/synapse/federation/transport/client.py b/synapse/federation/transport/client.py
index 492cd4e64b..2bd0e0040b 100644
--- a/synapse/federation/transport/client.py
+++ b/synapse/federation/transport/client.py
@@ -52,7 +52,7 @@ class TransportLayerClient(object):
                      destination, room_id)
 
         path = _create_v1_path("/state/%s", room_id)
-        return self.client.get_json(
+        return self.client.get_json_with_trailing_slashes_on_404(
             destination, path=path, args={"event_id": event_id},
         )
 
@@ -74,7 +74,7 @@ class TransportLayerClient(object):
                      destination, room_id)
 
         path = _create_v1_path("/state_ids/%s", room_id)
-        return self.client.get_json(
+        return self.client.get_json_with_trailing_slashes_on_404(
             destination, path=path, args={"event_id": event_id},
         )
 
@@ -96,7 +96,7 @@ class TransportLayerClient(object):
                      destination, event_id)
 
         path = _create_v1_path("/event/%s", event_id)
-        return self.client.get_json(destination, path=path, timeout=timeout)
+        return self.client.get_json_with_trailing_slashes_on_404(destination, path=path, timeout=timeout)
 
     @log_function
     def backfill(self, destination, room_id, event_tuples, limit):
@@ -128,7 +128,7 @@ class TransportLayerClient(object):
             "limit": [str(limit)],
         }
 
-        return self.client.get_json(
+        return self.client.get_json_with_trailing_slashes_on_404(
             destination,
             path=path,
             args=args,
@@ -169,7 +169,7 @@ class TransportLayerClient(object):
 
         path = _create_v1_path("/send/%s", transaction.transaction_id)
 
-        response = yield self.client.put_json(
+        response = yield self.client.put_json_with_trailing_slashes_on_404(
             transaction.destination,
             path=path,
             data=json_data,