GPU: Adding sync points for cross-channel synchronization

content/common/gpu/sync_point_manager.cc

Index: content/common/gpu/sync_point_manager.cc
diff --git a/content/common/gpu/sync_point_manager.cc b/content/common/gpu/sync_point_manager.cc
new file mode 100644
index 0000000000000000000000000000000000000000..3916d78c654a1a71819d7426e1d9bb8b2a09b463
--- /dev/null
+++ b/content/common/gpu/sync_point_manager.cc
@@ -0,0 +1,56 @@
+// Copyright (c) 2012 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/common/gpu/sync_point_manager.h"
+
+#include "base/logging.h"
+
+SyncPointManager::SyncPointManager()
+    : next_sync_point_(1) {
+}
+
+SyncPointManager::~SyncPointManager() {
+}
+
+uint32 SyncPointManager::GenerateSyncPoint() {
+  base::AutoLock lock(lock_);
+  uint32 sync_point = next_sync_point_++;
+
+  // Note: wrapping would take days for a buggy/compromized renderer that would
+  // insert sync points in a loop, but if that were to happen, better explicitly
+  // crash the GPU process than risk worse.
+  // For normal operation (at most a few per frame), it would take ~a year to
+  // wrap.
+  CHECK(sync_point_map_.find(sync_point) == sync_point_map_.end());
+  sync_point_map_.insert(std::make_pair(sync_point, ClosureList()));
+  return sync_point;
+}
+
+void SyncPointManager::RetireSyncPoint(uint32 sync_point) {
+  DCHECK(CalledOnValidThread());
+  ClosureList list;
+  {
+    base::AutoLock lock(lock_);
+    SyncPointMap::iterator it = sync_point_map_.find(sync_point);
+    DCHECK(it != sync_point_map_.end());
+    std::swap(list, it->second);

[apatrick_chromium, 2012/06/05 18:44:15]

nit: list.swap(it->second)

[piman, 2012/06/05 20:09:50]

Done.

+    sync_point_map_.erase(it);
+  }
+  for (ClosureList::iterator i = list.begin(); i != list.end(); ++i)
+    i->Run();
+}
+
+void SyncPointManager::AddSyncPointCallback(uint32 sync_point,
+                                            const base::Closure& callback) {
+  DCHECK(CalledOnValidThread());
+  {
+    base::AutoLock lock(lock_);
+    SyncPointMap::iterator it = sync_point_map_.find(sync_point);
+    if (it != sync_point_map_.end()) {
+      it->second.push_back(callback);
+      return;
+    }
+  }
+  callback.Run();
+}