Add read ready flag to log check. (#46)

Author: doru1004

rayvens/core/invocation.py

@@ -165,6 +165,9 @@ def _check_kamel_output(self,
             # Start thread analyzing logs:
             reading_thread.start()
 
+            # Initiate the first read:
+            reading_thread.read_flag.set()
+
         success = False
         while True:
             # Log progress of kamel subprocess:
@@ -194,12 +197,14 @@ def _check_kamel_output(self,
                 countdown -= 1
                 if countdown == 0:
                     break
+                reading_thread.read_flag.set()
                 time.sleep(0.01)
 
         # Terminate log thread:
         if with_timeout:
             reading_thread.stop_flag.set()
-            reading_thread.join()
+            if success:
+                reading_thread.join()
 
         return success
 

rayvens/core/utils.py

@@ -16,7 +16,6 @@
 
 import os
 import random
-import time
 import threading
 from queue import Queue, Empty
 
@@ -86,14 +85,16 @@ class LogThread(threading.Thread):
     def __init__(self, stdout):
         threading.Thread.__init__(self)
         self.stop_flag = threading.Event()
+        self.read_flag = threading.Event()
         self.stdout = stdout
         self.queue = Queue()
 
     def run(self):
         while not self.stop_flag.is_set():
-            line = self.stdout.readline().decode("utf-8")
-            self.queue.put(line.strip())
-            time.sleep(0.1)
+            if self.read_flag.is_set():
+                line = self.stdout.readline().decode("utf-8")
+                self.queue.put(line.strip())
+                self.read_flag.clear()
 
         print("[Logging thread] Kamel command logging terminated.")