diff options
author | Matthew Hodgson <matthew@matrix.org> | 2016-12-31 15:21:37 +0000 |
---|---|---|
committer | Mark Haines <mark.haines@matrix.org> | 2017-01-05 11:58:15 +0000 |
commit | eedf400d05ba72c2c21b55a64f67104af54e90bd (patch) | |
tree | 3c26480ce115e46e6f360bdfaf4e17cf572ef1e5 /synapse/federation/federation_client.py | |
parent | Merge pull request #1764 from matrix-org/markjh/fix_send_pdu (diff) | |
download | synapse-eedf400d05ba72c2c21b55a64f67104af54e90bd.tar.xz |
limit total timeout for get_missing_events to 10s
Diffstat (limited to 'synapse/federation/federation_client.py')
-rw-r--r-- | synapse/federation/federation_client.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/synapse/federation/federation_client.py b/synapse/federation/federation_client.py index 6851f2376d..b4bcec77ed 100644 --- a/synapse/federation/federation_client.py +++ b/synapse/federation/federation_client.py @@ -707,7 +707,7 @@ class FederationClient(FederationBase): @defer.inlineCallbacks def get_missing_events(self, destination, room_id, earliest_events_ids, - latest_events, limit, min_depth): + latest_events, limit, min_depth, timeout): """Tries to fetch events we are missing. This is called when we receive an event without having received all of its ancestors. @@ -721,6 +721,7 @@ class FederationClient(FederationBase): have all previous events for. limit (int): Maximum number of events to return. min_depth (int): Minimum depth of events tor return. + timeout (int): Max time to wait in ms """ try: content = yield self.transport_layer.get_missing_events( @@ -730,6 +731,7 @@ class FederationClient(FederationBase): latest_events=[e.event_id for e in latest_events], limit=limit, min_depth=min_depth, + timeout=timeout, ) events = [ |