1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
5 #include "content/browser/device_orientation/device_inertial_sensor_service.h"
8 #include "base/logging.h"
9 #include "base/memory/singleton.h"
10 #include "content/browser/device_orientation/data_fetcher_shared_memory.h"
11 #include "content/public/browser/render_process_host.h"
15 DeviceInertialSensorService::DeviceInertialSensorService()
16 : num_motion_readers_(0),
17 num_orientation_readers_(0),
21 DeviceInertialSensorService::~DeviceInertialSensorService() {
24 DeviceInertialSensorService* DeviceInertialSensorService::GetInstance() {
25 return Singleton<DeviceInertialSensorService,
26 LeakySingletonTraits<DeviceInertialSensorService> >::get();
29 void DeviceInertialSensorService::AddConsumer(ConsumerType consumer_type) {
30 if (!ChangeNumberConsumers(consumer_type, 1))
33 DCHECK(GetNumberConsumers(consumer_type));
36 data_fetcher_.reset(new DataFetcherSharedMemory);
37 data_fetcher_->StartFetchingDeviceData(consumer_type);
40 void DeviceInertialSensorService::RemoveConsumer(ConsumerType consumer_type) {
41 if (!ChangeNumberConsumers(consumer_type, -1))
44 if (GetNumberConsumers(consumer_type) == 0)
45 data_fetcher_->StopFetchingDeviceData(consumer_type);
48 bool DeviceInertialSensorService::ChangeNumberConsumers(
49 ConsumerType consumer_type, int delta) {
50 DCHECK(thread_checker_.CalledOnValidThread());
54 switch (consumer_type) {
55 case CONSUMER_TYPE_MOTION:
56 num_motion_readers_ += delta;
57 DCHECK(num_motion_readers_ >= 0);
59 case CONSUMER_TYPE_ORIENTATION:
60 num_orientation_readers_ += delta;
61 DCHECK(num_orientation_readers_ >= 0);
69 int DeviceInertialSensorService::GetNumberConsumers(
70 ConsumerType consumer_type) const {
71 switch (consumer_type) {
72 case CONSUMER_TYPE_MOTION:
73 return num_motion_readers_;
74 case CONSUMER_TYPE_ORIENTATION:
75 return num_orientation_readers_;
82 base::SharedMemoryHandle
83 DeviceInertialSensorService::GetSharedMemoryHandleForProcess(
84 ConsumerType consumer_type, base::ProcessHandle handle) {
85 DCHECK(thread_checker_.CalledOnValidThread());
86 return data_fetcher_->GetSharedMemoryHandleForProcess(consumer_type, handle);
89 void DeviceInertialSensorService::Shutdown() {
90 data_fetcher_.reset();
94 void DeviceInertialSensorService::SetDataFetcherForTests(
95 DataFetcherSharedMemory* test_data_fetcher) {
96 data_fetcher_.reset(test_data_fetcher);
99 } // namespace content