(self, room: int)
| 700 | self.release_memory(room) |
| 701 | |
| 702 | self.data_sender.pop(room, None) |
| 703 | self._data_mgr_sidecar.unwatch_output(room) |
| 704 | |
| 705 | if self.data_mgr is None: |
| 706 | return |
| 707 | |
| 708 | self.data_mgr.remove(room) |
| 709 | |
| 710 | def release(self): |
| 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(): |
no test coverage detected