OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "content/renderer/media/media_stream_video_renderer_sink.h" | 5 #include "content/renderer/media/media_stream_video_renderer_sink.h" |
6 | 6 |
7 #include "base/single_thread_task_runner.h" | 7 #include "base/single_thread_task_runner.h" |
8 #include "base/thread_task_runner_handle.h" | 8 #include "base/thread_task_runner_handle.h" |
9 #include "base/trace_event/trace_event.h" | 9 #include "base/trace_event/trace_event.h" |
10 #include "media/base/bind_to_current_loop.h" | 10 #include "media/base/bind_to_current_loop.h" |
(...skipping 16 matching lines...) Expand all Loading... |
27 : error_cb_(error_cb), | 27 : error_cb_(error_cb), |
28 repaint_cb_(repaint_cb), | 28 repaint_cb_(repaint_cb), |
29 task_runner_(base::ThreadTaskRunnerHandle::Get()), | 29 task_runner_(base::ThreadTaskRunnerHandle::Get()), |
30 state_(STOPPED), | 30 state_(STOPPED), |
31 frame_size_(kMinFrameSize, kMinFrameSize), | 31 frame_size_(kMinFrameSize, kMinFrameSize), |
32 video_track_(video_track), | 32 video_track_(video_track), |
33 media_task_runner_(media_task_runner), | 33 media_task_runner_(media_task_runner), |
34 weak_factory_(this) { | 34 weak_factory_(this) { |
35 if (gpu_factories && | 35 if (gpu_factories && |
36 gpu_factories->ShouldUseGpuMemoryBuffersForVideoFrames()) { | 36 gpu_factories->ShouldUseGpuMemoryBuffersForVideoFrames()) { |
37 gpu_memory_buffer_pool_.reset(new media::GpuMemoryBufferVideoFramePool( | 37 gpu_memory_buffer_copier_.reset(new media::GpuMemoryBufferVideoFrameCopier( |
38 media_task_runner, worker_task_runner, gpu_factories)); | 38 media_task_runner, worker_task_runner, gpu_factories)); |
39 } | 39 } |
40 } | 40 } |
41 | 41 |
42 MediaStreamVideoRendererSink::~MediaStreamVideoRendererSink() { | 42 MediaStreamVideoRendererSink::~MediaStreamVideoRendererSink() { |
43 if (gpu_memory_buffer_pool_) { | 43 if (gpu_memory_buffer_copier_) { |
44 media_task_runner_->DeleteSoon(FROM_HERE, | 44 media_task_runner_->DeleteSoon(FROM_HERE, |
45 gpu_memory_buffer_pool_.release()); | 45 gpu_memory_buffer_copier_.release()); |
46 } | 46 } |
47 } | 47 } |
48 | 48 |
49 void MediaStreamVideoRendererSink::Start() { | 49 void MediaStreamVideoRendererSink::Start() { |
50 DCHECK(task_runner_->BelongsToCurrentThread()); | 50 DCHECK(task_runner_->BelongsToCurrentThread()); |
51 DCHECK_EQ(state_, STOPPED); | 51 DCHECK_EQ(state_, STOPPED); |
52 | 52 |
53 MediaStreamVideoSink::ConnectToTrack(video_track_, | 53 MediaStreamVideoSink::ConnectToTrack(video_track_, |
54 media::BindToCurrentLoop( | 54 media::BindToCurrentLoop( |
55 base::Bind( | 55 base::Bind( |
(...skipping 24 matching lines...) Expand all Loading... |
80 state_ = STARTED; | 80 state_ = STARTED; |
81 } | 81 } |
82 | 82 |
83 void MediaStreamVideoRendererSink::Pause() { | 83 void MediaStreamVideoRendererSink::Pause() { |
84 DCHECK(task_runner_->BelongsToCurrentThread()); | 84 DCHECK(task_runner_->BelongsToCurrentThread()); |
85 if (state_ == STARTED) | 85 if (state_ == STARTED) |
86 state_ = PAUSED; | 86 state_ = PAUSED; |
87 } | 87 } |
88 | 88 |
89 void MediaStreamVideoRendererSink::SetGpuMemoryBufferVideoForTesting( | 89 void MediaStreamVideoRendererSink::SetGpuMemoryBufferVideoForTesting( |
90 media::GpuMemoryBufferVideoFramePool* gpu_memory_buffer_pool) { | 90 media::GpuMemoryBufferVideoFrameCopier* gpu_memory_buffer_copier) { |
91 gpu_memory_buffer_pool_.reset(gpu_memory_buffer_pool); | 91 gpu_memory_buffer_copier_.reset(gpu_memory_buffer_copier); |
92 } | 92 } |
93 | 93 |
94 void MediaStreamVideoRendererSink::OnReadyStateChanged( | 94 void MediaStreamVideoRendererSink::OnReadyStateChanged( |
95 blink::WebMediaStreamSource::ReadyState state) { | 95 blink::WebMediaStreamSource::ReadyState state) { |
96 DCHECK(task_runner_->BelongsToCurrentThread()); | 96 DCHECK(task_runner_->BelongsToCurrentThread()); |
97 if (state == blink::WebMediaStreamSource::ReadyStateEnded) | 97 if (state == blink::WebMediaStreamSource::ReadyStateEnded) |
98 RenderSignalingFrame(); | 98 RenderSignalingFrame(); |
99 } | 99 } |
100 | 100 |
101 void MediaStreamVideoRendererSink::OnVideoFrame( | 101 void MediaStreamVideoRendererSink::OnVideoFrame( |
102 const scoped_refptr<media::VideoFrame>& frame, | 102 const scoped_refptr<media::VideoFrame>& frame, |
103 base::TimeTicks estimated_capture_time) { | 103 base::TimeTicks estimated_capture_time) { |
104 DCHECK(task_runner_->BelongsToCurrentThread()); | 104 DCHECK(task_runner_->BelongsToCurrentThread()); |
105 DCHECK(frame); | 105 DCHECK(frame); |
106 if (state_ != STARTED) | 106 if (state_ != STARTED) |
107 return; | 107 return; |
108 | 108 |
109 if (!gpu_memory_buffer_pool_) { | 109 if (!gpu_memory_buffer_copier_) { |
110 FrameReady(frame); | 110 FrameReady(frame); |
111 return; | 111 return; |
112 } | 112 } |
113 | 113 |
114 // |gpu_memory_buffer_pool_| deletion is going to be posted to | 114 // |gpu_memory_buffer_copier_| deletion is going to be posted to |
115 // |media_task_runner_|. base::Unretained() usage is fine since | 115 // |media_task_runner_|. base::Unretained() usage is fine since |
116 // |gpu_memory_buffer_pool_| outlives the task. | 116 // |gpu_memory_buffer_copier_| outlives the task. |
117 media_task_runner_->PostTask( | 117 media_task_runner_->PostTask( |
118 FROM_HERE, | 118 FROM_HERE, |
119 base::Bind( | 119 base::Bind( |
120 &media::GpuMemoryBufferVideoFramePool::MaybeCreateHardwareFrame, | 120 &media::GpuMemoryBufferVideoFrameCopier::MaybeCreateHardwareFrame, |
121 base::Unretained(gpu_memory_buffer_pool_.get()), frame, | 121 base::Unretained(gpu_memory_buffer_copier_.get()), frame, |
122 media::BindToCurrentLoop( | 122 media::BindToCurrentLoop( |
123 base::Bind(&MediaStreamVideoRendererSink::FrameReady, | 123 base::Bind(&MediaStreamVideoRendererSink::FrameReady, |
124 weak_factory_.GetWeakPtr())))); | 124 weak_factory_.GetWeakPtr())))); |
125 } | 125 } |
126 | 126 |
127 void MediaStreamVideoRendererSink::FrameReady( | 127 void MediaStreamVideoRendererSink::FrameReady( |
128 const scoped_refptr<media::VideoFrame>& frame) { | 128 const scoped_refptr<media::VideoFrame>& frame) { |
129 DCHECK(task_runner_->BelongsToCurrentThread()); | 129 DCHECK(task_runner_->BelongsToCurrentThread()); |
130 DCHECK(frame); | 130 DCHECK(frame); |
131 | 131 |
(...skipping 14 matching lines...) Expand all Loading... |
146 scoped_refptr<media::VideoFrame> video_frame = | 146 scoped_refptr<media::VideoFrame> video_frame = |
147 media::VideoFrame::CreateBlackFrame(frame_size_); | 147 media::VideoFrame::CreateBlackFrame(frame_size_); |
148 video_frame->metadata()->SetBoolean(media::VideoFrameMetadata::END_OF_STREAM, | 148 video_frame->metadata()->SetBoolean(media::VideoFrameMetadata::END_OF_STREAM, |
149 true); | 149 true); |
150 video_frame->metadata()->SetTimeTicks( | 150 video_frame->metadata()->SetTimeTicks( |
151 media::VideoFrameMetadata::REFERENCE_TIME, base::TimeTicks::Now()); | 151 media::VideoFrameMetadata::REFERENCE_TIME, base::TimeTicks::Now()); |
152 OnVideoFrame(video_frame, base::TimeTicks()); | 152 OnVideoFrame(video_frame, base::TimeTicks()); |
153 } | 153 } |
154 | 154 |
155 } // namespace content | 155 } // namespace content |
OLD | NEW |