diff options
author | Erik Johnston <erik@matrix.org> | 2015-11-02 16:49:05 +0000 |
---|---|---|
committer | Erik Johnston <erik@matrix.org> | 2015-11-02 16:56:30 +0000 |
commit | eacb068ac2a6df8494d9f7255c80f4429e779209 (patch) | |
tree | c6e91c4528af327f62bc863f439e18ef1439eab7 /synapse/http/matrixfederationclient.py | |
parent | Merge pull request #338 from matrix-org/daniel/fixdb (diff) | |
download | synapse-eacb068ac2a6df8494d9f7255c80f4429e779209.tar.xz |
Retry dead servers a lot less often
Diffstat (limited to 'synapse/http/matrixfederationclient.py')
-rw-r--r-- | synapse/http/matrixfederationclient.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/synapse/http/matrixfederationclient.py b/synapse/http/matrixfederationclient.py index b50a0c445c..6e53538a52 100644 --- a/synapse/http/matrixfederationclient.py +++ b/synapse/http/matrixfederationclient.py @@ -35,6 +35,7 @@ from signedjson.sign import sign_json import simplejson as json import logging +import random import sys import urllib import urlparse @@ -55,6 +56,9 @@ incoming_responses_counter = metrics.register_counter( ) +MAX_RETRIES = 4 + + class MatrixFederationEndpointFactory(object): def __init__(self, hs): self.tls_server_context_factory = hs.tls_server_context_factory @@ -119,7 +123,7 @@ class MatrixFederationHttpClient(object): # XXX: Would be much nicer to retry only at the transaction-layer # (once we have reliable transactions in place) - retries_left = 5 + retries_left = MAX_RETRIES http_url_bytes = urlparse.urlunparse( ("", "", path_bytes, param_bytes, query_bytes, "") @@ -180,7 +184,9 @@ class MatrixFederationHttpClient(object): ) if retries_left and not timeout: - yield sleep(2 ** (5 - retries_left)) + delay = 5 ** (MAX_RETRIES + 1 - retries_left) + delay *= random.uniform(0.8, 1.4) + yield sleep(delay) retries_left -= 1 else: raise |