gandc/mtprotoproxy
1
0
Fork 0
mirror of https://github.com/alexbers/mtprotoproxy.git synced 2026-03-14 07:13:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

copy the way how the mask server closes the tcp connection to the client

Browse Source
This commit is contained in:
Alexander Bersenev
2019-08-18 21:59:33 +05:00
parent 4169e6acab
commit 9dc8521c18
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
mtprotoproxy.py
View File

@@ -799,7 +799,6 @@ async def handle_bad_client(reader_clt, writer_clt, handshake):
BUF_SIZE = 8192
CONNECT_TIMEOUT = 5
set_instant_rst(writer_clt.get_extra_info("socket"))
set_bufsizes(writer_clt.get_extra_info("socket"), BUF_SIZE, BUF_SIZE)
if not config.MASK or handshake is None:
@@ -844,6 +843,20 @@ async def handle_bad_client(reader_clt, writer_clt, handshake):
task_srv_to_clt.cancel()
task_clt_to_srv.cancel()
# if the server closed the connection with RST or FIN-RST, copy them to the client
if not writer_srv.transport.is_closing():
# workaround for uvloop, it doesn't fire exceptions on write_eof
srv_sock = writer_srv.get_extra_info('socket')
raw_sock = socket.socket(srv_sock.family, srv_sock.type, srv_sock.proto, srv_sock.fileno())
try:
raw_sock.shutdown(socket.SHUT_WR)
except OSError as E:
set_instant_rst(writer_clt.get_extra_info("socket"))
finally:
raw_sock.detach()
else:
set_instant_rst(writer_clt.get_extra_info("socket"))
writer_srv.transport.abort()