Implement CancelUserMediaRequest for the browser part

content/browser/renderer_host/media/media_stream_manager.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/media_stream_manager.h"
 
 #include <list>
 
 #include "base/bind.h"
 #include "base/compiler_specific.h"
@@ skipping 196 matching lines @@
           }
         }
       }
       requests_.erase(it++);
     } else {
       ++it;
     }
   }
 }
 
+void MediaStreamManager::CancelGenerateStream(const std::string& label) {
+  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
+
+  DeviceRequests::iterator it = requests_.find(label);
+  if (it != requests_.end()) {
+    // The request isn't complete.
+    if (!RequestDone(it->second)) {
+      DeviceRequest* request = &(it->second);
+      if (request->state[content::MEDIA_STREAM_DEVICE_TYPE_AUDIO_CAPTURE] ==
+          DeviceRequest::kOpening) {
+        for (StreamDeviceInfoArray::iterator it =
+             request->audio_devices.begin(); it != request->audio_devices.end();
+             ++it) {
+          if (it->in_use) {

[wjia(left Chromium), 2012/06/06 13:40:24]

This check is not needed. |in_use| is a signal for "opened". We have to call
"Close()" as long as we have called "Open()".

The |state| would be per device. But currently it's per device type. That's a
different problem.

+            audio_input_device_manager()->Close(it->session_id);
+          }
+        }
+      }
+      if (request->state[content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE] ==
+          DeviceRequest::kOpening) {
+        for (StreamDeviceInfoArray::iterator it =
+             request->video_devices.begin(); it != request->video_devices.end();
+             ++it) {
+          if (it->in_use) {

[wjia(left Chromium), 2012/06/06 13:40:24]

ditto.

+            video_capture_manager()->Close(it->session_id);
+          }
+        }
+      }
+      requests_.erase(it);
+    } else {
+      StopGeneratedStream(label);
+    }
+    device_settings_->RemovePendingCaptureRequest(label);
+  }
+}
+
 void MediaStreamManager::StopGeneratedStream(const std::string& label) {
   DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO));
   // Find the request and close all open devices for the request.
   DeviceRequests::iterator it = requests_.find(label);
   if (it != requests_.end()) {
     for (StreamDeviceInfoArray::iterator audio_it =
          it->second.audio_devices.begin();
          audio_it != it->second.audio_devices.end(); ++audio_it) {
       audio_input_device_manager()->Close(audio_it->session_id);
     }
@@ skipping 429 matching lines @@
   if (stream_type == content::MEDIA_STREAM_DEVICE_TYPE_VIDEO_CAPTURE) {
     return video_capture_manager();
   } else if (stream_type == content::MEDIA_STREAM_DEVICE_TYPE_AUDIO_CAPTURE) {
     return audio_input_device_manager();
   }
   NOTREACHED();
   return NULL;
 }
 
 }  // namespace media_stream