VideoCaptureHost

content/browser/renderer_host/video_capture_host.cc

+// 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 following compile error when
I change to DCHECK_EQ(entries_.find(controller_id), entries_.end());:
In file included from ./base/memory/weak_ptr.h:56,
                 from ./base/task.h:11,
                 from ./content/browser/browser_thread.h:11,
                 from ./content/browser/browser_message_filter.h:10,
                 from ./content/browser/renderer_host/video_capture_host.h:42,
                 from content/browser/renderer_host/video_capture_host.cc:5:
./base/logging.h: In function ‘std::string* logging::MakeCheckOpString(const
t1&, const t2&, const char*) [with t1 = std::_Rb_tree_iterator<std::pair<const
std::pair<int, int>, scoped_refptr<VideoCaptureController> > >, t2 =
std::_Rb_tree_iterator<std::pair<const std::pair<int, int>,
scoped_refptr<VideoCaptureController> > >]’:
./base/logging.h:512:   instantiated from ‘std::string*
logging::CheckEQImpl(const t1&, const t2&, const char*) [with t1 =
std::_Rb_tree_iterator<std::pair<const std::pair<int, int>,
scoped_refptr<VideoCaptureController> > >, t2 =
std::_Rb_tree_iterator<std::pair<const std::pair<int, int>,
scoped_refptr<VideoCaptureController> > >]’
content/browser/renderer_host/video_capture_host.cc:133:   instantiated from
here
./base/logging.h:465: error: no match for ‘operator<<’ in ‘std::operator<< [with
_Traits = std::char_traits<char>](((std::basic_ostream<char,
std::char_traits<char> >&)((std::basic_ostream<char, std::char_traits<char>
>*)std::operator<< [with _Traits =
std::char_traits<char>](((std::basic_ostream<char, std::char_traits<char> >&)(&
ss.std::basic_ostringstream<char, std::char_traits<char>, std::allocator<char>
>::<anonymous>)), names))), ((const char*)" (")) << v1’
/usr/include/c++/4.4/ostream:108: note: candidates are:
std::basic_ostream<_CharT, _Traits>& std::basic_ostream<_CharT,
_Traits>::operator<<(std::basic_ostream<_CharT, _Traits>& (*)

[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 VideoCaptureController?

[Per K, 2011/05/23 12:05:47]

Yes- since it is a ref_counted pointer.

VideoCaptureController::~VideoCaptureController() at
video_capture_controller.cc:26 0x3c044a3	
base::RefCountedThreadSafe<VideoCaptureController,
base::DefaultRefCountedThreadSafeTraits<VideoCaptureController>
>::DeleteInternal() at ref_counted.h:149 0x3b6d6f2	
base::DefaultRefCountedThreadSafeTraits<VideoCaptureController>::Destruct() at
ref_counted.h:114 0x3b6d182	
base::RefCountedThreadSafe<VideoCaptureController,
base::DefaultRefCountedThreadSafeTraits<VideoCaptureController> >::Release() at
ref_counted.h:143 0x3b6ca5c	
scoped_refptr<VideoCaptureController>::~scoped_refptr() at ref_counted.h:241
0x3b6c3a5	
std::pair<std::pair<int, int> const, scoped_refptr<VideoCaptureController>
>::~pair() at stl_pair.h:68 0x3b6bda2	
__gnu_cxx::new_allocator<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > >::destroy() at new_allocator.h:115
0x3b6d68a	
std::_Rb_tree<std::pair<int, int>, std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> >,
std::_Select1st<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > >, std::less<std::pair<int, int> >,
std::allocator<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > > >::_M_destroy_node() at stl_tree.h:383
0x3b6ce3d	
std::_Rb_tree<std::pair<int, int>, std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> >,
std::_Select1st<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > >, std::less<std::pair<int, int> >,
std::allocator<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > > >::_M_erase() at stl_tree.h:972
0x3b6c561	
std::_Rb_tree<std::pair<int, int>, std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> >,
std::_Select1st<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > >, std::less<std::pair<int, int> >,
std::allocator<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > > >::clear() at stl_tree.h:726
0x3b6d857	
std::_Rb_tree<std::pair<int, int>, std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> >,
std::_Select1st<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > >, std::less<std::pair<int, int> >,
std::allocator<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > > >::erase() at stl_tree.h:1,385
0x3b6d57e	
std::_Rb_tree<std::pair<int, int>, std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> >,
std::_Select1st<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > >, std::less<std::pair<int, int> >,
std::allocator<std::pair<std::pair<int, int> const,
scoped_refptr<VideoCaptureController> > > >::erase() at stl_tree.h:1,374
0x3b6cd56	
std::map<std::pair<int, int>, scoped_refptr<VideoCaptureController>,
std::less<std::pair<int, int> >, std::allocator<std::pair<std::pair<int, int>
const, scoped_refptr<VideoCaptureController> > > >::erase() at stl_map.h:582
0x3b6c4d7	
VideoCaptureHost::DoDeleteVideoCaptureController() at video_capture_host.cc:186
0x3b6b9e2	

+}