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

Revert "Revert "simplify dissconnect logic". The idea with task cancelation doesn't work"

Browse Source 
This reverts commit 32d3bffc7b.
This commit is contained in:
Alexander Bersenev
2018-06-27 11:11:50 +05:00
parent d74bb68f03
commit 2e86308e90
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
mtprotoproxy.py
View File

@@ -803,7 +803,6 @@ async def handle_client(reader_clt, writer_clt):
if not data: if not data:
wr.write_eof() wr.write_eof()
await wr.drain() await wr.drain()
wr.close()
return return
else: else:
update_stats(user, octets=len(data)) update_stats(user, octets=len(data))
@@ -812,8 +811,6 @@ async def handle_client(reader_clt, writer_clt):
except (OSError, asyncio.streams.IncompleteReadError) as e: except (OSError, asyncio.streams.IncompleteReadError) as e:
# print_err(e) # print_err(e)
pass pass
finally:
wr.transport.abort()
task_tg_to_clt = asyncio.ensure_future(connect_reader_to_writer(reader_tg, writer_clt, user)) task_tg_to_clt = asyncio.ensure_future(connect_reader_to_writer(reader_tg, writer_clt, user))
task_clt_to_tg = asyncio.ensure_future(connect_reader_to_writer(reader_clt, writer_tg, user)) task_clt_to_tg = asyncio.ensure_future(connect_reader_to_writer(reader_clt, writer_tg, user))