/external/chromium_org/net/quic/ |
H A D | quic_sent_packet_manager_test.cc | 312 QuicAckFrame ack_frame; local 313 ack_frame.largest_observed = 2; 314 ack_frame.missing_packets.insert(1); 316 manager_.OnIncomingAck(ack_frame, clock_.Now()); 332 QuicAckFrame ack_frame; local 333 ack_frame.largest_observed = 1; 335 manager_.OnIncomingAck(ack_frame, clock_.Now()); 354 QuicAckFrame ack_frame; local 355 ack_frame.largest_observed = 1; 356 manager_.OnIncomingAck(ack_frame, clock 378 QuicAckFrame ack_frame; local 403 QuicAckFrame ack_frame; local 451 QuicAckFrame ack_frame; local 482 QuicAckFrame ack_frame; local 521 QuicAckFrame ack_frame; local 553 QuicAckFrame ack_frame; local 586 QuicAckFrame ack_frame; local 618 QuicAckFrame ack_frame; local 628 QuicAckFrame ack_frame; local 682 QuicAckFrame ack_frame; local 723 QuicAckFrame ack_frame; local 746 QuicAckFrame ack_frame; local 765 QuicAckFrame ack_frame; local 783 QuicAckFrame ack_frame; local 800 QuicAckFrame ack_frame; local 841 QuicAckFrame ack_frame; local 945 QuicAckFrame ack_frame; local 1012 QuicAckFrame ack_frame; local 1085 QuicAckFrame ack_frame; local 1137 QuicAckFrame ack_frame; local 1279 QuicAckFrame ack_frame; local 1358 QuicAckFrame ack_frame; local [all...] |
H A D | quic_protocol_test.cc | 38 QuicAckFrame ack_frame; local 39 ack_frame.largest_observed = 10u; 40 EXPECT_TRUE(IsAwaitingPacket(ack_frame, 11u)); 41 EXPECT_FALSE(IsAwaitingPacket(ack_frame, 1u)); 43 ack_frame.missing_packets.insert(10); 44 EXPECT_TRUE(IsAwaitingPacket(ack_frame, 10u)); 48 QuicAckFrame ack_frame; local 49 InsertMissingPacketsBetween(&ack_frame, 4u, 10u); 50 EXPECT_EQ(6u, ack_frame.missing_packets.size()); 53 for (SequenceNumberSet::iterator it = ack_frame [all...] |
H A D | quic_sent_packet_manager.cc | 190 void QuicSentPacketManager::OnIncomingAck(const QuicAckFrame& ack_frame, argument 194 UpdatePacketInformationReceivedByPeer(ack_frame); 197 bool largest_observed_acked = MaybeUpdateRTT(ack_frame, ack_receive_time); 198 DCHECK_GE(ack_frame.largest_observed, unacked_packets_.largest_observed()); 199 unacked_packets_.IncreaseLargestObserved(ack_frame.largest_observed); 201 HandleAckForSentPackets(ack_frame); 216 if (ack_frame.is_truncated) { 230 debug_delegate_->OnIncomingAck(ack_frame, 239 const QuicAckFrame& ack_frame) { 240 if (ack_frame 238 UpdatePacketInformationReceivedByPeer( const QuicAckFrame& ack_frame) argument 261 HandleAckForSentPackets( const QuicAckFrame& ack_frame) argument 713 MaybeUpdateRTT( const QuicAckFrame& ack_frame, const QuicTime& ack_receive_time) argument [all...] |
H A D | quic_protocol.cc | 244 bool IsAwaitingPacket(const QuicAckFrame& ack_frame, argument 246 return sequence_number > ack_frame.largest_observed || 247 ContainsKey(ack_frame.missing_packets, sequence_number); 250 void InsertMissingPacketsBetween(QuicAckFrame* ack_frame, argument 254 ack_frame->missing_packets.insert(i); 328 ack_frame(frame) { 379 ostream& operator<<(ostream& os, const QuicAckFrame& ack_frame) { argument 380 os << "entropy_hash: " << static_cast<int>(ack_frame.entropy_hash) 381 << " largest_observed: " << ack_frame.largest_observed 383 << ack_frame [all...] |
H A D | quic_received_packet_manager.cc | 222 QuicAckFrame* ack_frame, QuicTime approximate_now) { 223 *ack_frame = ack_frame_; 224 ack_frame->entropy_hash = EntropyHash(ack_frame_.largest_observed); 228 ack_frame->delta_time_largest_observed = QuicTime::Delta::Infinite(); 234 ack_frame->delta_time_largest_observed = QuicTime::Delta::Zero(); 238 ack_frame->delta_time_largest_observed = 244 ack_frame->received_packet_times = received_packet_times_; 221 UpdateReceivedPacketInfo( QuicAckFrame* ack_frame, QuicTime approximate_now) argument
|
H A D | quic_sent_packet_manager.h | 67 const QuicAckFrame& ack_frame, 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, 66 OnIncomingAck( const QuicAckFrame& ack_frame, QuicTime ack_receive_time, QuicPacketSequenceNumber largest_observed, bool largest_observed_acked, QuicPacketSequenceNumber least_unacked_sent_packet) argument
|
H A D | quic_packet_creator_test.cc | 157 delete frames_[0].ack_frame; 249 delete frames_[0].ack_frame; 273 QuicFrame ack_frame = QuicFrame(new QuicAckFrame(MakeAckFrame(0u))); local 274 creator_.AddSavedFrame(ack_frame); 338 delete ack_frame.ack_frame; 421 delete frames_[0].ack_frame; 916 QuicAckFrame ack_frame(MakeAckFrame(0u)); 917 EXPECT_TRUE(creator_.AddSavedFrame(QuicFrame(&ack_frame))); 939 EXPECT_FALSE(creator_.AddSavedFrame(QuicFrame(&ack_frame))); 972 QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(2000u, 0u); local 1018 QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(2000u, 0u); local [all...] |
H A D | quic_received_packet_manager.h | 117 // Update the |ack_frame| for an outgoing ack. 118 void UpdateReceivedPacketInfo(QuicAckFrame* ack_frame,
|
H A D | quic_framer.cc | 358 header, *frame.ack_frame, &writer)) { 1321 bool QuicFramer::ProcessAckFrame(uint8 frame_type, QuicAckFrame* ack_frame) { argument 1330 ack_frame->is_truncated = frame_type & kQuicAckTruncatedMask; 1334 if (!reader_->ReadBytes(&ack_frame->entropy_hash, 1)) { 1339 if (!reader_->ReadBytes(&ack_frame->largest_observed, 1352 ack_frame->delta_time_largest_observed = QuicTime::Delta::Infinite(); 1354 ack_frame->delta_time_largest_observed = 1358 if (!ProcessTimestampsInAckFrame(ack_frame)) { 1372 QuicPacketSequenceNumber last_sequence_number = ack_frame->largest_observed; 1386 ack_frame 1415 ProcessTimestampsInAckFrame(QuicAckFrame* ack_frame) argument [all...] |
H A D | quic_framer_test.cc | 2609 // ack_frame.feedback.tcp.receive_window 3664 QuicAckFrame ack_frame; local 3665 ack_frame.entropy_hash = 0x43; 3666 ack_frame.largest_observed = GG_UINT64_C(0x770123456789ABF); 3667 ack_frame.delta_time_largest_observed = QuicTime::Delta::Zero(); 3668 ack_frame.missing_packets.insert( 3672 frames.push_back(QuicFrame(&ack_frame)); 3727 QuicAckFrame ack_frame; local 3728 ack_frame.entropy_hash = 0x43; 3729 ack_frame 3795 QuicAckFrame ack_frame; local 3910 QuicAckFrame ack_frame; local 4026 QuicAckFrame ack_frame; local 4095 QuicAckFrame ack_frame; local 4782 QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(300, 0u); local 4825 QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(300, 0u); local 4869 QuicAckFrame ack_frame = MakeAckFrameWithNackRanges(300, 0u); local 4908 QuicAckFrame ack_frame; local [all...] |
H A D | quic_protocol.h | 714 const QuicAckFrame& ack_frame, 719 QuicAckFrame* ack_frame, 884 QuicAckFrame* ack_frame; member in union:net::QuicFrame::__anon9476
|
H A D | quic_packet_generator.cc | 56 delete it->ack_frame;
|
H A D | quic_connection_logger.cc | 398 base::Bind(&NetLogQuicAckFrameCallback, frame.ack_frame)); 400 frame.ack_frame->missing_packets;
|
H A D | quic_connection_test.cc | 3717 QuicAckFrame ack_frame = InitAckFrame(1); local 3718 ProcessAckPacket(&ack_frame); 3812 QuicAckFrame ack_frame = InitAckFrame(1); local 3813 frames.push_back(QuicFrame(&ack_frame));
|