| 711 | for room in list(self._rdma_buffers.keys()): |
| 712 | self.remove(room) |
| 713 | self.reporter.stop() |
| 714 | if self._reporter_thread is not None and self._reporter_thread.is_alive(): |
| 715 | self._reporter_thread.join(timeout=1.0) |
| 716 | self._reporter_thread = None |
| 717 | if self.data_mgr is not None: |
| 718 | self.data_mgr.release() |
| 719 | self.data_sender.clear() |
| 720 | self.text_encoder = None |
| 721 | self.image_encoder = None |
| 722 | self.vae_encoder = None |
| 723 | |
| 724 | def run(self, stop_event=None): |
| 725 | req_queue = deque() |
| 726 | exec_queue = deque() |
| 727 | complete_queue: set[int] = set() |
| 728 | |