Chromium Code Reviews| 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/browser/renderer_host/media/video_capture_controller.h" | 5 #include "content/browser/renderer_host/media/video_capture_controller.h" |
| 6 | 6 |
| 7 #include <map> | 7 #include <map> |
| 8 #include <set> | 8 #include <set> |
| 9 | 9 |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| 11 #include "base/debug/trace_event.h" | 11 #include "base/debug/trace_event.h" |
| 12 #include "base/metrics/histogram.h" | 12 #include "base/metrics/histogram.h" |
| 13 #include "base/metrics/sparse_histogram.h" | 13 #include "base/metrics/sparse_histogram.h" |
| 14 #include "base/stl_util.h" | 14 #include "base/stl_util.h" |
| 15 #include "content/browser/compositor/image_transport_factory.h" | |
| 15 #include "content/browser/renderer_host/media/media_stream_manager.h" | 16 #include "content/browser/renderer_host/media/media_stream_manager.h" |
| 16 #include "content/browser/renderer_host/media/video_capture_manager.h" | 17 #include "content/browser/renderer_host/media/video_capture_manager.h" |
| 18 #include "content/common/gpu/client/gl_helper.h" | |
| 17 #include "content/public/browser/browser_thread.h" | 19 #include "content/public/browser/browser_thread.h" |
| 18 #include "gpu/command_buffer/common/mailbox_holder.h" | 20 #include "gpu/command_buffer/common/mailbox_holder.h" |
| 19 #include "media/base/video_frame.h" | 21 #include "media/base/video_frame.h" |
| 20 #include "media/base/video_util.h" | 22 #include "media/base/video_util.h" |
| 21 #include "media/base/yuv_convert.h" | 23 #include "media/base/yuv_convert.h" |
| 22 #include "third_party/libyuv/include/libyuv.h" | 24 #include "third_party/libyuv/include/libyuv.h" |
| 23 | 25 |
| 24 using media::VideoCaptureFormat; | 26 using media::VideoCaptureFormat; |
| 25 | 27 |
| 26 namespace content { | 28 namespace content { |
| (...skipping 19 matching lines...) Expand all Loading... | |
| 46 : Buffer(buffer_id, data, size), pool_(pool) { | 48 : Buffer(buffer_id, data, size), pool_(pool) { |
| 47 DCHECK(pool_); | 49 DCHECK(pool_); |
| 48 } | 50 } |
| 49 | 51 |
| 50 private: | 52 private: |
| 51 virtual ~PoolBuffer() { pool_->RelinquishProducerReservation(id()); } | 53 virtual ~PoolBuffer() { pool_->RelinquishProducerReservation(id()); } |
| 52 | 54 |
| 53 const scoped_refptr<VideoCaptureBufferPool> pool_; | 55 const scoped_refptr<VideoCaptureBufferPool> pool_; |
| 54 }; | 56 }; |
| 55 | 57 |
| 58 class SyncPointClientImpl : public media::VideoFrame::SyncPointClient { | |
| 59 public: | |
| 60 explicit SyncPointClientImpl(GLHelper* gl_helper) : gl_helper_(gl_helper) {} | |
| 61 virtual ~SyncPointClientImpl() {} | |
| 62 virtual uint32 InsertSyncPoint() OVERRIDE { | |
| 63 return gl_helper_->InsertSyncPoint(); | |
| 64 } | |
| 65 virtual void WaitSyncPoint(uint32 sync_point) OVERRIDE { | |
| 66 gl_helper_->WaitSyncPoint(sync_point); | |
| 67 } | |
| 68 | |
| 69 private: | |
| 70 GLHelper* gl_helper_; | |
| 71 }; | |
| 72 | |
| 73 void ReturnVideoFrame(const scoped_refptr<media::VideoFrame>& video_frame, | |
| 74 uint32 sync_point) { | |
| 75 DCHECK_CURRENTLY_ON(BrowserThread::UI); | |
| 76 GLHelper* gl_helper = ImageTransportFactory::GetInstance()->GetGLHelper(); | |
|
dshwang
2014/06/23 19:42:07
I found that android can not use ImageTransportFac
| |
| 77 DCHECK(gl_helper); | |
| 78 gl_helper->WaitSyncPoint(sync_point); | |
| 79 SyncPointClientImpl client(gl_helper); | |
| 80 video_frame->UpdateReleaseSyncPoint(&client); | |
| 81 } | |
| 82 | |
| 56 } // anonymous namespace | 83 } // anonymous namespace |
| 57 | 84 |
| 58 struct VideoCaptureController::ControllerClient { | 85 struct VideoCaptureController::ControllerClient { |
| 59 ControllerClient(const VideoCaptureControllerID& id, | 86 ControllerClient(const VideoCaptureControllerID& id, |
| 60 VideoCaptureControllerEventHandler* handler, | 87 VideoCaptureControllerEventHandler* handler, |
| 61 base::ProcessHandle render_process, | 88 base::ProcessHandle render_process, |
| 62 media::VideoCaptureSessionId session_id, | 89 media::VideoCaptureSessionId session_id, |
| 63 const media::VideoCaptureParams& params) | 90 const media::VideoCaptureParams& params) |
| 64 : controller_id(id), | 91 : controller_id(id), |
| 65 event_handler(handler), | 92 event_handler(handler), |
| (...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 242 if (client) { | 269 if (client) { |
| 243 client->session_closed = true; | 270 client->session_closed = true; |
| 244 client->event_handler->OnEnded(client->controller_id); | 271 client->event_handler->OnEnded(client->controller_id); |
| 245 } | 272 } |
| 246 } | 273 } |
| 247 | 274 |
| 248 void VideoCaptureController::ReturnBuffer( | 275 void VideoCaptureController::ReturnBuffer( |
| 249 const VideoCaptureControllerID& id, | 276 const VideoCaptureControllerID& id, |
| 250 VideoCaptureControllerEventHandler* event_handler, | 277 VideoCaptureControllerEventHandler* event_handler, |
| 251 int buffer_id, | 278 int buffer_id, |
| 252 const std::vector<uint32>& sync_points) { | 279 uint32 sync_point) { |
| 253 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 280 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 254 | 281 |
| 255 ControllerClient* client = FindClient(id, event_handler, controller_clients_); | 282 ControllerClient* client = FindClient(id, event_handler, controller_clients_); |
| 256 | 283 |
| 257 // If this buffer is not held by this client, or this client doesn't exist | 284 // If this buffer is not held by this client, or this client doesn't exist |
| 258 // in controller, do nothing. | 285 // in controller, do nothing. |
| 259 ControllerClient::ActiveBufferMap::iterator iter; | 286 ControllerClient::ActiveBufferMap::iterator iter; |
| 260 if (!client || (iter = client->active_buffers.find(buffer_id)) == | 287 if (!client || (iter = client->active_buffers.find(buffer_id)) == |
| 261 client->active_buffers.end()) { | 288 client->active_buffers.end()) { |
| 262 NOTREACHED(); | 289 NOTREACHED(); |
| 263 return; | 290 return; |
| 264 } | 291 } |
| 265 scoped_refptr<media::VideoFrame> frame = iter->second; | 292 scoped_refptr<media::VideoFrame> frame = iter->second; |
| 266 client->active_buffers.erase(iter); | 293 client->active_buffers.erase(iter); |
| 294 buffer_pool_->RelinquishConsumerHold(buffer_id, 1); | |
| 267 | 295 |
| 268 if (frame->format() == media::VideoFrame::NATIVE_TEXTURE) { | 296 if (sync_point) |
| 269 for (size_t i = 0; i < sync_points.size(); i++) | 297 BrowserThread::PostTask(BrowserThread::UI, |
| 270 frame->AppendReleaseSyncPoint(sync_points[i]); | 298 FROM_HERE, |
| 271 } | 299 base::Bind(&ReturnVideoFrame, frame, sync_point)); |
| 272 | |
| 273 buffer_pool_->RelinquishConsumerHold(buffer_id, 1); | |
| 274 } | 300 } |
| 275 | 301 |
| 276 const media::VideoCaptureFormat& | 302 const media::VideoCaptureFormat& |
| 277 VideoCaptureController::GetVideoCaptureFormat() const { | 303 VideoCaptureController::GetVideoCaptureFormat() const { |
| 278 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 304 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 279 return video_capture_format_; | 305 return video_capture_format_; |
| 280 } | 306 } |
| 281 | 307 |
| 282 scoped_refptr<media::VideoCaptureDevice::Client::Buffer> | 308 scoped_refptr<media::VideoCaptureDevice::Client::Buffer> |
| 283 VideoCaptureController::VideoCaptureDeviceClient::ReserveOutputBuffer( | 309 VideoCaptureController::VideoCaptureDeviceClient::ReserveOutputBuffer( |
| (...skipping 357 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 641 } | 667 } |
| 642 return NULL; | 668 return NULL; |
| 643 } | 669 } |
| 644 | 670 |
| 645 int VideoCaptureController::GetClientCount() { | 671 int VideoCaptureController::GetClientCount() { |
| 646 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 672 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 647 return controller_clients_.size(); | 673 return controller_clients_.size(); |
| 648 } | 674 } |
| 649 | 675 |
| 650 } // namespace content | 676 } // namespace content |
| OLD | NEW |