mirror of
https://github.com/frappe/gunicorn.git
synced 2026-01-14 11:09:11 +08:00
refactor paster entry point to use Config object.
This commit is contained in:
parent
b3341e3cbc
commit
443a6c8363
@ -154,40 +154,27 @@ def paste_server(app, global_conf=None, host="127.0.0.1", port=None,
|
|||||||
port = 5000
|
port = 5000
|
||||||
|
|
||||||
"""
|
"""
|
||||||
|
options = kwargs.copy()
|
||||||
|
if port and not host.startswith("unix:"):
|
||||||
|
bind = "%s:%s" % (host, port)
|
||||||
|
else:
|
||||||
|
bind = host
|
||||||
|
options['bind'] = bind
|
||||||
|
|
||||||
bind_addr = util.parse_address(util.to_bytestring(host), port)
|
|
||||||
|
|
||||||
# set others options
|
|
||||||
debug = kwargs.get('debug')
|
|
||||||
workers = kwargs.get("workers", 1)
|
|
||||||
pid = kwargs.get("pid")
|
|
||||||
daemon = kwargs.get("daemon")
|
|
||||||
umask = kwargs.get('umask', UMASK)
|
|
||||||
user = kwargs.get('user')
|
|
||||||
group = kwargs.get('group')
|
|
||||||
if global_conf:
|
if global_conf:
|
||||||
workers = int(global_conf.get('workers', workers))
|
for key, value in list(global_conf.items()):
|
||||||
debug = global_conf.get('debug', debug) == "true"
|
if value and value is not None:
|
||||||
if debug:
|
options[key] = value
|
||||||
# we force to one worker in debug mode.
|
|
||||||
workers = 1
|
conf = Config(options)
|
||||||
pid = global_conf.get('pid', pid)
|
arbiter = Arbiter(conf.address, conf.workers, app, debug=conf["debug"],
|
||||||
daemon = global_conf.get('daemon', daemonize)
|
pidfile=pidfile=conf["pidfile"], config=conf)
|
||||||
umask = global_conf.get('umask', umask)
|
if conf["daemon"] :
|
||||||
user = global_conf.get('user', user)
|
daemonize(conf["umask"])
|
||||||
group = global_conf.get('group', group)
|
|
||||||
|
|
||||||
kwargs = dict(
|
|
||||||
debug=debug,
|
|
||||||
pidfile=pid
|
|
||||||
)
|
|
||||||
|
|
||||||
arbiter = Arbiter(bind_addr, workers, app, **kwargs)
|
|
||||||
if daemon == "true":
|
|
||||||
daemonize(umask)
|
|
||||||
else:
|
else:
|
||||||
os.setpgrp()
|
os.setpgrp()
|
||||||
set_owner_process(user, group)
|
set_owner_process(conf["user"], conf["group"])
|
||||||
|
configure_logging(conf)
|
||||||
arbiter.run()
|
arbiter.run()
|
||||||
|
|
||||||
def run():
|
def run():
|
||||||
|
|||||||
@ -47,7 +47,6 @@ class Command(BaseCommand):
|
|||||||
if args:
|
if args:
|
||||||
raise CommandError('Usage is runserver %s' % self.args)
|
raise CommandError('Usage is runserver %s' % self.args)
|
||||||
|
|
||||||
|
|
||||||
options['bind'] = addrport or '127.0.0.1'
|
options['bind'] = addrport or '127.0.0.1'
|
||||||
conf = Config(options)
|
conf = Config(options)
|
||||||
|
|
||||||
@ -57,8 +56,6 @@ class Command(BaseCommand):
|
|||||||
print "Validating models..."
|
print "Validating models..."
|
||||||
self.validate(display_num_errors=True)
|
self.validate(display_num_errors=True)
|
||||||
print "\nDjango version %s, using settings %r" % (django.get_version(), settings.SETTINGS_MODULE)
|
print "\nDjango version %s, using settings %r" % (django.get_version(), settings.SETTINGS_MODULE)
|
||||||
|
|
||||||
|
|
||||||
print "Development server is running at %s" % str(conf.address)
|
print "Development server is running at %s" % str(conf.address)
|
||||||
print "Quit the server with %s." % quit_command
|
print "Quit the server with %s." % quit_command
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user