Home
last modified time | relevance | path

Searched refs:ack_frame (Results 1 – 14 of 14) sorted by relevance

/external/chromium_org/net/quic/
Dquic_sent_packet_manager_test.cc312 QuicAckFrame ack_frame; in TEST_F() local
313 ack_frame.largest_observed = 2; in TEST_F()
314 ack_frame.missing_packets.insert(1); in TEST_F()
316 manager_.OnIncomingAck(ack_frame, clock_.Now()); in TEST_F()
332 QuicAckFrame ack_frame; in TEST_F() local
333 ack_frame.largest_observed = 1; in TEST_F()
335 manager_.OnIncomingAck(ack_frame, clock_.Now()); in TEST_F()
354 QuicAckFrame ack_frame; in TEST_F() local
355 ack_frame.largest_observed = 1; in TEST_F()
356 manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow()); in TEST_F()
[all …]
Dquic_protocol_test.cc38 QuicAckFrame ack_frame; in TEST() local
39 ack_frame.largest_observed = 10u; in TEST()
40 EXPECT_TRUE(IsAwaitingPacket(ack_frame, 11u)); in TEST()
41 EXPECT_FALSE(IsAwaitingPacket(ack_frame, 1u)); in TEST()
43 ack_frame.missing_packets.insert(10); in TEST()
44 EXPECT_TRUE(IsAwaitingPacket(ack_frame, 10u)); in TEST()
48 QuicAckFrame ack_frame; in TEST() local
49 InsertMissingPacketsBetween(&ack_frame, 4u, 10u); in TEST()
50 EXPECT_EQ(6u, ack_frame.missing_packets.size()); in TEST()
53 for (SequenceNumberSet::iterator it = ack_frame.missing_packets.begin(); in TEST()
[all …]
Dquic_sent_packet_manager.cc190 void QuicSentPacketManager::OnIncomingAck(const QuicAckFrame& ack_frame, in OnIncomingAck() argument
194 UpdatePacketInformationReceivedByPeer(ack_frame); in OnIncomingAck()
197 bool largest_observed_acked = MaybeUpdateRTT(ack_frame, ack_receive_time); in OnIncomingAck()
198 DCHECK_GE(ack_frame.largest_observed, unacked_packets_.largest_observed()); in OnIncomingAck()
199 unacked_packets_.IncreaseLargestObserved(ack_frame.largest_observed); in OnIncomingAck()
201 HandleAckForSentPackets(ack_frame); in OnIncomingAck()
216 if (ack_frame.is_truncated) { in OnIncomingAck()
230 debug_delegate_->OnIncomingAck(ack_frame, in OnIncomingAck()
239 const QuicAckFrame& ack_frame) { in UpdatePacketInformationReceivedByPeer() argument
240 if (ack_frame.missing_packets.empty()) { in UpdatePacketInformationReceivedByPeer()
[all …]
Dquic_protocol.cc244 bool IsAwaitingPacket(const QuicAckFrame& ack_frame, in IsAwaitingPacket() argument
246 return sequence_number > ack_frame.largest_observed || in IsAwaitingPacket()
247 ContainsKey(ack_frame.missing_packets, sequence_number); in IsAwaitingPacket()
250 void InsertMissingPacketsBetween(QuicAckFrame* ack_frame, in InsertMissingPacketsBetween() argument
254 ack_frame->missing_packets.insert(i); in InsertMissingPacketsBetween()
328 ack_frame(frame) { in QuicFrame()
379 ostream& operator<<(ostream& os, const QuicAckFrame& ack_frame) { in operator <<() argument
380 os << "entropy_hash: " << static_cast<int>(ack_frame.entropy_hash) in operator <<()
381 << " largest_observed: " << ack_frame.largest_observed in operator <<()
383 << ack_frame.delta_time_largest_observed.ToMicroseconds() in operator <<()
[all …]
Dquic_received_packet_manager.cc222 QuicAckFrame* ack_frame, QuicTime approximate_now) { in UpdateReceivedPacketInfo() argument
223 *ack_frame = ack_frame_; in UpdateReceivedPacketInfo()
224 ack_frame->entropy_hash = EntropyHash(ack_frame_.largest_observed); in UpdateReceivedPacketInfo()
228 ack_frame->delta_time_largest_observed = QuicTime::Delta::Infinite(); in UpdateReceivedPacketInfo()
234 ack_frame->delta_time_largest_observed = QuicTime::Delta::Zero(); in UpdateReceivedPacketInfo()
238 ack_frame->delta_time_largest_observed = in UpdateReceivedPacketInfo()
244 ack_frame->received_packet_times = received_packet_times_; in UpdateReceivedPacketInfo()
Dquic_sent_packet_manager.h67 const QuicAckFrame& ack_frame, in OnIncomingAck() argument
129 void OnIncomingAck(const QuicAckFrame& ack_frame,
270 void UpdatePacketInformationReceivedByPeer(const QuicAckFrame& ack_frame);
273 void HandleAckForSentPackets(const QuicAckFrame& ack_frame);
295 bool MaybeUpdateRTT(const QuicAckFrame& ack_frame,
Dquic_framer_test.cc3664 QuicAckFrame ack_frame; in TEST_P() local
3665 ack_frame.entropy_hash = 0x43; in TEST_P()
3666 ack_frame.largest_observed = GG_UINT64_C(0x770123456789ABF); in TEST_P()
3667 ack_frame.delta_time_largest_observed = QuicTime::Delta::Zero(); in TEST_P()
3668 ack_frame.missing_packets.insert( in TEST_P()
3672 frames.push_back(QuicFrame(&ack_frame)); in TEST_P()
3727 QuicAckFrame ack_frame; in TEST_P() local
3728 ack_frame.entropy_hash = 0x43; in TEST_P()
3729 ack_frame.largest_observed = GG_UINT64_C(0x770123456789ABF); in TEST_P()
3730 ack_frame.delta_time_largest_observed = QuicTime::Delta::Zero(); in TEST_P()
[all …]
Dquic_packet_creator_test.cc157 delete frames_[0].ack_frame; in TEST_P()
249 delete frames_[0].ack_frame; in TEST_P()
273 QuicFrame ack_frame = QuicFrame(new QuicAckFrame(MakeAckFrame(0u))); in TEST_P() local
274 creator_.AddSavedFrame(ack_frame); in TEST_P()
338 delete ack_frame.ack_frame; in TEST_P()
421 delete frames_[0].ack_frame; in TEST_P()
916 QuicAckFrame ack_frame(MakeAckFrame(0u)); in TEST_P() local
917 EXPECT_TRUE(creator_.AddSavedFrame(QuicFrame(&ack_frame))); in TEST_P()
939 EXPECT_FALSE(creator_.AddSavedFrame(QuicFrame(&ack_frame))); in TEST_P()
972 QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(2000u, 0u); in TEST_P() local
[all …]
Dquic_framer.cc358 header, *frame.ack_frame, &writer)) { in BuildDataPacket()
1321 bool QuicFramer::ProcessAckFrame(uint8 frame_type, QuicAckFrame* ack_frame) { in ProcessAckFrame() argument
1330 ack_frame->is_truncated = frame_type & kQuicAckTruncatedMask; in ProcessAckFrame()
1334 if (!reader_->ReadBytes(&ack_frame->entropy_hash, 1)) { in ProcessAckFrame()
1339 if (!reader_->ReadBytes(&ack_frame->largest_observed, in ProcessAckFrame()
1352 ack_frame->delta_time_largest_observed = QuicTime::Delta::Infinite(); in ProcessAckFrame()
1354 ack_frame->delta_time_largest_observed = in ProcessAckFrame()
1358 if (!ProcessTimestampsInAckFrame(ack_frame)) { in ProcessAckFrame()
1372 QuicPacketSequenceNumber last_sequence_number = ack_frame->largest_observed; in ProcessAckFrame()
1386 ack_frame->missing_packets.insert(last_sequence_number - i); in ProcessAckFrame()
[all …]
Dquic_received_packet_manager.h118 void UpdateReceivedPacketInfo(QuicAckFrame* ack_frame,
Dquic_protocol.h714 const QuicAckFrame& ack_frame,
719 QuicAckFrame* ack_frame,
884 QuicAckFrame* ack_frame; member
Dquic_packet_generator.cc56 delete it->ack_frame; in ~QuicPacketGenerator()
Dquic_connection_logger.cc398 base::Bind(&NetLogQuicAckFrameCallback, frame.ack_frame)); in OnFrameAddedToPacket()
400 frame.ack_frame->missing_packets; in OnFrameAddedToPacket()
Dquic_connection_test.cc3717 QuicAckFrame ack_frame = InitAckFrame(1); in TEST_P() local
3718 ProcessAckPacket(&ack_frame); in TEST_P()
3812 QuicAckFrame ack_frame = InitAckFrame(1); in TEST_P() local
3813 frames.push_back(QuicFrame(&ack_frame)); in TEST_P()