maxmustermann/synapse
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

add some limiting

Browse source
This commit is contained in:
Amber H. Brown 2019-06-24 04:24:32 +10:00
parent 6cda36777b
commit 9abaa52ac1
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
synapse/http/federation/matrix_federation_agent.py
View file

@ -107,6 +107,7 @@ class MatrixFederationAgent(object):
Agent(self._reactor, pool=self._pool, **agent_args)
)
self._well_known_agent = _well_known_agent
self._well_known_limiter = defer.DeferredSemaphore(50)
# our cache of .well-known lookup results, mapping from server name
# to delegated name. The values can be:
@ -306,6 +307,9 @@ class MatrixFederationAgent(object):
try:
result = self._well_known_cache[server_name]
except KeyError:
yield make_deferred_yieldable(self._well_known_limiter.acquire())
# TODO: should we linearise so that we don't end up doing two .well-known
# requests for the same server in parallel?
with Measure(self._clock, "get_well_known"):
@ -314,6 +318,8 @@ class MatrixFederationAgent(object):
if cache_period > 0:
self._well_known_cache.set(server_name, result, cache_period)
self._well_known_limiter.release()
defer.returnValue(result)
@defer.inlineCallbacks