Commit 657f4b1b authored by Miyoung Shin's avatar Miyoung Shin Committed by Commit Bot

Convert HidManagerClient to new Mojo types

This CL converts HidManagerClient{AssociatedPtr, AssociatedPtrInfo
and AssociatedRequest} in device, services and extensions to the
new Mojo type.

Bug: 955171
Change-Id: I86e47ad4d6bdb35a89cca8337bd066aa167b2c5c
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1803938
Commit-Queue: Miyoung Shin <myid.shin@igalia.com>
Reviewed-by: default avatarOksana Zhuravlova <oksamyt@chromium.org>
Reviewed-by: default avatarReilly Grant <reillyg@chromium.org>
Reviewed-by: default avatarDominick Ng <dominickn@chromium.org>
Cr-Commit-Position: refs/heads/master@{#697482}
parent 35e8900d
......@@ -156,9 +156,7 @@ void FakeFidoHidManager::GetDevicesAndSetClient(
GetDevicesCallback callback) {
GetDevices(std::move(callback));
device::mojom::HidManagerClientAssociatedPtr client_ptr;
client_ptr.Bind(std::move(client));
clients_.AddPtr(std::move(client_ptr));
clients_.Add(std::move(client));
}
void FakeFidoHidManager::GetDevices(GetDevicesCallback callback) {
......@@ -185,9 +183,8 @@ void FakeFidoHidManager::Connect(
void FakeFidoHidManager::AddDevice(device::mojom::HidDeviceInfoPtr device) {
device::mojom::HidDeviceInfo* device_info = device.get();
clients_.ForAllPtrs([device_info](device::mojom::HidManagerClient* client) {
for (auto& client : clients_)
client->DeviceAdded(device_info->Clone());
});
devices_[device->guid] = std::move(device);
}
......@@ -205,9 +202,8 @@ void FakeFidoHidManager::RemoveDevice(const std::string device_guid) {
return;
device::mojom::HidDeviceInfo* device_info = it->second.get();
clients_.ForAllPtrs([device_info](device::mojom::HidManagerClient* client) {
for (auto& client : clients_)
client->DeviceRemoved(device_info->Clone());
});
devices_.erase(it);
}
......
......@@ -14,9 +14,9 @@
#include "base/macros.h"
#include "base/memory/ptr_util.h"
#include "device/fido/fido_constants.h"
#include "mojo/public/cpp/bindings/interface_ptr_set.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/receiver_set.h"
#include "mojo/public/cpp/bindings/remote_set.h"
#include "mojo/public/cpp/bindings/strong_binding.h"
#include "services/device/public/mojom/hid.mojom.h"
#include "testing/gmock/include/gmock/gmock.h"
......@@ -122,7 +122,7 @@ class FakeFidoHidManager : public device::mojom::HidManager {
private:
std::map<std::string, device::mojom::HidDeviceInfoPtr> devices_;
std::map<std::string, device::mojom::HidConnectionPtr> connections_;
mojo::AssociatedInterfacePtrSet<device::mojom::HidManagerClient> clients_;
mojo::AssociatedRemoteSet<device::mojom::HidManagerClient> clients_;
mojo::ReceiverSet<device::mojom::HidManager> receivers_;
DISALLOW_COPY_AND_ASSIGN(FakeFidoHidManager);
......
......@@ -8,7 +8,6 @@
#include "base/bind.h"
#include "device/fido/hid/fido_hid_device.h"
#include "mojo/public/cpp/bindings/interface_request.h"
#include "services/device/public/mojom/constants.mojom.h"
#include "services/service_manager/public/cpp/connector.h"
......@@ -16,8 +15,7 @@ namespace device {
FidoHidDiscovery::FidoHidDiscovery(::service_manager::Connector* connector)
: FidoDeviceDiscovery(FidoTransportProtocol::kUsbHumanInterfaceDevice),
connector_(connector),
binding_(this) {
connector_(connector) {
// TODO(piperc@): Give this constant a name.
filter_.SetUsagePage(0xf1d0);
}
......@@ -28,11 +26,10 @@ void FidoHidDiscovery::StartInternal() {
DCHECK(connector_);
connector_->Connect(device::mojom::kServiceName,
hid_manager_.BindNewPipeAndPassReceiver());
device::mojom::HidManagerClientAssociatedPtrInfo client;
binding_.Bind(mojo::MakeRequest(&client));
hid_manager_->GetDevicesAndSetClient(
std::move(client), base::BindOnce(&FidoHidDiscovery::OnGetDevices,
receiver_.BindNewEndpointAndPassRemote(),
base::BindOnce(&FidoHidDiscovery::OnGetDevices,
weak_factory_.GetWeakPtr()));
}
......
......@@ -12,7 +12,7 @@
#include "base/macros.h"
#include "base/memory/weak_ptr.h"
#include "device/fido/fido_device_discovery.h"
#include "mojo/public/cpp/bindings/associated_binding.h"
#include "mojo/public/cpp/bindings/associated_receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/device/public/cpp/hid/hid_device_filter.h"
#include "services/device/public/mojom/hid.mojom.h"
......@@ -45,7 +45,7 @@ class COMPONENT_EXPORT(DEVICE_FIDO) FidoHidDiscovery
service_manager::Connector* connector_;
mojo::Remote<device::mojom::HidManager> hid_manager_;
mojo::AssociatedBinding<device::mojom::HidManagerClient> binding_;
mojo::AssociatedReceiver<device::mojom::HidManagerClient> receiver_{this};
HidDeviceFilter filter_;
base::WeakPtrFactory<FidoHidDiscovery> weak_factory_{this};
......
......@@ -14,7 +14,7 @@
namespace device {
NintendoDataFetcher::NintendoDataFetcher() : binding_(this) {}
NintendoDataFetcher::NintendoDataFetcher() = default;
NintendoDataFetcher::~NintendoDataFetcher() {
for (auto& entry : controllers_) {
......@@ -32,10 +32,9 @@ void NintendoDataFetcher::OnAddedToProvider() {
// OnGetDevices will be called with a list of connected HID devices.
connector()->Connect(mojom::kServiceName,
hid_manager_.BindNewPipeAndPassReceiver());
mojom::HidManagerClientAssociatedPtrInfo client;
binding_.Bind(mojo::MakeRequest(&client));
hid_manager_->GetDevicesAndSetClient(
std::move(client), base::BindOnce(&NintendoDataFetcher::OnGetDevices,
receiver_.BindNewEndpointAndPassRemote(),
base::BindOnce(&NintendoDataFetcher::OnGetDevices,
weak_factory_.GetWeakPtr()));
}
......
......@@ -14,7 +14,7 @@
#include "device/gamepad/gamepad_data_fetcher.h"
#include "device/gamepad/nintendo_controller.h"
#include "device/gamepad/public/cpp/gamepads.h"
#include "mojo/public/cpp/bindings/associated_binding.h"
#include "mojo/public/cpp/bindings/associated_receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/device/public/mojom/hid.mojom.h"
......@@ -112,7 +112,7 @@ class DEVICE_GAMEPAD_EXPORT NintendoDataFetcher : public GamepadDataFetcher,
ControllerMap controllers_;
mojo::Remote<mojom::HidManager> hid_manager_;
mojo::AssociatedBinding<mojom::HidManagerClient> binding_;
mojo::AssociatedReceiver<mojom::HidManagerClient> receiver_{this};
base::WeakPtrFactory<NintendoDataFetcher> weak_factory_{this};
DISALLOW_COPY_AND_ASSIGN(NintendoDataFetcher);
......
......@@ -20,8 +20,7 @@
#include "extensions/browser/api/device_permissions_manager.h"
#include "extensions/browser/api/usb/usb_device_manager.h"
#include "extensions/common/extension.h"
#include "mojo/public/cpp/bindings/associated_binding.h"
#include "mojo/public/cpp/bindings/interface_request.h"
#include "mojo/public/cpp/bindings/associated_receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/device/public/cpp/hid/hid_device_filter.h"
#include "services/device/public/cpp/hid/hid_usage_and_page.h"
......@@ -195,8 +194,7 @@ class HidDevicePermissionsPrompt : public DevicePermissionsPrompt::Prompt,
: Prompt(extension, context, multiple),
initialized_(false),
filters_(filters),
callback_(callback),
binding_(this) {}
callback_(callback) {}
private:
~HidDevicePermissionsPrompt() override {}
......@@ -221,11 +219,8 @@ class HidDevicePermissionsPrompt : public DevicePermissionsPrompt::Prompt,
connector->Connect(device::mojom::kServiceName,
hid_manager_.BindNewPipeAndPassReceiver());
device::mojom::HidManagerClientAssociatedPtrInfo client;
binding_.Bind(mojo::MakeRequest(&client));
hid_manager_->GetDevicesAndSetClient(
std::move(client),
receiver_.BindNewEndpointAndPassRemote(),
base::BindOnce(&HidDevicePermissionsPrompt::OnDevicesEnumerated, this));
initialized_ = true;
......@@ -300,7 +295,7 @@ class HidDevicePermissionsPrompt : public DevicePermissionsPrompt::Prompt,
std::vector<HidDeviceFilter> filters_;
mojo::Remote<device::mojom::HidManager> hid_manager_;
DevicePermissionsPrompt::HidDevicesCallback callback_;
mojo::AssociatedBinding<device::mojom::HidManagerClient> binding_;
mojo::AssociatedReceiver<device::mojom::HidManagerClient> receiver_{this};
};
} // namespace
......
......@@ -23,7 +23,6 @@
#include "extensions/common/permissions/permissions_data.h"
#include "extensions/common/permissions/usb_device_permission.h"
#include "mojo/public/cpp/bindings/callback_helpers.h"
#include "mojo/public/cpp/bindings/interface_request.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "services/device/public/cpp/hid/hid_device_filter.h"
#include "services/device/public/cpp/hid/hid_usage_and_page.h"
......@@ -102,7 +101,7 @@ struct HidDeviceManager::GetApiDevicesParams {
};
HidDeviceManager::HidDeviceManager(content::BrowserContext* context)
: browser_context_(context), binding_(this) {
: browser_context_(context) {
event_router_ = EventRouter::Get(context);
if (event_router_) {
event_router_->RegisterObserver(this, hid::OnDeviceAdded::kEventName);
......@@ -296,10 +295,8 @@ void HidDeviceManager::LazyInitialize() {
}
// Enumerate HID devices and set client.
std::vector<device::mojom::HidDeviceInfoPtr> empty_devices;
device::mojom::HidManagerClientAssociatedPtrInfo client;
binding_.Bind(mojo::MakeRequest(&client));
hid_manager_->GetDevicesAndSetClient(
std::move(client),
receiver_.BindNewEndpointAndPassRemote(),
mojo::WrapCallbackWithDefaultInvokeIfNotRun(
base::BindOnce(&HidDeviceManager::OnEnumerationComplete,
weak_factory_.GetWeakPtr()),
......
......@@ -18,7 +18,7 @@
#include "extensions/browser/event_router.h"
#include "extensions/browser/extension_event_histogram_value.h"
#include "extensions/common/api/hid.h"
#include "mojo/public/cpp/bindings/associated_binding.h"
#include "mojo/public/cpp/bindings/associated_receiver.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/device/public/mojom/hid.mojom.h"
......@@ -125,7 +125,7 @@ class HidDeviceManager : public BrowserContextKeyedAPI,
EventRouter* event_router_ = nullptr;
bool initialized_ = false;
mojo::Remote<device::mojom::HidManager> hid_manager_;
mojo::AssociatedBinding<device::mojom::HidManagerClient> binding_;
mojo::AssociatedReceiver<device::mojom::HidManagerClient> receiver_{this};
bool enumeration_ready_ = false;
std::vector<std::unique_ptr<GetApiDevicesParams>> pending_enumerations_;
int next_resource_id_ = 0;
......
......@@ -10,6 +10,7 @@
#include "base/callback_helpers.h"
#include "base/lazy_instance.h"
#include "base/stl_util.h"
#include "mojo/public/cpp/bindings/associated_remote.h"
#include "mojo/public/cpp/bindings/strong_binding.h"
#include "services/device/hid/hid_connection_impl.h"
......@@ -50,23 +51,21 @@ void HidManagerImpl::GetDevicesAndSetClient(
}
void HidManagerImpl::GetDevices(GetDevicesCallback callback) {
hid_service_->GetDevices(base::BindOnce(&HidManagerImpl::CreateDeviceList,
weak_factory_.GetWeakPtr(),
std::move(callback), nullptr));
hid_service_->GetDevices(base::BindOnce(
&HidManagerImpl::CreateDeviceList, weak_factory_.GetWeakPtr(),
std::move(callback), mojo::NullAssociatedRemote()));
}
void HidManagerImpl::CreateDeviceList(
GetDevicesCallback callback,
mojom::HidManagerClientAssociatedPtrInfo client,
mojo::PendingAssociatedRemote<mojom::HidManagerClient> client,
std::vector<mojom::HidDeviceInfoPtr> devices) {
std::move(callback).Run(std::move(devices));
if (!client.is_valid())
return;
mojom::HidManagerClientAssociatedPtr client_ptr;
client_ptr.Bind(std::move(client));
clients_.AddPtr(std::move(client_ptr));
clients_.Add(std::move(client));
}
void HidManagerImpl::Connect(
......@@ -98,17 +97,13 @@ void HidManagerImpl::CreateConnection(
}
void HidManagerImpl::OnDeviceAdded(mojom::HidDeviceInfoPtr device) {
mojom::HidDeviceInfo* device_info = device.get();
clients_.ForAllPtrs([device_info](mojom::HidManagerClient* client) {
client->DeviceAdded(device_info->Clone());
});
for (auto& client : clients_)
client->DeviceAdded(device->Clone());
}
void HidManagerImpl::OnDeviceRemoved(mojom::HidDeviceInfoPtr device) {
mojom::HidDeviceInfo* device_info = device.get();
clients_.ForAllPtrs([device_info](mojom::HidManagerClient* client) {
client->DeviceRemoved(device_info->Clone());
});
for (auto& client : clients_)
client->DeviceRemoved(device->Clone());
}
} // namespace device
......@@ -9,9 +9,10 @@
#include "base/memory/ref_counted.h"
#include "base/memory/weak_ptr.h"
#include "base/scoped_observer.h"
#include "mojo/public/cpp/bindings/interface_ptr_set.h"
#include "mojo/public/cpp/bindings/pending_associated_remote.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/receiver_set.h"
#include "mojo/public/cpp/bindings/remote_set.h"
#include "services/device/hid/hid_device_info.h"
#include "services/device/hid/hid_service.h"
#include "services/device/public/mojom/hid.mojom.h"
......@@ -43,8 +44,9 @@ class HidManagerImpl : public mojom::HidManager, public HidService::Observer {
ConnectCallback callback) override;
private:
void CreateDeviceList(GetDevicesCallback callback,
mojom::HidManagerClientAssociatedPtrInfo client,
void CreateDeviceList(
GetDevicesCallback callback,
mojo::PendingAssociatedRemote<mojom::HidManagerClient> client,
std::vector<mojom::HidDeviceInfoPtr> devices);
void CreateConnection(
......@@ -58,7 +60,7 @@ class HidManagerImpl : public mojom::HidManager, public HidService::Observer {
std::unique_ptr<HidService> hid_service_;
mojo::ReceiverSet<mojom::HidManager> receivers_;
mojo::AssociatedInterfacePtrSet<mojom::HidManagerClient> clients_;
mojo::AssociatedRemoteSet<mojom::HidManagerClient> clients_;
ScopedObserver<HidService, HidService::Observer> hid_service_observer_;
base::WeakPtrFactory<HidManagerImpl> weak_factory_{this};
......
......@@ -8,7 +8,8 @@
#include "base/memory/ref_counted.h"
#include "base/run_loop.h"
#include "build/build_config.h"
#include "mojo/public/cpp/bindings/associated_binding.h"
#include "mojo/public/cpp/bindings/associated_receiver.h"
#include "mojo/public/cpp/bindings/pending_associated_receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/device/device_service_test_base.h"
#include "services/device/hid/hid_manager_impl.h"
......@@ -29,10 +30,11 @@ const char* kTestDeviceIds[] = {"A", "B"};
class MockHidManagerClient : public mojom::HidManagerClient {
public:
MockHidManagerClient() : binding_(this) {}
MockHidManagerClient() = default;
~MockHidManagerClient() override = default;
void Bind(mojom::HidManagerClientAssociatedRequest request) {
binding_.Bind(std::move(request));
void Bind(mojo::PendingAssociatedReceiver<mojom::HidManagerClient> receiver) {
receiver_.Bind(std::move(receiver));
}
void DeviceAdded(mojom::HidDeviceInfoPtr device_info) override {
......@@ -58,7 +60,7 @@ class MockHidManagerClient : public mojom::HidManagerClient {
void SetExpectGUID(std::string guid) { expect_guid_ = guid; }
private:
mojo::AssociatedBinding<mojom::HidManagerClient> binding_;
mojo::AssociatedReceiver<mojom::HidManagerClient> receiver_{this};
mojom::HidConnectionPtr hid_connection_;
base::OnceClosure quit_closure_;
std::string expect_guid_;
......@@ -181,8 +183,8 @@ TEST_F(HidManagerTest, GetDevicesAndSetClient) {
mock_hid_service_->FirstEnumerationComplete();
auto client = std::make_unique<MockHidManagerClient>();
mojom::HidManagerClientAssociatedPtrInfo hid_manager_client;
client->Bind(mojo::MakeRequest(&hid_manager_client));
mojo::PendingAssociatedRemote<mojom::HidManagerClient> hid_manager_client;
client->Bind(hid_manager_client.InitWithNewEndpointAndPassReceiver());
// Call GetDevicesAndSetClient, expect 1 device will be received in
// OnGetDevices().
......@@ -230,8 +232,8 @@ TEST_F(HidManagerTest, TestHidConnectionInterface) {
mock_hid_service_->FirstEnumerationComplete();
auto client = std::make_unique<MockHidManagerClient>();
mojom::HidManagerClientAssociatedPtrInfo hid_manager_client;
client->Bind(mojo::MakeRequest(&hid_manager_client));
mojo::PendingAssociatedRemote<mojom::HidManagerClient> hid_manager_client;
client->Bind(hid_manager_client.InitWithNewEndpointAndPassReceiver());
// Call GetDevicesAndSetClient, expect 1 device will be received in
// OnGetDevices().
......
......@@ -104,9 +104,7 @@ void FakeHidManager::GetDevicesAndSetClient(
GetDevicesCallback callback) {
GetDevices(std::move(callback));
mojom::HidManagerClientAssociatedPtr client_ptr;
client_ptr.Bind(std::move(client));
clients_.AddPtr(std::move(client_ptr));
clients_.Add(std::move(client));
}
void FakeHidManager::GetDevices(GetDevicesCallback callback) {
......@@ -184,17 +182,15 @@ void FakeHidManager::AddDevice(mojom::HidDeviceInfoPtr device) {
devices_[guid] = std::move(device);
mojom::HidDeviceInfo* device_info = devices_[guid].get();
clients_.ForAllPtrs([device_info](mojom::HidManagerClient* client) {
for (auto& client : clients_)
client->DeviceAdded(device_info->Clone());
});
}
void FakeHidManager::RemoveDevice(const std::string& guid) {
if (base::Contains(devices_, guid)) {
mojom::HidDeviceInfo* device_info = devices_[guid].get();
clients_.ForAllPtrs([device_info](mojom::HidManagerClient* client) {
for (auto& client : clients_)
client->DeviceRemoved(device_info->Clone());
});
devices_.erase(guid);
}
}
......
......@@ -9,9 +9,9 @@
#include <string>
#include <vector>
#include "mojo/public/cpp/bindings/interface_ptr_set.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/receiver_set.h"
#include "mojo/public/cpp/bindings/remote_set.h"
#include "services/device/public/mojom/hid.mojom.h"
namespace device {
......@@ -71,7 +71,7 @@ class FakeHidManager : public mojom::HidManager {
private:
std::map<std::string, mojom::HidDeviceInfoPtr> devices_;
mojo::AssociatedInterfacePtrSet<mojom::HidManagerClient> clients_;
mojo::AssociatedRemoteSet<mojom::HidManagerClient> clients_;
mojo::ReceiverSet<mojom::HidManager> receivers_;
};
......
......@@ -314,6 +314,9 @@ interface HidManager {
// Enumerates available devices and set as a client of HidManager.
// The implementation of HidManager guarantees that the returned callback
// will always be posted earlier than DeviceAdded() and DeviceRemoved().
// TODO(crbug.com/955171): Use |pending_associated_remote| instead of
// |associated| after supporting mojom_js_generator.py completely for
// associated interfaces.
GetDevicesAndSetClient(associated HidManagerClient client) =>
(array<HidDeviceInfo> devices);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment