Searched refs:largest_observed (Results 1 - 25 of 27) sorted by relevance

12

/external/chromium_org/net/quic/congestion_control/
H A Dloss_detection_interface.h32 QuicPacketSequenceNumber largest_observed,
H A Dtcp_loss_algorithm.h32 QuicPacketSequenceNumber largest_observed,
H A Dtime_loss_algorithm.h34 QuicPacketSequenceNumber largest_observed,
H A Dtcp_loss_algorithm.cc34 QuicPacketSequenceNumber largest_observed,
42 it != unacked_packets.end() && sequence_number <= largest_observed;
59 unacked_packets.largest_sent_packet() == largest_observed) {
31 DetectLostPackets( const QuicUnackedPacketMap& unacked_packets, const QuicTime& time, QuicPacketSequenceNumber largest_observed, const RttStats& rtt_stats) argument
H A Dtime_loss_algorithm.cc33 QuicPacketSequenceNumber largest_observed,
44 it != unacked_packets.end() && sequence_number <= largest_observed;
30 DetectLostPackets( const QuicUnackedPacketMap& unacked_packets, const QuicTime& time, QuicPacketSequenceNumber largest_observed, const RttStats& rtt_stats) argument
H A Dsend_algorithm_simulator.cc256 SentPacket largest_observed; local
281 largest_observed = *it;
285 DCHECK(largest_observed.ack_time.IsInitialized());
287 << largest_observed.send_time.ToDebuggingValue() << " to ack_time:"
288 << largest_observed.ack_time.ToDebuggingValue();
290 largest_observed.ack_time.Subtract(largest_observed.send_time);
H A Dtcp_loss_algorithm_test.cc34 void VerifyLosses(QuicPacketSequenceNumber largest_observed, argument
39 unacked_packets_, clock_.Now(), largest_observed, rtt_stats_);
H A Dtime_loss_algorithm_test.cc34 void VerifyLosses(QuicPacketSequenceNumber largest_observed, argument
39 unacked_packets_, clock_.Now(), largest_observed, rtt_stats_);
/external/chromium_org/net/quic/
H A Dquic_sent_entropy_manager.cc62 // First the entropy for largest_observed sequence number should be updated.
68 QuicPacketSequenceNumber largest_observed,
71 DCHECK_GE(largest_observed, last_valid_entropy_.sequence_number);
73 if (largest_observed > GetLargestPacketWithEntropy()) {
80 // First the entropy for largest_observed sequence number should be updated.
81 UpdateCumulativeEntropy(largest_observed, &last_valid_entropy_);
67 IsValidEntropy( QuicPacketSequenceNumber largest_observed, const SequenceNumberSet& missing_packets, QuicPacketEntropyHash entropy_hash) argument
H A Dquic_received_packet_manager.cc141 ack_frame_.largest_observed = 0;
156 max(ack_frame_.largest_observed + 1, peer_least_packet_awaiting_ack_),
159 if (ack_frame_.largest_observed > sequence_number) {
167 uint32 sequence_gap = ack_frame_.largest_observed - sequence_number;
175 if (sequence_number > ack_frame_.largest_observed) {
176 ack_frame_.largest_observed = sequence_number;
224 ack_frame->entropy_hash = EntropyHash(ack_frame_.largest_observed);
241 // Remove all packets that are too far from largest_observed to express.
242 received_packet_times_.remove_if(isTooLarge(ack_frame_.largest_observed));
292 (ack_frame_.largest_observed
[all...]
H A Dquic_unacked_packet_map.h64 QuicPacketSequenceNumber largest_observed() const { function in class:net::QuicUnackedPacketMap
133 void IncreaseLargestObserved(QuicPacketSequenceNumber largest_observed);
H A Dquic_sent_entropy_manager.h42 // up to |largest_observed| removing sequence numbers from |missing_packets|.
43 // Must always be called with a monotonically increasing |largest_observed|.
44 bool IsValidEntropy(QuicPacketSequenceNumber largest_observed,
H A Dquic_received_packet_manager_test.cc28 static QuicPacketSequenceNumber largest_observed( function in class:net::test::EntropyTrackerPeer
58 EXPECT_EQ(2u, EntropyTrackerPeer::largest_observed(tracker));
75 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracker));
93 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracker));
110 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracker));
128 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracker));
144 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracker));
159 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracker));
165 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracker));
175 EXPECT_EQ(9u, EntropyTrackerPeer::largest_observed(tracke
[all...]
H A Dquic_sent_packet_manager_test.cc100 void ExpectAck(QuicPacketSequenceNumber largest_observed) { argument
102 true, _, ElementsAre(Pair(largest_observed, _)), _));
108 void ExpectUpdatedRtt(QuicPacketSequenceNumber largest_observed) { argument
117 QuicPacketSequenceNumber largest_observed,
120 rtt_updated, _, ElementsAre(Pair(largest_observed, _)),
313 ack_frame.largest_observed = 2;
333 ack_frame.largest_observed = 1;
355 ack_frame.largest_observed = 1;
379 ack_frame.largest_observed = 1;
404 ack_frame.largest_observed
116 ExpectAckAndLoss(bool rtt_updated, QuicPacketSequenceNumber largest_observed, QuicPacketSequenceNumber lost_packet) argument
[all...]
H A Dquic_sent_packet_manager.cc198 DCHECK_GE(ack_frame.largest_observed, unacked_packets_.largest_observed());
199 unacked_packets_.IncreaseLargestObserved(ack_frame.largest_observed);
232 unacked_packets_.largest_observed(),
241 least_packet_awaited_by_peer_ = ack_frame.largest_observed + 1;
270 if (sequence_number > ack_frame.largest_observed) {
285 size_t min_nacks = ack_frame.largest_observed - sequence_number;
687 unacked_packets_.largest_observed(),
716 if (!unacked_packets_.IsUnacked(ack_frame.largest_observed)) {
722 unacked_packets_.GetTransmissionInfo(ack_frame.largest_observed);
[all...]
H A Dquic_sent_packet_manager.h69 QuicPacketSequenceNumber largest_observed,
226 QuicPacketSequenceNumber largest_observed() const { function in class:net::QuicSentPacketManager
227 return unacked_packets_.largest_observed();
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_unacked_packet_map.cc231 QuicPacketSequenceNumber largest_observed) {
232 DCHECK_LE(largest_observed_, largest_observed);
233 largest_observed_ = largest_observed;
230 IncreaseLargestObserved( QuicPacketSequenceNumber largest_observed) argument
H A Dquic_protocol_test.cc39 ack_frame.largest_observed = 10u;
H A Dquic_framer.cc986 DCHECK_GE(frame.largest_observed, *frame.missing_packets.rbegin());
1007 frame.largest_observed - last_missing);
1339 if (!reader_->ReadBytes(&ack_frame->largest_observed,
1372 QuicPacketSequenceNumber last_sequence_number = ack_frame->largest_observed;
1431 QuicPacketSequenceNumber seq_num = ack_frame->largest_observed -
1453 seq_num = ack_frame->largest_observed - delta_from_largest_observed;
1786 GetMinSequenceNumberLength(ack.largest_observed);
1996 QuicPacketSequenceNumber ack_largest_observed = frame.largest_observed;
2047 // range as the largest_observed.
2180 frame.largest_observed
[all...]
H A Dquic_connection.cc636 if (incoming_ack.largest_observed > packet_generator_.sequence_number()) {
638 << incoming_ack.largest_observed << " vs "
644 if (incoming_ack.largest_observed < sent_packet_manager_.largest_observed()) {
645 DLOG(ERROR) << ENDPOINT << "Peer's largest_observed packet decreased:"
646 << incoming_ack.largest_observed << " vs "
647 << sent_packet_manager_.largest_observed();
648 // A new ack has a diminished largest_observed value. Error out.
654 *incoming_ack.missing_packets.rbegin() > incoming_ack.largest_observed) {
658 << incoming_ack.largest_observed;
[all...]
H A Dquic_protocol.cc246 return sequence_number > ack_frame.largest_observed ||
267 largest_observed(0),
381 << " largest_observed: " << ack_frame.largest_observed
H A Dquic_framer_test.cc1732 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame.largest_observed);
1837 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame.largest_observed);
1960 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame.largest_observed);
2069 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame.largest_observed);
2174 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame.largest_observed);
2283 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame.largest_observed);
2375 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame->largest_observed);
2430 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame->largest_observed);
2496 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame->largest_observed);
2571 EXPECT_EQ(GG_UINT64_C(0x0123456789ABF), frame->largest_observed);
[all...]
H A Dquic_connection_test.cc939 // Initialize a frame acknowledging all packets up to largest_observed.
940 const QuicAckFrame InitAckFrame(QuicPacketSequenceNumber largest_observed) { argument
941 QuicAckFrame frame(MakeAckFrame(largest_observed));
942 if (largest_observed > 0) {
945 largest_observed);
1037 EXPECT_EQ(1u, outgoing_ack()->largest_observed);
1041 EXPECT_EQ(2u, outgoing_ack()->largest_observed);
1045 EXPECT_EQ(3u, outgoing_ack()->largest_observed);
1053 EXPECT_EQ(3u, outgoing_ack()->largest_observed);
1058 EXPECT_EQ(3u, outgoing_ack()->largest_observed);
1942 QuicPacketSequenceNumber largest_observed; local
[all...]
/external/chromium_org/net/quic/test_tools/
H A Dquic_test_utils.cc46 QuicAckFrame MakeAckFrame(QuicPacketSequenceNumber largest_observed) { argument
48 ack.largest_observed = largest_observed;
H A Dquic_test_utils.h96 // to 0 and largest_observed from peer set to |largest_observed|.
97 QuicAckFrame MakeAckFrame(QuicPacketSequenceNumber largest_observed);
483 QuicPacketSequenceNumber largest_observed,

Completed in 5390 milliseconds

12