Implement DeviceMotionEvent API

chromeos/accelerometer/accelerometer_reader.cc

 // 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 "chromeos/accelerometer/accelerometer_reader.h"
 
 #include <string>
 
 #include "base/bind.h"
 #include "base/files/file_util.h"
@@ skipping 184 matching lines @@
   // Asynchronously detect and initialize the accelerometer to avoid delaying
   // startup.
   base::PostTaskAndReplyWithResult(
       task_runner_.get(), FROM_HERE,
       base::Bind(&DetectAndReadAccelerometerConfiguration, configuration_),
       base::Bind(&AccelerometerReader::OnInitialized,
                  weak_factory_.GetWeakPtr(), configuration_));
 }
 
 void AccelerometerReader::AddObserver(Observer* observer) {
-  observers_.AddObserver(observer);
+  observers_->AddObserver(observer);
   if (has_update_)
     observer->OnAccelerometerUpdated(update_);
 }
 
 void AccelerometerReader::RemoveObserver(Observer* observer) {
-  observers_.RemoveObserver(observer);
+  observers_->RemoveObserver(observer);
+}
+
+bool AccelerometerReader::HasObserver(Observer* observer) {
+  return observers_->HasObserver(observer);
 }
 
 AccelerometerReader::AccelerometerReader()
     : has_update_(false),
       configuration_(new AccelerometerReader::Configuration()),
+      observers_(new ObserverListThreadSafe<Observer>()),
       weak_factory_(this) {
 }
 
 AccelerometerReader::~AccelerometerReader() {
 }
 
 void AccelerometerReader::OnInitialized(
     scoped_refptr<AccelerometerReader::Configuration> configuration,
     bool success) {
   if (success)
@@ skipping 27 matching lines @@
 
       int16* values = reinterpret_cast<int16*>(reading->data);
       update_.Set(static_cast<AccelerometerSource>(i),
                   values[configuration_->data.index[i][0]] *
                       configuration_->data.scale[i][0],
                   values[configuration_->data.index[i][1]] *
                       configuration_->data.scale[i][1],
                   values[configuration_->data.index[i][2]] *
                       configuration_->data.scale[i][2]);
     }
-    FOR_EACH_OBSERVER(Observer, observers_, OnAccelerometerUpdated(update_));
+    observers_->Notify(FROM_HERE, &Observer::OnAccelerometerUpdated, update_);

[flackr, 2015/02/25 23:15:16]

nit: Add TODO to move this to blocking thread (reference existing crbug). I
think this will be really easy given the threadsafe observer list.

[jonross, 2015/03/02 15:18:10]

Done.

   }
 
   // Trigger another read after the current sampling delay.
   base::MessageLoop::current()->PostDelayedTask(
       FROM_HERE,
       base::Bind(&AccelerometerReader::TriggerRead,
                  weak_factory_.GetWeakPtr()),
       base::TimeDelta::FromMilliseconds(kDelayBetweenReadsMs));
 }
 
 }  // namespace chromeos