net/quic/congestion_control/fix_rate_test.cc - Issue 420313005: Land Recent QUIC Changes.

Side by Side Diff: net/quic/congestion_control/fix_rate_test.cc

Issue 420313005: Land Recent QUIC Changes. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@Final_0723

Patch Set: change QUIC packet size to 1350 Created 6 years, 4 months ago

Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.

Jump to:

View unified diff | Download patch

OLD	NEW
	(Empty)
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

3 // found in the LICENSE file.

4

5 // Test for FixRate sender and receiver.

6

7 #include "base/logging.h"

8 #include "base/memory/scoped_ptr.h"

9 #include "net/quic/congestion_control/fix_rate_receiver.h"

10 #include "net/quic/congestion_control/fix_rate_sender.h"

11 #include "net/quic/congestion_control/rtt_stats.h"

12 #include "net/quic/quic_protocol.h"

13 #include "net/quic/test_tools/mock_clock.h"

14 #include "testing/gmock/include/gmock/gmock.h"

15 #include "testing/gtest/include/gtest/gtest.h"

16

17 namespace net {

18 namespace test {

19

20 // bytes_in_flight is unused by FixRateSender's OnPacketSent.

21 QuicByteCount kUnused = 0;

22

23 class FixRateReceiverPeer : public FixRateReceiver {

24 public:

25 FixRateReceiverPeer()

26 : FixRateReceiver() {

27 }

28 void SetBitrate(QuicBandwidth fix_rate) {

29 FixRateReceiver::configured_rate_ = fix_rate;

30 }

31 };

32

33 class FixRateTest : public ::testing::Test {

34 protected:

35 FixRateTest()

36 : sender_(new FixRateSender(&rtt_stats_)),

37 receiver_(new FixRateReceiverPeer()),

38 start_(clock_.Now()) {

39 // Make sure clock does not start at 0.

40 clock_.AdvanceTime(QuicTime::Delta::FromMilliseconds(2));

41 }

42 RttStats rtt_stats_;

43 MockClock clock_;

44 scoped_ptr<FixRateSender> sender_;

45 scoped_ptr<FixRateReceiverPeer> receiver_;

46 const QuicTime start_;

47 };

48

49 TEST_F(FixRateTest, ReceiverAPI) {

50 QuicCongestionFeedbackFrame feedback;

51 QuicTime timestamp(QuicTime::Zero());

52 receiver_->SetBitrate(QuicBandwidth::FromKBytesPerSecond(300));

53 receiver_->RecordIncomingPacket(1, 1, timestamp);

54 ASSERT_TRUE(receiver_->GenerateCongestionFeedback(&feedback));

55 EXPECT_EQ(kFixRate, feedback.type);

56 EXPECT_EQ(300000u, feedback.fix_rate.bitrate.ToBytesPerSecond());

57 }

58

59 TEST_F(FixRateTest, SenderAPI) {

60 QuicCongestionFeedbackFrame feedback;

61 feedback.type = kFixRate;

62 feedback.fix_rate.bitrate = QuicBandwidth::FromKBytesPerSecond(300);

63 sender_->OnIncomingQuicCongestionFeedbackFrame(feedback, clock_.Now());

64 EXPECT_EQ(300000, sender_->BandwidthEstimate().ToBytesPerSecond());

65 EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(),

66 0,

67 HAS_RETRANSMITTABLE_DATA).IsZero());

68

69 sender_->OnPacketSent(clock_.Now(), kUnused, 1, kDefaultMaxPacketSize,

70 HAS_RETRANSMITTABLE_DATA);

71 EXPECT_FALSE(sender_->TimeUntilSend(clock_.Now(),

72 kDefaultMaxPacketSize,

73 HAS_RETRANSMITTABLE_DATA).IsZero());

74 clock_.AdvanceTime(sender_->TimeUntilSend(clock_.Now(),

75 kDefaultMaxPacketSize,

76 HAS_RETRANSMITTABLE_DATA));

77 EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(),

78 kDefaultMaxPacketSize,

79 HAS_RETRANSMITTABLE_DATA).IsZero());

80 sender_->OnPacketSent(clock_.Now(), kUnused, 2, kDefaultMaxPacketSize,

81 HAS_RETRANSMITTABLE_DATA);

82 EXPECT_FALSE(sender_->TimeUntilSend(clock_.Now(),

83 kDefaultMaxPacketSize,

84 HAS_RETRANSMITTABLE_DATA).IsZero());

85 // Advance the time twice as much and expect only one packet to be sent.

86 clock_.AdvanceTime(sender_->TimeUntilSend(

87 clock_.Now(),

88 kDefaultMaxPacketSize,

89 HAS_RETRANSMITTABLE_DATA).Multiply(2));

90 EXPECT_TRUE(sender_->TimeUntilSend(clock_.Now(),

91 kDefaultMaxPacketSize,

92 HAS_RETRANSMITTABLE_DATA).IsZero());

93 sender_->OnPacketSent(clock_.Now(), kUnused, 3, kDefaultMaxPacketSize,

94 HAS_RETRANSMITTABLE_DATA);

95 EXPECT_FALSE(sender_->TimeUntilSend(clock_.Now(),

96 kDefaultMaxPacketSize,

97 HAS_RETRANSMITTABLE_DATA).IsZero());

98 }

99

100 } // namespace test

101 } // namespace net

OLD	NEW

« no previous file with comments | « net/quic/congestion_control/fix_rate_sender.cc ('k') | net/quic/congestion_control/receive_algorithm_interface.cc » ('j') | net/quic/quic_connection.h » ('J')