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

fix multiple worker problem

Browse Source
This commit is contained in:
Raphael Deem 2017-01-06 18:32:30 -08:00
parent d733c5bb7c
commit 77c04c4cf9
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
sanic/sanic.py
View File

@ -16,6 +16,8 @@ from .router import Router
from .server import serve, HttpProtocol from .server import serve, HttpProtocol
from .static import register as static_register from .static import register as static_register
from .exceptions import ServerError from .exceptions import ServerError
from socket import socket
from os import set_inheritable
class Sanic: class Sanic:
@ -350,19 +352,19 @@ class Sanic:
signal(SIGINT, lambda s, f: stop_event.set()) signal(SIGINT, lambda s, f: stop_event.set())
signal(SIGTERM, lambda s, f: stop_event.set()) signal(SIGTERM, lambda s, f: stop_event.set())
sock = socket()
sock.bind((server_settings['host'], server_settings['port']))
set_inheritable(sock.fileno(), True)
server_settings['sock'] = sock
server_settings['host'] = None
server_settings['port'] = None
processes = [] processes = []
for _ in range(workers): for _ in range(workers):
process = Process(target=serve, kwargs=server_settings) process = Process(target=serve, kwargs=server_settings)
process.start() process.start()
processes.append(process) processes.append(process)
# Infinitely wait for the stop event
try:
select(stop_event)
except:
pass
log.info('Spinning down workers...')
for process in processes: for process in processes:
process.terminate() process.terminate()
for process in processes: for process in processes: