1 files changed, 98 insertions, 0 deletions
diff --git a/chromium/content/browser/device_sensors/device_inertial_sensor_service.cc b/chromium/content/browser/device_sensors/device_inertial_sensor_service.cc
new file mode 100644
index 00000000000..cf96820649e
--- /dev/null
+++ b/chromium/content/browser/device_sensors/device_inertial_sensor_service.cc
@@ -0,0 +1,98 @@
+// Copyright 2014 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 "content/browser/device_sensors/device_inertial_sensor_service.h"
+
+#include "base/bind.h"
+#include "base/logging.h"
+#include "base/memory/singleton.h"
+#include "content/browser/device_sensors/data_fetcher_shared_memory.h"
+
+namespace content {
+
+DeviceInertialSensorService::DeviceInertialSensorService()
+    : num_motion_readers_(0),
+      num_orientation_readers_(0),
+      is_shutdown_(false) {
+}
+
+DeviceInertialSensorService::~DeviceInertialSensorService() {
+}
+
+DeviceInertialSensorService* DeviceInertialSensorService::GetInstance() {
+  return Singleton<DeviceInertialSensorService,
+                   LeakySingletonTraits<DeviceInertialSensorService> >::get();
+}
+
+void DeviceInertialSensorService::AddConsumer(ConsumerType consumer_type) {
+  if (!ChangeNumberConsumers(consumer_type, 1))
+    return;
+
+  DCHECK(GetNumberConsumers(consumer_type));
+
+  if (!data_fetcher_)
+    data_fetcher_.reset(new DataFetcherSharedMemory);
+  data_fetcher_->StartFetchingDeviceData(consumer_type);
+}
+
+void DeviceInertialSensorService::RemoveConsumer(ConsumerType consumer_type) {
+  if (!ChangeNumberConsumers(consumer_type, -1))
+    return;
+
+  if (GetNumberConsumers(consumer_type) == 0)
+    data_fetcher_->StopFetchingDeviceData(consumer_type);
+}
+
+bool DeviceInertialSensorService::ChangeNumberConsumers(
+    ConsumerType consumer_type, int delta) {
+  DCHECK(thread_checker_.CalledOnValidThread());
+  if (is_shutdown_)
+    return false;
+
+  switch (consumer_type) {
+    case CONSUMER_TYPE_MOTION:
+      num_motion_readers_ += delta;
+      DCHECK_GE(num_motion_readers_, 0);
+      return true;
+    case CONSUMER_TYPE_ORIENTATION:
+      num_orientation_readers_ += delta;
+      DCHECK_GE(num_orientation_readers_ , 0);
+      return true;
+    default:
+      NOTREACHED();
+  }
+  return false;
+}
+
+int DeviceInertialSensorService::GetNumberConsumers(
+    ConsumerType consumer_type) const {
+  switch (consumer_type) {
+    case CONSUMER_TYPE_MOTION:
+      return num_motion_readers_;
+    case CONSUMER_TYPE_ORIENTATION:
+      return num_orientation_readers_;
+    default:
+      NOTREACHED();
+  }
+  return 0;
+}
+
+base::SharedMemoryHandle
+DeviceInertialSensorService::GetSharedMemoryHandleForProcess(
+    ConsumerType consumer_type, base::ProcessHandle handle) {
+  DCHECK(thread_checker_.CalledOnValidThread());
+  return data_fetcher_->GetSharedMemoryHandleForProcess(consumer_type, handle);
+}
+
+void DeviceInertialSensorService::Shutdown() {
+  data_fetcher_.reset();
+  is_shutdown_ = true;
+}
+
+void DeviceInertialSensorService::SetDataFetcherForTesting(
+    DataFetcherSharedMemory* test_data_fetcher) {
+  data_fetcher_.reset(test_data_fetcher);
+}
+
+}  // namespace content