Lines Matching refs:_worker
107 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())
204 class _Worker(multiprocessing.Process):
206 super(_Worker, self).__init__()
217 self._worker = worker_factory(self)
222 if self._worker:
223 if hasattr(self._worker, 'stop'):
224 self._worker.stop()
225 self._worker = None
227 super(_Worker, self).terminate()
237 super(_Worker, self).start()
245 worker = self._worker
320 self._worker = worker
324 self._worker.log_messages.append(record)
