Lines Matching full:chunk

60         self._sent_chunks: list[transfer_pb2.Chunk] = []
64         self, method: _Method, responses: Iterable[Iterable[transfer_pb2.Chunk]]  argument
99         chunk = transfer_pb2.Chunk()
100         chunk.MergeFromString(packet.payload)
101         self._sent_chunks.append(chunk)
111         for chunk in self._sent_chunks:
112             data.extend(chunk.data)
124                     transfer_pb2.Chunk(
146                     transfer_pb2.Chunk(
149                     transfer_pb2.Chunk(
171                     transfer_pb2.Chunk(
174                     transfer_pb2.Chunk(
206                     transfer_pb2.Chunk(
210                     transfer_pb2.Chunk(
215                     transfer_pb2.Chunk(
218                     transfer_pb2.Chunk(
234         """Server sends the same chunk twice (retry) in a read transfer."""
244                     # chunk should be sent.
245                     transfer_pb2.Chunk(
248                     transfer_pb2.Chunk(
251                     transfer_pb2.Chunk(
256                     # Only one parameters chunk should be sent after the server
258                     transfer_pb2.Chunk(
261                     transfer_pb2.Chunk(
264                     transfer_pb2.Chunk(
267                     transfer_pb2.Chunk(
272                     transfer_pb2.Chunk(
287             self._sent_chunks[0].type, transfer_pb2.Chunk.Type.START
292             transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
297             transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
301             self._sent_chunks[3].type, transfer_pb2.Chunk.Type.COMPLETION
315                     transfer_pb2.Chunk(
345                     transfer_pb2.Chunk(  # Expected chunk.
388                     transfer_pb2.Chunk(
429                 # First window: 1 chunk.
431                     transfer_pb2.Chunk(
433                         type=transfer_pb2.Chunk.Type.DATA,
440                     transfer_pb2.Chunk(
442                         type=transfer_pb2.Chunk.Type.DATA,
446                     transfer_pb2.Chunk(
448                         type=transfer_pb2.Chunk.Type.DATA,
455                     transfer_pb2.Chunk(
457                         type=transfer_pb2.Chunk.Type.DATA,
471                 # First parameters: 1 chunk window.
472                 transfer_pb2.Chunk(
473                     type=transfer_pb2.Chunk.Type.START,
480                 # Second parameters: 2 chunk window.
481                 transfer_pb2.Chunk(
482                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
491                 # Third parameters: 4 chunk window.
492                 transfer_pb2.Chunk(
493                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
502                 transfer_pb2.Chunk(
503                     type=transfer_pb2.Chunk.Type.COMPLETION,
524                 # First window: 1 chunk.
526                     transfer_pb2.Chunk(
528                         type=transfer_pb2.Chunk.Type.DATA,
535                     transfer_pb2.Chunk(
537                         type=transfer_pb2.Chunk.Type.DATA,
541                     transfer_pb2.Chunk(
543                         type=transfer_pb2.Chunk.Type.DATA,
551                     transfer_pb2.Chunk(
553                         type=transfer_pb2.Chunk.Type.DATA,
560                     transfer_pb2.Chunk(
562                         type=transfer_pb2.Chunk.Type.DATA,
566                     transfer_pb2.Chunk(
568                         type=transfer_pb2.Chunk.Type.DATA,
575                     transfer_pb2.Chunk(
577                         type=transfer_pb2.Chunk.Type.DATA,
591                 # First parameters: 1 chunk window.
592                 transfer_pb2.Chunk(
593                     type=transfer_pb2.Chunk.Type.START,
600                 # Second parameters: 2 chunk window.
601                 transfer_pb2.Chunk(
602                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
611                 # Third parameters: 4 chunk window.
612                 transfer_pb2.Chunk(
613                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
623                 transfer_pb2.Chunk(
624                     type=transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
634                 # only increases by one chunk instead of doubling.
635                 transfer_pb2.Chunk(
636                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
645                 transfer_pb2.Chunk(
646                     type=transfer_pb2.Chunk.Type.COMPLETION,
668                     transfer_pb2.Chunk(
670                         type=transfer_pb2.Chunk.Type.START_ACK,
674                 # First window: 1 chunk.
676                     transfer_pb2.Chunk(
678                         type=transfer_pb2.Chunk.Type.DATA,
685                     transfer_pb2.Chunk(
687                         type=transfer_pb2.Chunk.Type.DATA,
691                     transfer_pb2.Chunk(
693                         type=transfer_pb2.Chunk.Type.DATA,
700                     transfer_pb2.Chunk(
702                         type=transfer_pb2.Chunk.Type.DATA,
709                     transfer_pb2.Chunk(
711                         type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
722                 transfer_pb2.Chunk(
729                     type=transfer_pb2.Chunk.Type.START,
732                 # First parameters: 1 chunk window.
733                 transfer_pb2.Chunk(
735                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
741                 # Second parameters: 2 chunk window.
742                 transfer_pb2.Chunk(
744                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
751                 # Third parameters: 4 chunk window.
752                 transfer_pb2.Chunk(
754                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
761                 transfer_pb2.Chunk(
763                     type=transfer_pb2.Chunk.Type.COMPLETION,
786                     transfer_pb2.Chunk(
788                         type=transfer_pb2.Chunk.Type.START_ACK,
792                 # First window: 1 chunk.
794                     transfer_pb2.Chunk(
796                         type=transfer_pb2.Chunk.Type.DATA,
803                     transfer_pb2.Chunk(
805                         type=transfer_pb2.Chunk.Type.DATA,
809                     transfer_pb2.Chunk(
811                         type=transfer_pb2.Chunk.Type.DATA,
819                     transfer_pb2.Chunk(
821                         type=transfer_pb2.Chunk.Type.DATA,
828                     transfer_pb2.Chunk(
830                         type=transfer_pb2.Chunk.Type.DATA,
834                     transfer_pb2.Chunk(
836                         type=transfer_pb2.Chunk.Type.DATA,
843                     transfer_pb2.Chunk(
845                         type=transfer_pb2.Chunk.Type.DATA,
852                     transfer_pb2.Chunk(
854                         type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
865                 transfer_pb2.Chunk(
866                     type=transfer_pb2.Chunk.Type.START,
875                 # First parameters: 1 chunk window.
876                 transfer_pb2.Chunk(
878                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
884                 # Second parameters: 2 chunk window.
885                 transfer_pb2.Chunk(
886                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
894                 # Third parameters: 4 chunk window.
895                 transfer_pb2.Chunk(
896                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
905                 transfer_pb2.Chunk(
906                     type=transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
915                 # only increases by one chunk instead of doubling.
916                 transfer_pb2.Chunk(
917                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
925                 transfer_pb2.Chunk(
926                     type=transfer_pb2.Chunk.Type.COMPLETION,
944                     transfer_pb2.Chunk(
951                 (transfer_pb2.Chunk(transfer_id=4, status=Status.OK.value),),
968                     transfer_pb2.Chunk(
976                 (transfer_pb2.Chunk(transfer_id=4, status=Status.OK.value),),
995                     transfer_pb2.Chunk(
1003                     transfer_pb2.Chunk(
1010                 (transfer_pb2.Chunk(transfer_id=4, status=Status.OK.value),),
1029                     transfer_pb2.Chunk(
1037                     transfer_pb2.Chunk(
1044                 (transfer_pb2.Chunk(transfer_id=4, status=Status.OK.value),),
1074                     transfer_pb2.Chunk(
1082                     transfer_pb2.Chunk(
1090                     transfer_pb2.Chunk(
1098                     transfer_pb2.Chunk(
1105                 (transfer_pb2.Chunk(transfer_id=4, status=Status.OK.value),),
1125                     transfer_pb2.Chunk(
1133                     transfer_pb2.Chunk(
1140                 (transfer_pb2.Chunk(transfer_id=4, status=Status.OK.value),),
1160                     transfer_pb2.Chunk(
1202                 transfer_pb2.Chunk(
1205                     type=transfer_pb2.Chunk.Type.START,
1206                 ),  # initial chunk
1207                 transfer_pb2.Chunk(
1210                     type=transfer_pb2.Chunk.Type.START,
1212                 transfer_pb2.Chunk(
1215                     type=transfer_pb2.Chunk.Type.START,
1225         """Tests write transfers that timeout after the initial chunk."""
1237                     transfer_pb2.Chunk(
1247         last_data_chunk = transfer_pb2.Chunk(
1252             type=transfer_pb2.Chunk.Type.DATA,
1258                 transfer_pb2.Chunk(
1261                     type=transfer_pb2.Chunk.Type.START,
1263                 transfer_pb2.Chunk(
1266                     type=transfer_pb2.Chunk.Type.DATA,
1268                 last_data_chunk,  # last chunk
1285             ((transfer_pb2.Chunk(transfer_id=23, pending_bytes=0),),),
1307                     transfer_pb2.Chunk(
1310                         type=transfer_pb2.Chunk.Type.START_ACK,
1315                     transfer_pb2.Chunk(
1317                         type=transfer_pb2.Chunk.Type.DATA,
1324                     transfer_pb2.Chunk(
1326                         type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
1337                 transfer_pb2.Chunk(
1344                     type=transfer_pb2.Chunk.Type.START,
1347                 transfer_pb2.Chunk(
1349                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
1356                 transfer_pb2.Chunk(
1358                     type=transfer_pb2.Chunk.Type.COMPLETION,
1374         # Respond to the START chunk with a legacy data transfer chunk instead
1380                     transfer_pb2.Chunk(
1382                         type=transfer_pb2.Chunk.Type.DATA,
1396                 transfer_pb2.Chunk(
1403                     type=transfer_pb2.Chunk.Type.START,
1406                 transfer_pb2.Chunk(
1408                     type=transfer_pb2.Chunk.Type.COMPLETION,
1428                     transfer_pb2.Chunk(
1431                         type=transfer_pb2.Chunk.Type.START_ACK,
1436                     transfer_pb2.Chunk(
1438                         type=transfer_pb2.Chunk.Type.DATA,
1443                     transfer_pb2.Chunk(
1445                         type=transfer_pb2.Chunk.Type.DATA,
1451                     transfer_pb2.Chunk(
1453                         type=transfer_pb2.Chunk.Type.DATA,
1460                     transfer_pb2.Chunk(
1462                         type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
1473                 transfer_pb2.Chunk(
1480                     type=transfer_pb2.Chunk.Type.START,
1483                 transfer_pb2.Chunk(
1485                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
1490                 # Should send a continue chunk in response to retransmission.
1491                 transfer_pb2.Chunk(
1493                     type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
1498                 transfer_pb2.Chunk(
1500                     type=transfer_pb2.Chunk.Type.COMPLETION,
1520                     transfer_pb2.Chunk(
1523                         type=transfer_pb2.Chunk.Type.START_ACK,
1528                     transfer_pb2.Chunk(
1530                         type=transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
1536                 (),  # In response to the first data chunk.
1538                     transfer_pb2.Chunk(
1540                         type=transfer_pb2.Chunk.Type.COMPLETION,
1552                 transfer_pb2.Chunk(
1556                     type=transfer_pb2.Chunk.Type.START,
1559                 transfer_pb2.Chunk(
1561                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
1564                 transfer_pb2.Chunk(
1566                     type=transfer_pb2.Chunk.Type.DATA,
1570                 transfer_pb2.Chunk(
1572                     type=transfer_pb2.Chunk.Type.DATA,
1577                 transfer_pb2.Chunk(
1579                     type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
1597                 # Send a parameters chunk immediately per the legacy protocol.
1599                     transfer_pb2.Chunk(
1601                         type=transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
1608                 (),  # In response to the first data chunk.
1610                     transfer_pb2.Chunk(
1612                         type=transfer_pb2.Chunk.Type.COMPLETION,
1624                 transfer_pb2.Chunk(
1628                     type=transfer_pb2.Chunk.Type.START,
1631                 transfer_pb2.Chunk(
1633                     type=transfer_pb2.Chunk.Type.DATA,
1637                 transfer_pb2.Chunk(
1639                     type=transfer_pb2.Chunk.Type.DATA,
1661                     transfer_pb2.Chunk(
1664                         type=transfer_pb2.Chunk.Type.START_ACK,
1669                     transfer_pb2.Chunk(
1671                         type=transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
1678                     transfer_pb2.Chunk(
1680                         type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
1686                 # Shrink the window end offset with a CONTINUE chunk.
1688                     transfer_pb2.Chunk(
1690                         type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
1696                 # The last chunk should be ignored; the receiver times out
1699                     transfer_pb2.Chunk(
1701                         type=transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
1708                     transfer_pb2.Chunk(
1710                         type=transfer_pb2.Chunk.Type.PARAMETERS_CONTINUE,
1717                     transfer_pb2.Chunk(
1719                         type=transfer_pb2.Chunk.Type.COMPLETION,
1731                 transfer_pb2.Chunk(
1735                     type=transfer_pb2.Chunk.Type.START,
1738                 transfer_pb2.Chunk(
1740                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
1743                 transfer_pb2.Chunk(
1745                     type=transfer_pb2.Chunk.Type.DATA,
1749                 transfer_pb2.Chunk(
1751                     type=transfer_pb2.Chunk.Type.DATA,
1755                 transfer_pb2.Chunk(
1757                     type=transfer_pb2.Chunk.Type.DATA,
1761                 transfer_pb2.Chunk(
1763                     type=transfer_pb2.Chunk.Type.DATA,
1767                 transfer_pb2.Chunk(
1769                     type=transfer_pb2.Chunk.Type.DATA,
1774                 transfer_pb2.Chunk(
1776                     type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
1794                     transfer_pb2.Chunk(
1797                         type=transfer_pb2.Chunk.Type.START_ACK,
1802                     transfer_pb2.Chunk(
1804                         type=transfer_pb2.Chunk.Type.COMPLETION,
1817                 transfer_pb2.Chunk(
1824                     type=transfer_pb2.Chunk.Type.START,
1827                 transfer_pb2.Chunk(
1829                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
1835                 transfer_pb2.Chunk(
1837                     type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
1859         start_chunk = transfer_pb2.Chunk(
1866             type=transfer_pb2.Chunk.Type.START,
1870         # The opening chunk should be sent initially, then retried three times.
1889                     transfer_pb2.Chunk(
1892                         type=transfer_pb2.Chunk.Type.START_ACK,
1899                     transfer_pb2.Chunk(
1901                         type=transfer_pb2.Chunk.Type.PARAMETERS_RETRANSMIT,
1907                 (),  # In response to the first data chunk.
1909                     transfer_pb2.Chunk(
1911                         type=transfer_pb2.Chunk.Type.COMPLETION,
1920         start_ack_confirmation = transfer_pb2.Chunk(
1922             type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
1929                 transfer_pb2.Chunk(
1933                     type=transfer_pb2.Chunk.Type.START,
1939                 transfer_pb2.Chunk(
1941                     type=transfer_pb2.Chunk.Type.DATA,
1945                 transfer_pb2.Chunk(
1947                     type=transfer_pb2.Chunk.Type.DATA,
1952                 transfer_pb2.Chunk(
1954                     type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
1962         """Tests an unexpected chunk response during the closing handshake."""
1973                     transfer_pb2.Chunk(
1976                         type=transfer_pb2.Chunk.Type.START_ACK,
1981                     transfer_pb2.Chunk(
1983                         type=transfer_pb2.Chunk.Type.DATA,
1989                 # In response to the COMPLETION, re-send the last chunk instead
1992                     transfer_pb2.Chunk(
1994                         type=transfer_pb2.Chunk.Type.DATA,
2001                     transfer_pb2.Chunk(
2003                         type=transfer_pb2.Chunk.Type.COMPLETION_ACK,
2014                 transfer_pb2.Chunk(
2021                     type=transfer_pb2.Chunk.Type.START,
2024                 transfer_pb2.Chunk(
2026                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
2031                 transfer_pb2.Chunk(
2033                     type=transfer_pb2.Chunk.Type.COMPLETION,
2036                 # Completion should be re-sent following the repeated chunk.
2037                 transfer_pb2.Chunk(
2039                     type=transfer_pb2.Chunk.Type.COMPLETION,
2059                     transfer_pb2.Chunk(
2062                         type=transfer_pb2.Chunk.Type.START_ACK,
2067                     transfer_pb2.Chunk(
2069                         type=transfer_pb2.Chunk.Type.DATA,
2075                 # Never send the expected COMPLETION_ACK chunk.
2084                 transfer_pb2.Chunk(
2091                     type=transfer_pb2.Chunk.Type.START,
2094                 transfer_pb2.Chunk(
2096                     type=transfer_pb2.Chunk.Type.START_ACK_CONFIRMATION,
2101                 transfer_pb2.Chunk(
2103                     type=transfer_pb2.Chunk.Type.COMPLETION,
2107                 transfer_pb2.Chunk(
2109                     type=transfer_pb2.Chunk.Type.COMPLETION,
2112                 transfer_pb2.Chunk(
2114                     type=transfer_pb2.Chunk.Type.COMPLETION,
2117                 transfer_pb2.Chunk(
2119                     type=transfer_pb2.Chunk.Type.COMPLETION,