(self, transp, file, offset, count)
| 760 | file.seek(offset) |
| 761 | |
| 762 | async def _sendfile_native(self, transp, file, offset, count): |
| 763 | resume_reading = transp.is_reading() |
| 764 | transp.pause_reading() |
| 765 | await transp._make_empty_waiter() |
| 766 | try: |
| 767 | return await self.sock_sendfile(transp._sock, file, offset, count, |
| 768 | fallback=False) |
| 769 | finally: |
| 770 | transp._reset_empty_waiter() |
| 771 | if resume_reading: |
| 772 | transp.resume_reading() |
| 773 | |
| 774 | def _close_self_pipe(self): |
| 775 | if self._self_reading_future is not None: |
nothing calls this directly
no test coverage detected