| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "media/remoting/courier_renderer.h" | 5 #include "media/remoting/courier_renderer.h" |
| 6 | 6 |
| 7 #include "base/memory/ptr_util.h" | 7 #include "base/memory/ptr_util.h" |
| 8 #include "base/run_loop.h" | 8 #include "base/run_loop.h" |
| 9 #include "base/test/simple_test_tick_clock.h" | 9 #include "base/test/simple_test_tick_clock.h" |
| 10 #include "base/threading/thread_task_runner_handle.h" | 10 #include "base/threading/thread_task_runner_handle.h" |
| 11 #include "media/base/pipeline_status.h" | 11 #include "media/base/pipeline_status.h" |
| 12 #include "media/base/renderer_client.h" | 12 #include "media/base/renderer_client.h" |
| 13 #include "media/base/test_helpers.h" | 13 #include "media/base/test_helpers.h" |
| 14 #include "media/remoting/fake_demuxer_stream_provider.h" | 14 #include "media/remoting/fake_media_resource.h" |
| 15 #include "media/remoting/fake_remoter.h" | 15 #include "media/remoting/fake_remoter.h" |
| 16 #include "media/remoting/renderer_controller.h" | 16 #include "media/remoting/renderer_controller.h" |
| 17 #include "testing/gmock/include/gmock/gmock.h" | 17 #include "testing/gmock/include/gmock/gmock.h" |
| 18 #include "testing/gtest/include/gtest/gtest.h" | 18 #include "testing/gtest/include/gtest/gtest.h" |
| 19 | 19 |
| 20 using testing::_; | 20 using testing::_; |
| 21 using testing::Invoke; | 21 using testing::Invoke; |
| 22 using testing::Return; | 22 using testing::Return; |
| 23 | 23 |
| 24 namespace media { | 24 namespace media { |
| (...skipping 197 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 222 void OnSendMessageToSink(std::unique_ptr<std::vector<uint8_t>> message) { | 222 void OnSendMessageToSink(std::unique_ptr<std::vector<uint8_t>> message) { |
| 223 std::unique_ptr<pb::RpcMessage> rpc(new pb::RpcMessage()); | 223 std::unique_ptr<pb::RpcMessage> rpc(new pb::RpcMessage()); |
| 224 ASSERT_TRUE(rpc->ParseFromArray(message->data(), message->size())); | 224 ASSERT_TRUE(rpc->ParseFromArray(message->data(), message->size())); |
| 225 received_rpc_.push_back(std::move(rpc)); | 225 received_rpc_.push_back(std::move(rpc)); |
| 226 } | 226 } |
| 227 | 227 |
| 228 protected: | 228 protected: |
| 229 void InitializeRenderer() { | 229 void InitializeRenderer() { |
| 230 // Register media::RendererClient implementation. | 230 // Register media::RendererClient implementation. |
| 231 render_client_.reset(new RendererClientImpl()); | 231 render_client_.reset(new RendererClientImpl()); |
| 232 demuxer_stream_provider_.reset(new FakeDemuxerStreamProvider()); | 232 media_resource_.reset(new FakeMediaResource()); |
| 233 EXPECT_CALL(*render_client_, OnPipelineStatus(_)).Times(1); | 233 EXPECT_CALL(*render_client_, OnPipelineStatus(_)).Times(1); |
| 234 DCHECK(renderer_); | 234 DCHECK(renderer_); |
| 235 // Redirect RPC message for simulate receiver scenario | 235 // Redirect RPC message for simulate receiver scenario |
| 236 controller_->GetRpcBroker()->SetMessageCallbackForTesting(base::Bind( | 236 controller_->GetRpcBroker()->SetMessageCallbackForTesting(base::Bind( |
| 237 &CourierRendererTest::RpcMessageResponseBot, base::Unretained(this))); | 237 &CourierRendererTest::RpcMessageResponseBot, base::Unretained(this))); |
| 238 RunPendingTasks(); | 238 RunPendingTasks(); |
| 239 renderer_->Initialize(demuxer_stream_provider_.get(), render_client_.get(), | 239 renderer_->Initialize(media_resource_.get(), render_client_.get(), |
| 240 base::Bind(&RendererClientImpl::OnPipelineStatus, | 240 base::Bind(&RendererClientImpl::OnPipelineStatus, |
| 241 base::Unretained(render_client_.get()))); | 241 base::Unretained(render_client_.get()))); |
| 242 RunPendingTasks(); | 242 RunPendingTasks(); |
| 243 // Redirect RPC message back to save for later check. | 243 // Redirect RPC message back to save for later check. |
| 244 controller_->GetRpcBroker()->SetMessageCallbackForTesting(base::Bind( | 244 controller_->GetRpcBroker()->SetMessageCallbackForTesting(base::Bind( |
| 245 &CourierRendererTest::OnSendMessageToSink, base::Unretained(this))); | 245 &CourierRendererTest::OnSendMessageToSink, base::Unretained(this))); |
| 246 RunPendingTasks(); | 246 RunPendingTasks(); |
| 247 } | 247 } |
| 248 | 248 |
| 249 bool IsRendererInitialized() const { | 249 bool IsRendererInitialized() const { |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 326 message->set_video_frames_dropped(stats.video_frames_dropped); | 326 message->set_video_frames_dropped(stats.video_frames_dropped); |
| 327 message->set_audio_memory_usage(stats.audio_memory_usage); | 327 message->set_audio_memory_usage(stats.audio_memory_usage); |
| 328 message->set_video_memory_usage(stats.video_memory_usage); | 328 message->set_video_memory_usage(stats.video_memory_usage); |
| 329 OnReceivedRpc(std::move(rpc)); | 329 OnReceivedRpc(std::move(rpc)); |
| 330 RunPendingTasks(); | 330 RunPendingTasks(); |
| 331 } | 331 } |
| 332 | 332 |
| 333 base::MessageLoop message_loop_; | 333 base::MessageLoop message_loop_; |
| 334 std::unique_ptr<RendererController> controller_; | 334 std::unique_ptr<RendererController> controller_; |
| 335 std::unique_ptr<RendererClientImpl> render_client_; | 335 std::unique_ptr<RendererClientImpl> render_client_; |
| 336 std::unique_ptr<FakeDemuxerStreamProvider> demuxer_stream_provider_; | 336 std::unique_ptr<FakeMediaResource> media_resource_; |
| 337 std::unique_ptr<CourierRenderer> renderer_; | 337 std::unique_ptr<CourierRenderer> renderer_; |
| 338 base::SimpleTestTickClock* clock_; // Owned by |renderer_|; | 338 base::SimpleTestTickClock* clock_; // Owned by |renderer_|; |
| 339 | 339 |
| 340 // RPC handles. | 340 // RPC handles. |
| 341 const int receiver_renderer_handle_; | 341 const int receiver_renderer_handle_; |
| 342 const int receiver_audio_demuxer_callback_handle_; | 342 const int receiver_audio_demuxer_callback_handle_; |
| 343 const int receiver_video_demuxer_callback_handle_; | 343 const int receiver_video_demuxer_callback_handle_; |
| 344 int sender_client_handle_; | 344 int sender_client_handle_; |
| 345 int sender_renderer_callback_handle_; | 345 int sender_renderer_callback_handle_; |
| 346 int sender_audio_demuxer_handle_; | 346 int sender_audio_demuxer_handle_; |
| (...skipping 265 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 612 ASSERT_FALSE(DidEncounterFatalError()); // Not enough measurements. | 612 ASSERT_FALSE(DidEncounterFatalError()); // Not enough measurements. |
| 613 IssueStatisticsUpdateRpc(); | 613 IssueStatisticsUpdateRpc(); |
| 614 clock_->Advance(base::TimeDelta::FromSeconds(1)); | 614 clock_->Advance(base::TimeDelta::FromSeconds(1)); |
| 615 RunPendingTasks(); | 615 RunPendingTasks(); |
| 616 } | 616 } |
| 617 ASSERT_TRUE(DidEncounterFatalError()); | 617 ASSERT_TRUE(DidEncounterFatalError()); |
| 618 } | 618 } |
| 619 | 619 |
| 620 } // namespace remoting | 620 } // namespace remoting |
| 621 } // namespace media | 621 } // namespace media |
| OLD | NEW |