断开处理
This commit is contained in:
@@ -95,6 +95,7 @@ def remote_client_handler(tcp_remote:socket):
|
|||||||
break
|
break
|
||||||
tcp_remote.close()
|
tcp_remote.close()
|
||||||
print("proxy close")
|
print("proxy close")
|
||||||
|
close_all()
|
||||||
if _local_server is not None:
|
if _local_server is not None:
|
||||||
_local_server.close()
|
_local_server.close()
|
||||||
|
|
||||||
@@ -128,7 +129,10 @@ def local_client_handler(tcp_server:socket,addr):
|
|||||||
if(_remote_client is not None):
|
if(_remote_client is not None):
|
||||||
cmd={'device':'client','option':'disconnect','ip':addr[0],'port':addr[1]}
|
cmd={'device':'client','option':'disconnect','ip':addr[0],'port':addr[1]}
|
||||||
data=pc.encode(json.dumps(cmd).encode('utf-8'),b'default')
|
data=pc.encode(json.dumps(cmd).encode('utf-8'),b'default')
|
||||||
_remote_client.send(data)
|
try:
|
||||||
|
_remote_client.send(data)
|
||||||
|
except Exception as e:
|
||||||
|
print("remote close",str(e))
|
||||||
_local_client.remove(addr_info)
|
_local_client.remove(addr_info)
|
||||||
|
|
||||||
|
|
||||||
|
@@ -131,7 +131,7 @@ def remote_client_handler(tcp_client_1:socket):
|
|||||||
break
|
break
|
||||||
tcp_client_1.close()
|
tcp_client_1.close()
|
||||||
print("proxy close.")
|
print("proxy close.")
|
||||||
|
close_all()
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
|
Reference in New Issue
Block a user