Home
last modified time | relevance | path

Searched refs:MarkConsumed (Results 1 – 22 of 22) sorted by relevance

/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
Dquic_spdy_stream.cc438 sequencer()->MarkConsumed(body_manager_.ReadBody(iov, iov_len, &bytes_read)); in Readv()
451 void QuicSpdyStream::MarkConsumed(size_t num_bytes) { in MarkConsumed() function in quic::QuicSpdyStream
454 sequencer()->MarkConsumed(num_bytes); in MarkConsumed()
458 sequencer()->MarkConsumed(body_manager_.OnBodyConsumed(num_bytes)); in MarkConsumed()
960 sequencer()->MarkConsumed(body_manager_.OnNonBody(header_length)); in OnDataFrameStart()
1049 sequencer()->MarkConsumed(body_manager_.OnNonBody(header_length)); in OnHeadersFrameStart()
1076 sequencer()->MarkConsumed(body_manager_.OnNonBody(payload.size())); in OnHeadersFramePayload()
1106 sequencer()->MarkConsumed(header_length); in OnWebTransportStreamFrameType()
1145 sequencer()->MarkConsumed(body_manager_.OnNonBody(header_length)); in OnUnknownFrameStart()
1155 sequencer()->MarkConsumed(body_manager_.OnNonBody(payload.size())); in OnUnknownFramePayload()
[all …]
Dweb_transport_http3.cc373 sequencer()->MarkConsumed(sequencer()->NumBytesBuffered()); in ReadSessionId()
377 sequencer()->MarkConsumed(session_id_length); in ReadSessionId()
Dquic_headers_stream.cc47 sequencer()->MarkConsumed(iov.iov_len); in OnDataAvailable()
Dquic_receive_control_stream.cc51 sequencer()->MarkConsumed(processed_bytes); in OnDataAvailable()
Dquic_spdy_client_stream.cc181 MarkConsumed(iov.iov_len); in OnBodyAvailable()
Dquic_spdy_stream.h179 void MarkConsumed(size_t num_bytes);
Dquic_spdy_session.cc1377 pending->MarkConsumed(pending->sequencer()->close_offset()); in ProcessPendingStream()
1381 pending->MarkConsumed(stream_type_length); in ProcessPendingStream()
Dquic_spdy_stream_test.cc899 stream_->MarkConsumed(body.length()); in TEST_P()
919 stream_->MarkConsumed(body1.length() + body2.length()); in TEST_P()
Dend_to_end_test.cc4526 MarkConsumed(iov.iov_len); in OnBodyAvailable()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/
Dquic_stream_sequencer_buffer_test.cc698 EXPECT_TRUE(buffer_->MarkConsumed(1024)); in TEST_F()
711 EXPECT_TRUE(buffer_->MarkConsumed(kBlockSizeBytes - 1024)); in TEST_F()
757 EXPECT_TRUE(buffer_->MarkConsumed(512)); in TEST_F()
760 buffer_->MarkConsumed(256); in TEST_F()
773 EXPECT_TRUE(buffer_->MarkConsumed(512)); in TEST_F()
777 EXPECT_FALSE(buffer_->MarkConsumed(257)); in TEST_F()
791 buffer_->MarkConsumed(2 * kBlockSizeBytes); in TEST_F()
810 buffer_->MarkConsumed(8 * kBlockSizeBytes - 1024); in TEST_F()
813 buffer_->MarkConsumed(0.5 * kBlockSizeBytes + 500); in TEST_F()
817 buffer_->MarkConsumed(12); in TEST_F()
[all …]
Dquic_stream_sequencer_test.cc514 TEST_F(QuicStreamSequencerTest, MarkConsumed) { in TEST_F() argument
531 sequencer_->MarkConsumed(1); in TEST_F()
539 sequencer_->MarkConsumed(2); in TEST_F()
547 sequencer_->MarkConsumed(5); in TEST_F()
571 sequencer_->MarkConsumed(4); in TEST_F()
590 sequencer_->MarkConsumed(6); in TEST_F()
Dquic_stream_sequencer.cc235 void QuicStreamSequencer::MarkConsumed(size_t num_bytes_consumed) { in MarkConsumed() function in quic::QuicStreamSequencer
237 bool result = buffered_frames_.MarkConsumed(num_bytes_consumed); in MarkConsumed()
Dquic_stream_sequencer_buffer.h141 bool MarkConsumed(size_t bytes_consumed);
Dquic_stream_sequencer.h102 void MarkConsumed(size_t num_bytes);
Dquic_stream.h98 void MarkConsumed(QuicByteCount num_bytes);
Dtls_chlo_extractor.cc197 crypto_stream_sequencer_.MarkConsumed(iov.iov_len); in OnDataAvailable()
Dquic_stream_sequencer_buffer.cc402 bool QuicStreamSequencerBuffer::MarkConsumed(size_t bytes_consumed) { in MarkConsumed() function in quic::QuicStreamSequencerBuffer
Dquic_stream.cc276 void PendingStream::MarkConsumed(QuicByteCount num_bytes) { in MarkConsumed() function in quic::PendingStream
277 sequencer_.MarkConsumed(num_bytes); in MarkConsumed()
Dquic_crypto_stream.cc123 sequencer->MarkConsumed(iov.iov_len); in OnDataAvailableInSequencer()
/external/cronet/net/third_party/quiche/src/quiche/quic/tools/
Dquic_simple_client_stream.cc20 MarkConsumed(iov.iov_len); in OnBodyAvailable()
Dquic_simple_server_stream.cc117 MarkConsumed(iov.iov_len); in OnBodyAvailable()
/external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/
Dqpack_receive_stream.cc29 sequencer()->MarkConsumed(iov.iov_len); in OnDataAvailable()