summary refs log tree commit diff
path: root/synapse/http/matrixfederationclient.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2022-04-20 17:59:16 +0100
committerErik Johnston <erik@matrix.org>2022-04-21 11:49:51 +0100
commite16ec8f804342061d16c44f923b2993bb8603514 (patch)
tree54b95752a9e6da49c6785aff1ad240328b9825e7 /synapse/http/matrixfederationclient.py
parentReduce default max retry times (diff)
downloadsynapse-e16ec8f804342061d16c44f923b2993bb8603514.tar.xz
Mark remote server as up when we can talk to it
Diffstat (limited to '')
-rw-r--r--synapse/http/matrixfederationclient.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/synapse/http/matrixfederationclient.py b/synapse/http/matrixfederationclient.py

index df99c53041..29d341835a 100644 --- a/synapse/http/matrixfederationclient.py +++ b/synapse/http/matrixfederationclient.py
@@ -358,6 +358,9 @@ class MatrixFederationHttpClient: self._sleeper = AwakenableSleeper(self.reactor) + self._notifier = hs.get_notifier() + self._replication_client = hs.get_replication_command_handler() + def wake_destination(self, destination: str) -> None: """Called when the remote server may have come back online.""" @@ -484,6 +487,8 @@ class MatrixFederationHttpClient: self._store, backoff_on_404=backoff_on_404, ignore_backoff=ignore_backoff, + notifier=self._notifier, + replication_client=self._replication_client, ) method_bytes = request.method.encode("ascii")