src/content/browser/renderer_host/media/video_capture_host.cc

   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
   3 // found in the LICENSE file.
   4
   5 #include "content/browser/renderer_host/media/video_capture_host.h"
   6
   7 #include "base/bind.h"
   8 #include "base/memory/scoped_ptr.h"
   9 #include "content/browser/browser_main_loop.h"
  10 #include "content/browser/renderer_host/media/media_stream_manager.h"
  11 #include "content/browser/renderer_host/media/video_capture_manager.h"
  12 #include "content/common/media/video_capture_messages.h"
  13
  14 namespace content {
  15
  16 VideoCaptureHost::VideoCaptureHost(MediaStreamManager* media_stream_manager)
  17     : media_stream_manager_(media_stream_manager) {
  18 }
  19
  20 VideoCaptureHost::~VideoCaptureHost() {}
  21
  22 void VideoCaptureHost::OnChannelClosing() {
  23   // Since the IPC channel is gone, close all requested VideoCaptureDevices.
  24   for (EntryMap::iterator it = entries_.begin(); it != entries_.end(); it++) {
  25     const base::WeakPtr<VideoCaptureController>& controller = it->second;
  26     if (controller) {
  27       VideoCaptureControllerID controller_id(it->first);
  28       media_stream_manager_->video_capture_manager()->StopCaptureForClient(
  29           controller.get(), controller_id, this);
  30     }
  31   }
  32 }
  33
  34 void VideoCaptureHost::OnDestruct() const {
  35   BrowserThread::DeleteOnIOThread::Destruct(this);
  36 }
  37
  38 ///////////////////////////////////////////////////////////////////////////////
  39
  40 // Implements VideoCaptureControllerEventHandler.
  41 void VideoCaptureHost::OnError(const VideoCaptureControllerID& controller_id) {
  42   DVLOG(1) << "VideoCaptureHost::OnError";
  43   BrowserThread::PostTask(
  44       BrowserThread::IO, FROM_HERE,
  45       base::Bind(&VideoCaptureHost::DoHandleErrorOnIOThread,
  46                  this, controller_id));
  47 }
  48
  49 void VideoCaptureHost::OnBufferCreated(
  50     const VideoCaptureControllerID& controller_id,
  51     base::SharedMemoryHandle handle,
  52     int length,
  53     int buffer_id) {
  54   BrowserThread::PostTask(
  55       BrowserThread::IO, FROM_HERE,
  56       base::Bind(&VideoCaptureHost::DoSendNewBufferOnIOThread,
  57                  this, controller_id, handle, length, buffer_id));
  58 }
  59
  60 void VideoCaptureHost::OnBufferDestroyed(
  61     const VideoCaptureControllerID& controller_id,
  62     int buffer_id) {
  63   BrowserThread::PostTask(
  64       BrowserThread::IO, FROM_HERE,
  65       base::Bind(&VideoCaptureHost::DoSendFreeBufferOnIOThread,
  66                  this, controller_id, buffer_id));
  67 }
  68
  69 void VideoCaptureHost::OnBufferReady(
  70     const VideoCaptureControllerID& controller_id,
  71     int buffer_id,
  72     base::Time timestamp,
  73     const media::VideoCaptureFormat& frame_format) {
  74   BrowserThread::PostTask(
  75       BrowserThread::IO, FROM_HERE,
  76       base::Bind(&VideoCaptureHost::DoSendFilledBufferOnIOThread,
  77                  this, controller_id, buffer_id, timestamp,
  78                  frame_format));
  79 }
  80
  81 void VideoCaptureHost::OnEnded(const VideoCaptureControllerID& controller_id) {
  82   DVLOG(1) << "VideoCaptureHost::OnEnded";
  83   BrowserThread::PostTask(
  84       BrowserThread::IO, FROM_HERE,
  85       base::Bind(&VideoCaptureHost::DoEndedOnIOThread, this, controller_id));
  86 }
  87
  88 void VideoCaptureHost::DoSendNewBufferOnIOThread(
  89     const VideoCaptureControllerID& controller_id,
  90     base::SharedMemoryHandle handle,
  91     int length,
  92     int buffer_id) {
  93   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
  94
  95   if (entries_.find(controller_id) == entries_.end())
  96     return;
  97
  98   Send(new VideoCaptureMsg_NewBuffer(controller_id.device_id, handle,
  99                                      length, buffer_id));
 100 }
 101
 102 void VideoCaptureHost::DoSendFreeBufferOnIOThread(
 103     const VideoCaptureControllerID& controller_id,
 104     int buffer_id) {
 105   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 106
 107   if (entries_.find(controller_id) == entries_.end())
 108     return;
 109
 110   Send(new VideoCaptureMsg_FreeBuffer(controller_id.device_id, buffer_id));
 111 }
 112
 113 void VideoCaptureHost::DoSendFilledBufferOnIOThread(
 114     const VideoCaptureControllerID& controller_id,
 115     int buffer_id, base::Time timestamp,
 116     const media::VideoCaptureFormat& format) {
 117   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 118
 119   if (entries_.find(controller_id) == entries_.end())
 120     return;
 121
 122   Send(new VideoCaptureMsg_BufferReady(controller_id.device_id, buffer_id,
 123                                        timestamp, format));
 124 }
 125
 126 void VideoCaptureHost::DoHandleErrorOnIOThread(
 127     const VideoCaptureControllerID& controller_id) {
 128   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 129
 130   if (entries_.find(controller_id) == entries_.end())
 131     return;
 132
 133   Send(new VideoCaptureMsg_StateChanged(controller_id.device_id,
 134                                         VIDEO_CAPTURE_STATE_ERROR));
 135   DeleteVideoCaptureControllerOnIOThread(controller_id);
 136 }
 137
 138 void VideoCaptureHost::DoEndedOnIOThread(
 139     const VideoCaptureControllerID& controller_id) {
 140   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 141   DVLOG(1) << "VideoCaptureHost::DoEndedOnIOThread";
 142   if (entries_.find(controller_id) == entries_.end())
 143     return;
 144
 145   Send(new VideoCaptureMsg_StateChanged(controller_id.device_id,
 146                                         VIDEO_CAPTURE_STATE_ENDED));
 147   DeleteVideoCaptureControllerOnIOThread(controller_id);
 148 }
 149
 150 ///////////////////////////////////////////////////////////////////////////////
 151 // IPC Messages handler.
 152 bool VideoCaptureHost::OnMessageReceived(const IPC::Message& message,
 153                                          bool* message_was_ok) {
 154   bool handled = true;
 155   IPC_BEGIN_MESSAGE_MAP_EX(VideoCaptureHost, message, *message_was_ok)
 156     IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Start, OnStartCapture)
 157     IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Pause, OnPauseCapture)
 158     IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_Stop, OnStopCapture)
 159     IPC_MESSAGE_HANDLER(VideoCaptureHostMsg_BufferReady, OnReceiveEmptyBuffer)
 160     IPC_MESSAGE_UNHANDLED(handled = false)
 161   IPC_END_MESSAGE_MAP_EX()
 162
 163   return handled;
 164 }
 165
 166 void VideoCaptureHost::OnStartCapture(int device_id,
 167                                       const media::VideoCaptureParams& params) {
 168   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 169   DVLOG(1) << "VideoCaptureHost::OnStartCapture, device_id " << device_id
 170            << ", (" << params.requested_format.width
 171            << ", " << params.requested_format.height
 172            << ", " << params.requested_format.frame_rate
 173            << ", " << params.session_id << ", variable resolution device:"
 174            << ((params.requested_format.frame_size_type ==
 175                media::VariableResolutionVideoCaptureDevice) ? "yes" : "no")
 176            << ")";
 177   VideoCaptureControllerID controller_id(device_id);
 178   DCHECK(entries_.find(controller_id) == entries_.end());
 179
 180   entries_[controller_id] = base::WeakPtr<VideoCaptureController>();
 181   media_stream_manager_->video_capture_manager()->StartCaptureForClient(
 182       params, PeerHandle(), controller_id, this, base::Bind(
 183           &VideoCaptureHost::OnControllerAdded, this, device_id, params));
 184 }
 185
 186 void VideoCaptureHost::OnControllerAdded(
 187     int device_id, const media::VideoCaptureParams& params,
 188     const base::WeakPtr<VideoCaptureController>& controller) {
 189   BrowserThread::PostTask(
 190       BrowserThread::IO, FROM_HERE,
 191       base::Bind(&VideoCaptureHost::DoControllerAddedOnIOThread,
 192                  this, device_id, params, controller));
 193 }
 194
 195 void VideoCaptureHost::DoControllerAddedOnIOThread(
 196     int device_id, const media::VideoCaptureParams& params,
 197     const base::WeakPtr<VideoCaptureController>& controller) {
 198   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 199   VideoCaptureControllerID controller_id(device_id);
 200   EntryMap::iterator it = entries_.find(controller_id);
 201   if (it == entries_.end()) {
 202     if (controller) {
 203       media_stream_manager_->video_capture_manager()->StopCaptureForClient(
 204           controller.get(), controller_id, this);
 205     }
 206     return;
 207   }
 208
 209   if (!controller) {
 210     Send(new VideoCaptureMsg_StateChanged(device_id,
 211                                           VIDEO_CAPTURE_STATE_ERROR));
 212     entries_.erase(controller_id);
 213     return;
 214   }
 215
 216   DCHECK(!it->second);
 217   it->second = controller;
 218 }
 219
 220 void VideoCaptureHost::OnStopCapture(int device_id) {
 221   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 222   DVLOG(1) << "VideoCaptureHost::OnStopCapture, device_id " << device_id;
 223
 224   VideoCaptureControllerID controller_id(device_id);
 225
 226   Send(new VideoCaptureMsg_StateChanged(device_id,
 227                                         VIDEO_CAPTURE_STATE_STOPPED));
 228   DeleteVideoCaptureControllerOnIOThread(controller_id);
 229 }
 230
 231 void VideoCaptureHost::OnPauseCapture(int device_id) {
 232   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 233   DVLOG(1) << "VideoCaptureHost::OnPauseCapture, device_id " << device_id;
 234   // Not used.
 235   Send(new VideoCaptureMsg_StateChanged(device_id, VIDEO_CAPTURE_STATE_ERROR));
 236 }
 237
 238 void VideoCaptureHost::OnReceiveEmptyBuffer(int device_id, int buffer_id) {
 239   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 240
 241   VideoCaptureControllerID controller_id(device_id);
 242   EntryMap::iterator it = entries_.find(controller_id);
 243   if (it != entries_.end()) {
 244     const base::WeakPtr<VideoCaptureController>& controller = it->second;
 245     if (controller)
 246       controller->ReturnBuffer(controller_id, this, buffer_id);
 247   }
 248 }
 249
 250 void VideoCaptureHost::DeleteVideoCaptureControllerOnIOThread(
 251     const VideoCaptureControllerID& controller_id) {
 252   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 253
 254   EntryMap::iterator it = entries_.find(controller_id);
 255   if (it == entries_.end())
 256     return;
 257
 258   if (it->second) {
 259     media_stream_manager_->video_capture_manager()->StopCaptureForClient(
 260         it->second.get(), controller_id, this);
 261   }
 262   entries_.erase(it);
 263 }
 264
 265 }  // namespace content