summary refs log tree commit diff
path: root/synapse/server.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-09-22 10:11:01 +0100
committerErik Johnston <erik@matrix.org>2020-09-22 10:11:01 +0100
commit7b6f857aa996ec4dde368e11115bf1684770d78f (patch)
tree1ccb99d237dddda41c92811d023216c7eda19dc4 /synapse/server.py
parentIntelligently select extremities used in backfill. (#8349) (diff)
parentAdd a note about including the changes from 1.19.3. (diff)
downloadsynapse-7b6f857aa996ec4dde368e11115bf1684770d78f.tar.xz
Merge remote-tracking branch 'origin/release-v1.20.0' into matrix-org-hotfixes
Diffstat (limited to 'synapse/server.py')
-rw-r--r--synapse/server.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/server.py b/synapse/server.py

index 9055b97ac3..5e3752c333 100644 --- a/synapse/server.py +++ b/synapse/server.py
@@ -114,6 +114,7 @@ from synapse.streams.events import EventSources from synapse.types import DomainSpecificString from synapse.util import Clock from synapse.util.distributor import Distributor +from synapse.util.ratelimitutils import FederationRateLimiter from synapse.util.stringutils import random_string logger = logging.getLogger(__name__) @@ -642,6 +643,10 @@ class HomeServer(metaclass=abc.ABCMeta): def get_replication_streams(self) -> Dict[str, Stream]: return {stream.NAME: stream(self) for stream in STREAMS_MAP.values()} + @cache_in_self + def get_federation_ratelimiter(self) -> FederationRateLimiter: + return FederationRateLimiter(self.clock, config=self.config.rc_federation) + async def remove_pusher(self, app_id: str, push_key: str, user_id: str): return await self.get_pusherpool().remove_pusher(app_id, push_key, user_id)