[Mojo Video Capture] Hook up connection lost events

content/browser/renderer_host/media/video_capture_controller.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_controller.h"
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <map>
@@ skipping 480 matching lines @@
 }
 
 void VideoCaptureController::OnDeviceLaunched(
     std::unique_ptr<LaunchedVideoCaptureDevice> device) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   launched_device_ = std::move(device);
   for (auto& entry : buffer_contexts_)
     entry.set_consumer_feedback_observer(launched_device_.get());
   if (device_launch_observer_) {
     device_launch_observer_->OnDeviceLaunched(this);
-    device_launch_observer_ = nullptr;
   }
 }
 
 void VideoCaptureController::OnDeviceLaunchFailed() {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   if (device_launch_observer_) {
     device_launch_observer_->OnDeviceLaunchFailed(this);
     device_launch_observer_ = nullptr;
   }
 }
 
 void VideoCaptureController::OnDeviceLaunchAborted() {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   if (device_launch_observer_) {
     device_launch_observer_->OnDeviceLaunchAborted();
     device_launch_observer_ = nullptr;
   }
 }
 
+void VideoCaptureController::OnDeviceConnectionLost() {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  if (device_launch_observer_) {
+    device_launch_observer_->OnDeviceConnectionLost(this);
+    device_launch_observer_ = nullptr;
+  }
+}
+
 void VideoCaptureController::CreateAndStartDeviceAsync(
     const media::VideoCaptureParams& params,
     VideoCaptureDeviceLaunchObserver* observer,
     base::OnceClosure done_cb) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   device_launch_observer_ = observer;
-  device_launcher_->LaunchDeviceAsync(device_id_, stream_type_, params,
-                                      GetWeakPtrForIOThread(), this,
-                                      std::move(done_cb));
+  device_launcher_->LaunchDeviceAsync(
+      device_id_, stream_type_, params, GetWeakPtrForIOThread(),
+      base::Bind(&VideoCaptureController::OnDeviceConnectionLost,
+                 GetWeakPtrForIOThread()),
+      this, std::move(done_cb));
 }
 
 void VideoCaptureController::ReleaseDeviceAsync(base::OnceClosure done_cb) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   if (!launched_device_) {
     device_launcher_->AbortLaunch();
     return;
   }
   launched_device_.reset();
 }
@@ skipping 128 matching lines @@
     EventHandlerAction action) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   for (const auto& client : controller_clients_) {
     if (client->session_closed)
       continue;
     action.Run(client->event_handler, client->controller_id);
   }
 }
 
 }  // namespace content