Lines Matching refs:_pipe
32 return self._logger._pipe[1]
41 self._pipe = list(os.pipe())
47 if self._pipe[1] != _PIPE_CLOSED:
48 os.close(self._pipe[1])
49 self._pipe[1] = _PIPE_CLOSED
60 self._pipe = list(os.pipe())
69 rlist = [l._pipe[0] for l in self._loggers]
70 rlist.append(self._pipe[0])
73 if r != self._pipe[0]:
78 os.close(self._pipe[0])
80 os.close(logger._pipe[0])
84 logger = next(l for l in self._loggers if l._pipe[0] == r)
87 os.close(logger._pipe[0])
103 os.write(self._pipe[1], '\0')
109 if self._pipe[1] != _PIPE_CLOSED:
110 os.close(self._pipe[1])
111 self._pipe[1] = _PIPE_CLOSED