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 |