Cross Reference: /external/chromium_org/net/quic/quic_sent_packet_manager

Lines Matching refs:manager_
47       : manager_(true, &clock_, &stats_, kCubic, kNack),
50     QuicSentPacketManagerPeer::SetSendAlgorithm(&manager_, send_algorithm_);
52     QuicSentPacketManagerPeer::SetMaxTailLossProbes(&manager_, 0);
55     manager_.set_network_change_visitor(network_change_visitor_.get());
71     return QuicSentPacketManagerPeer::GetBytesInFlight(&manager_);
76       EXPECT_FALSE(manager_.HasUnackedPackets());
78           &manager_));
82     EXPECT_TRUE(manager_.HasUnackedPackets());
83     EXPECT_EQ(packets[0], manager_.GetLeastUnacked());
85       EXPECT_TRUE(manager_.IsUnacked(packets[i])) << packets[i];
93                   &manager_));
95       EXPECT_TRUE(manager_.HasRetransmittableFrames(packets[i]))
157         &manager_, old_sequence_number, TLP_RETRANSMISSION);
158     EXPECT_TRUE(manager_.HasPendingRetransmissions());
160         manager_.NextPendingRetransmission();
164     manager_.OnRetransmittedPacket(old_sequence_number,
167         &manager_, new_sequence_number));
178     manager_.OnPacketSent(new_sequence_number,
213     manager_.OnSerializedPacket(packet);
214     manager_.OnPacketSent(sequence_number, clock_.Now(),
228     manager_.OnSerializedPacket(packet);
229     manager_.OnPacketSent(sequence_number, clock_.ApproximateNow(),
240     manager_.OnSerializedPacket(packet);
241     manager_.OnPacketSent(sequence_number, clock_.ApproximateNow(),
252     manager_.OnSerializedPacket(packet);
253     manager_.OnPacketSent(sequence_number, clock_.Now(),
261     EXPECT_TRUE(manager_.HasPendingRetransmissions());
267         manager_.NextPendingRetransmission();
268     manager_.OnRetransmittedPacket(pending.sequence_number,
270     manager_.OnPacketSent(retransmission_sequence_number, clock_.Now(),
275   QuicSentPacketManager manager_;
288   manager_.OnSerializedPacket(serialized_packet);
300   EXPECT_TRUE(QuicSentPacketManagerPeer::IsRetransmission(&manager_, 2));
316   manager_.OnIncomingAck(ack_frame, clock_.Now());
321   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
328       &manager_, 1, TLP_RETRANSMISSION);
329   EXPECT_TRUE(manager_.HasPendingRetransmissions());
335   manager_.OnIncomingAck(ack_frame, clock_.Now());
338   EXPECT_FALSE(manager_.HasPendingRetransmissions());
356   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
361   EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
366   EXPECT_EQ(QuicTime::Zero(), manager_.GetRetransmissionTime());
380   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
385   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
396   manager_.OnPacketSent(2, clock_.ApproximateNow(), kDefaultLength,
405   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
416   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
420   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
424   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
428   EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
433   EXPECT_EQ(QuicTime::Zero(), manager_.GetRetransmissionTime());
445   manager_.OnRetransmissionTimeout();
446   EXPECT_TRUE(manager_.HasPendingRetransmissions());
455   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
460   EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
465   EXPECT_EQ(QuicTime::Zero(), manager_.GetRetransmissionTime());
472   manager_.set_debug_delegate(&debug_delegate);
484   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
489   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
498   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
502   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
507   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
510   EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
527   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
529   EXPECT_FALSE(manager_.HasPendingRetransmissions());
532   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
539   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
541   EXPECT_FALSE(manager_.HasPendingRetransmissions());
559   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
561   EXPECT_TRUE(manager_.HasPendingRetransmissions());
572   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
574   EXPECT_FALSE(manager_.HasPendingRetransmissions());
596   manager_.OnIncomingAck(ack_frame, clock_.Now());
622     manager_.OnIncomingAck(ack_frame, clock_.Now());
623     EXPECT_TRUE(manager_.IsUnacked(4));
636     manager_.OnIncomingAck(ack_frame, clock_.Now());
647   EXPECT_EQ(1u, manager_.GetLeastUnacked());
653   manager_.OnSerializedPacket(serialized_packet);
654   EXPECT_EQ(1u, manager_.GetLeastUnacked());
660   manager_.OnSerializedPacket(serialized_packet);
661   EXPECT_EQ(1u, manager_.GetLeastUnacked());
668   EXPECT_EQ(1u, manager_.GetLeastUnacked());
671   EXPECT_EQ(1u, manager_.GetLeastUnacked());
674   EXPECT_EQ(1u, manager_.GetLeastUnacked());
685   manager_.OnIncomingAck(ack_frame, clock_.Now());
687   EXPECT_EQ(1u, manager_.GetLeastUnacked());
694   manager_.OnSerializedPacket(serialized_packet);
697   manager_.OnPacketSent(1, QuicTime::Zero(), kDefaultLength, NOT_RETRANSMISSION,
702   manager_.OnSerializedPacket(serialized_packet2);
705   manager_.OnPacketSent(2, sent_time, kDefaultLength, NOT_RETRANSMISSION,
712   EXPECT_TRUE(manager_.HasUnackedPackets());
714             QuicSentPacketManagerPeer::GetSentTime(&manager_, 1));
715   EXPECT_EQ(sent_time, QuicSentPacketManagerPeer::GetSentTime(&manager_, 2));
729   manager_.OnIncomingAck(ack_frame, clock_.Now());
736   manager_.OnIncomingAck(ack_frame, clock_.Now());
750   manager_.OnIncomingAck(ack_frame, clock_.Now());
752             QuicSentPacketManagerPeer::GetRttStats(&manager_)->latest_rtt());
769   manager_.OnIncomingAck(ack_frame, clock_.Now());
771             QuicSentPacketManagerPeer::GetRttStats(&manager_)->latest_rtt());
786   manager_.OnIncomingAck(ack_frame, clock_.Now());
788             QuicSentPacketManagerPeer::GetRttStats(&manager_)->latest_rtt());
803   manager_.OnIncomingAck(ack_frame, clock_.Now());
805             QuicSentPacketManagerPeer::GetRttStats(&manager_)->latest_rtt());
809   QuicSentPacketManagerPeer::SetMaxTailLossProbes(&manager_, 2);
816   manager_.OnRetransmissionTimeout();
818             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
819   EXPECT_FALSE(manager_.HasPendingRetransmissions());
820   manager_.MaybeRetransmitTailLossProbe();
821   EXPECT_TRUE(manager_.HasPendingRetransmissions());
823   EXPECT_FALSE(manager_.HasPendingRetransmissions());
826   manager_.OnRetransmissionTimeout();
828             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
829   EXPECT_FALSE(manager_.HasPendingRetransmissions());
830   manager_.MaybeRetransmitTailLossProbe();
831   EXPECT_TRUE(manager_.HasPendingRetransmissions());
836             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
837   EXPECT_FALSE(manager_.HasPendingRetransmissions());
845   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
847   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
853   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
855   EXPECT_FALSE(manager_.HasPendingRetransmissions());
856   EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
862   QuicSentPacketManagerPeer::SetMaxTailLossProbes(&manager_, 2);
871   manager_.OnRetransmissionTimeout();
873             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
874   EXPECT_FALSE(manager_.HasPendingRetransmissions());
875   manager_.MaybeRetransmitTailLossProbe();
876   EXPECT_TRUE(manager_.HasPendingRetransmissions());
881             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
882   EXPECT_FALSE(manager_.HasPendingRetransmissions());
885   manager_.OnRetransmissionTimeout();
887             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
888   EXPECT_FALSE(manager_.HasPendingRetransmissions());
889   EXPECT_TRUE(manager_.MaybeRetransmitTailLossProbe());
890   EXPECT_TRUE(manager_.HasPendingRetransmissions());
895             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
905   manager_.OnRetransmissionTimeout();
906   EXPECT_TRUE(manager_.HasPendingRetransmissions());
921   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
924   manager_.OnRetransmissionTimeout();
926             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
929   EXPECT_FALSE(manager_.HasPendingRetransmissions());
930   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
933   manager_.OnRetransmissionTimeout();
935             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
938   EXPECT_FALSE(manager_.HasPendingRetransmissions());
939   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
951   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
953   EXPECT_FALSE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
966   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
969   manager_.OnRetransmissionTimeout();
972   EXPECT_FALSE(manager_.HasPendingRetransmissions());
973   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
977   manager_.RetransmitUnackedPackets(ALL_UNACKED_RETRANSMISSION);
980   ASSERT_TRUE(manager_.HasPendingRetransmissions());
981   EXPECT_EQ(6u, manager_.NextPendingRetransmission().sequence_number);
983   EXPECT_EQ(7u, manager_.NextPendingRetransmission().sequence_number);
986   EXPECT_TRUE(manager_.HasPendingRetransmissions());
991   EXPECT_FALSE(manager_.HasPendingRetransmissions());
993   EXPECT_EQ(8u, manager_.GetLeastUnacked());
999   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1002   manager_.OnRetransmissionTimeout();
1006   manager_.OnRetransmissionTimeout();
1015   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
1017   EXPECT_FALSE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1029   manager_.OnSerializedPacket(packet);
1030   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1033   manager_.OnRetransmissionTimeout();
1036   EXPECT_FALSE(manager_.HasPendingRetransmissions());
1037   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1044   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1047   manager_.OnRetransmissionTimeout();
1052   manager_.RetransmitUnackedPackets(ALL_UNACKED_RETRANSMISSION);
1055   EXPECT_TRUE(manager_.HasPendingRetransmissions());
1056   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1057   EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
1064   EXPECT_TRUE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1067   manager_.OnRetransmissionTimeout();
1071   manager_.OnRetransmissionTimeout();
1076   manager_.NeuterUnencryptedPackets();
1080   EXPECT_FALSE(manager_.HasPendingRetransmissions());
1081   EXPECT_FALSE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1082   EXPECT_FALSE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
1090   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
1096   QuicSentPacketManagerPeer::SetMaxTailLossProbes(&manager_, 2);
1099   manager_.OnSerializedPacket(packet);
1101   EXPECT_FALSE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1102   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
1105   manager_.OnRetransmissionTimeout();
1107             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
1108   EXPECT_FALSE(manager_.HasPendingRetransmissions());
1109   manager_.MaybeRetransmitTailLossProbe();
1110   EXPECT_TRUE(manager_.HasPendingRetransmissions());
1115             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
1116   EXPECT_FALSE(manager_.HasPendingRetransmissions());
1117   EXPECT_FALSE(QuicSentPacketManagerPeer::HasUnackedCryptoPackets(&manager_));
1118   EXPECT_TRUE(QuicSentPacketManagerPeer::HasPendingPackets(&manager_));
1123   QuicSentPacketManagerPeer::GetRttStats(&manager_)->UpdateRtt(
1126             QuicSentPacketManagerPeer::GetRttStats(&manager_)->min_rtt());
1129                 &manager_)->recent_min_rtt());
1141   manager_.OnIncomingAck(ack_frame, clock_.Now());
1146                 &manager_)->recent_min_rtt());
1150   manager_.OnIncomingAck(ack_frame, clock_.Now());
1153             QuicSentPacketManagerPeer::GetRttStats(&manager_)->min_rtt());
1156                 &manager_)->recent_min_rtt());
1170   EXPECT_FALSE(manager_.MaybeRetransmitTailLossProbe());
1171   manager_.OnRetransmissionTimeout();
1175   EXPECT_EQ(QuicTime::Zero(), manager_.GetRetransmissionTime());
1182   QuicSentPacketManagerPeer::GetRttStats(&manager_)->set_initial_rtt_us(
1185             manager_.GetRetransmissionTime());
1188   QuicSentPacketManagerPeer::GetRttStats(&manager_)->set_initial_rtt_us(
1191   QuicTime::Delta srtt = manager_.GetRttStats()->SmoothedRtt();
1193   EXPECT_EQ(expected_time, manager_.GetRetransmissionTime());
1197   manager_.OnRetransmissionTimeout();
1202   EXPECT_EQ(expected_time, manager_.GetRetransmissionTime());
1206   QuicSentPacketManagerPeer::SetMaxTailLossProbes(&manager_, 2);
1211   QuicSentPacketManagerPeer::GetRttStats(&manager_)->set_initial_rtt_us(
1214             manager_.GetRetransmissionTime());
1217   QuicSentPacketManagerPeer::GetRttStats(&manager_)->set_initial_rtt_us(
1219   QuicTime::Delta srtt = manager_.GetRttStats()->SmoothedRtt();
1222   EXPECT_EQ(expected_time, manager_.GetRetransmissionTime());
1226   manager_.OnRetransmissionTimeout();
1228             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
1229   EXPECT_FALSE(manager_.HasPendingRetransmissions());
1230   EXPECT_TRUE(manager_.MaybeRetransmitTailLossProbe());
1231   EXPECT_TRUE(manager_.HasPendingRetransmissions());
1236             manager_.TimeUntilSend(clock_.Now(), HAS_RETRANSMITTABLE_DATA));
1237   EXPECT_FALSE(manager_.HasPendingRetransmissions());
1240   EXPECT_EQ(expected_time, manager_.GetRetransmissionTime());
1244   QuicSentPacketManagerPeer::GetRttStats(&manager_)->UpdateRtt(
1258   EXPECT_EQ(expected_time, manager_.GetRetransmissionTime());
1266   manager_.OnRetransmissionTimeout();
1267   EXPECT_EQ(0u, QuicSentPacketManagerPeer::GetBytesInFlight(&manager_));
1271             QuicSentPacketManagerPeer::GetBytesInFlight(&manager_));
1272   EXPECT_TRUE(manager_.HasPendingRetransmissions());
1276   EXPECT_EQ(expected_time, manager_.GetRetransmissionTime());
1284   manager_.OnIncomingAck(ack_frame, clock_.ApproximateNow());
1285   EXPECT_FALSE(manager_.HasPendingRetransmissions());
1287             QuicSentPacketManagerPeer::GetBytesInFlight(&manager_));
1292   EXPECT_EQ(expected_time, manager_.GetRetransmissionTime());
1305               QuicSentPacketManagerPeer::GetRetransmissionDelay(&manager_));
1311     manager_.OnRetransmissionTimeout();
1321             QuicSentPacketManagerPeer::GetRetransmissionDelay(&manager_));
1333               QuicSentPacketManagerPeer::GetRetransmissionDelay(&manager_));
1339     manager_.OnRetransmissionTimeout();
1346   QuicSentPacketManagerPeer::SetLossAlgorithm(&manager_, loss_algorithm);
1361   manager_.OnIncomingAck(ack_frame, clock_.Now());
1366   EXPECT_EQ(timeout, manager_.GetRetransmissionTime());
1372   manager_.OnRetransmissionTimeout();
1378                 &manager_)->GetLossDetectionType());
1386   manager_.SetFromConfig(config);
1390                 &manager_)->GetLossDetectionType());
1396                 &manager_)->GetLossDetectionType());
1406   manager_.SetFromConfig(config);
1410                 &manager_)->GetLossDetectionType());
1420   manager_.SetFromConfig(config);
1422       manager_)->GetCongestionControlType());
1430   manager_.SetFromConfig(config);
1432       manager_)->GetCongestionControlType());
1437   EXPECT_FALSE(manager_.using_pacing());
1447   manager_.SetFromConfig(config);
1449   EXPECT_TRUE(manager_.using_pacing());
1455             manager_.GetRttStats()->SmoothedRtt().ToMicroseconds());
1463   manager_.SetFromConfig(config);
1466             manager_.GetRttStats()->SmoothedRtt().ToMicroseconds());