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 |