(self)
| 396 | self._startup_time = time.monotonic() |
| 397 | |
| 398 | async def _run(self) -> None: |
| 399 | # Don't poll right after creation, wait 60 seconds first |
| 400 | if time.monotonic() < self._startup_time + common.MIN_SRV_RESCAN_INTERVAL: |
| 401 | return |
| 402 | seedlist = await self._get_seedlist() |
| 403 | if seedlist: |
| 404 | self._seedlist = seedlist |
| 405 | try: |
| 406 | await self._topology.on_srv_update(self._seedlist) |
| 407 | except ReferenceError: |
| 408 | # Topology was garbage-collected. |
| 409 | await self.close() |
| 410 | |
| 411 | async def _get_seedlist(self) -> Optional[list[tuple[str, Any]]]: |
| 412 | """Poll SRV records for a seedlist. |
nothing calls this directly
no test coverage detected