| /dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/test/ |
| H A D | test_QUICAckFrameCreator.cc | 47 ack_frame->~QUICFrame();
63 ack_frame->~QUICFrame();
76 ack_frame->~QUICFrame();
95 ack_frame->~QUICFrame();
114 ack_frame->~QUICFrame();
239 ack_frame->~QUICFrame();
267 ack_frame->~QUICFrame();
280 ack_frame->~QUICFrame();
347 ack_frame->~QUICFrame();
358 ack_frame->~QUICFrame();
[all …]
|
| /dports/www/trafficserver/trafficserver-9.1.1/iocore/net/quic/ |
| H A D | QUICAckFrameCreator.cc | 66 QUICAckFrame *ack_frame = nullptr; in generate_frame() local
69 return ack_frame; in generate_frame()
76 if (ack_frame != nullptr) { in generate_frame()
86 return ack_frame; in generate_frame()
254 return ack_frame; in generate_ack_frame()
258 if (ack_frame == nullptr || ack_frame->size() < maximum_frame_size) { in generate_ack_frame()
265 return ack_frame; in generate_ack_frame()
290 return ack_frame; in _create_ack_frame()
307 if (ack_frame) { in _create_ack_frame()
320 if (ack_frame) { in _create_ack_frame()
[all …]
|
| H A D | QUICLossDetector.cc | 237 QUICLossDetector::_on_ack_received(const QUICAckFrame &ack_frame, QUICPacketNumberSpace pn_space) in _on_ack_received() argument
243 this->_largest_acked_packet[index] = ack_frame.largest_acknowledged(); in _on_ack_received()
248 auto newly_acked_packets = this->_detect_and_remove_acked_packets(ack_frame, pn_space); in _on_ack_received()
261 ack_delay = HRTIME_USECONDS(ack_frame.ack_delay() << this->_ack_delay_exponent); in _on_ack_received()
268 if (ack_frame.ecn_section() != nullptr) { in _on_ack_received()
269 this->_cc->process_ecn(ack_frame, pn_space, largest_acked->time_sent); in _on_ack_received()
614 QUICLossDetector::_detect_and_remove_acked_packets(const QUICAckFrame &ack_frame, QUICPacketNumberS… in _detect_and_remove_acked_packets() argument
620 QUICPacketNumber x = ack_frame.largest_acknowledged(); in _detect_and_remove_acked_packets()
621 numbers.insert({x, static_cast<uint64_t>(x) - ack_frame.ack_block_section()->first_ack_block()}); in _detect_and_remove_acked_packets()
622 x -= ack_frame.ack_block_section()->first_ack_block() + 1; in _detect_and_remove_acked_packets()
[all …]
|
| H A D | QUICNewRenoCongestionController.cc | 133 QUICNewRenoCongestionController::process_ecn(const QUICAckFrame &ack_frame, QUICPacketNumberSpace p… in process_ecn() argument
138 …if (ack_frame.ecn_section()->ecn_ce_count() > this->_ecn_ce_counters[static_cast<int>(pn_space)]) { in process_ecn()
139 this->_ecn_ce_counters[static_cast<int>(pn_space)] = ack_frame.ecn_section()->ecn_ce_count(); in process_ecn()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/core/frames/ |
| H A D | quic_ack_frame.cc | 20 bool IsAwaitingPacket(const QuicAckFrame& ack_frame, in IsAwaitingPacket() argument
26 !ack_frame.packets.Contains(packet_number); in IsAwaitingPacket()
36 os << "{ largest_acked: " << LargestAcked(ack_frame) in operator <<()
37 << ", ack_delay_time: " << ack_frame.ack_delay_time.ToMicroseconds() in operator <<()
38 << ", packets: [ " << ack_frame.packets << " ]" in operator <<()
41 ack_frame.received_packet_times) { in operator <<()
45 os << ", ecn_counters_populated: " << ack_frame.ecn_counters_populated; in operator <<()
46 if (ack_frame.ecn_counters_populated) { in operator <<()
47 os << ", ect_0_count: " << ack_frame.ect_0_count in operator <<()
48 << ", ect_1_count: " << ack_frame.ect_1_count in operator <<()
[all …]
|
| H A D | quic_ack_frame.h | 102 const QuicAckFrame& ack_frame);
139 const QuicAckFrame& ack_frame,
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/core/frames/ |
| H A D | quic_ack_frame.cc | 20 bool IsAwaitingPacket(const QuicAckFrame& ack_frame, in IsAwaitingPacket() argument
26 !ack_frame.packets.Contains(packet_number); in IsAwaitingPacket()
41 os << "{ largest_acked: " << LargestAcked(ack_frame) in operator <<()
42 << ", ack_delay_time: " << ack_frame.ack_delay_time.ToMicroseconds() in operator <<()
43 << ", packets: [ " << ack_frame.packets << " ]" in operator <<()
46 ack_frame.received_packet_times) { in operator <<()
50 os << ", ecn_counters_populated: " << ack_frame.ecn_counters_populated; in operator <<()
51 if (ack_frame.ecn_counters_populated) { in operator <<()
52 os << ", ect_0_count: " << ack_frame.ect_0_count in operator <<()
53 << ", ect_1_count: " << ack_frame.ect_1_count in operator <<()
[all …]
|
| H A D | quic_ack_frame.h | 102 const QuicAckFrame& ack_frame);
139 const QuicAckFrame& ack_frame,
|
| H A D | quic_frame.cc | 28 QuicFrame::QuicFrame(QuicAckFrame* frame) : type(ACK_FRAME), ack_frame(frame) {} in QuicFrame()
98 delete frame->ack_frame; in DeleteFrame()
308 copy = QuicFrame(new QuicAckFrame(*frame.ack_frame)); in CopyQuicFrame()
404 os << "type { ACK_FRAME } " << *(frame.ack_frame); in operator <<()
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/net/third_party/quiche/src/quic/core/ |
| H A D | uber_received_packet_manager_test.cc | 151 EXPECT_EQ(QuicTime::Delta::Zero(), ack.ack_frame->ack_delay_time); in TEST_F()
152 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_F()
161 ack.ack_frame->ack_delay_time); in TEST_F()
163 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_F()
174 EXPECT_EQ(2u, ack.ack_frame->received_packet_times.size()); in TEST_F()
197 EXPECT_GE(10u, manager_->ack_frame().packets.NumIntervals()); in TEST_F()
199 manager_->ack_frame().packets.Max()); in TEST_F()
202 EXPECT_TRUE(manager_->ack_frame().packets.Contains( in TEST_F()
205 EXPECT_FALSE(manager_->ack_frame().packets.Contains( in TEST_F()
216 EXPECT_EQ(1u, manager_->ack_frame().received_packet_times.size()); in TEST_F()
[all …]
|
| H A D | quic_received_packet_manager_test.cc | 142 EXPECT_EQ(QuicTime::Delta::Zero(), ack.ack_frame->ack_delay_time); in TEST_P()
143 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_P()
152 ack.ack_frame->ack_delay_time); in TEST_P()
154 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_P()
168 EXPECT_EQ(2u, ack.ack_frame->received_packet_times.size()); in TEST_P()
191 EXPECT_GE(10u, received_manager_.ack_frame().packets.NumIntervals()); in TEST_P()
193 received_manager_.ack_frame().packets.Max()); in TEST_P()
196 EXPECT_TRUE(received_manager_.ack_frame().packets.Contains( in TEST_P()
199 EXPECT_FALSE(received_manager_.ack_frame().packets.Contains( in TEST_P()
210 EXPECT_EQ(1u, received_manager_.ack_frame().received_packet_times.size()); in TEST_P()
[all …]
|
| H A D | quic_coalesced_packet_test.cc | 28 QuicAckFrame ack_frame(InitAckFrame(1)); in TEST() local
29 packet1.nonretransmittable_frames.push_back(QuicFrame(&ack_frame)); in TEST()
145 QuicAckFrame ack_frame(InitAckFrame(1)); in TEST() local
146 packet1.nonretransmittable_frames.push_back(QuicFrame(&ack_frame)); in TEST()
|
| H A D | uber_received_packet_manager.cc | 213 const QuicAckFrame& UberReceivedPacketManager::ack_frame() const { in ack_frame() function in quic::UberReceivedPacketManager
215 return received_packet_managers_[0].ack_frame(); in ack_frame()
221 return received_packet_managers_[packet_number_space].ack_frame(); in GetAckFrame()
|
| H A D | quic_trace_visitor.cc | 199 info->set_ack_delay_us(frame.ack_frame->ack_delay_time.ToMicroseconds()); in PopulateFrameInfo()
200 for (const auto& interval : frame.ack_frame->packets) { in PopulateFrameInfo()
303 const QuicAckFrame& ack_frame, in OnIncomingAck() argument
315 QuicAckFrame copy_of_ack = ack_frame; in OnIncomingAck()
|
| H A D | quic_packets_test.cc | 85 QuicAckFrame ack_frame(InitAckFrame(1)); in TEST_F() local
86 packet.nonretransmittable_frames.push_back(QuicFrame(&ack_frame)); in TEST_F()
|
| /dports/net/wireshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-reload-framing.c | 52 guint32 ack_frame; in eq()
236 reload_frame->ack_frame = 0; in eq()
253 if (reload_frame->ack_frame == 0) { in eq()
254 reload_frame->ack_frame = pinfo->num; in eq()
269 reload_frame->ack_frame = (type!=DATA) ? pinfo->num : 0; in eq()
287 if (reload_frame->ack_frame) { in eq()
289 …e_add_uint(reload_framing_tree, hf_reload_framing_response_in, tvb, 0, 0, reload_frame->ack_frame); in eq()
295 if (reload_frame->ack_frame != pinfo->num) { in eq()
297 …ree_add_uint(reload_framing_tree, hf_reload_framing_duplicate, tvb, 0, 0, reload_frame->ack_frame); in eq()
|
| /dports/net/wireshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-reload-framing.c | 52 guint32 ack_frame; member
236 reload_frame->ack_frame = 0; in dissect_reload_framing_message()
253 if (reload_frame->ack_frame == 0) { in dissect_reload_framing_message()
254 reload_frame->ack_frame = pinfo->num; in dissect_reload_framing_message()
269 reload_frame->ack_frame = (type!=DATA) ? pinfo->num : 0; in dissect_reload_framing_message()
287 if (reload_frame->ack_frame) { in dissect_reload_framing_message()
289 …e_add_uint(reload_framing_tree, hf_reload_framing_response_in, tvb, 0, 0, reload_frame->ack_frame); in dissect_reload_framing_message()
295 if (reload_frame->ack_frame != pinfo->num) { in dissect_reload_framing_message()
297 …ree_add_uint(reload_framing_tree, hf_reload_framing_duplicate, tvb, 0, 0, reload_frame->ack_frame); in dissect_reload_framing_message()
|
| /dports/net/tshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-reload-framing.c | 52 guint32 ack_frame; member
236 reload_frame->ack_frame = 0; in dissect_reload_framing_message()
253 if (reload_frame->ack_frame == 0) { in dissect_reload_framing_message()
254 reload_frame->ack_frame = pinfo->num; in dissect_reload_framing_message()
269 reload_frame->ack_frame = (type!=DATA) ? pinfo->num : 0; in dissect_reload_framing_message()
287 if (reload_frame->ack_frame) { in dissect_reload_framing_message()
289 …e_add_uint(reload_framing_tree, hf_reload_framing_response_in, tvb, 0, 0, reload_frame->ack_frame); in dissect_reload_framing_message()
295 if (reload_frame->ack_frame != pinfo->num) { in dissect_reload_framing_message()
297 …ree_add_uint(reload_framing_tree, hf_reload_framing_duplicate, tvb, 0, 0, reload_frame->ack_frame); in dissect_reload_framing_message()
|
| /dports/net/tshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-reload-framing.c | 52 guint32 ack_frame; member
236 reload_frame->ack_frame = 0; in dissect_reload_framing_message()
253 if (reload_frame->ack_frame == 0) { in dissect_reload_framing_message()
254 reload_frame->ack_frame = pinfo->num; in dissect_reload_framing_message()
269 reload_frame->ack_frame = (type!=DATA) ? pinfo->num : 0; in dissect_reload_framing_message()
287 if (reload_frame->ack_frame) { in dissect_reload_framing_message()
289 …e_add_uint(reload_framing_tree, hf_reload_framing_response_in, tvb, 0, 0, reload_frame->ack_frame); in dissect_reload_framing_message()
295 if (reload_frame->ack_frame != pinfo->num) { in dissect_reload_framing_message()
297 …ree_add_uint(reload_framing_tree, hf_reload_framing_duplicate, tvb, 0, 0, reload_frame->ack_frame); in dissect_reload_framing_message()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/core/ |
| H A D | uber_received_packet_manager_test.cc | 165 EXPECT_EQ(QuicTime::Delta::Zero(), ack.ack_frame->ack_delay_time); in TEST_F()
166 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_F()
175 ack.ack_frame->ack_delay_time); in TEST_F()
177 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_F()
188 EXPECT_EQ(2u, ack.ack_frame->received_packet_times.size()); in TEST_F()
211 EXPECT_GE(10u, manager_->ack_frame().packets.NumIntervals()); in TEST_F()
213 manager_->ack_frame().packets.Max()); in TEST_F()
216 EXPECT_TRUE(manager_->ack_frame().packets.Contains( in TEST_F()
219 EXPECT_FALSE(manager_->ack_frame().packets.Contains( in TEST_F()
230 EXPECT_EQ(1u, manager_->ack_frame().received_packet_times.size()); in TEST_F()
[all …]
|
| H A D | quic_received_packet_manager_test.cc | 150 EXPECT_EQ(QuicTime::Delta::Zero(), ack.ack_frame->ack_delay_time); in TEST_P()
151 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_P()
160 ack.ack_frame->ack_delay_time); in TEST_P()
162 EXPECT_EQ(1u, ack.ack_frame->received_packet_times.size()); in TEST_P()
176 EXPECT_EQ(2u, ack.ack_frame->received_packet_times.size()); in TEST_P()
199 EXPECT_GE(10u, received_manager_.ack_frame().packets.NumIntervals()); in TEST_P()
201 received_manager_.ack_frame().packets.Max()); in TEST_P()
204 EXPECT_TRUE(received_manager_.ack_frame().packets.Contains( in TEST_P()
207 EXPECT_FALSE(received_manager_.ack_frame().packets.Contains( in TEST_P()
218 EXPECT_EQ(1u, received_manager_.ack_frame().received_packet_times.size()); in TEST_P()
[all …]
|
| H A D | uber_received_packet_manager.cc | 207 const QuicAckFrame& UberReceivedPacketManager::ack_frame() const { in ack_frame() function in quic::UberReceivedPacketManager
209 return received_packet_managers_[0].ack_frame(); in ack_frame()
215 return received_packet_managers_[packet_number_space].ack_frame(); in GetAckFrame()
|
| H A D | quic_trace_visitor.cc | 129 info->set_ack_delay_us(frame.ack_frame->ack_delay_time.ToMicroseconds()); in PopulateFrameInfo()
130 for (const auto& interval : frame.ack_frame->packets) { in PopulateFrameInfo()
232 const QuicAckFrame& ack_frame, in OnIncomingAck() argument
244 QuicAckFrame copy_of_ack = ack_frame; in OnIncomingAck()
|
| H A D | quic_coalesced_packet_test.cc | 27 QuicAckFrame ack_frame(InitAckFrame(1)); in TEST() local
28 packet1.nonretransmittable_frames.push_back(QuicFrame(&ack_frame)); in TEST()
|
| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/net/third_party/quiche/src/quic/test_tools/ |
| H A D | simple_quic_framer.cc | 97 QuicAckFrame ack_frame; in OnAckFrameStart() local
98 ack_frame.largest_acked = largest_acked; in OnAckFrameStart()
99 ack_frame.ack_delay_time = ack_delay_time; in OnAckFrameStart()
100 ack_frames_.push_back(ack_frame); in OnAckFrameStart()
|