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

/external/chromium_org/net/quic/
H A Dquic_sent_packet_manager_test.cc312 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 Dquic_protocol_test.cc38 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 Dquic_sent_packet_manager.cc190 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 Dquic_protocol.cc244 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 Dquic_received_packet_manager.cc222 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 Dquic_sent_packet_manager.h67 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 Dquic_packet_creator_test.cc157 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 Dquic_received_packet_manager.h117 // Update the |ack_frame| for an outgoing ack.
118 void UpdateReceivedPacketInfo(QuicAckFrame* ack_frame,
H A Dquic_framer.cc358 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 Dquic_framer_test.cc2609 // 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 Dquic_protocol.h714 const QuicAckFrame& ack_frame,
719 QuicAckFrame* ack_frame,
884 QuicAckFrame* ack_frame; member in union:net::QuicFrame::__anon9476
H A Dquic_packet_generator.cc56 delete it->ack_frame;
H A Dquic_connection_logger.cc398 base::Bind(&NetLogQuicAckFrameCallback, frame.ack_frame));
400 frame.ack_frame->missing_packets;
H A Dquic_connection_test.cc3717 QuicAckFrame ack_frame = InitAckFrame(1); local
3718 ProcessAckPacket(&ack_frame);
3812 QuicAckFrame ack_frame = InitAckFrame(1); local
3813 frames.push_back(QuicFrame(&ack_frame));

Completed in 536 milliseconds