| /external/chromium_org/net/quic/ |
| quic_sent_entropy_manager.cc | 62 // 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_);
|
| quic_sent_entropy_manager.h | 42 // 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,
|
| quic_received_packet_manager.cc | 141 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...] |
| quic_received_packet_manager_test.cc | 28 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(tracker))
[all...] |
| quic_sent_packet_manager_test.cc | 100 void ExpectAck(QuicPacketSequenceNumber largest_observed) {
102 true, _, ElementsAre(Pair(largest_observed, _)), _));
108 void ExpectUpdatedRtt(QuicPacketSequenceNumber largest_observed) {
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 = 1
[all...] |
| quic_sent_packet_manager.cc | 198 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...] |
| quic_unacked_packet_map.h | 64 QuicPacketSequenceNumber largest_observed() const { function in class:net::QuicUnackedPacketMap
133 void IncreaseLargestObserved(QuicPacketSequenceNumber largest_observed);
|
| quic_sent_packet_manager.h | 69 QuicPacketSequenceNumber largest_observed,
226 QuicPacketSequenceNumber largest_observed() const { function in class:net::QuicSentPacketManager
227 return unacked_packets_.largest_observed();
|
| quic_unacked_packet_map.cc | 231 QuicPacketSequenceNumber largest_observed) {
232 DCHECK_LE(largest_observed_, largest_observed);
233 largest_observed_ = largest_observed;
|
| quic_protocol.cc | 246 return sequence_number > ack_frame.largest_observed ||
267 largest_observed(0),
381 << " largest_observed: " << ack_frame.largest_observed
|
| quic_connection.cc | 636 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...] |
| quic_framer.cc | [all...] |
| quic_connection_test.cc | 939 // Initialize a frame acknowledging all packets up to largest_observed.
940 const QuicAckFrame InitAckFrame(QuicPacketSequenceNumber largest_observed) {
941 QuicAckFrame frame(MakeAckFrame(largest_observed));
942 if (largest_observed > 0) {
945 largest_observed);
1942 QuicPacketSequenceNumber largest_observed; local
[all...] |
| quic_protocol_test.cc | 39 ack_frame.largest_observed = 10u;
|
| quic_received_packet_manager.h | 166 // The time we received the largest_observed sequence number, or zero if
|
| /external/chromium_org/net/quic/congestion_control/ |
| tcp_loss_algorithm.cc | 34 QuicPacketSequenceNumber largest_observed,
42 it != unacked_packets.end() && sequence_number <= largest_observed;
59 unacked_packets.largest_sent_packet() == largest_observed) {
|
| loss_detection_interface.h | 32 QuicPacketSequenceNumber largest_observed,
|
| time_loss_algorithm.cc | 33 QuicPacketSequenceNumber largest_observed,
44 it != unacked_packets.end() && sequence_number <= largest_observed;
|
| tcp_loss_algorithm.h | 32 QuicPacketSequenceNumber largest_observed,
|
| time_loss_algorithm.h | 34 QuicPacketSequenceNumber largest_observed,
|
| send_algorithm_simulator.cc | 256 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);
|
| tcp_loss_algorithm_test.cc | 34 void VerifyLosses(QuicPacketSequenceNumber largest_observed,
39 unacked_packets_, clock_.Now(), largest_observed, rtt_stats_);
|
| time_loss_algorithm_test.cc | 34 void VerifyLosses(QuicPacketSequenceNumber largest_observed,
39 unacked_packets_, clock_.Now(), largest_observed, rtt_stats_);
|
| /external/chromium_org/net/quic/test_tools/ |
| quic_test_utils.h | 96 // to 0 and largest_observed from peer set to |largest_observed|.
97 QuicAckFrame MakeAckFrame(QuicPacketSequenceNumber largest_observed);
483 QuicPacketSequenceNumber largest_observed,
|
| quic_test_utils.cc | 46 QuicAckFrame MakeAckFrame(QuicPacketSequenceNumber largest_observed) {
48 ack.largest_observed = largest_observed;
|
