| Index: device/sensors/sensor_provider_impl.cc
|
| diff --git a/device/sensors/sensor_provider_impl.cc b/device/sensors/sensor_provider_impl.cc
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..d525f6b196b8c66d8a2cda619cebe00a1eda8996
|
| --- /dev/null
|
| +++ b/device/sensors/sensor_provider_impl.cc
|
| @@ -0,0 +1,82 @@
|
| +// 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 "device/sensors/sensor_provider_impl.h"
|
| +
|
| +#include <utility>
|
| +
|
| +#include "device/sensors/platform_sensor_provider.h"
|
| +#include "device/sensors/sensor_impl.h"
|
| +
|
| +namespace device {
|
| +namespace mojom {
|
| +
|
| +namespace {
|
| +const uint64_t kSharedBufferSizeInBytes =
|
| + SensorReadBuffer::kReadBufferSize * static_cast<uint64_t>(SensorType::LAST);
|
| +}
|
| +
|
| +PlatformSensorProvider* SensorProviderImpl::s_provider_ = nullptr;
|
| +
|
| +// static
|
| +void SensorProviderImpl::Create(
|
| + mojo::InterfaceRequest<SensorProvider> request) {
|
| + if (!s_provider_)
|
| + s_provider_ = PlatformSensorProvider::Create(kSharedBufferSizeInBytes);
|
| +
|
| + if (s_provider_) {
|
| + new SensorProviderImpl(std::move(request));
|
| + }
|
| +}
|
| +
|
| +SensorProviderImpl::SensorProviderImpl(
|
| + mojo::InterfaceRequest<SensorProvider> request)
|
| + : binding_(this, std::move(request)) {}
|
| +
|
| +SensorProviderImpl::~SensorProviderImpl() {}
|
| +
|
| +namespace {
|
| +
|
| +void ReportError(const SensorProvider::GetSensorCallback& callback) {
|
| + callback.Run(nullptr, nullptr);
|
| +}
|
| +
|
| +uint64_t GetBufferOffset(device::SensorType type) {
|
| + return (static_cast<uint64_t>(SensorType::LAST) -
|
| + static_cast<uint64_t>(type)) *
|
| + SensorReadBuffer::kReadBufferSize;
|
| +}
|
| +
|
| +} // namespace
|
| +
|
| +void SensorProviderImpl::GetSensor(device::SensorType type,
|
| + SensorRequest sensor_request,
|
| + const GetSensorCallback& callback) {
|
| + auto cloned_handle = s_provider_->GetClonedSharedBufferHandle();
|
| + if (!cloned_handle.is_valid()) {
|
| + ReportError(callback);
|
| + return;
|
| + }
|
| +
|
| + auto sensor = s_provider_->GetSensor(type);
|
| + if (!sensor)
|
| + sensor = s_provider_->CreateSensor(type, SensorReadBuffer::kReadBufferSize,
|
| + GetBufferOffset(type));
|
| + if (!sensor) {
|
| + ReportError(callback);
|
| + return;
|
| + }
|
| +
|
| + SensorImpl* sensor_impl = new SensorImpl(std::move(sensor_request), sensor);
|
| +
|
| + SensorReadBufferPtr sensor_read_buffer = SensorReadBuffer::New();
|
| + sensor_read_buffer->memory = std::move(cloned_handle);
|
| + sensor_read_buffer->offset = GetBufferOffset(type);
|
| + sensor_read_buffer->mode = sensor->GetReportingMode();
|
| +
|
| + callback.Run(std::move(sensor_read_buffer), sensor_impl->GetClient());
|
| +}
|
| +
|
| +} // namespace mojom
|
| +} // namespace device
|
|
|