Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(636)

Unified Diff: base/synchronization/seqlock.h

Issue 8689011: Renderer reading side of gamepad (Closed) Base URL: http://git.chromium.org/chromium/src.git@master
Patch Set: using separate seqlock Created 9 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « no previous file | content/browser/gamepad/gamepad_provider.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: base/synchronization/seqlock.h
diff --git a/base/synchronization/seqlock.h b/base/synchronization/seqlock.h
new file mode 100644
index 0000000000000000000000000000000000000000..b740da07795627037868e156319161bde5d54161
--- /dev/null
+++ b/base/synchronization/seqlock.h
@@ -0,0 +1,67 @@
+// Copyright (c) 2011 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.
+
+#ifndef BASE_SYNCHRONIZATION_SEQLOCK_H_
+#define BASE_SYNCHRONIZATION_SEQLOCK_H_
+#pragma once
+
+#include "base/base_export.h"
+#include "base/atomicops.h"
+
+namespace base {
+
+// This SeqLock handles only *one* writer and multiple readers. It may be
+// suitable for low-contention with relatively infrequent writes, and many
+// readers. See:
+// http://en.wikipedia.org/wiki/Seqlock
+// http://www.concurrencykit.org/doc/ck_sequence.html
+class BASE_EXPORT SeqLock {
+ public:
+ SeqLock() : sequence_(0) {}
+
+ subtle::Atomic32 ReadBegin() {
+ base::subtle::Atomic32 version;
+ for (;;) {
+ version = subtle::Acquire_Load(&sequence_);
+
+ // If the a sequence is even, then the associated data may be in a
+ // consistent state.
+ if ((version & 1) == 0)
+ break;
+
+ // Otherwise, a thread is in the middle of an update. Retry the read.
+ PlatformThread::YieldCurrentThread();
+ }
+ return version;
+ }
+
+ bool ReadRetry(subtle::Atomic32 version) {
+ // If the sequence number was updated then a read should be re-attempted.
+ // -- Load fence, read membarrier
+ bool ret = subtle::Release_Load(&sequence_) != version;
+ return ret;
+ }
+
+ void WriteBegin() {
+ // Increment the sequence number to odd to indicate the beginning of a
+ // write update.
+ subtle::Barrier_AtomicIncrement(&sequence_, 1);
jbates 2011/11/29 00:05:26 I'm not sure why there's BarrierAtomicIncrement an
+ // -- Store fence, write membarrier
+ }
+
+ void WriteEnd() {
+ // Increment the sequence to an even number to indicate the completion of
+ // a write update.
+ // -- Store fence, write membarrier
+ subtle::Barrier_AtomicIncrement(&sequence_, 1);
jbates 2011/11/29 00:05:26 And this: subtle::Release_Store(&sequence_, sequen
+ }
+
+ private:
+ base::subtle::Atomic32 sequence_;
+ DISALLOW_COPY_AND_ASSIGN(SeqLock);
+};
+
+} // namespace base
+
+#endif // BASE_SYNCHRONIZATION_SEQLOCK_H_
« no previous file with comments | « no previous file | content/browser/gamepad/gamepad_provider.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698