Lines Matching refs:pipe
81 return '<pipe>'
488 def _make_read_pipe_transport(self, pipe, protocol, waiter=None,
490 """Create read pipe transport."""
493 def _make_write_pipe_transport(self, pipe, protocol, waiter=None,
495 """Create write pipe transport."""
505 """Write a byte to self-pipe, to wake up the event loop.
509 The subclass is responsible for implementing the self-pipe.
1586 async def connect_read_pipe(self, protocol_factory, pipe):
1589 transport = self._make_read_pipe_transport(pipe, protocol, waiter)
1598 logger.debug('Read pipe %r connected: (%r, %r)',
1599 pipe.fileno(), transport, protocol)
1602 async def connect_write_pipe(self, protocol_factory, pipe):
1605 transport = self._make_write_pipe_transport(pipe, protocol, waiter)
1614 logger.debug('Write pipe %r connected: (%r, %r)',
1615 pipe.fileno(), transport, protocol)