(channel, data)
| 392 | del mux.channels[channel] |
| 393 | |
| 394 | def udp_open(channel, data): |
| 395 | debug2('Incoming UDP open.') |
| 396 | family = int(data) |
| 397 | mux.channels[channel] = lambda cmd, data: udp_req(channel, cmd, |
| 398 | data) |
| 399 | if channel in udphandlers: |
| 400 | raise Fatal('UDP connection channel %d already open' % |
| 401 | channel) |
| 402 | else: |
| 403 | h = UdpProxy(mux, channel, family) |
| 404 | handlers.append(h) |
| 405 | udphandlers[channel] = h |
| 406 | mux.got_udp_open = udp_open |
| 407 | |
| 408 | while mux.ok: |