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

do not listen if listen addr is zero

Browse Source
This commit is contained in:
Alexander Bersenev
2019-07-19 15:46:34 +05:00
parent a2890cf213
commit 1c875e3d31
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
mtprotoproxy.py
View File

@@ -1350,11 +1350,12 @@ def main():
reuse_port = hasattr(socket, "SO_REUSEPORT") reuse_port = hasattr(socket, "SO_REUSEPORT")
task_v4 = asyncio.start_server(handle_client_wrapper, config.LISTEN_ADDR_IPV4, config.PORT, if config.LISTEN_ADDR_IPV4:
limit=get_to_tg_bufsize(), reuse_port=reuse_port, loop=loop) task_v4 = asyncio.start_server(handle_client_wrapper, config.LISTEN_ADDR_IPV4, config.PORT,
server_v4 = loop.run_until_complete(task_v4) limit=get_to_tg_bufsize(), reuse_port=reuse_port, loop=loop)
server_v4 = loop.run_until_complete(task_v4)
if socket.has_ipv6: if config.LISTEN_ADDR_IPV6 and socket.has_ipv6:
task_v6 = asyncio.start_server(handle_client_wrapper, config.LISTEN_ADDR_IPV6, config.PORT, task_v6 = asyncio.start_server(handle_client_wrapper, config.LISTEN_ADDR_IPV6, config.PORT,
limit=get_to_tg_bufsize(), reuse_port=reuse_port, loop=loop) limit=get_to_tg_bufsize(), reuse_port=reuse_port, loop=loop)
server_v6 = loop.run_until_complete(task_v6) server_v6 = loop.run_until_complete(task_v6)
@@ -1366,10 +1367,11 @@ def main():
stats_printer_task.cancel() stats_printer_task.cancel()
server_v4.close() if config.LISTEN_ADDR_IPV4:
loop.run_until_complete(server_v4.wait_closed()) server_v4.close()
loop.run_until_complete(server_v4.wait_closed())
if socket.has_ipv6: if config.LISTEN_ADDR_IPV6 and socket.has_ipv6:
server_v6.close() server_v6.close()
loop.run_until_complete(server_v6.wait_closed()) loop.run_until_complete(server_v6.wait_closed())