Implement the content/renderer and content/browser part of the Device Motion API.

content/renderer/shared_memory_seqlock_reader_base.cc

Index: content/renderer/shared_memory_seqlock_reader_base.cc
diff --git a/content/renderer/shared_memory_seqlock_reader_base.cc b/content/renderer/shared_memory_seqlock_reader_base.cc
new file mode 100644
index 0000000000000000000000000000000000000000..01c7f86067f9d63cee195d5f28d7c0d6e3cf612e
--- /dev/null
+++ b/content/renderer/shared_memory_seqlock_reader_base.cc
@@ -0,0 +1,57 @@
+// Copyright (c) 2013 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 "shared_memory_seqlock_reader_base.h"
+
+namespace content {
+
+SharedMemorySeqLockBufferBase*
+SharedMemorySeqLockReaderBase::InitializeSharedMemory(
+    base::SharedMemoryHandle shared_memory_handle, size_t buffer_size) {
+  renderer_shared_memory_handle_ = shared_memory_handle;
+  if (!base::SharedMemory::IsHandleValid(renderer_shared_memory_handle_))
+    return 0;
+  renderer_shared_memory_.reset(new base::SharedMemory(
+      renderer_shared_memory_handle_, true));
+  if (renderer_shared_memory_->Map(buffer_size)) {
+    base_buffer_ = static_cast<SharedMemorySeqLockBufferBase*>(
+        renderer_shared_memory_->memory());
+    return base_buffer_;
+  }
+  return 0;
+}
+
+bool SharedMemorySeqLockReaderBase::FetchFromBuffer(
+    void* final, void* temp, void* from, size_t size) {
+
+  if (!base::SharedMemory::IsHandleValid(renderer_shared_memory_handle_))
+    return false;
+
+  // Only try to read this many times before failing to avoid waiting here
+  // very long in case of contention with the writer.
+  bool is_ready = false;
+  int contention_count = -1;
+  base::subtle::Atomic32 version;
+  do {
+    version = base_buffer_->seqlock.ReadBegin();
+    is_ready = base_buffer_->is_ready_for_read;
+    memcpy(temp, from, size);
+    ++contention_count;
+    if (contention_count == kMaximumContentionCount)
+      break;
+  } while (base_buffer_->seqlock.ReadRetry(version));
+
+  if (contention_count >= kMaximumContentionCount) {
+    // We failed to successfully read, presumably because the hardware
+    // thread was taking unusually long. Don't copy the data to the output
+    // buffer, and simply leave what was there before.
+    return false;
+  }
+
+  // New data was read successfully, copy it into the output buffer.
+  memcpy(final, temp, size);
+  return is_ready;
+}
+
+}  // namespace content