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
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "chromecast/external_mojo/external_service_support/chromium_service.h"
#include <utility>
#include "base/check.h"
#include "base/functional/bind.h"
#include "base/token.h"
#include "chromecast/external_mojo/external_service_support/external_connector.h"
#include "mojo/public/cpp/bindings/pending_associated_receiver.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "services/service_manager/public/cpp/bind_source_info.h"
#include "services/service_manager/public/cpp/connector.h"
#include "services/service_manager/public/mojom/connector.mojom.h"
#include "services/service_manager/public/mojom/service_control.mojom.h"
namespace chromecast {
namespace external_service_support {
namespace {
void OnStartCallback(
ExternalConnector* connector,
mojo::PendingReceiver<service_manager::mojom::Connector> connector_receiver,
mojo::PendingAssociatedReceiver<service_manager::mojom::ServiceControl>
control_receiver) {
DCHECK(connector);
if (connector_receiver.is_valid()) {
connector->SendChromiumConnectorRequest(connector_receiver.PassPipe());
}
}
} // namespace
ChromiumServiceWrapper::ChromiumServiceWrapper(
ExternalConnector* connector,
mojo::Remote<service_manager::mojom::Service> service_remote,
std::unique_ptr<service_manager::Service> chromium_service,
const std::string& service_name)
: service_remote_(std::move(service_remote)),
chromium_service_(std::move(chromium_service)) {
DCHECK(connector);
DCHECK(chromium_service_);
connector->RegisterService(service_name,
service_receiver_.BindNewPipeAndPassRemote());
}
ChromiumServiceWrapper::~ChromiumServiceWrapper() = default;
void ChromiumServiceWrapper::OnBindInterface(
const std::string& interface_name,
mojo::ScopedMessagePipeHandle interface_pipe) {
chromium_service_->OnBindInterface(
service_manager::BindSourceInfo(
service_manager::Identity("unique", base::Token::CreateRandom(),
base::Token::CreateRandom(),
base::Token::CreateRandom()),
service_manager::CapabilitySet()),
interface_name, std::move(interface_pipe));
}
mojo::PendingReceiver<service_manager::mojom::Service>
CreateChromiumServiceReceiver(
ExternalConnector* connector,
mojo::Remote<service_manager::mojom::Service>* service_remote,
service_manager::Identity identity) {
DCHECK(connector);
if (identity.name().empty()) {
identity = service_manager::Identity(
"unspecified", base::Token::CreateRandom(), base::Token::CreateRandom(),
base::Token::CreateRandom());
}
auto receiver = service_remote->BindNewPipeAndPassReceiver();
(*service_remote)
->OnStart(identity, base::BindOnce(&OnStartCallback, connector));
return receiver;
}
std::unique_ptr<service_manager::Connector> CreateChromiumConnector(
ExternalConnector* connector) {
mojo::MessagePipe pipe;
connector->SendChromiumConnectorRequest(std::move(pipe.handle1));
return std::make_unique<service_manager::Connector>(
mojo::Remote<service_manager::mojom::Connector>(
mojo::PendingRemote<service_manager::mojom::Connector>(
std::move(pipe.handle0), 0)));
}
} // namespace external_service_support
} // namespace chromecast
|
