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
98
99
|
// Copyright 2018 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef THIRD_PARTY_BLINK_RENDERER_MODULES_SENSOR_SENSOR_PROXY_IMPL_H_
#define THIRD_PARTY_BLINK_RENDERER_MODULES_SENSOR_SENSOR_PROXY_IMPL_H_
#include "third_party/blink/renderer/modules/sensor/sensor_proxy.h"
#include "base/task/single_thread_task_runner.h"
#include "third_party/blink/renderer/platform/heap/garbage_collected.h"
#include "third_party/blink/renderer/platform/mojo/heap_mojo_receiver.h"
#include "third_party/blink/renderer/platform/mojo/heap_mojo_remote.h"
#include "third_party/blink/renderer/platform/timer.h"
#include "third_party/blink/renderer/platform/wtf/vector.h"
namespace blink {
class SensorProviderProxy;
// This class wraps 'Sensor' mojo interface and used by multiple
// JS sensor instances of the same type (within a single frame).
class SensorProxyImpl final : public SensorProxy,
public device::mojom::blink::SensorClient {
public:
SensorProxyImpl(device::mojom::blink::SensorType,
SensorProviderProxy*,
Page*);
SensorProxyImpl(const SensorProxyImpl&) = delete;
SensorProxyImpl& operator=(const SensorProxyImpl&) = delete;
~SensorProxyImpl() override;
void Trace(Visitor*) const override;
private:
// SensorProxy overrides.
void Initialize() override;
void AddConfiguration(device::mojom::blink::SensorConfigurationPtr,
base::OnceCallback<void(bool)>) override;
void RemoveConfiguration(
device::mojom::blink::SensorConfigurationPtr) override;
double GetDefaultFrequency() const override;
std::pair<double, double> GetFrequencyLimits() const override;
void ReportError(DOMExceptionCode code, const String& message) override;
void Suspend() override;
void Resume() override;
// Updates sensor reading from shared buffer.
void UpdateSensorReading();
void NotifySensorChanged(double timestamp);
// device::mojom::blink::SensorClient overrides.
void RaiseError() override;
void SensorReadingChanged() override;
// Generic handler for a fatal error.
void HandleSensorError(
device::mojom::blink::SensorCreationResult =
device::mojom::blink::SensorCreationResult::ERROR_NOT_AVAILABLE);
// mojo call callbacks.
void OnSensorCreated(device::mojom::blink::SensorCreationResult,
device::mojom::blink::SensorInitParamsPtr);
void OnPollingTimer(TimerBase*);
// Returns 'true' if readings should be propagated to Observers
// (i.e. proxy is initialized, not suspended and has active configurations);
// returns 'false' otherwise.
bool ShouldProcessReadings() const;
// Starts or stops polling timer.
void UpdatePollingStatus();
void RemoveActiveFrequency(double frequency);
void AddActiveFrequency(double frequency);
device::mojom::blink::ReportingMode mode_ =
device::mojom::blink::ReportingMode::CONTINUOUS;
HeapMojoRemote<device::mojom::blink::Sensor> sensor_remote_;
HeapMojoReceiver<device::mojom::blink::SensorClient, SensorProxyImpl>
client_receiver_;
scoped_refptr<base::SingleThreadTaskRunner> task_runner_;
std::unique_ptr<device::SensorReadingSharedBufferReader>
shared_buffer_reader_;
double default_frequency_ = 0.0;
std::pair<double, double> frequency_limits_;
bool suspended_ = false;
WTF::Vector<double> active_frequencies_;
HeapTaskRunnerTimer<SensorProxyImpl> polling_timer_;
};
} // namespace blink
#endif // THIRD_PARTY_BLINK_RENDERER_MODULES_SENSOR_SENSOR_PROXY_IMPL_H_
|
