(self)
| 331 | self.data_mgr.remove(room) |
| 332 | |
| 333 | def release(self): |
| 334 | for room in list(self._rdma_buffers.keys()): |
| 335 | self.remove(room) |
| 336 | self.reporter.stop() |
| 337 | if self._reporter_thread is not None and self._reporter_thread.is_alive(): |
| 338 | self._reporter_thread.join(timeout=1.0) |
| 339 | self._reporter_thread = None |
| 340 | if self.data_mgr is not None: |
| 341 | self.data_mgr.release() |
| 342 | self.data_receiver.clear() |
| 343 | self.vae_decoder = None |
| 344 | |
| 345 | def run(self, stop_event=None): |
| 346 | req_queue = deque() |