Matrix-Mirrors/synapse-product
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse-product.git synced 2024-12-24 11:49:21 -05:00
Code Issues Packages Projects Releases Wiki Activity

Add a lower bound for TTL on well known results.

Browse Source 
It costs both us and the remote server for us to fetch the well known
for every single request we send, so we add a minimum cache period. This
is set to 5m so that we still honour the basic premise of "refetch
frequently".
This commit is contained in:
Erik Johnston 2019-08-06 16:27:46 +01:00
parent d1b5b055be
commit af9f1c0764
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
synapse/http/federation/matrix_federation_agent.py
View File

@ -47,6 +47,9 @@ WELL_KNOWN_INVALID_CACHE_PERIOD = 1 * 3600
# cap for .well-known cache period # cap for .well-known cache period
WELL_KNOWN_MAX_CACHE_PERIOD = 48 * 3600 WELL_KNOWN_MAX_CACHE_PERIOD = 48 * 3600
# lower bound for .well-known cache period
WELL_KNOWN_MIN_CACHE_PERIOD = 5 * 60
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
well_known_cache = TTLCache("well-known") well_known_cache = TTLCache("well-known")
@ -356,6 +359,7 @@ class MatrixFederationAgent(object):
cache_period += random.uniform(0, WELL_KNOWN_DEFAULT_CACHE_PERIOD_JITTER) cache_period += random.uniform(0, WELL_KNOWN_DEFAULT_CACHE_PERIOD_JITTER)
else: else:
cache_period = min(cache_period, WELL_KNOWN_MAX_CACHE_PERIOD) cache_period = min(cache_period, WELL_KNOWN_MAX_CACHE_PERIOD)
cache_period = max(cache_period, WELL_KNOWN_MIN_CACHE_PERIOD)
return (result, cache_period) return (result, cache_period)

4
tests/http/federation/test_matrix_federation_agent.py
View File

@ -953,7 +953,7 @@ class MatrixFederationAgentTests(TestCase):
well_known_server = self._handle_well_known_connection( well_known_server = self._handle_well_known_connection(
client_factory, client_factory,
expected_sni=b"testserv", expected_sni=b"testserv",
response_headers={b"Cache-Control": b"max-age=10"}, response_headers={b"Cache-Control": b"max-age=1000"},
content=b'{ "m.server": "target-server" }', content=b'{ "m.server": "target-server" }',
) )
@ -969,7 +969,7 @@ class MatrixFederationAgentTests(TestCase):
self.assertEqual(r, b"target-server") self.assertEqual(r, b"target-server")
# expire the cache # expire the cache
self.reactor.pump((10.0,)) self.reactor.pump((1000.0,))
# now it should connect again # now it should connect again
fetch_d = self.do_get_well_known(b"testserv") fetch_d = self.do_get_well_known(b"testserv")