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/capture_video_decoder.h" | 5 #include "content/renderer/media/capture_video_decoder.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/callback_helpers.h" |
8 #include "content/renderer/media/video_capture_impl_manager.h" | 9 #include "content/renderer/media/video_capture_impl_manager.h" |
9 #include "media/base/filter_host.h" | 10 #include "media/base/filter_host.h" |
10 #include "media/base/limits.h" | 11 #include "media/base/limits.h" |
11 #include "media/base/video_util.h" | 12 #include "media/base/video_util.h" |
12 | 13 |
13 using media::CopyYPlane; | 14 using media::CopyYPlane; |
14 using media::CopyUPlane; | 15 using media::CopyUPlane; |
15 using media::CopyVPlane; | 16 using media::CopyVPlane; |
16 | 17 |
17 CaptureVideoDecoder::CaptureVideoDecoder( | 18 CaptureVideoDecoder::CaptureVideoDecoder( |
(...skipping 177 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
195 | 196 |
196 cb.Run(media::PIPELINE_OK); | 197 cb.Run(media::PIPELINE_OK); |
197 state_ = kNormal; | 198 state_ = kNormal; |
198 } | 199 } |
199 | 200 |
200 void CaptureVideoDecoder::OnStoppedOnDecoderThread( | 201 void CaptureVideoDecoder::OnStoppedOnDecoderThread( |
201 media::VideoCapture* capture) { | 202 media::VideoCapture* capture) { |
202 DVLOG(1) << "OnStoppedOnDecoderThread"; | 203 DVLOG(1) << "OnStoppedOnDecoderThread"; |
203 DCHECK(message_loop_proxy_->BelongsToCurrentThread()); | 204 DCHECK(message_loop_proxy_->BelongsToCurrentThread()); |
204 if (!pending_stop_cb_.is_null()) | 205 if (!pending_stop_cb_.is_null()) |
205 media::ResetAndRunCB(&pending_stop_cb_); | 206 base::ResetAndReturn(&pending_stop_cb_).Run(); |
206 vc_manager_->RemoveDevice(video_stream_id_, this); | 207 vc_manager_->RemoveDevice(video_stream_id_, this); |
207 } | 208 } |
208 | 209 |
209 void CaptureVideoDecoder::OnDeviceInfoReceivedOnDecoderThread( | 210 void CaptureVideoDecoder::OnDeviceInfoReceivedOnDecoderThread( |
210 media::VideoCapture* capture, | 211 media::VideoCapture* capture, |
211 const media::VideoCaptureParams& device_info) { | 212 const media::VideoCaptureParams& device_info) { |
212 DCHECK(message_loop_proxy_->BelongsToCurrentThread()); | 213 DCHECK(message_loop_proxy_->BelongsToCurrentThread()); |
213 if (device_info.width != natural_size_.width() || | 214 if (device_info.width != natural_size_.width() || |
214 device_info.height != natural_size_.height()) { | 215 device_info.height != natural_size_.height()) { |
215 natural_size_.SetSize(device_info.width, device_info.height); | 216 natural_size_.SetSize(device_info.width, device_info.height); |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
277 capture->FeedBuffer(buf); | 278 capture->FeedBuffer(buf); |
278 } | 279 } |
279 | 280 |
280 void CaptureVideoDecoder::DeliverFrame( | 281 void CaptureVideoDecoder::DeliverFrame( |
281 const scoped_refptr<media::VideoFrame>& video_frame) { | 282 const scoped_refptr<media::VideoFrame>& video_frame) { |
282 // Reset the callback before running to protect against reentrancy. | 283 // Reset the callback before running to protect against reentrancy. |
283 ReadCB read_cb = read_cb_; | 284 ReadCB read_cb = read_cb_; |
284 read_cb_.Reset(); | 285 read_cb_.Reset(); |
285 read_cb.Run(video_frame); | 286 read_cb.Run(video_frame); |
286 } | 287 } |
OLD | NEW |