| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 <gtest/gtest.h> | 5 #include <gtest/gtest.h> |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include "base/test/simple_test_tick_clock.h" | 9 #include "base/test/simple_test_tick_clock.h" |
| 10 #include "base/time/time.h" | 10 #include "base/time/time.h" |
| 11 #include "media/cast/net/rtp/receiver_stats.h" | 11 #include "media/cast/net/rtp/receiver_stats.h" |
| 12 #include "media/cast/net/rtp/rtp_defines.h" | 12 #include "media/cast/net/rtp/rtp_defines.h" |
| 13 | 13 |
| 14 namespace media { | 14 namespace media { |
| 15 namespace cast { | 15 namespace cast { |
| 16 | 16 |
| 17 static const int64 kStartMillisecond = INT64_C(12345678900000); | 17 static const int64_t kStartMillisecond = INT64_C(12345678900000); |
| 18 static const uint32 kStdTimeIncrementMs = 33; | 18 static const uint32_t kStdTimeIncrementMs = 33; |
| 19 | 19 |
| 20 class ReceiverStatsTest : public ::testing::Test { | 20 class ReceiverStatsTest : public ::testing::Test { |
| 21 protected: | 21 protected: |
| 22 ReceiverStatsTest() | 22 ReceiverStatsTest() |
| 23 : stats_(&testing_clock_) { | 23 : stats_(&testing_clock_) { |
| 24 testing_clock_.Advance( | 24 testing_clock_.Advance( |
| 25 base::TimeDelta::FromMilliseconds(kStartMillisecond)); | 25 base::TimeDelta::FromMilliseconds(kStartMillisecond)); |
| 26 start_time_ = testing_clock_.NowTicks(); | 26 start_time_ = testing_clock_.NowTicks(); |
| 27 delta_increments_ = base::TimeDelta::FromMilliseconds(kStdTimeIncrementMs); | 27 delta_increments_ = base::TimeDelta::FromMilliseconds(kStdTimeIncrementMs); |
| 28 } | 28 } |
| 29 ~ReceiverStatsTest() override {} | 29 ~ReceiverStatsTest() override {} |
| 30 | 30 |
| 31 uint32 ExpectedJitter(uint32 const_interval, int num_packets) { | 31 uint32_t ExpectedJitter(uint32_t const_interval, int num_packets) { |
| 32 float jitter = 0; | 32 float jitter = 0; |
| 33 // Assume timestamps have a constant kStdTimeIncrementMs interval. | 33 // Assume timestamps have a constant kStdTimeIncrementMs interval. |
| 34 float float_interval = | 34 float float_interval = |
| 35 static_cast<float>(const_interval - kStdTimeIncrementMs); | 35 static_cast<float>(const_interval - kStdTimeIncrementMs); |
| 36 for (int i = 0; i < num_packets; ++i) { | 36 for (int i = 0; i < num_packets; ++i) { |
| 37 jitter += (float_interval - jitter) / 16; | 37 jitter += (float_interval - jitter) / 16; |
| 38 } | 38 } |
| 39 return static_cast<uint32>(jitter + 0.5f); | 39 return static_cast<uint32_t>(jitter + 0.5f); |
| 40 } | 40 } |
| 41 | 41 |
| 42 ReceiverStats stats_; | 42 ReceiverStats stats_; |
| 43 RtpCastHeader rtp_header_; | 43 RtpCastHeader rtp_header_; |
| 44 base::SimpleTestTickClock testing_clock_; | 44 base::SimpleTestTickClock testing_clock_; |
| 45 base::TimeTicks start_time_; | 45 base::TimeTicks start_time_; |
| 46 base::TimeDelta delta_increments_; | 46 base::TimeDelta delta_increments_; |
| 47 | 47 |
| 48 private: | 48 private: |
| 49 DISALLOW_COPY_AND_ASSIGN(ReceiverStatsTest); | 49 DISALLOW_COPY_AND_ASSIGN(ReceiverStatsTest); |
| (...skipping 14 matching lines...) Expand all Loading... |
| 64 if (i % 3) { | 64 if (i % 3) { |
| 65 rtp_header_.rtp_timestamp += 33 * 90; | 65 rtp_header_.rtp_timestamp += 33 * 90; |
| 66 } | 66 } |
| 67 ++rtp_header_.sequence_number; | 67 ++rtp_header_.sequence_number; |
| 68 testing_clock_.Advance(delta_increments_); | 68 testing_clock_.Advance(delta_increments_); |
| 69 } | 69 } |
| 70 RtpReceiverStatistics s = stats_.GetStatistics(); | 70 RtpReceiverStatistics s = stats_.GetStatistics(); |
| 71 EXPECT_EQ(63u, s.fraction_lost); | 71 EXPECT_EQ(63u, s.fraction_lost); |
| 72 EXPECT_EQ(74u, s.cumulative_lost); | 72 EXPECT_EQ(74u, s.cumulative_lost); |
| 73 // Build extended sequence number. | 73 // Build extended sequence number. |
| 74 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; | 74 const uint32_t extended_seq_num = rtp_header_.sequence_number - 1; |
| 75 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 75 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
| 76 } | 76 } |
| 77 | 77 |
| 78 TEST_F(ReceiverStatsTest, NoLossWrap) { | 78 TEST_F(ReceiverStatsTest, NoLossWrap) { |
| 79 rtp_header_.sequence_number = 65500; | 79 rtp_header_.sequence_number = 65500; |
| 80 for (int i = 0; i < 300; ++i) { | 80 for (int i = 0; i < 300; ++i) { |
| 81 stats_.UpdateStatistics(rtp_header_); | 81 stats_.UpdateStatistics(rtp_header_); |
| 82 if (i % 3) { | 82 if (i % 3) { |
| 83 rtp_header_.rtp_timestamp += 33 * 90; | 83 rtp_header_.rtp_timestamp += 33 * 90; |
| 84 } | 84 } |
| 85 ++rtp_header_.sequence_number; | 85 ++rtp_header_.sequence_number; |
| 86 testing_clock_.Advance(delta_increments_); | 86 testing_clock_.Advance(delta_increments_); |
| 87 } | 87 } |
| 88 RtpReceiverStatistics s = stats_.GetStatistics(); | 88 RtpReceiverStatistics s = stats_.GetStatistics(); |
| 89 EXPECT_EQ(0u, s.fraction_lost); | 89 EXPECT_EQ(0u, s.fraction_lost); |
| 90 EXPECT_EQ(0u, s.cumulative_lost); | 90 EXPECT_EQ(0u, s.cumulative_lost); |
| 91 // Build extended sequence number (one wrap cycle). | 91 // Build extended sequence number (one wrap cycle). |
| 92 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; | 92 const uint32_t extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; |
| 93 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 93 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
| 94 } | 94 } |
| 95 | 95 |
| 96 TEST_F(ReceiverStatsTest, LossCountWrap) { | 96 TEST_F(ReceiverStatsTest, LossCountWrap) { |
| 97 const uint32 kStartSequenceNumber = 65500; | 97 const uint32_t kStartSequenceNumber = 65500; |
| 98 rtp_header_.sequence_number = kStartSequenceNumber; | 98 rtp_header_.sequence_number = kStartSequenceNumber; |
| 99 for (int i = 0; i < 300; ++i) { | 99 for (int i = 0; i < 300; ++i) { |
| 100 if (i % 4) | 100 if (i % 4) |
| 101 stats_.UpdateStatistics(rtp_header_); | 101 stats_.UpdateStatistics(rtp_header_); |
| 102 if (i % 3) | 102 if (i % 3) |
| 103 // Update timestamp. | 103 // Update timestamp. |
| 104 ++rtp_header_.rtp_timestamp; | 104 ++rtp_header_.rtp_timestamp; |
| 105 ++rtp_header_.sequence_number; | 105 ++rtp_header_.sequence_number; |
| 106 testing_clock_.Advance(delta_increments_); | 106 testing_clock_.Advance(delta_increments_); |
| 107 } | 107 } |
| 108 RtpReceiverStatistics s = stats_.GetStatistics(); | 108 RtpReceiverStatistics s = stats_.GetStatistics(); |
| 109 EXPECT_EQ(63u, s.fraction_lost); | 109 EXPECT_EQ(63u, s.fraction_lost); |
| 110 EXPECT_EQ(74u, s.cumulative_lost); | 110 EXPECT_EQ(74u, s.cumulative_lost); |
| 111 // Build extended sequence number (one wrap cycle). | 111 // Build extended sequence number (one wrap cycle). |
| 112 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; | 112 const uint32_t extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; |
| 113 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 113 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
| 114 } | 114 } |
| 115 | 115 |
| 116 TEST_F(ReceiverStatsTest, BasicJitter) { | 116 TEST_F(ReceiverStatsTest, BasicJitter) { |
| 117 for (int i = 0; i < 300; ++i) { | 117 for (int i = 0; i < 300; ++i) { |
| 118 stats_.UpdateStatistics(rtp_header_); | 118 stats_.UpdateStatistics(rtp_header_); |
| 119 ++rtp_header_.sequence_number; | 119 ++rtp_header_.sequence_number; |
| 120 rtp_header_.rtp_timestamp += 33 * 90; | 120 rtp_header_.rtp_timestamp += 33 * 90; |
| 121 testing_clock_.Advance(delta_increments_); | 121 testing_clock_.Advance(delta_increments_); |
| 122 } | 122 } |
| 123 RtpReceiverStatistics s = stats_.GetStatistics(); | 123 RtpReceiverStatistics s = stats_.GetStatistics(); |
| 124 EXPECT_FALSE(s.fraction_lost); | 124 EXPECT_FALSE(s.fraction_lost); |
| 125 EXPECT_FALSE(s.cumulative_lost); | 125 EXPECT_FALSE(s.cumulative_lost); |
| 126 // Build extended sequence number (one wrap cycle). | 126 // Build extended sequence number (one wrap cycle). |
| 127 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; | 127 const uint32_t extended_seq_num = rtp_header_.sequence_number - 1; |
| 128 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 128 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
| 129 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs, 300), s.jitter); | 129 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs, 300), s.jitter); |
| 130 } | 130 } |
| 131 | 131 |
| 132 TEST_F(ReceiverStatsTest, NonTrivialJitter) { | 132 TEST_F(ReceiverStatsTest, NonTrivialJitter) { |
| 133 const int kAdditionalIncrement = 5; | 133 const int kAdditionalIncrement = 5; |
| 134 for (int i = 0; i < 300; ++i) { | 134 for (int i = 0; i < 300; ++i) { |
| 135 stats_.UpdateStatistics(rtp_header_); | 135 stats_.UpdateStatistics(rtp_header_); |
| 136 ++rtp_header_.sequence_number; | 136 ++rtp_header_.sequence_number; |
| 137 rtp_header_.rtp_timestamp += 33 * 90; | 137 rtp_header_.rtp_timestamp += 33 * 90; |
| 138 base::TimeDelta additional_delta = | 138 base::TimeDelta additional_delta = |
| 139 base::TimeDelta::FromMilliseconds(kAdditionalIncrement); | 139 base::TimeDelta::FromMilliseconds(kAdditionalIncrement); |
| 140 testing_clock_.Advance(delta_increments_ + additional_delta); | 140 testing_clock_.Advance(delta_increments_ + additional_delta); |
| 141 } | 141 } |
| 142 RtpReceiverStatistics s = stats_.GetStatistics(); | 142 RtpReceiverStatistics s = stats_.GetStatistics(); |
| 143 EXPECT_FALSE(s.fraction_lost); | 143 EXPECT_FALSE(s.fraction_lost); |
| 144 EXPECT_FALSE(s.cumulative_lost); | 144 EXPECT_FALSE(s.cumulative_lost); |
| 145 // Build extended sequence number (one wrap cycle). | 145 // Build extended sequence number (one wrap cycle). |
| 146 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; | 146 const uint32_t extended_seq_num = rtp_header_.sequence_number - 1; |
| 147 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 147 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
| 148 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs + kAdditionalIncrement, 300), | 148 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs + kAdditionalIncrement, 300), |
| 149 s.jitter); | 149 s.jitter); |
| 150 } | 150 } |
| 151 | 151 |
| 152 } // namespace cast | 152 } // namespace cast |
| 153 } // namespace media | 153 } // namespace media |
| OLD | NEW |