Wake all monitors, wait for at least one to check its server.
(self, wait_time: int = 5)
| 684 | self._receive_cluster_time_no_lock(cluster_time) |
| 685 | |
| 686 | async def request_check_all(self, wait_time: int = 5) -> None: |
| 687 | """Wake all monitors, wait for at least one to check its server.""" |
| 688 | async with self._lock: |
| 689 | self._request_check_all() |
| 690 | await _async_cond_wait(self._condition, wait_time) |
| 691 | |
| 692 | def data_bearing_servers(self) -> list[ServerDescription]: |
| 693 | """Return a list of all data-bearing servers. |
nothing calls this directly
no test coverage detected