(self, config)
| 94 | self._relays[port] = (t, u) |
| 95 | |
| 96 | def remove_port(self, config): |
| 97 | port = int(config['server_port']) |
| 98 | servers = self._relays.get(port, None) |
| 99 | if servers: |
| 100 | logging.info("removing server at %s:%d" % (config['server'], port)) |
| 101 | t, u = servers |
| 102 | t.close(next_tick=False) |
| 103 | u.close(next_tick=False) |
| 104 | del self._relays[port] |
| 105 | else: |
| 106 | logging.error("server not exist at %s:%d" % (config['server'], |
| 107 | port)) |
| 108 | |
| 109 | def handle_event(self, sock, fd, event): |
| 110 | if sock == self._control_socket and event == eventloop.POLL_IN: |
no test coverage detected