Periodically update heartbeat.
(self)
| 280 | pass |
| 281 | |
| 282 | async def _heartbeat_loop(self): |
| 283 | """Periodically update heartbeat.""" |
| 284 | while self.alive: |
| 285 | self.notify() |
| 286 | await asyncio.sleep(self.cfg.dirty_timeout / 2.0) |
| 287 | |
| 288 | async def handle_connection(self, reader, writer): |
| 289 | """ |