Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(256)

Side by Side Diff: content/browser/renderer_host/media/video_capture_controller.cc

Issue 7284037: Adding MediaStreamManager. (Closed) Base URL: http://src.chromium.org/svn/trunk/src/
Patch Set: Changes based on review by wjia Created 9 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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-inl.h" 7 #include "base/stl_util-inl.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/video_capture_manager.h" 10 #include "content/browser/renderer_host/media/video_capture_manager.h"
10 #include "media/base/yuv_convert.h" 11 #include "media/base/yuv_convert.h"
11 12
12 // The number of TransportDIBs VideoCaptureController allocate. 13 // The number of TransportDIBs VideoCaptureController allocate.
13 static const size_t kNoOfDIBS = 3; 14 static const size_t kNoOfDIBS = 3;
14 15
15 VideoCaptureController::VideoCaptureController( 16 VideoCaptureController::VideoCaptureController(
16 const VideoCaptureControllerID& id, 17 const VideoCaptureControllerID& id,
17 base::ProcessHandle render_process, 18 base::ProcessHandle render_process,
18 VideoCaptureControllerEventHandler* event_handler) 19 VideoCaptureControllerEventHandler* event_handler)
19 : render_handle_(render_process), 20 : render_handle_(render_process),
20 report_ready_to_delete_(false), 21 report_ready_to_delete_(false),
21 event_handler_(event_handler), 22 event_handler_(event_handler),
22 id_(id) { 23 id_(id) {
23 memset(&params_, 0, sizeof(params_)); 24 memset(&params_, 0, sizeof(params_));
24 } 25 }
25 26
26 VideoCaptureController::~VideoCaptureController() { 27 VideoCaptureController::~VideoCaptureController() {
27 // Delete all TransportDIBs. 28 // Delete all TransportDIBs.
28 STLDeleteContainerPairSecondPointers(owned_dibs_.begin(), 29 STLDeleteContainerPairSecondPointers(owned_dibs_.begin(),
29 owned_dibs_.end()); 30 owned_dibs_.end());
30 } 31 }
31 32
32 void VideoCaptureController::StartCapture( 33 void VideoCaptureController::StartCapture(
33 const media::VideoCaptureParams& params) { 34 const media::VideoCaptureParams& params) {
34 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); 35 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
35 36
36 params_ = params; 37 params_ = params;
37 media_stream::VideoCaptureManager* manager = 38 media_stream::VideoCaptureManager* manager =
38 media_stream::VideoCaptureManager::Get(); 39 media_stream::MediaStreamManager::Get()->GetVideoCaptureManager();
39 // Order the manager to start the actual capture. 40 // Order the manager to start the actual capture.
40 manager->Start(params, this); 41 manager->Start(params, this);
41 } 42 }
42 43
43 void VideoCaptureController::StopCapture(Task* stopped_task) { 44 void VideoCaptureController::StopCapture(Task* stopped_task) {
44 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); 45 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
45 46
46 media_stream::VideoCaptureManager* manager = 47 media_stream::VideoCaptureManager* manager =
47 media_stream::VideoCaptureManager::Get(); 48 media_stream::MediaStreamManager::Get()->GetVideoCaptureManager();
48 manager->Stop(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));
52 } 53 }
53 54
54 void VideoCaptureController::ReturnBuffer(int buffer_id) { 55 void VideoCaptureController::ReturnBuffer(int buffer_id) {
55 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); 56 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
56 57
57 bool ready_to_delete; 58 bool ready_to_delete;
(...skipping 91 matching lines...) Expand 10 before | Expand all | Expand 10 after
149 } 150 }
150 default: 151 default:
151 NOTREACHED(); 152 NOTREACHED();
152 } 153 }
153 154
154 event_handler_->OnBufferReady(id_, buffer_id, timestamp); 155 event_handler_->OnBufferReady(id_, buffer_id, timestamp);
155 } 156 }
156 157
157 void VideoCaptureController::OnError() { 158 void VideoCaptureController::OnError() {
158 event_handler_->OnError(id_); 159 event_handler_->OnError(id_);
159 media_stream::VideoCaptureManager::Get()->Error(params_.session_id); 160 media_stream::MediaStreamManager::Get()->GetVideoCaptureManager()->
161 Error(params_.session_id);
160 } 162 }
161 163
162 void VideoCaptureController::OnFrameInfo( 164 void VideoCaptureController::OnFrameInfo(
163 const media::VideoCaptureDevice::Capability& info) { 165 const media::VideoCaptureDevice::Capability& info) {
164 DCHECK(owned_dibs_.empty()); 166 DCHECK(owned_dibs_.empty());
165 bool frames_created = true; 167 bool frames_created = true;
166 const size_t needed_size = (info.width * info.height * 3) / 2; 168 const size_t needed_size = (info.width * info.height * 3) / 2;
Leandro Graciá Gil 2011/07/01 11:31:35 Just as a sidenote, I guess you know this better t
mflodman1 2011/07/01 14:07:23 As it is now, this is an I420 frame without any al
167 for (size_t i = 1; i <= kNoOfDIBS; ++i) { 169 for (size_t i = 1; i <= kNoOfDIBS; ++i) {
168 base::SharedMemory* shared_memory = new base::SharedMemory(); 170 base::SharedMemory* shared_memory = new base::SharedMemory();
169 if (!shared_memory->CreateAndMapAnonymous(needed_size)) { 171 if (!shared_memory->CreateAndMapAnonymous(needed_size)) {
170 frames_created = false; 172 frames_created = false;
171 break; 173 break;
172 } 174 }
173 base::SharedMemoryHandle remote_handle; 175 base::SharedMemoryHandle remote_handle;
174 shared_memory->ShareToProcess(render_handle_, &remote_handle); 176 shared_memory->ShareToProcess(render_handle_, &remote_handle);
175 177
176 base::AutoLock lock(lock_); 178 base::AutoLock lock(lock_);
(...skipping 27 matching lines...) Expand all
204 } 206 }
205 207
206 if (ready_to_delete_now) { 208 if (ready_to_delete_now) {
207 event_handler_->OnReadyToDelete(id_); 209 event_handler_->OnReadyToDelete(id_);
208 } 210 }
209 if (stopped_task) { 211 if (stopped_task) {
210 stopped_task->Run(); 212 stopped_task->Run();
211 delete stopped_task; 213 delete stopped_task;
212 } 214 }
213 } 215 }
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698