| 42 | |
| 43 | |
| 44 | class FlushingThread(threading.Thread): |
| 45 | def __init__(self, kc, kill_sema): |
| 46 | threading.Thread.__init__(self) |
| 47 | self.kill_sema = kill_sema |
| 48 | self.kc = kc |
| 49 | |
| 50 | def run(self): |
| 51 | logger.info("Running message flusher...") |
| 52 | while True: |
| 53 | |
| 54 | if self.kill_sema.acquire(blocking=False): |
| 55 | logger.info("Sema was released to kill thread") |
| 56 | sys.exit() |
| 57 | |
| 58 | flush_kernel_msgs(self.kc) |
| 59 | time.sleep(1) |
| 60 | |
| 61 | |
| 62 | def cleanup_spawned_processes(): |