(self)
| 772 | transp.resume_reading() |
| 773 | |
| 774 | def _close_self_pipe(self): |
| 775 | if self._self_reading_future is not None: |
| 776 | self._self_reading_future.cancel() |
| 777 | self._self_reading_future = None |
| 778 | self._ssock.close() |
| 779 | self._ssock = None |
| 780 | self._csock.close() |
| 781 | self._csock = None |
| 782 | self._internal_fds -= 1 |
| 783 | |
| 784 | def _make_self_pipe(self): |
| 785 | # A self-socket, really. :-) |