| 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 |