(self, sock)
| 273 | return |
| 274 | |
| 275 | def callback(self, sock): |
| 276 | try: |
| 277 | data, peer = sock.recvfrom(4096) |
| 278 | except socket.error: |
| 279 | _, e = sys.exc_info()[:2] |
| 280 | log('UDP recv from %r port %d: %s' % (peer[0], peer[1], e)) |
| 281 | return |
| 282 | debug2('UDP response: %d bytes' % len(data)) |
| 283 | hdr = b("%s,%r," % (peer[0], peer[1])) |
| 284 | self.mux.send(self.chan, ssnet.CMD_UDP_DATA, hdr + data) |
| 285 | |
| 286 | |
| 287 | def main(latency_control, latency_buffer_size, auto_hosts, to_nameserver, |