Cancel any concurrent hello check. Note: this is called from a weakref.proxy callback and MUST NOT take any locks.
(self)
| 167 | self._stream = not _is_faas() |
| 168 | |
| 169 | def cancel_check(self) -> None: |
| 170 | """Cancel any concurrent hello check. |
| 171 | |
| 172 | Note: this is called from a weakref.proxy callback and MUST NOT take |
| 173 | any locks. |
| 174 | """ |
| 175 | context = self._cancel_context |
| 176 | if context: |
| 177 | # Note: we cannot close the socket because doing so may cause |
| 178 | # concurrent reads/writes to hang until a timeout occurs |
| 179 | # (depending on the platform). |
| 180 | context.cancel() |
| 181 | |
| 182 | def _start_rtt_monitor(self) -> None: |
| 183 | """Start an _RttMonitor that periodically runs ping.""" |
no test coverage detected