Update fifo.py

manatlan · Jun 3, 2024 · d456af3 · d456af3
1 parent f59d16a
commit d456af3
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/htagweb/fifo.py b/htagweb/fifo.py
@@ -68,7 +68,10 @@ async def com(self,command:str,**args) -> "str|dict":  # for client only
             frame = await fifo_in.readline()
 
             #print("Client receive:",frame)
-            c = json.loads(frame.strip())
+            try:
+                c = json.loads(frame.strip())
+            except Exception:
+                raise Exception(f"com error : {frame}")
             return c["response"]
 
 
@@ -87,4 +90,4 @@ def destroy(self):
                     os.kill(int(fid.readline().strip()),9)
                 except ProcessLookupError:
                     pass
-        self.removePipes()
+        self.removePipes()