Index: device/generic_sensor/public/cpp/sensor_shared_buffer_reader.cc |
diff --git a/device/generic_sensor/public/cpp/sensor_shared_buffer_reader.cc b/device/generic_sensor/public/cpp/sensor_shared_buffer_reader.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..6dadf92a83feb3aac7b99c20da52ab3616b36ec0 |
--- /dev/null |
+++ b/device/generic_sensor/public/cpp/sensor_shared_buffer_reader.cc |
@@ -0,0 +1,44 @@ |
+// Copyright 2017 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/generic_sensor/public/cpp/sensor_shared_buffer_reader.h" |
+ |
+#include "device/base/synchronization/shared_memory_seqlock_buffer.h" |
+#include "device/generic_sensor/public/cpp/sensor_reading.h" |
+ |
+namespace { |
+ |
+constexpr int kMaxReadAttemptsCount = 10; |
+ |
+} // namespace |
+ |
+namespace device { |
+ |
+SensorSharedBufferReader::SensorSharedBufferReader( |
+ const SensorReadingSharedBuffer* buffer) |
+ : buffer_(buffer) {} |
+ |
+SensorSharedBufferReader::~SensorSharedBufferReader() = default; |
+ |
+bool SensorSharedBufferReader::GetSensorReading(SensorReading* result) { |
+ int read_attempts = 0; |
+ while (!TryReadFromBuffer(result)) { |
+ if (++read_attempts == kMaxReadAttemptsCount) |
+ return false; |
+ } |
+ |
+ return true; |
+} |
+ |
+bool SensorSharedBufferReader::TryReadFromBuffer(SensorReading* result) { |
+ const OneWriterSeqLock& seqlock = buffer_->seqlock.value(); |
+ auto version = seqlock.ReadBegin(); |
+ auto reading_data = buffer_->reading; |
+ if (seqlock.ReadRetry(version)) |
+ return false; |
+ *result = reading_data; |
+ return true; |
+} |
+ |
+} // namespace device |