on close event
(self)
| 130 | self.close() |
| 131 | |
| 132 | def on_close_event(self): |
| 133 | """on close event""" |
| 134 | assert not self._done |
| 135 | logging.info("RPCProxy:on_close_event %s ...", self.name()) |
| 136 | if self.match_key: |
| 137 | key = self.match_key |
| 138 | if self._proxy._client_pool.get(key, None) == self: |
| 139 | self._proxy._client_pool.pop(key) |
| 140 | if self._proxy._server_pool.get(key, None) == self: |
| 141 | self._proxy._server_pool.pop(key) |
| 142 | self._done = True |
| 143 | self.forward_proxy = None |
| 144 | |
| 145 | |
| 146 | class TCPHandler(tornado_util.TCPHandler, ForwardHandler): |