Lines Matching refs:_pipe
31 return self._logger._pipe[1]
40 self._pipe = list(os.pipe())
46 if self._pipe[1] != _PIPE_CLOSED:
47 os.close(self._pipe[1])
48 self._pipe[1] = _PIPE_CLOSED
59 self._pipe = list(os.pipe())
68 rlist = [l._pipe[0] for l in self._loggers]
69 rlist.append(self._pipe[0])
72 if r != self._pipe[0]:
77 os.close(self._pipe[0])
79 os.close(logger._pipe[0])
83 logger = next(l for l in self._loggers if l._pipe[0] == r)
86 os.close(logger._pipe[0])
102 os.write(self._pipe[1], '\0')
108 if self._pipe[1] != _PIPE_CLOSED:
109 os.close(self._pipe[1])
110 self._pipe[1] = _PIPE_CLOSED
