(self)
| 363 | yield self._recv() |
| 364 | |
| 365 | def reset_state(self): |
| 366 | super(MultiProcessRunnerZMQ, self).reset_state() |
| 367 | self._guard = DataFlowReentrantGuard() |
| 368 | self.context = zmq.Context() |
| 369 | self.socket = self.context.socket(zmq.PULL) |
| 370 | self.socket.set_hwm(self._hwm) |
| 371 | pipename = _get_pipe_name('dataflow') |
| 372 | _bind_guard(self.socket, pipename) |
| 373 | |
| 374 | self._procs = [MultiProcessRunnerZMQ._Worker(self.ds, pipename, self._hwm, idx) |
| 375 | for idx in range(self.num_proc)] |
| 376 | self._start_processes() |
| 377 | |
| 378 | |
| 379 | class MultiThreadRunner(DataFlow): |
nothing calls this directly
no test coverage detected