handle the case when device is closed before media pipeline is fully initialized.

content/browser/renderer_host/media/video_capture_host.cc

 // Copyright (c) 2012 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/media/video_capture_host.h"
 
 #include "base/bind.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/stl_util.h"
 #include "content/browser/renderer_host/media/media_stream_manager.h"
@@ skipping 52 matching lines @@
 void VideoCaptureHost::OnDestruct() const {
   BrowserThread::DeleteOnIOThread::Destruct(this);
 }
 
 ///////////////////////////////////////////////////////////////////////////////
 
 // Implements VideoCaptureControllerEventHandler.
 void VideoCaptureHost::OnError(const VideoCaptureControllerID& id) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
-      base::Bind(&VideoCaptureHost::DoHandleError, this, id.device_id));
+      base::Bind(&VideoCaptureHost::DoHandleErrorOnIOThread,
+                 this, id.device_id));
 }
 
 void VideoCaptureHost::OnBufferCreated(
     const VideoCaptureControllerID& id,
     base::SharedMemoryHandle handle,
     int length,
     int buffer_id) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
-      base::Bind(&VideoCaptureHost::DoSendNewBuffer,
+      base::Bind(&VideoCaptureHost::DoSendNewBufferOnIOThread,
                  this, id.device_id, handle, length, buffer_id));
 }
 
 void VideoCaptureHost::OnBufferReady(
     const VideoCaptureControllerID& id,
     int buffer_id,
     base::Time timestamp) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
-      base::Bind(&VideoCaptureHost::DoSendFilledBuffer,
+      base::Bind(&VideoCaptureHost::DoSendFilledBufferOnIOThread,
                  this, id.device_id, buffer_id, timestamp));
 }
 
 void VideoCaptureHost::OnFrameInfo(const VideoCaptureControllerID& id,
                                    int width,
                                    int height,
                                    int frame_per_second) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
-      base::Bind(&VideoCaptureHost::DoSendFrameInfo,
+      base::Bind(&VideoCaptureHost::DoSendFrameInfoOnIOThread,
                  this, id.device_id, width, height, frame_per_second));
 }
 
+void VideoCaptureHost::OnPaused(const VideoCaptureControllerID& id) {
+  BrowserThread::PostTask(
+      BrowserThread::IO, FROM_HERE,
+      base::Bind(&VideoCaptureHost::DoPausedOnIOThread, this, id.device_id));
+}
+
 void VideoCaptureHost::OnReadyToDelete(const VideoCaptureControllerID& id) {
   BrowserThread::PostTask(
       BrowserThread::IO, FROM_HERE,
-      base::Bind(&VideoCaptureHost::DoDeleteVideoCaptureController, this, id));
+      base::Bind(&VideoCaptureHost::DoDeleteVideoCaptureControllerOnIOThread,
+                 this, id));
 }
 
-void VideoCaptureHost::DoSendNewBuffer(
+void VideoCaptureHost::DoSendNewBufferOnIOThread(
     int device_id, base::SharedMemoryHandle handle,
     int length, int buffer_id) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 
   Send(new VideoCaptureMsg_NewBuffer(device_id, handle,
                                      length, buffer_id));
 }
 
-void VideoCaptureHost::DoSendFilledBuffer(
+void VideoCaptureHost::DoSendFilledBufferOnIOThread(
     int device_id, int buffer_id, base::Time timestamp) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 
   Send(new VideoCaptureMsg_BufferReady(device_id, buffer_id,
                                        timestamp));
 }
 
-void VideoCaptureHost::DoHandleError(int device_id) {
+void VideoCaptureHost::DoHandleErrorOnIOThread(int device_id) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 
   VideoCaptureControllerID id(device_id);
   EntryMap::iterator it = entries_.find(id);
   if (it == entries_.end() || it->second->state == video_capture::kError)
     return;
 
   it->second->state = video_capture::kError;
   Send(new VideoCaptureMsg_StateChanged(device_id,
                                         video_capture::kError));
 
   VideoCaptureController* controller = it->second->controller;
   controller->StopCapture(id, this, false);
 }
 
-void VideoCaptureHost::DoSendFrameInfo(int device_id,
+void VideoCaptureHost::DoPausedOnIOThread(int device_id) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+  VideoCaptureControllerID id(device_id);
+  EntryMap::iterator it = entries_.find(id);
+  if (it == entries_.end() || it->second->state == video_capture::kPaused)
+    return;
+
+  it->second->state = video_capture::kPaused;
+  Send(new VideoCaptureMsg_StateChanged(device_id,
+                                        video_capture::kPaused));
+}
+
+void VideoCaptureHost::DoSendFrameInfoOnIOThread(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(device_id, params));
@@ skipping 57 matching lines @@
                                           video_capture::kError));
     return;
   }
 
   Entry* entry = it->second;
   entry->controller = controller;
   if (entry->state == video_capture::kStarting) {
     entry->state = video_capture::kStarted;
     controller->StartCapture(controller_id, this, peer_handle(), params);
   } else if (entry->state == video_capture::kStopping) {
-    DoDeleteVideoCaptureController(controller_id);
+    DoDeleteVideoCaptureControllerOnIOThread(controller_id);
   } else {
     NOTREACHED();
   }
 }
 
 void VideoCaptureHost::OnStopCapture(int device_id) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   DVLOG(1) << "VideoCaptureHost::OnStopCapture, device_id " << device_id;
 
   VideoCaptureControllerID controller_id(device_id);
@@ skipping 33 matching lines @@
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 
   VideoCaptureControllerID controller_id(device_id);
   EntryMap::iterator it = entries_.find(controller_id);
   if (it != entries_.end()) {
     scoped_refptr<VideoCaptureController> controller = it->second->controller;
     controller->ReturnBuffer(controller_id, this, buffer_id);
   }
 }
 
-void VideoCaptureHost::DoDeleteVideoCaptureController(
+void VideoCaptureHost::DoDeleteVideoCaptureControllerOnIOThread(
     const VideoCaptureControllerID& id) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
 
   // Report that the device have successfully been stopped.
   Send(new VideoCaptureMsg_StateChanged(id.device_id,
                                         video_capture::kStopped));
   EntryMap::iterator it = entries_.find(id);
   if (it != entries_.end()) {
     if (it->second->controller) {
       GetVideoCaptureManager()->RemoveController(it->second->controller, this);
     }
     delete it->second;
     entries_.erase(id);
   }
 }
 
 media_stream::VideoCaptureManager* VideoCaptureHost::GetVideoCaptureManager() {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   return media_stream::MediaStreamManager::GetForResourceContext(
       resource_context_, audio_manager_)->video_capture_manager();
 }