| Index: services/video_capture/device_factory_media_to_mojo_adapter.cc
|
| diff --git a/services/video_capture/device_factory_media_to_mojo_adapter.cc b/services/video_capture/device_factory_media_to_mojo_adapter.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..c39f5c90743dc4b026daad77763c847242d048a4
|
| --- /dev/null
|
| +++ b/services/video_capture/device_factory_media_to_mojo_adapter.cc
|
| @@ -0,0 +1,101 @@
|
| +// Copyright 2016 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 "services/video_capture/device_factory_media_to_mojo_adapter.h"
|
| +
|
| +#include <sstream>
|
| +
|
| +#include "base/logging.h"
|
| +#include "base/strings/stringprintf.h"
|
| +#include "media/capture/video/fake_video_capture_device.h"
|
| +#include "mojo/public/cpp/bindings/strong_binding.h"
|
| +#include "services/video_capture/device_mock_to_media_adapter.h"
|
| +#include "services/video_capture/video_capture_device_proxy_impl.h"
|
| +
|
| +namespace video_capture {
|
| +
|
| +DeviceFactoryMediaToMojoAdapter::ActiveDeviceEntry::ActiveDeviceEntry() =
|
| + default;
|
| +
|
| +DeviceFactoryMediaToMojoAdapter::ActiveDeviceEntry::~ActiveDeviceEntry() =
|
| + default;
|
| +
|
| +DeviceFactoryMediaToMojoAdapter::ActiveDeviceEntry::ActiveDeviceEntry(
|
| + DeviceFactoryMediaToMojoAdapter::ActiveDeviceEntry&& other) = default;
|
| +
|
| +DeviceFactoryMediaToMojoAdapter::ActiveDeviceEntry&
|
| +DeviceFactoryMediaToMojoAdapter::ActiveDeviceEntry::operator=(
|
| + DeviceFactoryMediaToMojoAdapter::ActiveDeviceEntry&& other) = default;
|
| +
|
| +DeviceFactoryMediaToMojoAdapter::DeviceFactoryMediaToMojoAdapter(
|
| + std::unique_ptr<media::VideoCaptureDeviceFactory> device_factory,
|
| + const media::VideoCaptureJpegDecoderFactoryCB&
|
| + jpeg_decoder_factory_callback)
|
| + : device_factory_(std::move(device_factory)),
|
| + jpeg_decoder_factory_callback_(jpeg_decoder_factory_callback) {}
|
| +
|
| +DeviceFactoryMediaToMojoAdapter::~DeviceFactoryMediaToMojoAdapter() = default;
|
| +
|
| +void DeviceFactoryMediaToMojoAdapter::EnumerateDeviceDescriptors(
|
| + const EnumerateDeviceDescriptorsCallback& callback) {
|
| + media::VideoCaptureDeviceDescriptors descriptors;
|
| + device_factory_->GetDeviceDescriptors(&descriptors);
|
| + callback.Run(descriptors);
|
| +}
|
| +
|
| +void DeviceFactoryMediaToMojoAdapter::GetSupportedFormats(
|
| + const media::VideoCaptureDeviceDescriptor& device_descriptor,
|
| + const GetSupportedFormatsCallback& callback) {
|
| + std::vector<VideoCaptureFormat> result;
|
| + NOTIMPLEMENTED();
|
| + callback.Run(std::move(result));
|
| +}
|
| +
|
| +void DeviceFactoryMediaToMojoAdapter::CreateDeviceProxy(
|
| + const media::VideoCaptureDeviceDescriptor& device_descriptor,
|
| + mojom::VideoCaptureDeviceProxyRequest proxy_request,
|
| + const CreateDeviceProxyCallback& callback) {
|
| + if (active_devices_.find(device_descriptor) != active_devices_.end()) {
|
| + // The requested device is already in use.
|
| + // Revoke the access and close the device, then bind to the new request.
|
| + ActiveDeviceEntry& device_entry = active_devices_[device_descriptor];
|
| + device_entry.binding->Unbind();
|
| + device_entry.device_proxy->Stop();
|
| + device_entry.binding->Bind(std::move(proxy_request));
|
| + device_entry.binding->set_connection_error_handler(base::Bind(
|
| + &DeviceFactoryMediaToMojoAdapter::OnClientConnectionErrorOrClose,
|
| + base::Unretained(this), device_descriptor));
|
| + callback.Run(mojom::DeviceAccessResultCode::SUCCESS);
|
| + return;
|
| + }
|
| +
|
| + std::unique_ptr<media::VideoCaptureDevice> media_device =
|
| + device_factory_->CreateDevice(device_descriptor);
|
| + if (media_device == nullptr) {
|
| + callback.Run(mojom::DeviceAccessResultCode::ERROR_DEVICE_NOT_FOUND);
|
| + return;
|
| + }
|
| +
|
| + // Add entry to |active_devices| to keep track of it
|
| + ActiveDeviceEntry device_entry;
|
| + device_entry.device_proxy = base::MakeUnique<VideoCaptureDeviceProxyImpl>(
|
| + std::move(media_device), jpeg_decoder_factory_callback_);
|
| + device_entry.binding =
|
| + base::MakeUnique<mojo::Binding<mojom::VideoCaptureDeviceProxy>>(
|
| + device_entry.device_proxy.get(), std::move(proxy_request));
|
| + device_entry.binding->set_connection_error_handler(base::Bind(
|
| + &DeviceFactoryMediaToMojoAdapter::OnClientConnectionErrorOrClose,
|
| + base::Unretained(this), device_descriptor));
|
| + active_devices_[device_descriptor] = std::move(device_entry);
|
| +
|
| + callback.Run(mojom::DeviceAccessResultCode::SUCCESS);
|
| +}
|
| +
|
| +void DeviceFactoryMediaToMojoAdapter::OnClientConnectionErrorOrClose(
|
| + const media::VideoCaptureDeviceDescriptor& descriptor) {
|
| + active_devices_[descriptor].device_proxy->Stop();
|
| + active_devices_.erase(descriptor);
|
| +}
|
| +
|
| +} // namespace video_capture
|
|
|