|
|
|
@ -53,11 +53,8 @@ class TCPTransport: |
|
|
|
async def _alive_loop(self): |
|
|
|
try: |
|
|
|
while True: |
|
|
|
if self.writer: |
|
|
|
#logger.debug("Send alive", int(time() - self.socket_start)) |
|
|
|
self.writer.write(b"0") |
|
|
|
await self.writer.drain() |
|
|
|
await asyncio.sleep(1) |
|
|
|
await self.send(b"0") |
|
|
|
await asyncio.sleep(1) |
|
|
|
except asyncio.CancelledError: |
|
|
|
pass |
|
|
|
except: |
|
|
|
|