Home
last modified time | relevance | path

Searched refs:fin_consumed (Results 1 – 12 of 12) sorted by relevance

/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/
H A Dquic_stream.cc791 consumed_data.fin_consumed = fin; in WriteMemSlices()
807 fin_buffered_ = consumed_data.fin_consumed; in WriteMemSlices()
1170 consumed.fin_consumed); in RetransmitStreamData()
1172 retransmit_fin = !consumed.fin_consumed; in RetransmitStreamData()
1175 (can_bundle_fin && !consumed.fin_consumed)) { in RetransmitStreamData()
1186 if (!consumed.fin_consumed) { in RetransmitStreamData()
1259 << " fin is sent: " << consumed_data.fin_consumed in WriteBufferedData()
1272 if (fin && consumed_data.fin_consumed) { in WriteBufferedData()
1283 } else if (fin && !consumed_data.fin_consumed && !write_side_closed_) { in WriteBufferedData()
1289 if (consumed_data.bytes_consumed > 0 || consumed_data.fin_consumed) { in WriteBufferedData()
[all …]
H A Dquic_packet_creator_test.cc2945 EXPECT_FALSE(consumed.fin_consumed); in TEST_F()
2948 EXPECT_TRUE(consumed.fin_consumed); in TEST_F()
2974 EXPECT_TRUE(consumed.fin_consumed); in TEST_F()
2985 EXPECT_FALSE(consumed.fin_consumed); in TEST_F()
2999 EXPECT_TRUE(consumed.fin_consumed); in TEST_F()
3017 EXPECT_TRUE(consumed.fin_consumed); in TEST_F()
3133 EXPECT_FALSE(consumed.fin_consumed); in TEST_F()
3149 EXPECT_TRUE(consumed.fin_consumed); in TEST_F()
3207 EXPECT_FALSE(consumed.fin_consumed); in TEST_F()
3218 EXPECT_TRUE(consumed.fin_consumed); in TEST_F()
[all …]
H A Dquic_types.h75 constexpr QuicConsumedData(size_t bytes_consumed, bool fin_consumed) in QuicConsumedData()
76 : bytes_consumed(bytes_consumed), fin_consumed(fin_consumed) {} in QuicConsumedData()
89 bool fin_consumed; member
H A Dquic_stream_test.cc1191 EXPECT_FALSE(consumed.fin_consumed); in TEST_P()
1202 EXPECT_FALSE(consumed.fin_consumed); in TEST_P()
1226 EXPECT_FALSE(consumed.fin_consumed); in TEST_P()
1287 EXPECT_FALSE(consumed.fin_consumed); in TEST_P()
1295 EXPECT_FALSE(consumed.fin_consumed); in TEST_P()
1315 EXPECT_TRUE(consumed.fin_consumed); in TEST_P()
H A Dquic_generic_session_test.cc503 bool fin_consumed = stream->SkipBytes(result.peeked_data.size()); in TEST_F() local
504 if (fin_consumed) { in TEST_F()
H A Dquic_packet_creator.cc1377 bool fin_consumed = false; in ConsumeData() local
1419 fin_consumed = fin && total_bytes_consumed == write_length; in ConsumeData()
1420 if (fin_consumed && state == FIN_AND_PADDING) { in ConsumeData()
1451 return QuicConsumedData(total_bytes_consumed, fin_consumed); in ConsumeData()
H A Dquic_types.cc20 << " fin_consumed: " << s.fin_consumed; in operator <<()
H A Dquic_crypto_stream.cc360 consumed.fin_consumed); in RetransmitStreamDataAtLevel()
H A Dquic_connection_test.cc4113 EXPECT_TRUE(consumed.fin_consumed); in TEST_P()
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/
H A Dsimple_session_notifier.cc67 consumed.fin_consumed); in WriteOrBufferData()
219 consumed.fin_consumed); in OnCanWrite()
221 (can_bundle_fin && !consumed.fin_consumed)) { in OnCanWrite()
423 retransmit_fin = !consumed.fin_consumed; in RetransmitFrames()
426 (can_bundle_fin && !consumed.fin_consumed)) { in RetransmitFrames()
436 if (!consumed.fin_consumed) { in RetransmitFrames()
654 state.fin_lost = !consumed.fin_consumed; in RetransmitLostStreamData()
673 if (consumed.fin_consumed) { in RetransmitLostStreamData()
677 (can_bundle_fin && !consumed.fin_consumed)) { in RetransmitLostStreamData()
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/web_transport/encapsulated/
H A Dencapsulated_web_transport.cc560 bool fin_consumed = SkipBytes(total_size); in Read() local
561 return ReadResult{total_size, fin_consumed}; in Read()
/aosp_15_r20/external/cronet/net/third_party/quiche/src/quiche/quic/core/http/
H A Dquic_spdy_client_session_test.cc257 EXPECT_FALSE(consumed.fin_consumed); in TEST_P()