|
Lines 231-237
class Process(object):
Tools/Scripts/libraries/webkitcorepy/webkitcorepy/task_pool.py_sec1
|
| 231 |
cls.working = False |
231 |
cls.working = False |
| 232 |
|
232 |
|
| 233 |
@classmethod |
233 |
@classmethod |
| 234 |
def main(cls, name, setup, setupargs, setupkwargs, queue, teardown, teardownargs, teardownkwargs): |
234 |
def main(cls, name, loglevel, setup, setupargs, setupkwargs, queue, teardown, teardownargs, teardownkwargs): |
| 235 |
from tblib import pickling_support |
235 |
from tblib import pickling_support |
| 236 |
|
236 |
|
| 237 |
cls.name = name |
237 |
cls.name = name |
|
Lines 250-255
class Process(object):
Tools/Scripts/libraries/webkitcorepy/webkitcorepy/task_pool.py_sec2
|
| 250 |
for handler in logger.handlers: |
250 |
for handler in logger.handlers: |
| 251 |
logger.removeHandler(handler) |
251 |
logger.removeHandler(handler) |
| 252 |
logger.addHandler(cls.LogHandler(queue)) |
252 |
logger.addHandler(cls.LogHandler(queue)) |
|
|
253 |
logger.setLevel(loglevel) |
| 253 |
|
254 |
|
| 254 |
queue.send(State(State.STARTING)) |
255 |
queue.send(State(State.STARTING)) |
| 255 |
|
256 |
|
|
Lines 304-310
class TaskPool(object):
Tools/Scripts/libraries/webkitcorepy/webkitcorepy/task_pool.py_sec3
|
| 304 |
self.workers = [multiprocessing.Process( |
305 |
self.workers = [multiprocessing.Process( |
| 305 |
target=Process.main, |
306 |
target=Process.main, |
| 306 |
args=( |
307 |
args=( |
| 307 |
'{}/{}'.format(name, count), |
308 |
'{}/{}'.format(name, count), logging.getLogger().getEffectiveLevel(), |
| 308 |
setup, setupargs, setupkwargs, |
309 |
setup, setupargs, setupkwargs, |
| 309 |
BiDirectionalQueue(outgoing=self.queue.incoming, incoming=self.queue.outgoing), |
310 |
BiDirectionalQueue(outgoing=self.queue.incoming, incoming=self.queue.outgoing), |
| 310 |
teardown, teardownargs, teardownkwargs, |
311 |
teardown, teardownargs, teardownkwargs, |