OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "base/stl_util.h" | 7 #include "base/stl_util.h" |
8 #include "content/browser/browser_thread.h" | 8 #include "content/browser/browser_thread.h" |
9 #include "content/browser/renderer_host/media/media_stream_manager.h" | 9 #include "content/browser/renderer_host/media/media_stream_manager.h" |
10 #include "content/browser/renderer_host/media/video_capture_manager.h" | 10 #include "content/browser/renderer_host/media/video_capture_manager.h" |
11 #include "media/base/yuv_convert.h" | 11 #include "media/base/yuv_convert.h" |
12 | 12 |
13 // The number of TransportDIBs VideoCaptureController allocate. | 13 // The number of TransportDIBs VideoCaptureController allocate. |
14 static const size_t kNoOfDIBS = 3; | 14 static const size_t kNoOfDIBS = 3; |
15 | 15 |
16 VideoCaptureController::VideoCaptureController( | 16 VideoCaptureController::VideoCaptureController( |
17 const VideoCaptureControllerID& id, | 17 const VideoCaptureControllerID& id, |
18 base::ProcessHandle render_process, | 18 base::ProcessHandle render_process, |
19 VideoCaptureControllerEventHandler* event_handler) | 19 VideoCaptureControllerEventHandler* event_handler, |
| 20 media_stream::VideoCaptureManager* video_capture_manager) |
20 : render_handle_(render_process), | 21 : render_handle_(render_process), |
21 report_ready_to_delete_(false), | 22 report_ready_to_delete_(false), |
22 event_handler_(event_handler), | 23 event_handler_(event_handler), |
23 id_(id) { | 24 id_(id), |
| 25 video_capture_manager_(video_capture_manager) { |
24 memset(¶ms_, 0, sizeof(params_)); | 26 memset(¶ms_, 0, sizeof(params_)); |
25 } | 27 } |
26 | 28 |
27 VideoCaptureController::~VideoCaptureController() { | 29 VideoCaptureController::~VideoCaptureController() { |
28 // Delete all TransportDIBs. | 30 // Delete all TransportDIBs. |
29 STLDeleteContainerPairSecondPointers(owned_dibs_.begin(), | 31 STLDeleteContainerPairSecondPointers(owned_dibs_.begin(), |
30 owned_dibs_.end()); | 32 owned_dibs_.end()); |
31 } | 33 } |
32 | 34 |
33 void VideoCaptureController::StartCapture( | 35 void VideoCaptureController::StartCapture( |
34 const media::VideoCaptureParams& params) { | 36 const media::VideoCaptureParams& params) { |
35 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 37 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
36 | 38 |
37 params_ = params; | 39 params_ = params; |
38 media_stream::VideoCaptureManager* manager = | |
39 media_stream::MediaStreamManager::Get()->video_capture_manager(); | |
40 // Order the manager to start the actual capture. | 40 // Order the manager to start the actual capture. |
41 manager->Start(params, this); | 41 video_capture_manager_->Start(params, this); |
42 } | 42 } |
43 | 43 |
44 void VideoCaptureController::StopCapture(Task* stopped_task) { | 44 void VideoCaptureController::StopCapture(Task* stopped_task) { |
45 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 45 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
46 | 46 |
47 media_stream::VideoCaptureManager* manager = | 47 video_capture_manager_->Stop( |
48 media_stream::MediaStreamManager::Get()->video_capture_manager(); | 48 params_.session_id, |
49 manager->Stop(params_.session_id, | 49 NewRunnableMethod(this, |
50 NewRunnableMethod(this, | 50 &VideoCaptureController::OnDeviceStopped, |
51 &VideoCaptureController::OnDeviceStopped, | 51 stopped_task)); |
52 stopped_task)); | |
53 } | 52 } |
54 | 53 |
55 void VideoCaptureController::ReturnBuffer(int buffer_id) { | 54 void VideoCaptureController::ReturnBuffer(int buffer_id) { |
56 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 55 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
57 | 56 |
58 bool ready_to_delete; | 57 bool ready_to_delete; |
59 { | 58 { |
60 base::AutoLock lock(lock_); | 59 base::AutoLock lock(lock_); |
61 free_dibs_.push_back(buffer_id); | 60 free_dibs_.push_back(buffer_id); |
62 ready_to_delete = (free_dibs_.size() == owned_dibs_.size()) && | 61 ready_to_delete = (free_dibs_.size() == owned_dibs_.size()) && |
(...skipping 88 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
151 } | 150 } |
152 default: | 151 default: |
153 NOTREACHED(); | 152 NOTREACHED(); |
154 } | 153 } |
155 | 154 |
156 event_handler_->OnBufferReady(id_, buffer_id, timestamp); | 155 event_handler_->OnBufferReady(id_, buffer_id, timestamp); |
157 } | 156 } |
158 | 157 |
159 void VideoCaptureController::OnError() { | 158 void VideoCaptureController::OnError() { |
160 event_handler_->OnError(id_); | 159 event_handler_->OnError(id_); |
161 media_stream::MediaStreamManager::Get()->video_capture_manager()-> | 160 video_capture_manager_->Error(params_.session_id); |
162 Error(params_.session_id); | |
163 } | 161 } |
164 | 162 |
165 void VideoCaptureController::OnFrameInfo( | 163 void VideoCaptureController::OnFrameInfo( |
166 const media::VideoCaptureDevice::Capability& info) { | 164 const media::VideoCaptureDevice::Capability& info) { |
167 DCHECK(owned_dibs_.empty()); | 165 DCHECK(owned_dibs_.empty()); |
168 bool frames_created = true; | 166 bool frames_created = true; |
169 const size_t needed_size = (info.width * info.height * 3) / 2; | 167 const size_t needed_size = (info.width * info.height * 3) / 2; |
170 for (size_t i = 1; i <= kNoOfDIBS; ++i) { | 168 for (size_t i = 1; i <= kNoOfDIBS; ++i) { |
171 base::SharedMemory* shared_memory = new base::SharedMemory(); | 169 base::SharedMemory* shared_memory = new base::SharedMemory(); |
172 if (!shared_memory->CreateAndMapAnonymous(needed_size)) { | 170 if (!shared_memory->CreateAndMapAnonymous(needed_size)) { |
(...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
207 } | 205 } |
208 | 206 |
209 if (ready_to_delete_now) { | 207 if (ready_to_delete_now) { |
210 event_handler_->OnReadyToDelete(id_); | 208 event_handler_->OnReadyToDelete(id_); |
211 } | 209 } |
212 if (stopped_task) { | 210 if (stopped_task) { |
213 stopped_task->Run(); | 211 stopped_task->Run(); |
214 delete stopped_task; | 212 delete stopped_task; |
215 } | 213 } |
216 } | 214 } |
OLD | NEW |