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/constants.h" |
11 #include "media/cast/net/rtp/receiver_stats.h" | 12 #include "media/cast/net/rtp/receiver_stats.h" |
12 #include "media/cast/net/rtp/rtp_defines.h" | 13 #include "media/cast/net/rtp/rtp_defines.h" |
13 | 14 |
14 namespace media { | 15 namespace media { |
15 namespace cast { | 16 namespace cast { |
16 | 17 |
17 static const int64 kStartMillisecond = INT64_C(12345678900000); | 18 static const int64 kStartMillisecond = INT64_C(12345678900000); |
18 static const uint32 kStdTimeIncrementMs = 33; | 19 static const uint32 kStdTimeIncrementMs = 33; |
19 | 20 |
20 class ReceiverStatsTest : public ::testing::Test { | 21 class ReceiverStatsTest : public ::testing::Test { |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
53 RtpReceiverStatistics s = stats_.GetStatistics(); | 54 RtpReceiverStatistics s = stats_.GetStatistics(); |
54 EXPECT_EQ(0u, s.fraction_lost); | 55 EXPECT_EQ(0u, s.fraction_lost); |
55 EXPECT_EQ(0u, s.cumulative_lost); | 56 EXPECT_EQ(0u, s.cumulative_lost); |
56 EXPECT_EQ(0u, s.extended_high_sequence_number); | 57 EXPECT_EQ(0u, s.extended_high_sequence_number); |
57 EXPECT_EQ(0u, s.jitter); | 58 EXPECT_EQ(0u, s.jitter); |
58 } | 59 } |
59 | 60 |
60 TEST_F(ReceiverStatsTest, LossCount) { | 61 TEST_F(ReceiverStatsTest, LossCount) { |
61 for (int i = 0; i < 300; ++i) { | 62 for (int i = 0; i < 300; ++i) { |
62 if (i % 4) | 63 if (i % 4) |
63 stats_.UpdateStatistics(rtp_header_); | 64 stats_.UpdateStatistics(rtp_header_, kVideoFrequency); |
64 if (i % 3) { | 65 if (i % 3) { |
65 rtp_header_.rtp_timestamp += 33 * 90; | 66 rtp_header_.rtp_timestamp += RtpTimeDelta::FromTimeDelta( |
| 67 base::TimeDelta::FromMilliseconds(33), kVideoFrequency); |
66 } | 68 } |
67 ++rtp_header_.sequence_number; | 69 ++rtp_header_.sequence_number; |
68 testing_clock_.Advance(delta_increments_); | 70 testing_clock_.Advance(delta_increments_); |
69 } | 71 } |
70 RtpReceiverStatistics s = stats_.GetStatistics(); | 72 RtpReceiverStatistics s = stats_.GetStatistics(); |
71 EXPECT_EQ(63u, s.fraction_lost); | 73 EXPECT_EQ(63u, s.fraction_lost); |
72 EXPECT_EQ(74u, s.cumulative_lost); | 74 EXPECT_EQ(74u, s.cumulative_lost); |
73 // Build extended sequence number. | 75 // Build extended sequence number. |
74 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; | 76 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; |
75 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 77 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
76 } | 78 } |
77 | 79 |
78 TEST_F(ReceiverStatsTest, NoLossWrap) { | 80 TEST_F(ReceiverStatsTest, NoLossWrap) { |
79 rtp_header_.sequence_number = 65500; | 81 rtp_header_.sequence_number = 65500; |
80 for (int i = 0; i < 300; ++i) { | 82 for (int i = 0; i < 300; ++i) { |
81 stats_.UpdateStatistics(rtp_header_); | 83 stats_.UpdateStatistics(rtp_header_, kVideoFrequency); |
82 if (i % 3) { | 84 if (i % 3) { |
83 rtp_header_.rtp_timestamp += 33 * 90; | 85 rtp_header_.rtp_timestamp += RtpTimeDelta::FromTimeDelta( |
| 86 base::TimeDelta::FromMilliseconds(33), kVideoFrequency); |
84 } | 87 } |
85 ++rtp_header_.sequence_number; | 88 ++rtp_header_.sequence_number; |
86 testing_clock_.Advance(delta_increments_); | 89 testing_clock_.Advance(delta_increments_); |
87 } | 90 } |
88 RtpReceiverStatistics s = stats_.GetStatistics(); | 91 RtpReceiverStatistics s = stats_.GetStatistics(); |
89 EXPECT_EQ(0u, s.fraction_lost); | 92 EXPECT_EQ(0u, s.fraction_lost); |
90 EXPECT_EQ(0u, s.cumulative_lost); | 93 EXPECT_EQ(0u, s.cumulative_lost); |
91 // Build extended sequence number (one wrap cycle). | 94 // Build extended sequence number (one wrap cycle). |
92 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; | 95 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; |
93 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 96 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
94 } | 97 } |
95 | 98 |
96 TEST_F(ReceiverStatsTest, LossCountWrap) { | 99 TEST_F(ReceiverStatsTest, LossCountWrap) { |
97 const uint32 kStartSequenceNumber = 65500; | 100 const uint32 kStartSequenceNumber = 65500; |
98 rtp_header_.sequence_number = kStartSequenceNumber; | 101 rtp_header_.sequence_number = kStartSequenceNumber; |
99 for (int i = 0; i < 300; ++i) { | 102 for (int i = 0; i < 300; ++i) { |
100 if (i % 4) | 103 if (i % 4) |
101 stats_.UpdateStatistics(rtp_header_); | 104 stats_.UpdateStatistics(rtp_header_, kVideoFrequency); |
102 if (i % 3) | 105 if (i % 3) |
103 // Update timestamp. | 106 rtp_header_.rtp_timestamp += RtpTimeDelta::FromTicks(1); |
104 ++rtp_header_.rtp_timestamp; | |
105 ++rtp_header_.sequence_number; | 107 ++rtp_header_.sequence_number; |
106 testing_clock_.Advance(delta_increments_); | 108 testing_clock_.Advance(delta_increments_); |
107 } | 109 } |
108 RtpReceiverStatistics s = stats_.GetStatistics(); | 110 RtpReceiverStatistics s = stats_.GetStatistics(); |
109 EXPECT_EQ(63u, s.fraction_lost); | 111 EXPECT_EQ(63u, s.fraction_lost); |
110 EXPECT_EQ(74u, s.cumulative_lost); | 112 EXPECT_EQ(74u, s.cumulative_lost); |
111 // Build extended sequence number (one wrap cycle). | 113 // Build extended sequence number (one wrap cycle). |
112 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; | 114 const uint32 extended_seq_num = (1 << 16) + rtp_header_.sequence_number - 1; |
113 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 115 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
114 } | 116 } |
115 | 117 |
116 TEST_F(ReceiverStatsTest, BasicJitter) { | 118 TEST_F(ReceiverStatsTest, BasicJitter) { |
117 for (int i = 0; i < 300; ++i) { | 119 for (int i = 0; i < 300; ++i) { |
118 stats_.UpdateStatistics(rtp_header_); | 120 stats_.UpdateStatistics(rtp_header_, kVideoFrequency); |
119 ++rtp_header_.sequence_number; | 121 ++rtp_header_.sequence_number; |
120 rtp_header_.rtp_timestamp += 33 * 90; | 122 rtp_header_.rtp_timestamp += RtpTimeDelta::FromTimeDelta( |
| 123 base::TimeDelta::FromMilliseconds(33), kVideoFrequency); |
121 testing_clock_.Advance(delta_increments_); | 124 testing_clock_.Advance(delta_increments_); |
122 } | 125 } |
123 RtpReceiverStatistics s = stats_.GetStatistics(); | 126 RtpReceiverStatistics s = stats_.GetStatistics(); |
124 EXPECT_FALSE(s.fraction_lost); | 127 EXPECT_FALSE(s.fraction_lost); |
125 EXPECT_FALSE(s.cumulative_lost); | 128 EXPECT_FALSE(s.cumulative_lost); |
126 // Build extended sequence number (one wrap cycle). | 129 // Build extended sequence number (one wrap cycle). |
127 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; | 130 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; |
128 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 131 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
129 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs, 300), s.jitter); | 132 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs, 300), s.jitter); |
130 } | 133 } |
131 | 134 |
132 TEST_F(ReceiverStatsTest, NonTrivialJitter) { | 135 TEST_F(ReceiverStatsTest, NonTrivialJitter) { |
133 const int kAdditionalIncrement = 5; | 136 const int kAdditionalIncrement = 5; |
134 for (int i = 0; i < 300; ++i) { | 137 for (int i = 0; i < 300; ++i) { |
135 stats_.UpdateStatistics(rtp_header_); | 138 stats_.UpdateStatistics(rtp_header_, kVideoFrequency); |
136 ++rtp_header_.sequence_number; | 139 ++rtp_header_.sequence_number; |
137 rtp_header_.rtp_timestamp += 33 * 90; | 140 rtp_header_.rtp_timestamp += RtpTimeDelta::FromTimeDelta( |
| 141 base::TimeDelta::FromMilliseconds(33), kVideoFrequency); |
138 base::TimeDelta additional_delta = | 142 base::TimeDelta additional_delta = |
139 base::TimeDelta::FromMilliseconds(kAdditionalIncrement); | 143 base::TimeDelta::FromMilliseconds(kAdditionalIncrement); |
140 testing_clock_.Advance(delta_increments_ + additional_delta); | 144 testing_clock_.Advance(delta_increments_ + additional_delta); |
141 } | 145 } |
142 RtpReceiverStatistics s = stats_.GetStatistics(); | 146 RtpReceiverStatistics s = stats_.GetStatistics(); |
143 EXPECT_FALSE(s.fraction_lost); | 147 EXPECT_FALSE(s.fraction_lost); |
144 EXPECT_FALSE(s.cumulative_lost); | 148 EXPECT_FALSE(s.cumulative_lost); |
145 // Build extended sequence number (one wrap cycle). | 149 // Build extended sequence number (one wrap cycle). |
146 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; | 150 const uint32 extended_seq_num = rtp_header_.sequence_number - 1; |
147 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); | 151 EXPECT_EQ(extended_seq_num, s.extended_high_sequence_number); |
148 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs + kAdditionalIncrement, 300), | 152 EXPECT_EQ(ExpectedJitter(kStdTimeIncrementMs + kAdditionalIncrement, 300), |
149 s.jitter); | 153 s.jitter); |
150 } | 154 } |
151 | 155 |
152 } // namespace cast | 156 } // namespace cast |
153 } // namespace media | 157 } // namespace media |
OLD | NEW |