add heaithy handler

This commit is contained in:
Stefan Allius
2024-06-16 13:26:05 +02:00
parent 4649beb075
commit 3cebab40c8

View File

@@ -1,5 +1,6 @@
import logging import logging
import traceback import traceback
import time
from asyncio import StreamReader, StreamWriter from asyncio import StreamReader, StreamWriter
from messages import hex_dump_memory from messages import hex_dump_memory
from typing import Self from typing import Self
@@ -117,6 +118,15 @@ class AsyncStream():
logger.debug(f'AsyncStream.close() l{self.l_addr} | r{self.r_addr}') logger.debug(f'AsyncStream.close() l{self.l_addr} | r{self.r_addr}')
self.writer.close() self.writer.close()
def healthy(self) -> bool:
elapsed = 0
if self.proc_start is not None:
elapsed = time.time() - self.proc_start
logging.info('async_stream healthy() elapsed: '
f'{round(1000*elapsed)}ms'
f' max:{round(1000*self.proc_max)}ms')
return elapsed < 5
''' '''
Our private methods Our private methods
''' '''