Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(137)

Side by Side Diff: media/remoting/courier_renderer_unittest.cc

Issue 2668393002: Rename DemuxerStreamProvider into MediaResource (Closed)
Patch Set: rebase Created 3 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698