(self)
| 3900 | self.assertEqual(self.server_buffer, self.DATA) |
| 3901 | |
| 3902 | async def test_send_at_certain_offset(self): |
| 3903 | # start sending a file at a certain offset |
| 3904 | total_sent = 0 |
| 3905 | offset = len(self.DATA) // 2 |
| 3906 | must_send = len(self.DATA) - offset |
| 3907 | nbytes = 4096 |
| 3908 | while total_sent < must_send: |
| 3909 | sent = await self.sendfile_wrapper(self.sockno, self.fileno, |
| 3910 | offset, nbytes) |
| 3911 | if sent == 0: |
| 3912 | break |
| 3913 | offset += sent |
| 3914 | total_sent += sent |
| 3915 | self.assertTrue(sent <= nbytes) |
| 3916 | |
| 3917 | self.client.shutdown(socket.SHUT_RDWR) |
| 3918 | self.client.close() |
| 3919 | await self.server.wait_closed() |
| 3920 | expected = self.DATA[len(self.DATA) // 2:] |
| 3921 | self.assertEqual(total_sent, len(expected)) |
| 3922 | self.assertEqual(len(self.server_buffer), len(expected)) |
| 3923 | self.assertEqual(self.server_buffer, expected) |
| 3924 | |
| 3925 | async def test_offset_overflow(self): |
| 3926 | # specify an offset > file size |
nothing calls this directly
no test coverage detected