Vasanko/sanic
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #506 from zenixls2/bugfix/bind-listener

Browse Source 
special handling when sock is provided and number of workers > 1
This commit is contained in:
Eli Uriegas 2017-03-02 09:08:59 -06:00 committed by GitHub
commit 5aed18862d
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
sanic/server.py
View File

@ -396,13 +396,15 @@ def serve_multiple(server_settings, workers, stop_event=None):
" has more information.", DeprecationWarning) " has more information.", DeprecationWarning)
server_settings['reuse_port'] = True server_settings['reuse_port'] = True
sock = socket() # Handling when custom socket is not provided.
sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) if server_settings.get('sock') is None:
sock.bind((server_settings['host'], server_settings['port'])) sock = socket()
set_inheritable(sock.fileno(), True) sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
server_settings['sock'] = sock sock.bind((server_settings['host'], server_settings['port']))
server_settings['host'] = None set_inheritable(sock.fileno(), True)
server_settings['port'] = None server_settings['sock'] = sock
server_settings['host'] = None
server_settings['port'] = None
if stop_event is None: if stop_event is None:
stop_event = Event() stop_event = Event()
@ -423,6 +425,6 @@ def serve_multiple(server_settings, workers, stop_event=None):
# the above processes will block this until they're stopped # the above processes will block this until they're stopped
for process in processes: for process in processes:
process.terminate() process.terminate()
sock.close() server_settings.get('sock').close()
asyncio.get_event_loop().stop() asyncio.get_event_loop().stop()