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
100
101
102
103
104
105
106
107
108
|
// Copyright 2020 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef ASH_ACCELEROMETER_ACCEL_GYRO_SAMPLES_OBSERVER_H_
#define ASH_ACCELEROMETER_ACCEL_GYRO_SAMPLES_OBSERVER_H_
#include <stdint.h>
#include <memory>
#include <string>
#include <vector>
#include "ash/accelerometer/accelerometer_constants.h"
#include "ash/ash_export.h"
#include "base/sequence_checker.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/components/sensors/mojom/sensor.mojom.h"
#include "mojo/public/cpp/bindings/receiver.h"
#include "mojo/public/cpp/bindings/remote.h"
namespace ash {
// A AccelGryoSamplesObserver for an accelerometer/gyroscope device.
// AccelGryoSamplesObserver should only be used on the UI thread.
class ASH_EXPORT AccelGryoSamplesObserver
: public chromeos::sensors::mojom::SensorDeviceSamplesObserver {
public:
using OnSampleUpdatedCallback =
base::RepeatingCallback<void(int iio_device_id,
std::vector<float> sample)>;
AccelGryoSamplesObserver(
int iio_device_id,
mojo::Remote<chromeos::sensors::mojom::SensorDevice> sensor_device_remote,
float scale,
OnSampleUpdatedCallback on_sample_updated_callback,
chromeos::sensors::mojom::DeviceType device_type =
chromeos::sensors::mojom::DeviceType::ACCEL,
float frequency = kReadFrequencyInHz);
AccelGryoSamplesObserver(const AccelGryoSamplesObserver&) = delete;
AccelGryoSamplesObserver& operator=(const AccelGryoSamplesObserver&) = delete;
~AccelGryoSamplesObserver() override;
// Sets the observer |enabled| by setting the frequency to iioservice.
// Should be called on |task_runner_|.
void SetEnabled(bool enabled);
// chromeos::sensors::mojom::SensorDeviceSamplesObserver overrides:
void OnSampleUpdated(const base::flat_map<int32_t, int64_t>& sample) override;
void OnErrorOccurred(
chromeos::sensors::mojom::ObserverErrorType type) override;
private:
void Reset();
void GetAllChannelIdsCallback(
const std::vector<std::string>& iio_channel_ids);
void StartReading();
// If |frequency_| is 0, updates this sensor device's frequency to
// kReadFrequencyInHz if |enabled_| is true, and to 0 if |enabled_| is false.
// If |frequency_| is not 0, updates this sensor device's frequency to
// frequency_ if |enabled_| is true, and to 0 if |enabled_| is false.
void UpdateSensorDeviceFrequency();
mojo::PendingRemote<chromeos::sensors::mojom::SensorDeviceSamplesObserver>
GetPendingRemote();
void OnObserverDisconnect();
void SetFrequencyCallback(bool enabled, double result_frequency);
void SetChannelsEnabledCallback(const std::vector<int32_t>& failed_indices);
static constexpr double kReadFrequencyInHz = 10.0;
int iio_device_id_;
mojo::Remote<chromeos::sensors::mojom::SensorDevice> sensor_device_remote_;
double scale_;
float frequency_;
const chromeos::sensors::mojom::DeviceType device_type_;
// Callback to send samples to the owner of this class.
OnSampleUpdatedCallback on_sample_updated_callback_;
// Boolean to indicate if this accelerometer should set a valid frequency and
// keep reading samples.
bool enabled_ = false;
// The list of channel ids retrieved from iioservice. Use channels' indices
// in this list to identify them.
std::vector<std::string> iio_channel_ids_;
// Channel indices (of accel_x, accel_y, and accel_z respectively) to
// enable.
int32_t channel_indices_[kNumberOfAxes];
mojo::Receiver<chromeos::sensors::mojom::SensorDeviceSamplesObserver>
receiver_{this};
SEQUENCE_CHECKER(sequence_checker_);
base::WeakPtrFactory<AccelGryoSamplesObserver> weak_factory_{this};
};
} // namespace ash
#endif // ASH_ACCELEROMETER_ACCEL_GYRO_SAMPLES_OBSERVER_H_
|
