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" |
| (...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 46 : Buffer(buffer_id, data, size), pool_(pool) { | 46 : Buffer(buffer_id, data, size), pool_(pool) { |
| 47 DCHECK(pool_); | 47 DCHECK(pool_); |
| 48 } | 48 } |
| 49 | 49 |
| 50 private: | 50 private: |
| 51 virtual ~PoolBuffer() { pool_->RelinquishProducerReservation(id()); } | 51 virtual ~PoolBuffer() { pool_->RelinquishProducerReservation(id()); } |
| 52 | 52 |
| 53 const scoped_refptr<VideoCaptureBufferPool> pool_; | 53 const scoped_refptr<VideoCaptureBufferPool> pool_; |
| 54 }; | 54 }; |
| 55 | 55 |
| 56 class SyncPointProviderImpl : public media::VideoFrame::SyncPointProvider { | |
| 57 public: | |
| 58 explicit SyncPointProviderImpl(uint32 sync_point) : sync_point_(sync_point) {} | |
| 59 virtual ~SyncPointProviderImpl(); | |
| 60 virtual uint32 InsertSyncPoint(); | |
| 61 virtual void WaitSyncPoint(uint32 sync_point); | |
| 62 | |
| 63 private: | |
| 64 uint32 sync_point_; | |
| 65 }; | |
| 66 | |
| 67 SyncPointProviderImpl::~SyncPointProviderImpl() { | |
| 68 } | |
| 69 | |
| 70 uint32 SyncPointProviderImpl::InsertSyncPoint() { | |
| 71 return sync_point_; | |
| 72 } | |
| 73 | |
| 74 void SyncPointProviderImpl::WaitSyncPoint(uint32 sync_point) { | |
|
danakj
2014/06/19 15:56:26
Why is this ok to drop the current sync point in t
dshwang
2014/06/23 18:33:20
I misunderstood that this file is used by only uni
| |
| 75 } | |
| 76 | |
| 56 } // anonymous namespace | 77 } // anonymous namespace |
| 57 | 78 |
| 58 struct VideoCaptureController::ControllerClient { | 79 struct VideoCaptureController::ControllerClient { |
| 59 ControllerClient(const VideoCaptureControllerID& id, | 80 ControllerClient(const VideoCaptureControllerID& id, |
| 60 VideoCaptureControllerEventHandler* handler, | 81 VideoCaptureControllerEventHandler* handler, |
| 61 base::ProcessHandle render_process, | 82 base::ProcessHandle render_process, |
| 62 media::VideoCaptureSessionId session_id, | 83 media::VideoCaptureSessionId session_id, |
| 63 const media::VideoCaptureParams& params) | 84 const media::VideoCaptureParams& params) |
| 64 : controller_id(id), | 85 : controller_id(id), |
| 65 event_handler(handler), | 86 event_handler(handler), |
| (...skipping 176 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 242 if (client) { | 263 if (client) { |
| 243 client->session_closed = true; | 264 client->session_closed = true; |
| 244 client->event_handler->OnEnded(client->controller_id); | 265 client->event_handler->OnEnded(client->controller_id); |
| 245 } | 266 } |
| 246 } | 267 } |
| 247 | 268 |
| 248 void VideoCaptureController::ReturnBuffer( | 269 void VideoCaptureController::ReturnBuffer( |
| 249 const VideoCaptureControllerID& id, | 270 const VideoCaptureControllerID& id, |
| 250 VideoCaptureControllerEventHandler* event_handler, | 271 VideoCaptureControllerEventHandler* event_handler, |
| 251 int buffer_id, | 272 int buffer_id, |
| 252 const std::vector<uint32>& sync_points) { | 273 uint32 sync_point) { |
| 253 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 274 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 254 | 275 |
| 255 ControllerClient* client = FindClient(id, event_handler, controller_clients_); | 276 ControllerClient* client = FindClient(id, event_handler, controller_clients_); |
| 256 | 277 |
| 257 // If this buffer is not held by this client, or this client doesn't exist | 278 // If this buffer is not held by this client, or this client doesn't exist |
| 258 // in controller, do nothing. | 279 // in controller, do nothing. |
| 259 ControllerClient::ActiveBufferMap::iterator iter; | 280 ControllerClient::ActiveBufferMap::iterator iter; |
| 260 if (!client || (iter = client->active_buffers.find(buffer_id)) == | 281 if (!client || (iter = client->active_buffers.find(buffer_id)) == |
| 261 client->active_buffers.end()) { | 282 client->active_buffers.end()) { |
| 262 NOTREACHED(); | 283 NOTREACHED(); |
| 263 return; | 284 return; |
| 264 } | 285 } |
| 265 scoped_refptr<media::VideoFrame> frame = iter->second; | 286 scoped_refptr<media::VideoFrame> frame = iter->second; |
| 266 client->active_buffers.erase(iter); | 287 client->active_buffers.erase(iter); |
| 267 | 288 |
| 268 if (frame->format() == media::VideoFrame::NATIVE_TEXTURE) { | 289 SyncPointProviderImpl provider(sync_point); |
| 269 for (size_t i = 0; i < sync_points.size(); i++) | 290 frame->UpdateReleaseSyncPoint(provider); |
| 270 frame->AppendReleaseSyncPoint(sync_points[i]); | |
| 271 } | |
| 272 | 291 |
| 273 buffer_pool_->RelinquishConsumerHold(buffer_id, 1); | 292 buffer_pool_->RelinquishConsumerHold(buffer_id, 1); |
| 274 } | 293 } |
| 275 | 294 |
| 276 const media::VideoCaptureFormat& | 295 const media::VideoCaptureFormat& |
| 277 VideoCaptureController::GetVideoCaptureFormat() const { | 296 VideoCaptureController::GetVideoCaptureFormat() const { |
| 278 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 297 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 279 return video_capture_format_; | 298 return video_capture_format_; |
| 280 } | 299 } |
| 281 | 300 |
| (...skipping 359 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 641 } | 660 } |
| 642 return NULL; | 661 return NULL; |
| 643 } | 662 } |
| 644 | 663 |
| 645 int VideoCaptureController::GetClientCount() { | 664 int VideoCaptureController::GetClientCount() { |
| 646 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 665 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 647 return controller_clients_.size(); | 666 return controller_clients_.size(); |
| 648 } | 667 } |
| 649 | 668 |
| 650 } // namespace content | 669 } // namespace content |
| OLD | NEW |