From 3cebab40c8ce475e2ddb59222e6e6c28ded3d465 Mon Sep 17 00:00:00 2001
From: Stefan Allius <stefan.allius@t-online.de>
Date: Sun, 16 Jun 2024 13:26:05 +0200
Subject: [PATCH] add heaithy handler

---
 app/src/async_stream.py | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/app/src/async_stream.py b/app/src/async_stream.py
index 3deeb43..bd2352d 100644
--- a/app/src/async_stream.py
+++ b/app/src/async_stream.py
@@ -1,5 +1,6 @@
 import logging
 import traceback
+import time
 from asyncio import StreamReader, StreamWriter
 from messages import hex_dump_memory
 from typing import Self
@@ -117,6 +118,15 @@ class AsyncStream():
         logger.debug(f'AsyncStream.close() l{self.l_addr} | r{self.r_addr}')
         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
     '''