mirror of
https://github.com/sshuttle/sshuttle.git
synced 2025-04-22 10:18:59 +02:00
Rename onaccept to onaccept_tcp as it is tcp specific.
This commit is contained in:
parent
97dca42291
commit
50c2b86f15
@ -185,7 +185,7 @@ def expire_connections(now, mux):
|
|||||||
debug3('Remaining DNS requests: %d\n' % len(dnsreqs))
|
debug3('Remaining DNS requests: %d\n' % len(dnsreqs))
|
||||||
|
|
||||||
|
|
||||||
def onaccept(listener, mux, handlers):
|
def onaccept_tcp(listener, mux, handlers):
|
||||||
global _extra_fd
|
global _extra_fd
|
||||||
try:
|
try:
|
||||||
sock,srcip = listener.accept()
|
sock,srcip = listener.accept()
|
||||||
@ -321,7 +321,7 @@ def _main(tcp_listener, fw, ssh_cmd, remotename, python, latency_control,
|
|||||||
fw.sethostip(name, ip)
|
fw.sethostip(name, ip)
|
||||||
mux.got_host_list = onhostlist
|
mux.got_host_list = onhostlist
|
||||||
|
|
||||||
handlers.append(Handler([tcp_listener], lambda: onaccept(tcp_listener, mux, handlers)))
|
handlers.append(Handler([tcp_listener], lambda: onaccept_tcp(tcp_listener, mux, handlers)))
|
||||||
|
|
||||||
if dns_listener:
|
if dns_listener:
|
||||||
handlers.append(Handler([dns_listener], lambda: ondns(dns_listener, mux, handlers)))
|
handlers.append(Handler([dns_listener], lambda: ondns(dns_listener, mux, handlers)))
|
||||||
|
Loading…
Reference in New Issue
Block a user