blob: aba986057d5258f00e388f1bec58cb6b7a6ba0bd (
plain)
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
|
// 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 "third_party/blink/renderer/modules/sensor/sensor_provider_proxy.h"
#include "third_party/blink/public/common/browser_interface_broker_proxy.h"
#include "third_party/blink/renderer/modules/sensor/sensor_proxy_impl.h"
#include "third_party/blink/renderer/modules/sensor/sensor_proxy_inspector_impl.h"
#include "third_party/blink/renderer/platform/mojo/mojo_helper.h"
namespace blink {
// SensorProviderProxy
SensorProviderProxy::SensorProviderProxy(Document& document)
: Supplement<Document>(document), inspector_mode_(false) {}
void SensorProviderProxy::InitializeIfNeeded() {
if (IsInitialized())
return;
GetSupplementable()->GetBrowserInterfaceBroker().GetInterface(
sensor_provider_.BindNewPipeAndPassReceiver());
sensor_provider_.set_disconnect_handler(
WTF::Bind(&SensorProviderProxy::OnSensorProviderConnectionError,
WrapWeakPersistent(this)));
}
// static
const char SensorProviderProxy::kSupplementName[] = "SensorProvider";
// static
SensorProviderProxy* SensorProviderProxy::From(Document* document) {
DCHECK(document);
SensorProviderProxy* provider_proxy =
Supplement<Document>::From<SensorProviderProxy>(*document);
if (!provider_proxy) {
provider_proxy = MakeGarbageCollected<SensorProviderProxy>(*document);
Supplement<Document>::ProvideTo(*document, provider_proxy);
}
provider_proxy->InitializeIfNeeded();
return provider_proxy;
}
SensorProviderProxy::~SensorProviderProxy() = default;
void SensorProviderProxy::Trace(blink::Visitor* visitor) {
visitor->Trace(sensor_proxies_);
Supplement<Document>::Trace(visitor);
}
SensorProxy* SensorProviderProxy::CreateSensorProxy(
device::mojom::blink::SensorType type,
Page* page) {
DCHECK(!GetSensorProxy(type));
SensorProxy* sensor =
inspector_mode_
? static_cast<SensorProxy*>(
MakeGarbageCollected<SensorProxyInspectorImpl>(type, this,
page))
: static_cast<SensorProxy*>(
MakeGarbageCollected<SensorProxyImpl>(type, this, page));
sensor_proxies_.insert(sensor);
return sensor;
}
SensorProxy* SensorProviderProxy::GetSensorProxy(
device::mojom::blink::SensorType type) {
for (SensorProxy* sensor : sensor_proxies_) {
// TODO(Mikhail) : Hash sensors by type for efficiency.
if (sensor->type() == type)
return sensor;
}
return nullptr;
}
void SensorProviderProxy::OnSensorProviderConnectionError() {
sensor_provider_.reset();
for (SensorProxy* sensor : sensor_proxies_) {
sensor->ReportError(DOMExceptionCode::kNotReadableError,
SensorProxy::kDefaultErrorDescription);
}
}
void SensorProviderProxy::RemoveSensorProxy(SensorProxy* proxy) {
DCHECK(sensor_proxies_.Contains(proxy));
sensor_proxies_.erase(proxy);
}
} // namespace blink
|
