| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "base/logging.h" | 5 #include "base/logging.h" |
| 6 #include "base/memory/scoped_ptr.h" | 6 #include "base/memory/scoped_ptr.h" |
| 7 #include "net/quic/congestion_control/quic_receipt_metrics_collector.h" | 7 #include "net/quic/congestion_control/quic_receipt_metrics_collector.h" |
| 8 #include "net/quic/congestion_control/quic_send_scheduler.h" | 8 #include "net/quic/congestion_control/quic_send_scheduler.h" |
| 9 #include "net/quic/test_tools/mock_clock.h" | 9 #include "net/quic/test_tools/mock_clock.h" |
| 10 #include "net/quic/quic_protocol.h" | 10 #include "net/quic/quic_protocol.h" |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 47 SetUpCongestionType(kFixRate); | 47 SetUpCongestionType(kFixRate); |
| 48 QuicAckFrame ack; | 48 QuicAckFrame ack; |
| 49 ack.received_info.largest_observed = 0; | 49 ack.received_info.largest_observed = 0; |
| 50 sender_->OnIncomingAckFrame(ack); | 50 sender_->OnIncomingAckFrame(ack); |
| 51 | 51 |
| 52 QuicCongestionFeedbackFrame feedback; | 52 QuicCongestionFeedbackFrame feedback; |
| 53 feedback.type = kFixRate; | 53 feedback.type = kFixRate; |
| 54 feedback.fix_rate.bitrate_in_bytes_per_second = 100000; | 54 feedback.fix_rate.bitrate_in_bytes_per_second = 100000; |
| 55 sender_->OnIncomingQuicCongestionFeedbackFrame(feedback); | 55 sender_->OnIncomingQuicCongestionFeedbackFrame(feedback); |
| 56 | 56 |
| 57 QuicTime acc_advance_time; | 57 QuicTime acc_advance_time(QuicTime::Zero()); |
| 58 for (int i = 1; i <= 100; ++i) { | 58 for (int i = 1; i <= 100; ++i) { |
| 59 EXPECT_TRUE(sender_->TimeUntilSend(false).IsZero()); | 59 EXPECT_TRUE(sender_->TimeUntilSend(false).IsZero()); |
| 60 EXPECT_EQ(kMaxPacketSize, sender_->AvailableCongestionWindow()); | 60 EXPECT_EQ(kMaxPacketSize, sender_->AvailableCongestionWindow()); |
| 61 sender_->SentPacket(i, kMaxPacketSize, false); | 61 sender_->SentPacket(i, kMaxPacketSize, false); |
| 62 QuicTime::Delta advance_time = sender_->TimeUntilSend(false); | 62 QuicTime::Delta advance_time = sender_->TimeUntilSend(false); |
| 63 clock_.AdvanceTime(advance_time); | 63 clock_.AdvanceTime(advance_time); |
| 64 acc_advance_time = acc_advance_time.Add(advance_time); | 64 acc_advance_time = acc_advance_time.Add(advance_time); |
| 65 // Ack the packet we sent. | 65 // Ack the packet we sent. |
| 66 ack.received_info.RecordReceived(i); | 66 ack.received_info.RecordReceived(i); |
| 67 sender_->OnIncomingAckFrame(ack); | 67 sender_->OnIncomingAckFrame(ack); |
| (...skipping 99 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 167 QuicAckFrame ack; | 167 QuicAckFrame ack; |
| 168 ack.received_info.largest_observed = 0; | 168 ack.received_info.largest_observed = 0; |
| 169 sender_->OnIncomingAckFrame(ack); | 169 sender_->OnIncomingAckFrame(ack); |
| 170 | 170 |
| 171 QuicCongestionFeedbackFrame feedback; | 171 QuicCongestionFeedbackFrame feedback; |
| 172 feedback.type = kFixRate; | 172 feedback.type = kFixRate; |
| 173 // Test a high bitrate (8Mbit/s) to trigger pacing. | 173 // Test a high bitrate (8Mbit/s) to trigger pacing. |
| 174 feedback.fix_rate.bitrate_in_bytes_per_second = 1000000; | 174 feedback.fix_rate.bitrate_in_bytes_per_second = 1000000; |
| 175 sender_->OnIncomingQuicCongestionFeedbackFrame(feedback); | 175 sender_->OnIncomingQuicCongestionFeedbackFrame(feedback); |
| 176 | 176 |
| 177 QuicTime acc_advance_time; | 177 QuicTime acc_advance_time(QuicTime::Zero()); |
| 178 for (int i = 1; i <= 100;) { | 178 for (int i = 1; i <= 100;) { |
| 179 EXPECT_TRUE(sender_->TimeUntilSend(false).IsZero()); | 179 EXPECT_TRUE(sender_->TimeUntilSend(false).IsZero()); |
| 180 EXPECT_EQ(kMaxPacketSize * 2, sender_->AvailableCongestionWindow()); | 180 EXPECT_EQ(kMaxPacketSize * 2, sender_->AvailableCongestionWindow()); |
| 181 sender_->SentPacket(i++, kMaxPacketSize, false); | 181 sender_->SentPacket(i++, kMaxPacketSize, false); |
| 182 EXPECT_TRUE(sender_->TimeUntilSend(false).IsZero()); | 182 EXPECT_TRUE(sender_->TimeUntilSend(false).IsZero()); |
| 183 sender_->SentPacket(i++, kMaxPacketSize, false); | 183 sender_->SentPacket(i++, kMaxPacketSize, false); |
| 184 QuicTime::Delta advance_time = sender_->TimeUntilSend(false); | 184 QuicTime::Delta advance_time = sender_->TimeUntilSend(false); |
| 185 clock_.AdvanceTime(advance_time); | 185 clock_.AdvanceTime(advance_time); |
| 186 acc_advance_time = acc_advance_time.Add(advance_time); | 186 acc_advance_time = acc_advance_time.Add(advance_time); |
| 187 // Ack the packets we sent. | 187 // Ack the packets we sent. |
| 188 ack.received_info.RecordReceived(i - 2); | 188 ack.received_info.RecordReceived(i - 2); |
| 189 sender_->OnIncomingAckFrame(ack); | 189 sender_->OnIncomingAckFrame(ack); |
| 190 ack.received_info.RecordReceived(i - 1); | 190 ack.received_info.RecordReceived(i - 1); |
| 191 sender_->OnIncomingAckFrame(ack); | 191 sender_->OnIncomingAckFrame(ack); |
| 192 } | 192 } |
| 193 EXPECT_EQ(QuicTime::FromMilliseconds(120), acc_advance_time); | 193 EXPECT_EQ(QuicTime::FromMilliseconds(120), acc_advance_time); |
| 194 } | 194 } |
| 195 | 195 |
| 196 } // namespace test | 196 } // namespace test |
| 197 } // namespace net | 197 } // namespace net |
| OLD | NEW |