(self)
| 181 | self.client.disconnect() |
| 182 | |
| 183 | def close(self): |
| 184 | self.queue.close() |
| 185 | self.disconnect_client() |
| 186 | global MGE_PLASMA_STORE_MANAGER |
| 187 | MGE_PLASMA_STORE_MANAGER.refcount -= 1 |
| 188 | _clear_plasma_store() |
| 189 | |
| 190 | def cancel_join_thread(self): |
| 191 | self.queue.cancel_join_thread() |