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_host.h" | 5 #include "content/browser/renderer_host/media/video_capture_host.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/bind_helpers.h" | 8 #include "base/bind_helpers.h" |
9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
10 #include "content/browser/browser_main_loop.h" | 10 #include "content/browser/browser_main_loop.h" |
(...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
140 } | 140 } |
141 | 141 |
142 /////////////////////////////////////////////////////////////////////////////// | 142 /////////////////////////////////////////////////////////////////////////////// |
143 // IPC Messages handler. | 143 // IPC Messages handler. |
144 bool VideoCaptureHost::OnMessageReceived(const IPC::Message& message) { | 144 bool VideoCaptureHost::OnMessageReceived(const IPC::Message& message) { |
145 bool handled = true; | 145 bool handled = true; |
146 IPC_BEGIN_MESSAGE_MAP(VideoCaptureHost, message) | 146 IPC_BEGIN_MESSAGE_MAP(VideoCaptureHost, message) |
147 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Start, OnStartCapture) | 147 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Start, OnStartCapture) |
148 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Pause, OnPauseCapture) | 148 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Pause, OnPauseCapture) |
149 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Resume, OnResumeCapture) | 149 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Resume, OnResumeCapture) |
| 150 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_RequestRefreshFrame, |
| 151 OnRequestRefreshFrame) |
150 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Stop, OnStopCapture) | 152 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Stop, OnStopCapture) |
151 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_BufferReady, | 153 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_BufferReady, |
152 OnRendererFinishedWithBuffer) | 154 OnRendererFinishedWithBuffer) |
153 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_GetDeviceSupportedFormats, | 155 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_GetDeviceSupportedFormats, |
154 OnGetDeviceSupportedFormats) | 156 OnGetDeviceSupportedFormats) |
155 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_GetDeviceFormatsInUse, | 157 IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_GetDeviceFormatsInUse, |
156 OnGetDeviceFormatsInUse) | 158 OnGetDeviceFormatsInUse) |
157 IPC_MESSAGE_UNHANDLED(handled = false) | 159 IPC_MESSAGE_UNHANDLED(handled = false) |
158 IPC_END_MESSAGE_MAP() | 160 IPC_END_MESSAGE_MAP() |
159 | 161 |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
255 EntryMap::iterator it = entries_.find(controller_id); | 257 EntryMap::iterator it = entries_.find(controller_id); |
256 if (it == entries_.end()) | 258 if (it == entries_.end()) |
257 return; | 259 return; |
258 | 260 |
259 if (it->second) { | 261 if (it->second) { |
260 media_stream_manager_->video_capture_manager()->ResumeCaptureForClient( | 262 media_stream_manager_->video_capture_manager()->ResumeCaptureForClient( |
261 session_id, params, it->second.get(), controller_id, this); | 263 session_id, params, it->second.get(), controller_id, this); |
262 } | 264 } |
263 } | 265 } |
264 | 266 |
| 267 void VideoCaptureHost::OnRequestRefreshFrame(int device_id) { |
| 268 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 269 DVLOG(1) << "VideoCaptureHost::OnRequestRefreshFrame, device_id " |
| 270 << device_id; |
| 271 |
| 272 VideoCaptureControllerID controller_id(device_id); |
| 273 EntryMap::iterator it = entries_.find(controller_id); |
| 274 if (it == entries_.end()) |
| 275 return; |
| 276 |
| 277 if (VideoCaptureController* controller = it->second.get()) { |
| 278 media_stream_manager_->video_capture_manager() |
| 279 ->RequestRefreshFrameForClient(controller); |
| 280 } |
| 281 } |
| 282 |
265 void VideoCaptureHost::OnRendererFinishedWithBuffer( | 283 void VideoCaptureHost::OnRendererFinishedWithBuffer( |
266 int device_id, | 284 int device_id, |
267 int buffer_id, | 285 int buffer_id, |
268 const gpu::SyncToken& sync_token, | 286 const gpu::SyncToken& sync_token, |
269 double consumer_resource_utilization) { | 287 double consumer_resource_utilization) { |
270 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 288 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
271 | 289 |
272 VideoCaptureControllerID controller_id(device_id); | 290 VideoCaptureControllerID controller_id(device_id); |
273 EntryMap::iterator it = entries_.find(controller_id); | 291 EntryMap::iterator it = entries_.find(controller_id); |
274 if (it != entries_.end()) { | 292 if (it != entries_.end()) { |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
323 return; | 341 return; |
324 | 342 |
325 if (it->second) { | 343 if (it->second) { |
326 media_stream_manager_->video_capture_manager()->StopCaptureForClient( | 344 media_stream_manager_->video_capture_manager()->StopCaptureForClient( |
327 it->second.get(), controller_id, this, on_error); | 345 it->second.get(), controller_id, this, on_error); |
328 } | 346 } |
329 entries_.erase(it); | 347 entries_.erase(it); |
330 } | 348 } |
331 | 349 |
332 } // namespace content | 350 } // namespace content |
OLD | NEW |