blob: b961bc37c3854136f0e18129dad6a36e0b69ef67 [file] [log] [blame]
// Copyright 2016 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef SERVICES_VIDEO_CAPTURE_DEVICE_FACTORY_MEDIA_TO_MOJO_ADAPTER_H_
#define SERVICES_VIDEO_CAPTURE_DEVICE_FACTORY_MEDIA_TO_MOJO_ADAPTER_H_
#include <map>
#include "base/task/sequenced_task_runner.h"
#include "build/build_config.h"
#include "build/chromeos_buildflags.h"
#include "media/capture/video/video_capture_device_client.h"
#include "media/capture/video/video_capture_system.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/receiver.h"
#include "services/video_capture/device_factory.h"
#include "services/video_capture/public/mojom/devices_changed_observer.mojom.h"
#if BUILDFLAG(IS_CHROMEOS_ASH)
#include "media/capture/video/chromeos/video_capture_device_factory_chromeos.h"
#endif // BUILDFLAG(IS_CHROMEOS_ASH)
namespace video_capture {
class DeviceMediaToMojoAdapter;
// Wraps a media::VideoCaptureSystem and exposes its functionality through the
// mojom::DeviceFactory interface. Keeps track of device instances that have
// been created to ensure that it does not create more than one instance of the
// same media::VideoCaptureDevice at the same time.
class DeviceFactoryMediaToMojoAdapter : public DeviceFactory {
public:
#if BUILDFLAG(IS_CHROMEOS_ASH)
DeviceFactoryMediaToMojoAdapter(
std::unique_ptr<media::VideoCaptureSystem> capture_system,
media::MojoMjpegDecodeAcceleratorFactoryCB jpeg_decoder_factory_callback,
scoped_refptr<base::SequencedTaskRunner> jpeg_decoder_task_runner);
#else
DeviceFactoryMediaToMojoAdapter(
std::unique_ptr<media::VideoCaptureSystem> capture_system);
#endif // BUILDFLAG(IS_CHROMEOS_ASH)
DeviceFactoryMediaToMojoAdapter(const DeviceFactoryMediaToMojoAdapter&) =
delete;
DeviceFactoryMediaToMojoAdapter& operator=(
const DeviceFactoryMediaToMojoAdapter&) = delete;
~DeviceFactoryMediaToMojoAdapter() override;
// DeviceFactory implementation.
void GetDeviceInfos(GetDeviceInfosCallback callback) override;
void CreateDevice(const std::string& device_id,
mojo::PendingReceiver<mojom::Device> device_receiver,
CreateDeviceCallback callback) override;
void CreateDeviceInProcess(const std::string& device_id,
CreateDeviceInProcessCallback callback) override;
void StopDeviceInProcess(const std::string device_id) override;
void AddSharedMemoryVirtualDevice(
const media::VideoCaptureDeviceInfo& device_info,
mojo::PendingRemote<mojom::Producer> producer,
mojo::PendingReceiver<mojom::SharedMemoryVirtualDevice>
virtual_device_receiver) override;
void AddTextureVirtualDevice(
const media::VideoCaptureDeviceInfo& device_info,
mojo::PendingReceiver<mojom::TextureVirtualDevice>
virtual_device_receiver) override;
void AddGpuMemoryBufferVirtualDevice(
const media::VideoCaptureDeviceInfo& device_info,
mojo::PendingReceiver<mojom::GpuMemoryBufferVirtualDevice>
virtual_device_receiver) override;
void RegisterVirtualDevicesChangedObserver(
mojo::PendingRemote<mojom::DevicesChangedObserver> observer,
bool raise_event_if_virtual_devices_already_present) override;
#if BUILDFLAG(IS_WIN)
void OnGpuInfoUpdate(const CHROME_LUID& luid) override;
#endif
private:
struct ActiveDeviceEntry {
ActiveDeviceEntry();
~ActiveDeviceEntry();
ActiveDeviceEntry(ActiveDeviceEntry&& other);
ActiveDeviceEntry& operator=(ActiveDeviceEntry&& other);
std::unique_ptr<DeviceMediaToMojoAdapter> device;
// TODO(chfremer) Use mojo::Receiver<> directly instead of unique_ptr<> when
// mojo::Receiver<> supports move operators.
// https://crbug.com/644314
std::unique_ptr<mojo::Receiver<mojom::Device>> receiver;
};
void CreateDeviceInternal(
const std::string& device_id,
absl::optional<mojo::PendingReceiver<mojom::Device>> device_receiver,
absl::optional<CreateDeviceCallback> create_callback,
absl::optional<CreateDeviceInProcessCallback> create_in_process_callback,
bool create_in_process);
void CreateAndAddNewDevice(
const std::string& device_id,
absl::optional<mojo::PendingReceiver<mojom::Device>> device_receiver,
absl::optional<CreateDeviceCallback> create_callback,
absl::optional<CreateDeviceInProcessCallback> create_in_process_callback,
bool create_in_process);
void OnClientConnectionErrorOrClose(const std::string& device_id);
const std::unique_ptr<media::VideoCaptureSystem> capture_system_;
std::map<std::string, ActiveDeviceEntry> active_devices_by_id_;
#if BUILDFLAG(IS_CHROMEOS_ASH)
const media::MojoMjpegDecodeAcceleratorFactoryCB
jpeg_decoder_factory_callback_;
scoped_refptr<base::SequencedTaskRunner> jpeg_decoder_task_runner_;
#endif // BUILDFLAG(IS_CHROMEOS_ASH)
bool has_called_get_device_infos_;
base::WeakPtrFactory<DeviceFactoryMediaToMojoAdapter> weak_factory_{this};
};
} // namespace video_capture
#endif // SERVICES_VIDEO_CAPTURE_DEVICE_FACTORY_MEDIA_TO_MOJO_ADAPTER_H_