(self)
| 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(): |
no test coverage detected