Lines Matching refs:Chunk
43 last_chunk_sent_ == Chunk::Type::kStartAck) { in HandleEvent()
132 Chunk start_chunk(desired_protocol_version_, Chunk::Type::kStart); in InitiateTransferAsClient()
189 Chunk chunk(ProtocolVersion::kLegacy, Chunk::Type::kStart); in SendInitialLegacyTransmitChunk()
255 void Context::SetTransferParameters(Chunk& parameters) { in SetTransferParameters()
269 Chunk::Type type = Chunk::Type::kParametersRetransmit; in SendTransferParameters()
273 type = Chunk::Type::kStart; in SendTransferParameters()
277 type = Chunk::Type::kParametersRetransmit; in SendTransferParameters()
280 type = Chunk::Type::kParametersContinue; in SendTransferParameters()
284 Chunk parameters(configured_protocol_version_, type); in SendTransferParameters()
314 void Context::EncodeAndSendChunk(const Chunk& chunk) { in EncodeAndSendChunk()
320 (chunk.type() != Chunk::Type::kData && in EncodeAndSendChunk()
321 chunk.type() != Chunk::Type::kParametersContinue)) { in EncodeAndSendChunk()
327 if (chunk.type() == Chunk::Type::kData || in EncodeAndSendChunk()
328 chunk.type() == Chunk::Type::kParametersContinue) { in EncodeAndSendChunk()
399 last_chunk_sent_ = Chunk::Type::kStart; in Initialize()
412 Result<Chunk> maybe_chunk = in HandleChunkEvent()
413 Chunk::Parse(ConstByteSpan(event.data, event.size)); in HandleChunkEvent()
418 Chunk chunk = *maybe_chunk; in HandleChunkEvent()
425 if (chunk.type() != Chunk::Type::kData && in HandleChunkEvent()
426 chunk.type() != Chunk::Type::kParametersContinue) { in HandleChunkEvent()
431 if (chunk.type() == Chunk::Type::kData || in HandleChunkEvent()
432 chunk.type() == Chunk::Type::kParametersContinue) { in HandleChunkEvent()
455 void Context::PerformInitialHandshake(const Chunk& chunk) { in PerformInitialHandshake()
458 case Chunk::Type::kStart: { in PerformInitialHandshake()
469 Chunk start_ack(configured_protocol_version_, Chunk::Type::kStartAck); in PerformInitialHandshake()
480 case Chunk::Type::kStartAck: { in PerformInitialHandshake()
489 Chunk start_ack_confirmation(configured_protocol_version_, in PerformInitialHandshake()
490 Chunk::Type::kStartAckConfirmation); in PerformInitialHandshake()
512 case Chunk::Type::kStartAckConfirmation: { in PerformInitialHandshake()
527 case Chunk::Type::kData: in PerformInitialHandshake()
528 case Chunk::Type::kParametersRetransmit: in PerformInitialHandshake()
529 case Chunk::Type::kParametersContinue: in PerformInitialHandshake()
559 case Chunk::Type::kCompletion: in PerformInitialHandshake()
560 case Chunk::Type::kCompletionAck: in PerformInitialHandshake()
568 void Context::UpdateLocalProtocolConfigurationFromPeer(const Chunk& chunk) { in UpdateLocalProtocolConfigurationFromPeer()
581 void Context::HandleTransmitChunk(const Chunk& chunk) { in HandleTransmitChunk()
622 void Context::HandleTransferParametersUpdate(const Chunk& chunk) { in HandleTransferParametersUpdate()
697 Chunk chunk(configured_protocol_version_, Chunk::Type::kData); in TransmitNextChunk()
709 pwpb::Chunk::Fields::kRemainingBytes, total_size); in TransmitNextChunk()
809 void Context::HandleReceiveChunk(const Chunk& chunk) { in HandleReceiveChunk()
888 void Context::HandleReceivedData(const Chunk& chunk) { in HandleReceivedData()
891 chunk.type() != Chunk::Type::kStartAckConfirmation) { in HandleReceivedData()
1006 if (chunk.type() == Chunk::Type::kStartAckConfirmation) { in HandleReceivedData()
1029 void Context::HandleTerminatingChunk(const Chunk& chunk) { in HandleTerminatingChunk()
1031 case Chunk::Type::kCompletion: in HandleTerminatingChunk()
1034 case Chunk::Type::kCompletionAck: in HandleTerminatingChunk()
1040 case Chunk::Type::kData: in HandleTerminatingChunk()
1041 case Chunk::Type::kStart: in HandleTerminatingChunk()
1042 case Chunk::Type::kParametersRetransmit: in HandleTerminatingChunk()
1043 case Chunk::Type::kParametersContinue: in HandleTerminatingChunk()
1044 case Chunk::Type::kStartAck: in HandleTerminatingChunk()
1045 case Chunk::Type::kStartAckConfirmation: in HandleTerminatingChunk()
1049 Chunk::Final(configured_protocol_version_, session_id_, status_)); in HandleTerminatingChunk()
1093 Chunk(configured_protocol_version_, Chunk::Type::kCompletionAck) in HandleTermination()
1120 Chunk chunk = in SendFinalStatusChunk()
1121 Chunk::Final(configured_protocol_version_, session_id_, status_); in SendFinalStatusChunk()
1168 last_chunk_sent_ == Chunk::Type::kStart) { in HandleTimeout()
1205 last_chunk_sent_ == Chunk::Type::kStartAckConfirmation) { in Retry()
1212 Chunk::Final(configured_protocol_version_, session_id_, status_)); in Retry()
1253 Chunk retry_chunk(configured_protocol_version_, last_chunk_sent_); in RetryHandshake()
1256 case Chunk::Type::kStart: in RetryHandshake()
1268 case Chunk::Type::kStartAck: in RetryHandshake()
1273 case Chunk::Type::kStartAckConfirmation: in RetryHandshake()
1280 case Chunk::Type::kData: in RetryHandshake()
1281 case Chunk::Type::kParametersRetransmit: in RetryHandshake()
1282 case Chunk::Type::kParametersContinue: in RetryHandshake()
1283 case Chunk::Type::kCompletion: in RetryHandshake()
1284 case Chunk::Type::kCompletionAck: in RetryHandshake()