@@ -291,22 +291,22 @@ def onaccept(listener_sock):
291
291
292
292
dnsreqs = {}
293
293
def dns_done (chan , data ):
294
- peer ,timeout = dnsreqs .get (chan ) or (None ,None )
294
+ peer ,sock , timeout = dnsreqs .get (chan ) or (None , None ,None )
295
295
debug3 ('dns_done: channel=%r peer=%r\n ' % (chan , peer ))
296
296
if peer :
297
297
del dnsreqs [chan ]
298
298
debug3 ('doing sendto %r\n ' % (peer ,))
299
- dnslistener .sendto (data , peer )
299
+ sock .sendto (data , peer )
300
300
def ondns (listener_sock ):
301
301
pkt ,peer = listener_sock .recvfrom (4096 )
302
302
now = time .time ()
303
303
if pkt :
304
304
debug1 ('DNS request from %r: %d bytes\n ' % (peer , len (pkt )))
305
305
chan = mux .next_channel ()
306
- dnsreqs [chan ] = peer ,now + 30
306
+ dnsreqs [chan ] = peer ,listener_sock , now + 30
307
307
mux .send (chan , ssnet .CMD_DNS_REQ , pkt )
308
308
mux .channels [chan ] = lambda cmd ,data : dns_done (chan ,data )
309
- for chan ,(peer ,timeout ) in dnsreqs .items ():
309
+ for chan ,(peer ,sock , timeout ) in dnsreqs .items ():
310
310
if timeout < now :
311
311
del dnsreqs [chan ]
312
312
debug3 ('Remaining DNS requests: %d\n ' % len (dnsreqs ))
0 commit comments