put creation of worker in its own class so we can pass custom workers to

it.
This commit is contained in:
benoitc 2010-03-11 14:29:20 +01:00
parent f75a413773
commit 5bb0734532
2 changed files with 5 additions and 3 deletions

View File

@ -344,6 +344,9 @@ class Arbiter(object):
if worker.age < age:
pid, age = wpid, worker.age
self.kill_worker(pid, signal.SIGQUIT)
def init_worker(self, worker_age, pid, listener, app, timeout, conf):
return Worker(worker_age, pid, listener, app, timeout, conf)
def spawn_workers(self):
"""\
@ -355,8 +358,8 @@ class Arbiter(object):
for i in range(self.num_workers - len(self.WORKERS.keys())):
self.worker_age += 1
worker = Worker(self.worker_age, self.pid, self.LISTENER, self.app,
self.timeout/2.0, self.conf)
worker = self.init_worker(self.worker_age, self.pid, self.LISTENER,
self.app, self.timeout/2.0, self.conf)
self.conf.before_fork(self, worker)
pid = os.fork()
if pid != 0:

View File

@ -93,7 +93,6 @@ class Worker(object):
util.close_on_exec(self.socket)
util.close_on_exec(self.fd)
self.init_signals()
def accept(self):
try: