OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/test/simple_test_tick_clock.h" | 5 #include "base/test/simple_test_tick_clock.h" |
6 #include "media/cast/cast_defines.h" | 6 #include "media/cast/cast_defines.h" |
7 #include "media/cast/cast_environment.h" | 7 #include "media/cast/cast_environment.h" |
8 #include "media/cast/rtcp/mock_rtcp_receiver_feedback.h" | 8 #include "media/cast/rtcp/mock_rtcp_receiver_feedback.h" |
9 #include "media/cast/rtcp/mock_rtcp_sender_feedback.h" | 9 #include "media/cast/rtcp/mock_rtcp_sender_feedback.h" |
10 #include "media/cast/rtcp/rtcp.h" | 10 #include "media/cast/rtcp/rtcp.h" |
(...skipping 127 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
138 | 138 |
139 using Rtcp::CheckForWrapAround; | 139 using Rtcp::CheckForWrapAround; |
140 using Rtcp::OnReceivedLipSyncInfo; | 140 using Rtcp::OnReceivedLipSyncInfo; |
141 }; | 141 }; |
142 | 142 |
143 class RtcpTest : public ::testing::Test { | 143 class RtcpTest : public ::testing::Test { |
144 protected: | 144 protected: |
145 RtcpTest() | 145 RtcpTest() |
146 : testing_clock_(new base::SimpleTestTickClock()), | 146 : testing_clock_(new base::SimpleTestTickClock()), |
147 task_runner_(new test::FakeSingleThreadTaskRunner(testing_clock_)), | 147 task_runner_(new test::FakeSingleThreadTaskRunner(testing_clock_)), |
| 148 logging_config_(GetDefaultCastSenderLoggingConfig()), |
148 cast_environment_(new CastEnvironment( | 149 cast_environment_(new CastEnvironment( |
149 scoped_ptr<base::TickClock>(testing_clock_).Pass(), | 150 scoped_ptr<base::TickClock>(testing_clock_).Pass(), |
150 task_runner_, | 151 task_runner_, |
151 task_runner_, | 152 task_runner_, |
152 task_runner_, | 153 task_runner_, |
153 task_runner_, | 154 task_runner_, |
154 task_runner_, | 155 task_runner_, |
155 task_runner_, | 156 task_runner_, |
156 GetDefaultCastSenderLoggingConfig())), | 157 logging_config_)), |
157 sender_to_receiver_(testing_clock_), | 158 sender_to_receiver_(testing_clock_), |
158 receiver_to_sender_(cast_environment_, testing_clock_) { | 159 receiver_to_sender_(cast_environment_, testing_clock_) { |
159 testing_clock_->Advance( | 160 testing_clock_->Advance( |
160 base::TimeDelta::FromMilliseconds(kStartMillisecond)); | 161 base::TimeDelta::FromMilliseconds(kStartMillisecond)); |
161 net::IPEndPoint dummy_endpoint; | 162 net::IPEndPoint dummy_endpoint; |
162 transport_sender_.reset(new transport::CastTransportSenderImpl( | 163 transport_sender_.reset(new transport::CastTransportSenderImpl( |
163 NULL, | 164 NULL, |
164 testing_clock_, | 165 testing_clock_, |
165 dummy_endpoint, | 166 dummy_endpoint, |
166 dummy_endpoint, | 167 dummy_endpoint, |
| 168 logging_config_, |
167 base::Bind(&UpdateCastTransportStatus), | 169 base::Bind(&UpdateCastTransportStatus), |
| 170 transport::BulkRawEventsCallback(), |
| 171 base::TimeDelta(), |
168 task_runner_, | 172 task_runner_, |
169 &sender_to_receiver_)); | 173 &sender_to_receiver_)); |
170 EXPECT_CALL(mock_sender_feedback_, OnReceivedCastFeedback(_)).Times(0); | 174 EXPECT_CALL(mock_sender_feedback_, OnReceivedCastFeedback(_)).Times(0); |
171 } | 175 } |
172 | 176 |
173 virtual ~RtcpTest() {} | 177 virtual ~RtcpTest() {} |
174 | 178 |
175 static void UpdateCastTransportStatus(transport::CastTransportStatus status) { | 179 static void UpdateCastTransportStatus(transport::CastTransportStatus status) { |
176 bool result = (status == transport::TRANSPORT_AUDIO_INITIALIZED || | 180 bool result = (status == transport::TRANSPORT_AUDIO_INITIALIZED || |
177 status == transport::TRANSPORT_VIDEO_INITIALIZED); | 181 status == transport::TRANSPORT_VIDEO_INITIALIZED); |
178 EXPECT_TRUE(result); | 182 EXPECT_TRUE(result); |
179 } | 183 } |
180 | 184 |
181 void RunTasks(int during_ms) { | 185 void RunTasks(int during_ms) { |
182 for (int i = 0; i < during_ms; ++i) { | 186 for (int i = 0; i < during_ms; ++i) { |
183 // Call process the timers every 1 ms. | 187 // Call process the timers every 1 ms. |
184 testing_clock_->Advance(base::TimeDelta::FromMilliseconds(1)); | 188 testing_clock_->Advance(base::TimeDelta::FromMilliseconds(1)); |
185 task_runner_->RunTasks(); | 189 task_runner_->RunTasks(); |
186 } | 190 } |
187 } | 191 } |
188 | 192 |
189 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. | 193 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. |
190 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; | 194 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; |
| 195 CastLoggingConfig logging_config_; |
191 scoped_refptr<CastEnvironment> cast_environment_; | 196 scoped_refptr<CastEnvironment> cast_environment_; |
192 RtcpTestPacketSender sender_to_receiver_; | 197 RtcpTestPacketSender sender_to_receiver_; |
193 scoped_ptr<transport::CastTransportSenderImpl> transport_sender_; | 198 scoped_ptr<transport::CastTransportSenderImpl> transport_sender_; |
194 LocalRtcpTransport receiver_to_sender_; | 199 LocalRtcpTransport receiver_to_sender_; |
195 MockRtcpSenderFeedback mock_sender_feedback_; | 200 MockRtcpSenderFeedback mock_sender_feedback_; |
196 | 201 |
197 DISALLOW_COPY_AND_ASSIGN(RtcpTest); | 202 DISALLOW_COPY_AND_ASSIGN(RtcpTest); |
198 }; | 203 }; |
199 | 204 |
200 TEST_F(RtcpTest, TimeToSend) { | 205 TEST_F(RtcpTest, TimeToSend) { |
(...skipping 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
626 rtcp_peer.OnReceivedLipSyncInfo(rtp_timestamp, ntp_seconds, ntp_fractions); | 631 rtcp_peer.OnReceivedLipSyncInfo(rtp_timestamp, ntp_seconds, ntp_fractions); |
627 rtp_timestamp = 64000; | 632 rtp_timestamp = 64000; |
628 EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime( | 633 EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime( |
629 frequency, rtp_timestamp, &rtp_timestamp_in_ticks)); | 634 frequency, rtp_timestamp, &rtp_timestamp_in_ticks)); |
630 EXPECT_EQ(input_time + base::TimeDelta::FromMilliseconds(4000), | 635 EXPECT_EQ(input_time + base::TimeDelta::FromMilliseconds(4000), |
631 rtp_timestamp_in_ticks); | 636 rtp_timestamp_in_ticks); |
632 } | 637 } |
633 | 638 |
634 } // namespace cast | 639 } // namespace cast |
635 } // namespace media | 640 } // namespace media |
OLD | NEW |