blob: b250981100c98fb550742ccfe9e9a966ee870e42 [file] [log] [blame]
// 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 "services/device/generic_sensor/platform_sensor_linux.h"
#include "base/single_thread_task_runner.h"
#include "services/device/generic_sensor/linux/sensor_data_linux.h"
#include "services/device/generic_sensor/platform_sensor_reader_linux.h"
namespace device {
namespace {
// Checks if at least one value has been changed.
bool HaveValuesChanged(const SensorReading& lhs, const SensorReading& rhs) {
for (size_t i = 0; i < SensorReadingRaw::kValuesCount; ++i) {
if (lhs.raw.values[i] != rhs.raw.values[i])
return true;
}
return false;
}
} // namespace
PlatformSensorLinux::PlatformSensorLinux(
mojom::SensorType type,
mojo::ScopedSharedBufferMapping mapping,
PlatformSensorProvider* provider,
const SensorInfoLinux* sensor_device,
scoped_refptr<base::SingleThreadTaskRunner> polling_thread_task_runner)
: PlatformSensor(type, std::move(mapping), provider),
default_configuration_(
PlatformSensorConfiguration(sensor_device->device_frequency)),
reporting_mode_(sensor_device->reporting_mode),
polling_thread_task_runner_(std::move(polling_thread_task_runner)),
weak_factory_(this) {
sensor_reader_ = SensorReader::Create(
sensor_device, weak_factory_.GetWeakPtr(), task_runner_);
}
PlatformSensorLinux::~PlatformSensorLinux() {
DCHECK(task_runner_->BelongsToCurrentThread());
polling_thread_task_runner_->DeleteSoon(FROM_HERE, sensor_reader_.release());
}
mojom::ReportingMode PlatformSensorLinux::GetReportingMode() {
DCHECK(task_runner_->BelongsToCurrentThread());
return reporting_mode_;
}
void PlatformSensorLinux::UpdatePlatformSensorReading(SensorReading reading) {
DCHECK(task_runner_->BelongsToCurrentThread());
if (GetReportingMode() == mojom::ReportingMode::ON_CHANGE &&
!HaveValuesChanged(reading, old_values_)) {
return;
}
old_values_ = reading;
reading.raw.timestamp =
(base::TimeTicks::Now() - base::TimeTicks()).InSecondsF();
UpdateSharedBufferAndNotifyClients(reading);
}
void PlatformSensorLinux::NotifyPlatformSensorError() {
DCHECK(task_runner_->BelongsToCurrentThread());
NotifySensorError();
}
bool PlatformSensorLinux::StartSensor(
const PlatformSensorConfiguration& configuration) {
DCHECK(task_runner_->BelongsToCurrentThread());
polling_thread_task_runner_->PostTask(
FROM_HERE,
base::Bind(&SensorReader::StartFetchingData,
base::Unretained(sensor_reader_.get()), configuration));
return true;
}
void PlatformSensorLinux::StopSensor() {
DCHECK(task_runner_->BelongsToCurrentThread());
polling_thread_task_runner_->PostTask(
FROM_HERE, base::Bind(&SensorReader::StopFetchingData,
base::Unretained(sensor_reader_.get())));
}
bool PlatformSensorLinux::CheckSensorConfiguration(
const PlatformSensorConfiguration& configuration) {
DCHECK(task_runner_->BelongsToCurrentThread());
return configuration.frequency() > 0 &&
configuration.frequency() <= default_configuration_.frequency();
}
PlatformSensorConfiguration PlatformSensorLinux::GetDefaultConfiguration() {
DCHECK(task_runner_->BelongsToCurrentThread());
return default_configuration_;
}
} // namespace device