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

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: content/browser/renderer_host/video_capture_host.cc

Issue 7002027: VideoCaptureHost (Closed) Base URL: http://src.chromium.org/svn/trunk/src/
Patch Set: '' Created 9 years, 7 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 side-by-side diff with in-line comments
Download patch
« content/browser/renderer_host/video_capture_controller.cc ('K') | « content/browser/renderer_host/video_capture_host.h ('k') | content/browser/renderer_host/video_capture_host_unittest.cc » ('j') | content/browser/renderer_host/video_capture_host_unittest.cc » ('J')
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: content/browser/renderer_host/video_capture_host.cc
===================================================================
--- content/browser/renderer_host/video_capture_host.cc (revision 0)
+++ content/browser/renderer_host/video_capture_host.cc (revision 0)
@@ -0,0 +1,187 @@
+// Copyright (c) 2011 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+
+#include "content/browser/renderer_host/video_capture_host.h"
+
+#include "base/memory/scoped_ptr.h"
+#include "base/stl_util-inl.h"
+#include "content/common/video_capture_messages.h"
+
+VideoCaptureHost::VideoCaptureHost() {}
+
+VideoCaptureHost::~VideoCaptureHost() {
scherkus (not reviewing) 2011/05/23 05:05:09 nit: collapse onto one line {}
Per K 2011/05/23 12:05:47 Done.
+}
+
+void VideoCaptureHost::OnChannelClosing() {
+ BrowserMessageFilter::OnChannelClosing();
+
+ // Since the IPC channel is gone, close all requested VideCaptureDevices.
+ for (EntryMap::iterator it = entries_.begin(); it != entries_.end(); it++) {
+ VideoCaptureController* controller = it->second;
+ // Since the channel is closing we need a task to make sure VideoCaptureHost
+ // is not deleted before VideoCaptureController.
+ controller->StopCapture(
+ NewRunnableMethod(this, &VideoCaptureHost::OnReadyToDelete, it->first));
+ }
+}
+
+void VideoCaptureHost::OnDestruct() const {
+ BrowserThread::DeleteOnIOThread::Destruct(this);
+}
+
+///////////////////////////////////////////////////////////////////////////////
+
+// Implements VideoCaptureController::EventHandler.
+void VideoCaptureHost::OnError(VideoCaptureController::ControllerId id) {
+ BrowserThread::PostTask(
+ BrowserThread::IO, FROM_HERE,
+ NewRunnableMethod(this, &VideoCaptureHost::DoHandleError, id.first,
+ id.second));
+}
+
+void VideoCaptureHost::OnBufferReady(
+ VideoCaptureController::ControllerId id,
+ TransportDIB::Handle handle,
+ base::Time timestamp) {
+ BrowserThread::PostTask(
+ BrowserThread::IO, FROM_HERE,
+ NewRunnableMethod(this, &VideoCaptureHost::DoSendFilledBuffer, id.first,
+ id.second, handle, timestamp));
+}
+
+void VideoCaptureHost::OnFrameInfo(VideoCaptureController::ControllerId id,
+ int width,
+ int height,
+ int frame_per_second) {
+ BrowserThread::PostTask(
+ BrowserThread::IO, FROM_HERE,
+ NewRunnableMethod(this, &VideoCaptureHost::DoSendFrameInfo, id.first,
+ id.second, width, height, frame_per_second));
+}
+
+void VideoCaptureHost::OnReadyToDelete(
+ VideoCaptureController::ControllerId id) {
+ BrowserThread::PostTask(
+ BrowserThread::IO, FROM_HERE,
+ NewRunnableMethod(this, &VideoCaptureHost::DoDeleteVideoCaptureController,
+ id));
+}
+
+void VideoCaptureHost::DoSendFilledBuffer(int32 routing_id,
+ int device_id,
+ TransportDIB::Handle handle,
+ base::Time timestamp) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+ Send(new VideoCaptureMsg_BufferReady(routing_id, device_id, handle,
+ timestamp));
+}
+
+void VideoCaptureHost::DoHandleError(int32 routing_id, int device_id) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+ Send(new VideoCaptureMsg_StateChanged(routing_id, device_id,
+ media::VideoCapture::kError));
+
+ VideoCaptureController::ControllerId id(routing_id, device_id);
+ EntryMap::iterator it = entries_.find(id);
+ if (it != entries_.end()) {
+ VideoCaptureController* controller = it->second;
+ controller->StopCapture(NULL);
+ }
+}
+
+void VideoCaptureHost::DoSendFrameInfo(int32 routing_id,
+ int device_id,
+ int width,
+ int height,
+ int frame_per_second) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+ media::VideoCaptureParams params;
+ params.width = width;
+ params.height = height;
+ params.frame_per_second = frame_per_second;
+ Send(new VideoCaptureMsg_DeviceInfo(routing_id, device_id, params));
+ Send(new VideoCaptureMsg_StateChanged(routing_id, device_id,
+ media::VideoCapture::kStarted));
+}
+
+///////////////////////////////////////////////////////////////////////////////
+// IPC Messages handler.
+bool VideoCaptureHost::OnMessageReceived(const IPC::Message& message,
+ bool* message_was_ok) {
+ bool handled = true;
+ IPC_BEGIN_MESSAGE_MAP_EX(VideoCaptureHost, message, *message_was_ok)
+ IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Start, OnStartCapture)
scherkus (not reviewing) 2011/05/23 05:05:09 indent the HANDLER functions by 2 spaces
Per K 2011/05/23 12:05:47 Done.
+ IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Pause, OnPauseCapture)
+ IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Stop, OnStopCapture)
+ IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_BufferReady, OnReceiveEmptyBuffer)
+ IPC_MESSAGE_UNHANDLED(handled = false)
+ IPC_END_MESSAGE_MAP_EX()
+
+ return handled;
+}
+
+void VideoCaptureHost::OnStartCapture(const IPC::Message& msg, int device_id,
+ const media::VideoCaptureParams& params) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+ VideoCaptureController::ControllerId controller_id(msg.routing_id(),
+ device_id);
+
+ DCHECK(entries_.find(controller_id) == entries_.end());
scherkus (not reviewing) 2011/05/23 05:05:09 DCHECK_EQ
Per K 2011/05/23 12:05:47 Can I really do that with complex types? I get the
scherkus (not reviewing) 2011/05/23 21:19:17 ah I thought it was a basic type! my bad!
+
+ scoped_refptr<VideoCaptureController> controller =
+ new VideoCaptureController(controller_id, this);
+ entries_.insert(std::make_pair(controller_id, controller));
+ controller->StartCapture(params);
+}
+
+void VideoCaptureHost::OnStopCapture(const IPC::Message& msg, int device_id) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+ VideoCaptureController::ControllerId controller_id(msg.routing_id(),
+ device_id);
+ EntryMap::iterator it = entries_.find(controller_id);
+ if (it != entries_.end()) {
+ scoped_refptr<VideoCaptureController> controller = it->second;
+ controller->StopCapture(NULL);
+ } else {
+ // It does not exist so it must have been stopped already.
scherkus (not reviewing) 2011/05/23 05:05:09 indentation
Per K 2011/05/23 12:05:47 Done.
+ Send(new VideoCaptureMsg_StateChanged(msg.routing_id(), device_id,
+ media::VideoCapture::kStopped));
+ }
+}
+
+void VideoCaptureHost::OnPauseCapture(const IPC::Message& msg, int device_id) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+ // Not used.
+ Send(new VideoCaptureMsg_StateChanged(msg.routing_id(), device_id,
+ media::VideoCapture::kError));
+}
+
+void VideoCaptureHost::OnReceiveEmptyBuffer(const IPC::Message& msg,
+ int device_id,
+ TransportDIB::Handle handle) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+ VideoCaptureController::ControllerId controller_id(msg.routing_id(),
+ device_id);
+ EntryMap::iterator it = entries_.find(controller_id);
+ if (it != entries_.end()) {
+ scoped_refptr<VideoCaptureController> controller = it->second;
+ controller->ReturnTransportDIB(handle);
+ }
+}
+
+void VideoCaptureHost::DoDeleteVideoCaptureController(
+ VideoCaptureController::ControllerId id) {
+ DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+ // Report that the device have successfully been stopped.
+ Send(new VideoCaptureMsg_StateChanged(id.first, id.second,
+ media::VideoCapture::kStopped));
+ entries_.erase(id);
scherkus (not reviewing) 2011/05/23 05:05:09 will this actually delete the VideoCaptureControll
Per K 2011/05/23 12:05:47 Yes- since it is a ref_counted pointer. VideoCapt
+}
« content/browser/renderer_host/video_capture_controller.cc ('K') | « content/browser/renderer_host/video_capture_host.h ('k') | content/browser/renderer_host/video_capture_host_unittest.cc » ('j') | content/browser/renderer_host/video_capture_host_unittest.cc » ('J')

Powered by Google App Engine
This is Rietveld 408576698