Run a "hello" command and return the RTT.
(self)
| 489 | self._pool.reset() |
| 490 | |
| 491 | def _ping(self) -> float: |
| 492 | """Run a "hello" command and return the RTT.""" |
| 493 | with self._pool.checkout() as conn: |
| 494 | if self._executor._stopped: |
| 495 | raise Exception("_RttMonitor closed") |
| 496 | start = time.monotonic() |
| 497 | conn.hello() |
| 498 | return _monotonic_duration(start) |
| 499 | |
| 500 | |
| 501 | # Close monitors to cancel any in progress streaming checks before joining |
no test coverage detected