1
    2
    3
    4
    5
    6
    7
    8
    9
   10
   11
   12
   13
   14
   15
   16
   17
   18
   19
   20
   21
   22
   23
   24
   25
   26
   27
   28
   29
   30
   31
   32
   33
   34
   35
   36
   37
   38
   39
   40
   41
   42
   43
   44
   45
   46
   47
   48
   49
   50
   51


content / browser / renderer_host / media / video_capture_devices_changed_observer.cc [blame]

// Copyright 2023 The Chromium Authors
// 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_devices_manager.h"

#include "content/public/browser/video_capture_service.h"
#include "services/video_capture/public/mojom/video_capture_service.mojom.h"

namespace content {

MediaDevicesManager::VideoCaptureDevicesChangedObserver::
    VideoCaptureDevicesChangedObserver(base::RepeatingClosure disconnect_cb,
                                       base::RepeatingClosure listener_cb)
    : disconnect_cb_(std::move(disconnect_cb)),
      listener_cb_(std::move(listener_cb)) {}

MediaDevicesManager::VideoCaptureDevicesChangedObserver::
    ~VideoCaptureDevicesChangedObserver() = default;

void MediaDevicesManager::VideoCaptureDevicesChangedObserver::
    OnDevicesChanged() {
  listener_cb_.Run();
}

void MediaDevicesManager::VideoCaptureDevicesChangedObserver::
    ConnectToService() {
  CHECK(!mojo_device_notifier_);
  CHECK(!receiver_.is_bound());
  GetVideoCaptureService().ConnectToVideoSourceProvider(
      mojo_device_notifier_.BindNewPipeAndPassReceiver());
  mojo_device_notifier_.set_disconnect_handler(
      base::BindOnce(&MediaDevicesManager::VideoCaptureDevicesChangedObserver::
                         OnConnectionError,
                     base::Unretained(this)));
  mojo_device_notifier_->RegisterDevicesChangedObserver(
      receiver_.BindNewPipeAndPassRemote());
}

void MediaDevicesManager::VideoCaptureDevicesChangedObserver::
    OnConnectionError() {
  mojo_device_notifier_.reset();
  receiver_.reset();

  if (disconnect_cb_) {
    disconnect_cb_.Run();
  }
  ConnectToService();
}

}  // namespace content