Index: gpu/command_buffer/service/sync_point_manager.cc |
diff --git a/gpu/command_buffer/service/sync_point_manager.cc b/gpu/command_buffer/service/sync_point_manager.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..cd8c49088b4e79405f3abe814db9b7da70525a9b |
--- /dev/null |
+++ b/gpu/command_buffer/service/sync_point_manager.cc |
@@ -0,0 +1,84 @@ |
+// 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 "gpu/command_buffer/service/sync_point_manager.h" |
+ |
+#include <climits> |
+ |
+#include "base/logging.h" |
+#include "base/rand_util.h" |
+ |
+namespace gpu { |
+ |
+static const int kMaxSyncBase = INT_MAX; |
+ |
+SyncPointManager::SyncPointManager() |
+ : next_sync_point_(base::RandInt(1, kMaxSyncBase)) { |
+ // To reduce the risk that a sync point created in a previous GPU process |
+ // will be in flight in the next GPU process, randomize the starting sync |
+ // point number. http://crbug.com/373452 |
+} |
+ |
+SyncPointManager::~SyncPointManager() { |
+} |
+ |
+uint32 SyncPointManager::GenerateSyncPoint() { |
+ base::AutoLock lock(lock_); |
+ uint32 sync_point = next_sync_point_++; |
+ // When an integer overflow occurs, don't return 0. |
+ if (!sync_point) |
+ 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(thread_checker_.CalledOnValidThread()); |
+ ClosureList list; |
+ { |
+ base::AutoLock lock(lock_); |
+ SyncPointMap::iterator it = sync_point_map_.find(sync_point); |
+ if (it == sync_point_map_.end()) { |
+ LOG(ERROR) << "Attempted to retire sync point that" |
+ " didn't exist or was already retired."; |
+ return; |
+ } |
+ list.swap(it->second); |
+ 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(thread_checker_.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(); |
+} |
+ |
+bool SyncPointManager::IsSyncPointRetired(uint32 sync_point) { |
+ DCHECK(thread_checker_.CalledOnValidThread()); |
+ { |
+ base::AutoLock lock(lock_); |
+ SyncPointMap::iterator it = sync_point_map_.find(sync_point); |
+ return it == sync_point_map_.end(); |
+ } |
+} |
+ |
+} // namespace gpu |