| Index: third_party/WebKit/Tools/Scripts/webkitpy/common/message_pool.py
|
| diff --git a/third_party/WebKit/Tools/Scripts/webkitpy/common/message_pool.py b/third_party/WebKit/Tools/Scripts/webkitpy/common/message_pool.py
|
| index 2e8eb7db96110ee854ef14107e09dfec4d9920e5..98727b179403473a89c5fe150c5913b029f86e14 100644
|
| --- a/third_party/WebKit/Tools/Scripts/webkitpy/common/message_pool.py
|
| +++ b/third_party/WebKit/Tools/Scripts/webkitpy/common/message_pool.py
|
| @@ -62,6 +62,7 @@ def get(caller, worker_factory, num_workers, host=None):
|
|
|
|
|
| class _MessagePool(object):
|
| +
|
| def __init__(self, caller, worker_factory, num_workers, host=None):
|
| self._caller = caller
|
| self._worker_factory = worker_factory
|
| @@ -103,7 +104,8 @@ class _MessagePool(object):
|
| host = self._host
|
|
|
| for worker_number in xrange(self._num_workers):
|
| - worker = _Worker(host, self._messages_to_manager, self._messages_to_worker, self._worker_factory, worker_number, self._running_inline, self if self._running_inline else None, self._worker_log_level())
|
| + worker = _Worker(host, self._messages_to_manager, self._messages_to_worker, self._worker_factory,
|
| + worker_number, self._running_inline, self if self._running_inline else None, self._worker_log_level())
|
| self._workers.append(worker)
|
| worker.start()
|
|
|
| @@ -187,6 +189,7 @@ class WorkerException(BaseException):
|
|
|
|
|
| class _Message(object):
|
| +
|
| def __init__(self, src, message_name, message_args, from_user, logs):
|
| self.src = src
|
| self.name = message_name
|
| @@ -199,6 +202,7 @@ class _Message(object):
|
|
|
|
|
| class _Worker(multiprocessing.Process):
|
| +
|
| def __init__(self, host, messages_to_manager, messages_to_worker, worker_factory, worker_number, running_inline, manager, log_level):
|
| super(_Worker, self).__init__()
|
| self.host = host
|
| @@ -317,6 +321,7 @@ class _Worker(multiprocessing.Process):
|
|
|
|
|
| class _WorkerLogHandler(logging.Handler):
|
| +
|
| def __init__(self, worker):
|
| logging.Handler.__init__(self)
|
| self._worker = worker
|
|
|