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

Side by Side Diff: gpu/command_buffer/service/sync_point_manager.h

Issue 1414793018: Revert of Converted video frame and image callbacks to use new sync tokens. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 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 unified diff | Download patch
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef GPU_COMMAND_BUFFER_SERVICE_SYNC_POINT_MANAGER_H_ 5 #ifndef GPU_COMMAND_BUFFER_SERVICE_SYNC_POINT_MANAGER_H_
6 #define GPU_COMMAND_BUFFER_SERVICE_SYNC_POINT_MANAGER_H_ 6 #define GPU_COMMAND_BUFFER_SERVICE_SYNC_POINT_MANAGER_H_
7 7
8 #include <functional> 8 #include <functional>
9 #include <queue> 9 #include <queue>
10 #include <vector> 10 #include <vector>
11 11
12 #include "base/atomic_sequence_num.h" 12 #include "base/atomic_sequence_num.h"
13 #include "base/callback.h" 13 #include "base/callback.h"
14 #include "base/containers/hash_tables.h" 14 #include "base/containers/hash_tables.h"
15 #include "base/logging.h" 15 #include "base/logging.h"
16 #include "base/macros.h"
17 #include "base/memory/ref_counted.h" 16 #include "base/memory/ref_counted.h"
18 #include "base/memory/scoped_ptr.h" 17 #include "base/memory/scoped_ptr.h"
19 #include "base/synchronization/condition_variable.h" 18 #include "base/synchronization/condition_variable.h"
20 #include "base/synchronization/lock.h" 19 #include "base/synchronization/lock.h"
21 #include "base/threading/thread_checker.h" 20 #include "base/threading/thread_checker.h"
22 #include "gpu/command_buffer/common/constants.h" 21 #include "gpu/command_buffer/common/constants.h"
23 #include "gpu/gpu_export.h" 22 #include "gpu/gpu_export.h"
24 23
25 namespace base { 24 namespace base {
26 class SingleThreadTaskRunner; 25 class SingleThreadTaskRunner;
(...skipping 104 matching lines...) Expand 10 before | Expand all | Expand 10 after
131 } 130 }
132 131
133 uint64_t fence_sync_release() { 132 uint64_t fence_sync_release() {
134 base::AutoLock auto_lock(fence_sync_lock_); 133 base::AutoLock auto_lock(fence_sync_lock_);
135 return fence_sync_release_; 134 return fence_sync_release_;
136 } 135 }
137 136
138 private: 137 private:
139 friend class base::RefCountedThreadSafe<SyncPointClientState>; 138 friend class base::RefCountedThreadSafe<SyncPointClientState>;
140 friend class SyncPointClient; 139 friend class SyncPointClient;
141 friend class SyncPointClientWaiter;
142 friend class SyncPointOrderData; 140 friend class SyncPointOrderData;
143 141
144 struct ReleaseCallback { 142 struct ReleaseCallback {
145 uint64_t release_count; 143 uint64_t release_count;
146 base::Closure callback_closure; 144 base::Closure callback_closure;
147 145
148 ReleaseCallback(uint64_t release, const base::Closure& callback); 146 ReleaseCallback(uint64_t release, const base::Closure& callback);
149 ~ReleaseCallback(); 147 ~ReleaseCallback();
150 148
151 bool operator>(const ReleaseCallback& rhs) const { 149 bool operator>(const ReleaseCallback& rhs) const {
(...skipping 75 matching lines...) Expand 10 before | Expand all | Expand 10 after
227 // Keep the state that is sharable across multiple threads. 225 // Keep the state that is sharable across multiple threads.
228 scoped_refptr<SyncPointClientState> client_state_; 226 scoped_refptr<SyncPointClientState> client_state_;
229 227
230 // Unique namespace/client id pair for this sync point client. 228 // Unique namespace/client id pair for this sync point client.
231 const CommandBufferNamespace namespace_id_; 229 const CommandBufferNamespace namespace_id_;
232 const uint64_t client_id_; 230 const uint64_t client_id_;
233 231
234 DISALLOW_COPY_AND_ASSIGN(SyncPointClient); 232 DISALLOW_COPY_AND_ASSIGN(SyncPointClient);
235 }; 233 };
236 234
237 // A SyncPointClientWaiter is a Sync Point Client which can only wait and on
238 // fence syncs and not release any fence syncs itself. Because they cannot
239 // release any fence syncs they do not need an associated order number since
240 // deadlocks cannot happen. Note that it is important that this class does
241 // not exist in the same execution context as a SyncPointClient, or else a
242 // deadlock could occur. Basically, SyncPointClientWaiter::Wait() should never
243 // be called between SyncPointOrderData::BeginProcessingOrderNumber() and
244 // SyncPointOrderData::FinishProcessingOrderNumber() on the same thread.
245 class GPU_EXPORT SyncPointClientWaiter {
246 public:
247 SyncPointClientWaiter() {}
248 ~SyncPointClientWaiter() {}
249
250 bool Wait(SyncPointClientState* release_state,
251 uint64_t release_count,
252 const base::Closure& wait_complete_callback);
253
254 bool WaitNonThreadSafe(SyncPointClientState* release_state,
255 uint64_t release_count,
256 scoped_refptr<base::SingleThreadTaskRunner> runner,
257 const base::Closure& wait_complete_callback);
258
259 private:
260 DISALLOW_COPY_AND_ASSIGN(SyncPointClientWaiter);
261 };
262
263 // This class manages the sync points, which allow cross-channel 235 // This class manages the sync points, which allow cross-channel
264 // synchronization. 236 // synchronization.
265 class GPU_EXPORT SyncPointManager { 237 class GPU_EXPORT SyncPointManager {
266 public: 238 public:
267 explicit SyncPointManager(bool allow_threaded_wait); 239 explicit SyncPointManager(bool allow_threaded_wait);
268 ~SyncPointManager(); 240 ~SyncPointManager();
269 241
270 // Creates/Destroy a sync point client which message processors should hold. 242 // Creates/Destroy a sync point client which message processors should hold.
271 scoped_ptr<SyncPointClient> CreateSyncPointClient( 243 scoped_ptr<SyncPointClient> CreateSyncPointClient(
272 scoped_refptr<SyncPointOrderData> order_data, 244 scoped_refptr<SyncPointOrderData> order_data,
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
325 SyncPointMap sync_point_map_; 297 SyncPointMap sync_point_map_;
326 uint32 next_sync_point_; 298 uint32 next_sync_point_;
327 base::ConditionVariable retire_cond_var_; 299 base::ConditionVariable retire_cond_var_;
328 300
329 DISALLOW_COPY_AND_ASSIGN(SyncPointManager); 301 DISALLOW_COPY_AND_ASSIGN(SyncPointManager);
330 }; 302 };
331 303
332 } // namespace gpu 304 } // namespace gpu
333 305
334 #endif // GPU_COMMAND_BUFFER_SERVICE_SYNC_POINT_MANAGER_H_ 306 #endif // GPU_COMMAND_BUFFER_SERVICE_SYNC_POINT_MANAGER_H_
OLDNEW
« no previous file with comments | « gpu/command_buffer/service/in_process_command_buffer.cc ('k') | gpu/command_buffer/service/sync_point_manager.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698