| OLD | NEW |
| 1 // Copyright (c) 2015 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2015 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 "net/quic/congestion_control/tcp_cubic_bytes_sender.h" | 5 #include "net/quic/congestion_control/tcp_cubic_bytes_sender.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
| 11 #include "net/quic/congestion_control/rtt_stats.h" | 11 #include "net/quic/congestion_control/rtt_stats.h" |
| 12 #include "net/quic/crypto/crypto_protocol.h" | 12 #include "net/quic/crypto/crypto_protocol.h" |
| 13 #include "net/quic/proto/cached_network_parameters.pb.h" | 13 #include "net/quic/proto/cached_network_parameters.pb.h" |
| 14 #include "net/quic/quic_flags.h" | 14 #include "net/quic/quic_flags.h" |
| 15 #include "net/quic/quic_protocol.h" | 15 #include "net/quic/quic_protocol.h" |
| 16 #include "net/quic/quic_utils.h" | 16 #include "net/quic/quic_utils.h" |
| 17 #include "net/quic/test_tools/mock_clock.h" | 17 #include "net/quic/test_tools/mock_clock.h" |
| 18 #include "net/quic/test_tools/quic_config_peer.h" | 18 #include "net/quic/test_tools/quic_config_peer.h" |
| 19 #include "net/quic/test_tools/quic_test_utils.h" | 19 #include "net/quic/test_tools/quic_test_utils.h" |
| 20 #include "testing/gtest/include/gtest/gtest.h" | 20 #include "testing/gtest/include/gtest/gtest.h" |
| 21 | 21 |
| 22 namespace net { | 22 namespace net { |
| 23 namespace test { | 23 namespace test { |
| 24 | 24 |
| 25 // TODO(ianswett): A number of theses tests were written with the assumption of | 25 // TODO(ianswett): A number of theses tests were written with the assumption of |
| 26 // an initial CWND of 10. They have carefully calculated values which should be | 26 // an initial CWND of 10. They have carefully calculated values which should be |
| 27 // updated to be based on kInitialCongestionWindowInsecure. | 27 // updated to be based on kInitialCongestionWindowInsecure. |
| 28 const uint32 kInitialCongestionWindowPackets = 10; | 28 const uint32_t kInitialCongestionWindowPackets = 10; |
| 29 const uint32 kDefaultWindowTCP = | 29 const uint32_t kDefaultWindowTCP = |
| 30 kInitialCongestionWindowPackets * kDefaultTCPMSS; | 30 kInitialCongestionWindowPackets * kDefaultTCPMSS; |
| 31 const float kRenoBeta = 0.7f; // Reno backoff factor. | 31 const float kRenoBeta = 0.7f; // Reno backoff factor. |
| 32 | 32 |
| 33 class TcpCubicBytesSenderPeer : public TcpCubicBytesSender { | 33 class TcpCubicBytesSenderPeer : public TcpCubicBytesSender { |
| 34 public: | 34 public: |
| 35 TcpCubicBytesSenderPeer(const QuicClock* clock, bool reno) | 35 TcpCubicBytesSenderPeer(const QuicClock* clock, bool reno) |
| 36 : TcpCubicBytesSender(clock, | 36 : TcpCubicBytesSender(clock, |
| 37 &rtt_stats_, | 37 &rtt_stats_, |
| 38 reno, | 38 reno, |
| 39 kInitialCongestionWindowPackets, | 39 kInitialCongestionWindowPackets, |
| (...skipping 324 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 364 TEST_F(TcpCubicBytesSenderTest, RTOCongestionWindowNoRetransmission) { | 364 TEST_F(TcpCubicBytesSenderTest, RTOCongestionWindowNoRetransmission) { |
| 365 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); | 365 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); |
| 366 | 366 |
| 367 // Expect the window to remain unchanged if the RTO fires but no packets are | 367 // Expect the window to remain unchanged if the RTO fires but no packets are |
| 368 // retransmitted. | 368 // retransmitted. |
| 369 sender_->OnRetransmissionTimeout(false); | 369 sender_->OnRetransmissionTimeout(false); |
| 370 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); | 370 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); |
| 371 } | 371 } |
| 372 | 372 |
| 373 TEST_F(TcpCubicBytesSenderTest, RetransmissionDelay) { | 373 TEST_F(TcpCubicBytesSenderTest, RetransmissionDelay) { |
| 374 const int64 kRttMs = 10; | 374 const int64_t kRttMs = 10; |
| 375 const int64 kDeviationMs = 3; | 375 const int64_t kDeviationMs = 3; |
| 376 EXPECT_EQ(QuicTime::Delta::Zero(), sender_->RetransmissionDelay()); | 376 EXPECT_EQ(QuicTime::Delta::Zero(), sender_->RetransmissionDelay()); |
| 377 | 377 |
| 378 sender_->rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(kRttMs), | 378 sender_->rtt_stats_.UpdateRtt(QuicTime::Delta::FromMilliseconds(kRttMs), |
| 379 QuicTime::Delta::Zero(), clock_.Now()); | 379 QuicTime::Delta::Zero(), clock_.Now()); |
| 380 | 380 |
| 381 // Initial value is to set the median deviation to half of the initial rtt, | 381 // Initial value is to set the median deviation to half of the initial rtt, |
| 382 // the median in then multiplied by a factor of 4 and finally the smoothed rtt | 382 // the median in then multiplied by a factor of 4 and finally the smoothed rtt |
| 383 // is added which is the initial rtt. | 383 // is added which is the initial rtt. |
| 384 QuicTime::Delta expected_delay = | 384 QuicTime::Delta expected_delay = |
| 385 QuicTime::Delta::FromMilliseconds(kRttMs + kRttMs / 2 * 4); | 385 QuicTime::Delta::FromMilliseconds(kRttMs + kRttMs / 2 * 4); |
| 386 EXPECT_EQ(expected_delay, sender_->RetransmissionDelay()); | 386 EXPECT_EQ(expected_delay, sender_->RetransmissionDelay()); |
| 387 | 387 |
| 388 for (int i = 0; i < 100; ++i) { | 388 for (int i = 0; i < 100; ++i) { |
| 389 // Run to make sure that we converge. | 389 // Run to make sure that we converge. |
| 390 sender_->rtt_stats_.UpdateRtt( | 390 sender_->rtt_stats_.UpdateRtt( |
| 391 QuicTime::Delta::FromMilliseconds(kRttMs + kDeviationMs), | 391 QuicTime::Delta::FromMilliseconds(kRttMs + kDeviationMs), |
| 392 QuicTime::Delta::Zero(), clock_.Now()); | 392 QuicTime::Delta::Zero(), clock_.Now()); |
| 393 sender_->rtt_stats_.UpdateRtt( | 393 sender_->rtt_stats_.UpdateRtt( |
| 394 QuicTime::Delta::FromMilliseconds(kRttMs - kDeviationMs), | 394 QuicTime::Delta::FromMilliseconds(kRttMs - kDeviationMs), |
| 395 QuicTime::Delta::Zero(), clock_.Now()); | 395 QuicTime::Delta::Zero(), clock_.Now()); |
| 396 } | 396 } |
| 397 expected_delay = QuicTime::Delta::FromMilliseconds(kRttMs + kDeviationMs * 4); | 397 expected_delay = QuicTime::Delta::FromMilliseconds(kRttMs + kDeviationMs * 4); |
| 398 | 398 |
| 399 EXPECT_NEAR(kRttMs, sender_->rtt_stats_.smoothed_rtt().ToMilliseconds(), 1); | 399 EXPECT_NEAR(kRttMs, sender_->rtt_stats_.smoothed_rtt().ToMilliseconds(), 1); |
| 400 EXPECT_NEAR(expected_delay.ToMilliseconds(), | 400 EXPECT_NEAR(expected_delay.ToMilliseconds(), |
| 401 sender_->RetransmissionDelay().ToMilliseconds(), 1); | 401 sender_->RetransmissionDelay().ToMilliseconds(), 1); |
| 402 EXPECT_EQ( | 402 EXPECT_EQ(static_cast<int64_t>( |
| 403 static_cast<int64>(sender_->GetCongestionWindow() * kNumMicrosPerSecond / | 403 sender_->GetCongestionWindow() * kNumMicrosPerSecond / |
| 404 sender_->rtt_stats_.smoothed_rtt().ToMicroseconds()), | 404 sender_->rtt_stats_.smoothed_rtt().ToMicroseconds()), |
| 405 sender_->BandwidthEstimate().ToBytesPerSecond()); | 405 sender_->BandwidthEstimate().ToBytesPerSecond()); |
| 406 } | 406 } |
| 407 | 407 |
| 408 TEST_F(TcpCubicBytesSenderTest, TcpCubicResetEpochOnQuiescence) { | 408 TEST_F(TcpCubicBytesSenderTest, TcpCubicResetEpochOnQuiescence) { |
| 409 const int kMaxCongestionWindow = 50; | 409 const int kMaxCongestionWindow = 50; |
| 410 const QuicByteCount kMaxCongestionWindowBytes = | 410 const QuicByteCount kMaxCongestionWindowBytes = |
| 411 kMaxCongestionWindow * kDefaultTCPMSS; | 411 kMaxCongestionWindow * kDefaultTCPMSS; |
| 412 int num_sent = SendAvailableSendWindow(); | 412 int num_sent = SendAvailableSendWindow(); |
| 413 | 413 |
| 414 // Make sure we fall out of slow start. | 414 // Make sure we fall out of slow start. |
| 415 QuicByteCount saved_cwnd = sender_->GetCongestionWindow(); | 415 QuicByteCount saved_cwnd = sender_->GetCongestionWindow(); |
| (...skipping 148 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 564 for (int i = 0; i < 10; ++i) { | 564 for (int i = 0; i < 10; ++i) { |
| 565 // Send our full send window. | 565 // Send our full send window. |
| 566 SendAvailableSendWindow(); | 566 SendAvailableSendWindow(); |
| 567 EXPECT_TRUE(sender_->InRecovery()); | 567 EXPECT_TRUE(sender_->InRecovery()); |
| 568 AckNPackets(2); | 568 AckNPackets(2); |
| 569 EXPECT_EQ(expected_send_window, sender_->GetCongestionWindow()); | 569 EXPECT_EQ(expected_send_window, sender_->GetCongestionWindow()); |
| 570 } | 570 } |
| 571 EXPECT_FALSE(sender_->InRecovery()); | 571 EXPECT_FALSE(sender_->InRecovery()); |
| 572 | 572 |
| 573 // Out of recovery now. Congestion window should not grow during RTT. | 573 // Out of recovery now. Congestion window should not grow during RTT. |
| 574 for (uint64 i = 0; i < expected_send_window / kDefaultTCPMSS - 2; i += 2) { | 574 for (uint64_t i = 0; i < expected_send_window / kDefaultTCPMSS - 2; i += 2) { |
| 575 // Send our full send window. | 575 // Send our full send window. |
| 576 SendAvailableSendWindow(); | 576 SendAvailableSendWindow(); |
| 577 AckNPackets(2); | 577 AckNPackets(2); |
| 578 EXPECT_EQ(expected_send_window, sender_->GetCongestionWindow()); | 578 EXPECT_EQ(expected_send_window, sender_->GetCongestionWindow()); |
| 579 } | 579 } |
| 580 | 580 |
| 581 // Next ack should cause congestion window to grow by 1MSS. | 581 // Next ack should cause congestion window to grow by 1MSS. |
| 582 SendAvailableSendWindow(); | 582 SendAvailableSendWindow(); |
| 583 AckNPackets(2); | 583 AckNPackets(2); |
| 584 expected_send_window += kDefaultTCPMSS; | 584 expected_send_window += kDefaultTCPMSS; |
| (...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 677 // Resets cwnd and slow start threshold on connection migrations. | 677 // Resets cwnd and slow start threshold on connection migrations. |
| 678 sender_->OnConnectionMigration(); | 678 sender_->OnConnectionMigration(); |
| 679 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); | 679 EXPECT_EQ(kDefaultWindowTCP, sender_->GetCongestionWindow()); |
| 680 EXPECT_EQ(kMaxCongestionWindow * kDefaultTCPMSS, | 680 EXPECT_EQ(kMaxCongestionWindow * kDefaultTCPMSS, |
| 681 sender_->GetSlowStartThreshold()); | 681 sender_->GetSlowStartThreshold()); |
| 682 EXPECT_FALSE(sender_->hybrid_slow_start().started()); | 682 EXPECT_FALSE(sender_->hybrid_slow_start().started()); |
| 683 } | 683 } |
| 684 | 684 |
| 685 } // namespace test | 685 } // namespace test |
| 686 } // namespace net | 686 } // namespace net |
| OLD | NEW |