Home
last modified time | relevance | path

Searched refs:packet_number (Results 1 – 25 of 258) sorted by relevance

1234567891011

/external/cronet/tot/net/quic/
Dquic_proxy_client_socket_unittest.cc165 int packet_number = 1; in TEST_P() local
167 ConstructSettingsPacket(packet_number++)); in TEST_P()
169 ConstructConnectRequestPacket(packet_number++)); in TEST_P()
173 SYNCHRONOUS, ConstructAckAndRstPacket(packet_number++, in TEST_P()
207 int packet_number = 1; in TEST_P() local
209 ConstructSettingsPacket(packet_number++)); in TEST_P()
213 packet_number++, in TEST_P()
222 SYNCHRONOUS, ConstructAckAndRstPacket(packet_number++, in TEST_P()
243 int packet_number = 1; in TEST_P() local
245 ConstructSettingsPacket(packet_number++)); in TEST_P()
[all …]
Dquic_proxy_datagram_client_socket_unittest.cc168 int packet_number = 1; in TEST_P() local
171 ConstructSettingsPacket(packet_number++)); in TEST_P()
173 ConstructConnectRequestPacket(packet_number++)); in TEST_P()
179 packet_number++, quic::QUIC_STREAM_CANCELLED, in TEST_P()
209 int packet_number = 1; in TEST_P() local
212 ConstructSettingsPacket(packet_number++)); in TEST_P()
215 ConstructConnectRequestPacket(packet_number++, extra_expected_headers)); in TEST_P()
223 packet_number++, quic::QUIC_STREAM_CANCELLED, in TEST_P()
247 int packet_number = 1; in TEST_P() local
250 ConstructSettingsPacket(packet_number++)); in TEST_P()
[all …]
Dquic_proxy_client_socket_test_base.cc230 QuicProxyClientSocketTestBase::ConstructSettingsPacket(uint64_t packet_number) { in ConstructSettingsPacket() argument
231 return client_maker_.MakeInitialSettingsPacket(packet_number); in ConstructSettingsPacket()
236 uint64_t packet_number, in ConstructAckAndRstOnlyPacket() argument
240 return client_maker_.Packet(packet_number++) in ConstructAckAndRstOnlyPacket()
248 uint64_t packet_number, in ConstructAckAndRstPacket() argument
252 return client_maker_.Packet(packet_number++) in ConstructAckAndRstPacket()
261 uint64_t packet_number, in ConstructRstPacket() argument
263 return client_maker_.Packet(packet_number) in ConstructRstPacket()
271 uint64_t packet_number, in ConstructConnectRequestPacket() argument
277 packet_number, client_data_stream_id1_, !kFin, in ConstructConnectRequestPacket()
[all …]
Dquic_proxy_client_socket_test_base.h129 uint64_t packet_number);
132 uint64_t packet_number,
138 uint64_t packet_number,
144 uint64_t packet_number,
148 uint64_t packet_number,
154 uint64_t packet_number,
159 uint64_t packet_number);
162 uint64_t packet_number,
166 uint64_t packet_number,
170 uint64_t packet_number,
[all …]
Dquic_http_stream_test.cc468 uint64_t packet_number, in ConstructClientDataPacket() argument
471 return client_maker_.Packet(packet_number) in ConstructClientDataPacket()
477 uint64_t packet_number, in ConstructServerDataPacket() argument
480 return server_maker_.Packet(packet_number) in ConstructServerDataPacket()
486 uint64_t packet_number, in InnerConstructRequestHeadersPacket() argument
494 packet_number, stream_id, fin, priority, std::move(request_headers_), in InnerConstructRequestHeadersPacket()
500 uint64_t packet_number, in ConstructRequestHeadersAndDataFramesPacket() argument
509 packet_number, stream_id, fin, priority, std::move(request_headers_), in ConstructRequestHeadersAndDataFramesPacket()
514 uint64_t packet_number, in ConstructRequestAndRstPacket() argument
523 packet_number, stream_id, fin, priority, std::move(request_headers_), in ConstructRequestAndRstPacket()
[all …]
/external/cronet/stable/net/quic/
Dquic_proxy_client_socket_unittest.cc165 int packet_number = 1; in TEST_P() local
167 ConstructSettingsPacket(packet_number++)); in TEST_P()
169 ConstructConnectRequestPacket(packet_number++)); in TEST_P()
173 SYNCHRONOUS, ConstructAckAndRstPacket(packet_number++, in TEST_P()
207 int packet_number = 1; in TEST_P() local
209 ConstructSettingsPacket(packet_number++)); in TEST_P()
213 packet_number++, in TEST_P()
222 SYNCHRONOUS, ConstructAckAndRstPacket(packet_number++, in TEST_P()
243 int packet_number = 1; in TEST_P() local
245 ConstructSettingsPacket(packet_number++)); in TEST_P()
[all …]
Dquic_proxy_datagram_client_socket_unittest.cc168 int packet_number = 1; in TEST_P() local
171 ConstructSettingsPacket(packet_number++)); in TEST_P()
173 ConstructConnectRequestPacket(packet_number++)); in TEST_P()
179 packet_number++, quic::QUIC_STREAM_CANCELLED, in TEST_P()
209 int packet_number = 1; in TEST_P() local
212 ConstructSettingsPacket(packet_number++)); in TEST_P()
215 ConstructConnectRequestPacket(packet_number++, extra_expected_headers)); in TEST_P()
223 packet_number++, quic::QUIC_STREAM_CANCELLED, in TEST_P()
247 int packet_number = 1; in TEST_P() local
250 ConstructSettingsPacket(packet_number++)); in TEST_P()
[all …]
Dquic_proxy_client_socket_test_base.cc230 QuicProxyClientSocketTestBase::ConstructSettingsPacket(uint64_t packet_number) { in ConstructSettingsPacket() argument
231 return client_maker_.MakeInitialSettingsPacket(packet_number); in ConstructSettingsPacket()
236 uint64_t packet_number, in ConstructAckAndRstOnlyPacket() argument
240 return client_maker_.Packet(packet_number++) in ConstructAckAndRstOnlyPacket()
248 uint64_t packet_number, in ConstructAckAndRstPacket() argument
252 return client_maker_.Packet(packet_number++) in ConstructAckAndRstPacket()
261 uint64_t packet_number, in ConstructRstPacket() argument
263 return client_maker_.Packet(packet_number) in ConstructRstPacket()
271 uint64_t packet_number, in ConstructConnectRequestPacket() argument
277 packet_number, client_data_stream_id1_, !kFin, in ConstructConnectRequestPacket()
[all …]
Dquic_proxy_client_socket_test_base.h129 uint64_t packet_number);
132 uint64_t packet_number,
138 uint64_t packet_number,
144 uint64_t packet_number,
148 uint64_t packet_number,
154 uint64_t packet_number,
159 uint64_t packet_number);
162 uint64_t packet_number,
166 uint64_t packet_number,
170 uint64_t packet_number,
[all …]
Dquic_http_stream_test.cc468 uint64_t packet_number, in ConstructClientDataPacket() argument
471 return client_maker_.Packet(packet_number) in ConstructClientDataPacket()
477 uint64_t packet_number, in ConstructServerDataPacket() argument
480 return server_maker_.Packet(packet_number) in ConstructServerDataPacket()
486 uint64_t packet_number, in InnerConstructRequestHeadersPacket() argument
494 packet_number, stream_id, fin, priority, std::move(request_headers_), in InnerConstructRequestHeadersPacket()
500 uint64_t packet_number, in ConstructRequestHeadersAndDataFramesPacket() argument
509 packet_number, stream_id, fin, priority, std::move(request_headers_), in ConstructRequestHeadersAndDataFramesPacket()
514 uint64_t packet_number, in ConstructRequestAndRstPacket() argument
523 packet_number, stream_id, fin, priority, std::move(request_headers_), in ConstructRequestAndRstPacket()
[all …]
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/
Dpacket_number_indexed_queue.h46 T* GetEntry(QuicPacketNumber packet_number);
47 const T* GetEntry(QuicPacketNumber packet_number) const;
54 bool Emplace(QuicPacketNumber packet_number, Args&&... args);
58 bool Remove(QuicPacketNumber packet_number);
63 bool Remove(QuicPacketNumber packet_number, Function f);
68 void RemoveUpTo(QuicPacketNumber packet_number);
127 T* PacketNumberIndexedQueue<T>::GetEntry(QuicPacketNumber packet_number) { in GetEntry() argument
128 EntryWrapper* entry = GetEntryWrapper(packet_number); in GetEntry()
137 QuicPacketNumber packet_number) const { in GetEntry() argument
138 const EntryWrapper* entry = GetEntryWrapper(packet_number); in GetEntry()
[all …]
Dquic_unacked_packet_map.cc143 QuicPacketNumber packet_number = packet.packet_number; in AddDispatcherSentPacket() local
147 largest_sent_packet_ >= packet_number) in AddDispatcherSentPacket()
149 << ", packet_number: " << packet_number; in AddDispatcherSentPacket()
150 QUICHE_DCHECK_GE(packet_number, least_unacked_ + unacked_packets_.size()); in AddDispatcherSentPacket()
151 while (least_unacked_ + unacked_packets_.size() < packet_number) { in AddDispatcherSentPacket()
165 largest_sent_packet_ = packet_number; in AddDispatcherSentPacket()
175 QuicPacketNumber packet_number = packet.packet_number; in AddSentPacket() local
178 largest_sent_packet_ >= packet_number) in AddSentPacket()
180 << ", packet_number: " << packet_number; in AddSentPacket()
181 QUICHE_DCHECK_GE(packet_number, least_unacked_ + unacked_packets_.size()); in AddSentPacket()
[all …]
Dquic_sent_packet_manager.cc420 QuicPacketNumber packet_number = unacked_packets_.GetLeastUnacked(); in MarkInitialPacketsForRetransmission() local
422 for (; packet_number <= largest_sent_packet; ++packet_number) { in MarkInitialPacketsForRetransmission()
424 unacked_packets_.GetMutableTransmissionInfo(packet_number); in MarkInitialPacketsForRetransmission()
430 MarkForRetransmission(packet_number, ALL_INITIAL_RETRANSMISSION); in MarkInitialPacketsForRetransmission()
440 QuicPacketNumber packet_number = unacked_packets_.GetLeastUnacked(); in MarkZeroRttPacketsForRetransmission() local
442 for (; packet_number <= largest_sent_packet; ++packet_number) { in MarkZeroRttPacketsForRetransmission()
444 unacked_packets_.GetMutableTransmissionInfo(packet_number); in MarkZeroRttPacketsForRetransmission()
452 MarkForRetransmission(packet_number, ALL_ZERO_RTT_RETRANSMISSION); in MarkZeroRttPacketsForRetransmission()
459 for (QuicPacketNumber packet_number : in NeuterUnencryptedPackets() local
461 send_algorithm_->OnPacketNeutered(packet_number); in NeuterUnencryptedPackets()
[all …]
Dquic_received_packet_manager.cc78 const QuicPacketNumber packet_number = header.packet_number; in RecordPacketReceived() local
79 QUICHE_DCHECK(IsAwaitingPacket(packet_number)) in RecordPacketReceived()
80 << " packet_number:" << packet_number; in RecordPacketReceived()
81 was_last_packet_missing_ = IsMissing(packet_number); in RecordPacketReceived()
90 LargestAcked(ack_frame_) > packet_number) { in RecordPacketReceived()
96 LargestAcked(ack_frame_) - packet_number); in RecordPacketReceived()
103 packet_number > LargestAcked(ack_frame_)) { in RecordPacketReceived()
104 ack_frame_.largest_acked = packet_number; in RecordPacketReceived()
107 ack_frame_.packets.Add(packet_number); in RecordPacketReceived()
114 << packet_number; in RecordPacketReceived()
[all …]
Dquic_unacked_packet_map.h52 bool IsUnacked(QuicPacketNumber packet_number) const;
59 bool NotifyFramesAcked(QuicPacketNumber packet_number,
75 void RemoveFromInFlight(QuicPacketNumber packet_number);
89 bool HasRetransmittableFrames(QuicPacketNumber packet_number) const;
140 QuicPacketNumber packet_number) const;
145 QuicPacketNumber packet_number);
175 void RemoveRetransmittability(QuicPacketNumber packet_number);
184 PacketNumberSpace packet_number_space, QuicPacketNumber packet_number);
196 void MaybeAggregateAckedStreamFrame(QuicPacketNumber packet_number,
213 PacketNumberSpace GetPacketNumberSpace(QuicPacketNumber packet_number) const;
[all …]
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/
Dpacket_number_indexed_queue.h46 T* GetEntry(QuicPacketNumber packet_number);
47 const T* GetEntry(QuicPacketNumber packet_number) const;
54 bool Emplace(QuicPacketNumber packet_number, Args&&... args);
58 bool Remove(QuicPacketNumber packet_number);
63 bool Remove(QuicPacketNumber packet_number, Function f);
68 void RemoveUpTo(QuicPacketNumber packet_number);
127 T* PacketNumberIndexedQueue<T>::GetEntry(QuicPacketNumber packet_number) { in GetEntry() argument
128 EntryWrapper* entry = GetEntryWrapper(packet_number); in GetEntry()
137 QuicPacketNumber packet_number) const { in GetEntry() argument
138 const EntryWrapper* entry = GetEntryWrapper(packet_number); in GetEntry()
[all …]
Dquic_unacked_packet_map.cc143 QuicPacketNumber packet_number = packet.packet_number; in AddDispatcherSentPacket() local
147 largest_sent_packet_ >= packet_number) in AddDispatcherSentPacket()
149 << ", packet_number: " << packet_number; in AddDispatcherSentPacket()
150 QUICHE_DCHECK_GE(packet_number, least_unacked_ + unacked_packets_.size()); in AddDispatcherSentPacket()
151 while (least_unacked_ + unacked_packets_.size() < packet_number) { in AddDispatcherSentPacket()
165 largest_sent_packet_ = packet_number; in AddDispatcherSentPacket()
175 QuicPacketNumber packet_number = packet.packet_number; in AddSentPacket() local
178 largest_sent_packet_ >= packet_number) in AddSentPacket()
180 << ", packet_number: " << packet_number; in AddSentPacket()
181 QUICHE_DCHECK_GE(packet_number, least_unacked_ + unacked_packets_.size()); in AddSentPacket()
[all …]
Dquic_sent_packet_manager.cc420 QuicPacketNumber packet_number = unacked_packets_.GetLeastUnacked(); in MarkInitialPacketsForRetransmission() local
422 for (; packet_number <= largest_sent_packet; ++packet_number) { in MarkInitialPacketsForRetransmission()
424 unacked_packets_.GetMutableTransmissionInfo(packet_number); in MarkInitialPacketsForRetransmission()
430 MarkForRetransmission(packet_number, ALL_INITIAL_RETRANSMISSION); in MarkInitialPacketsForRetransmission()
440 QuicPacketNumber packet_number = unacked_packets_.GetLeastUnacked(); in MarkZeroRttPacketsForRetransmission() local
442 for (; packet_number <= largest_sent_packet; ++packet_number) { in MarkZeroRttPacketsForRetransmission()
444 unacked_packets_.GetMutableTransmissionInfo(packet_number); in MarkZeroRttPacketsForRetransmission()
452 MarkForRetransmission(packet_number, ALL_ZERO_RTT_RETRANSMISSION); in MarkZeroRttPacketsForRetransmission()
459 for (QuicPacketNumber packet_number : in NeuterUnencryptedPackets() local
461 send_algorithm_->OnPacketNeutered(packet_number); in NeuterUnencryptedPackets()
[all …]
Dquic_received_packet_manager.cc78 const QuicPacketNumber packet_number = header.packet_number; in RecordPacketReceived() local
79 QUICHE_DCHECK(IsAwaitingPacket(packet_number)) in RecordPacketReceived()
80 << " packet_number:" << packet_number; in RecordPacketReceived()
81 was_last_packet_missing_ = IsMissing(packet_number); in RecordPacketReceived()
90 LargestAcked(ack_frame_) > packet_number) { in RecordPacketReceived()
96 LargestAcked(ack_frame_) - packet_number); in RecordPacketReceived()
103 packet_number > LargestAcked(ack_frame_)) { in RecordPacketReceived()
104 ack_frame_.largest_acked = packet_number; in RecordPacketReceived()
107 ack_frame_.packets.Add(packet_number); in RecordPacketReceived()
114 << packet_number; in RecordPacketReceived()
[all …]
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/congestion_control/
Dgeneral_loss_algorithm.cc45 packets_acked.front().packet_number == least_in_flight_) { in DetectLosses()
46 if (packets_acked.back().packet_number == largest_newly_acked && in DetectLosses()
57 if (acked.packet_number != least_in_flight_) { in DetectLosses()
66 QuicPacketNumber packet_number = unacked_packets.GetLeastUnacked(); in DetectLosses() local
68 if (least_in_flight_.IsInitialized() && least_in_flight_ >= packet_number) { in DetectLosses()
74 it += (least_in_flight_ - packet_number); in DetectLosses()
75 packet_number = least_in_flight_; in DetectLosses()
82 for (; it != unacked_packets.end() && packet_number <= largest_newly_acked; in DetectLosses()
83 ++it, ++packet_number) { in DetectLosses()
94 if (parent_ != nullptr && largest_newly_acked != packet_number) { in DetectLosses()
[all …]
Dhybrid_slow_start_test.cc27 QuicPacketNumber packet_number(1); in TEST_F() local
31 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
34 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number)); in TEST_F()
36 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
37 EXPECT_TRUE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
40 EXPECT_TRUE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
44 while (packet_number < end_packet_number) { in TEST_F()
45 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
47 EXPECT_TRUE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/congestion_control/
Dgeneral_loss_algorithm.cc45 packets_acked.front().packet_number == least_in_flight_) { in DetectLosses()
46 if (packets_acked.back().packet_number == largest_newly_acked && in DetectLosses()
57 if (acked.packet_number != least_in_flight_) { in DetectLosses()
66 QuicPacketNumber packet_number = unacked_packets.GetLeastUnacked(); in DetectLosses() local
68 if (least_in_flight_.IsInitialized() && least_in_flight_ >= packet_number) { in DetectLosses()
74 it += (least_in_flight_ - packet_number); in DetectLosses()
75 packet_number = least_in_flight_; in DetectLosses()
82 for (; it != unacked_packets.end() && packet_number <= largest_newly_acked; in DetectLosses()
83 ++it, ++packet_number) { in DetectLosses()
94 if (parent_ != nullptr && largest_newly_acked != packet_number) { in DetectLosses()
[all …]
Dhybrid_slow_start_test.cc27 QuicPacketNumber packet_number(1); in TEST_F() local
31 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
34 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number)); in TEST_F()
36 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
37 EXPECT_TRUE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
40 EXPECT_TRUE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
44 while (packet_number < end_packet_number) { in TEST_F()
45 EXPECT_FALSE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
47 EXPECT_TRUE(slow_start_->IsEndOfRound(packet_number++)); in TEST_F()
/external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/frames/
Dquic_ack_frame.cc18 QuicPacketNumber packet_number, in IsAwaitingPacket() argument
20 QUICHE_DCHECK(packet_number.IsInitialized()); in IsAwaitingPacket()
22 packet_number >= peer_least_packet_awaiting_ack) && in IsAwaitingPacket()
23 !ack_frame.packets.Contains(packet_number); in IsAwaitingPacket()
70 void PacketNumberQueue::Add(QuicPacketNumber packet_number) { in Add() argument
71 if (!packet_number.IsInitialized()) { in Add()
74 packet_number_intervals_.AddOptimizedForAppend(packet_number, in Add()
75 packet_number + 1); in Add()
104 bool PacketNumberQueue::Contains(QuicPacketNumber packet_number) const { in Contains()
105 if (!packet_number.IsInitialized()) { in Contains()
[all …]
/external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/frames/
Dquic_ack_frame.cc18 QuicPacketNumber packet_number, in IsAwaitingPacket() argument
20 QUICHE_DCHECK(packet_number.IsInitialized()); in IsAwaitingPacket()
22 packet_number >= peer_least_packet_awaiting_ack) && in IsAwaitingPacket()
23 !ack_frame.packets.Contains(packet_number); in IsAwaitingPacket()
70 void PacketNumberQueue::Add(QuicPacketNumber packet_number) { in Add() argument
71 if (!packet_number.IsInitialized()) { in Add()
74 packet_number_intervals_.AddOptimizedForAppend(packet_number, in Add()
75 packet_number + 1); in Add()
104 bool PacketNumberQueue::Contains(QuicPacketNumber packet_number) const { in Contains()
105 if (!packet_number.IsInitialized()) { in Contains()
[all …]

1234567891011