| 545 | return '<{}>'.format(' '.join(info)) |
| 546 | |
| 547 | def _read_ready(self): |
| 548 | try: |
| 549 | data = os.read(self._fileno, self.max_size) |
| 550 | except (BlockingIOError, InterruptedError): |
| 551 | pass |
| 552 | except OSError as exc: |
| 553 | self._fatal_error(exc, 'Fatal read error on pipe transport') |
| 554 | else: |
| 555 | if data: |
| 556 | self._protocol.data_received(data) |
| 557 | else: |
| 558 | if self._loop.get_debug(): |
| 559 | logger.info("%r was closed by peer", self) |
| 560 | self._closing = True |
| 561 | self._loop._remove_reader(self._fileno) |
| 562 | self._loop.call_soon(self._protocol.eof_received) |
| 563 | self._loop.call_soon(self._call_connection_lost, None) |
| 564 | |
| 565 | def pause_reading(self): |
| 566 | if not self.is_reading(): |