| 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 transport::CastTransportConfig transport_config; | 162 transport::CastTransportConfig transport_config; |
| 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 transport_config, | 166 transport_config, |
| 167 logging_config_, |
| 166 base::Bind(&UpdateCastTransportStatus), | 168 base::Bind(&UpdateCastTransportStatus), |
| 169 transport::BulkRawEventsCallback(), |
| 170 base::TimeDelta(), |
| 167 task_runner_, | 171 task_runner_, |
| 168 &sender_to_receiver_)); | 172 &sender_to_receiver_)); |
| 169 EXPECT_CALL(mock_sender_feedback_, OnReceivedCastFeedback(_)).Times(0); | 173 EXPECT_CALL(mock_sender_feedback_, OnReceivedCastFeedback(_)).Times(0); |
| 170 } | 174 } |
| 171 | 175 |
| 172 virtual ~RtcpTest() {} | 176 virtual ~RtcpTest() {} |
| 173 | 177 |
| 174 static void UpdateCastTransportStatus(transport::CastTransportStatus status) { | 178 static void UpdateCastTransportStatus(transport::CastTransportStatus status) { |
| 175 EXPECT_EQ(status, transport::TRANSPORT_INITIALIZED); | 179 EXPECT_EQ(status, transport::TRANSPORT_INITIALIZED); |
| 176 } | 180 } |
| 177 | 181 |
| 178 void RunTasks(int during_ms) { | 182 void RunTasks(int during_ms) { |
| 179 for (int i = 0; i < during_ms; ++i) { | 183 for (int i = 0; i < during_ms; ++i) { |
| 180 // Call process the timers every 1 ms. | 184 // Call process the timers every 1 ms. |
| 181 testing_clock_->Advance(base::TimeDelta::FromMilliseconds(1)); | 185 testing_clock_->Advance(base::TimeDelta::FromMilliseconds(1)); |
| 182 task_runner_->RunTasks(); | 186 task_runner_->RunTasks(); |
| 183 } | 187 } |
| 184 } | 188 } |
| 185 | 189 |
| 186 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. | 190 base::SimpleTestTickClock* testing_clock_; // Owned by CastEnvironment. |
| 187 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; | 191 scoped_refptr<test::FakeSingleThreadTaskRunner> task_runner_; |
| 192 CastLoggingConfig logging_config_; |
| 188 scoped_refptr<CastEnvironment> cast_environment_; | 193 scoped_refptr<CastEnvironment> cast_environment_; |
| 189 RtcpTestPacketSender sender_to_receiver_; | 194 RtcpTestPacketSender sender_to_receiver_; |
| 190 scoped_ptr<transport::CastTransportSenderImpl> transport_sender_; | 195 scoped_ptr<transport::CastTransportSenderImpl> transport_sender_; |
| 191 LocalRtcpTransport receiver_to_sender_; | 196 LocalRtcpTransport receiver_to_sender_; |
| 192 MockRtcpSenderFeedback mock_sender_feedback_; | 197 MockRtcpSenderFeedback mock_sender_feedback_; |
| 193 | 198 |
| 194 DISALLOW_COPY_AND_ASSIGN(RtcpTest); | 199 DISALLOW_COPY_AND_ASSIGN(RtcpTest); |
| 195 }; | 200 }; |
| 196 | 201 |
| 197 TEST_F(RtcpTest, TimeToSend) { | 202 TEST_F(RtcpTest, TimeToSend) { |
| (...skipping 425 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 623 rtcp_peer.OnReceivedLipSyncInfo(rtp_timestamp, ntp_seconds, ntp_fractions); | 628 rtcp_peer.OnReceivedLipSyncInfo(rtp_timestamp, ntp_seconds, ntp_fractions); |
| 624 rtp_timestamp = 64000; | 629 rtp_timestamp = 64000; |
| 625 EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime( | 630 EXPECT_TRUE(rtcp_peer.RtpTimestampInSenderTime( |
| 626 frequency, rtp_timestamp, &rtp_timestamp_in_ticks)); | 631 frequency, rtp_timestamp, &rtp_timestamp_in_ticks)); |
| 627 EXPECT_EQ(input_time + base::TimeDelta::FromMilliseconds(4000), | 632 EXPECT_EQ(input_time + base::TimeDelta::FromMilliseconds(4000), |
| 628 rtp_timestamp_in_ticks); | 633 rtp_timestamp_in_ticks); |
| 629 } | 634 } |
| 630 | 635 |
| 631 } // namespace cast | 636 } // namespace cast |
| 632 } // namespace media | 637 } // namespace media |
| OLD | NEW |