(self)
| 31 | self.kc = kc |
| 32 | |
| 33 | def run(self): |
| 34 | logger.info("Running message flusher...") |
| 35 | while True: |
| 36 | |
| 37 | if self.kill_sema.acquire(blocking=False): |
| 38 | logger.info("Sema was released to kill thread") |
| 39 | sys.exit() |
| 40 | |
| 41 | flush_kernel_msgs(self.kc) |
| 42 | time.sleep(1) |
| 43 | |
| 44 | |
| 45 | def cleanup_spawned_processes(): |
no test coverage detected