gpu: Thread-safe command buffer state lookup.

gpu/command_buffer/tests/gl_manager.cc

 // 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/tests/gl_manager.h"
 
 #include <GLES2/gl2.h>
 #include <GLES2/gl2ext.h>
 #include <GLES2/gl2extchromium.h>
 #include <stddef.h>
@@ skipping 410 matching lines @@
         base_share_group_->get(), base_surface_->get(),
         gl::GLContextAttribs()));
     #endif
   }
   ++use_count_;
 }
 
 void GLManager::OnFenceSyncRelease(uint64_t release) {
   DCHECK(sync_point_client_);
   DCHECK(!sync_point_client_->client_state()->IsFenceSyncReleased(release));
+  command_buffer_->SetReleaseCount(release);
   sync_point_client_->ReleaseFenceSync(release);
 }
 
 bool GLManager::OnWaitFenceSync(gpu::CommandBufferNamespace namespace_id,
                                 gpu::CommandBufferId command_buffer_id,
                                 uint64_t release) {
   DCHECK(sync_point_client_);
   scoped_refptr<gpu::SyncPointClientState> release_state =
       sync_point_manager_->GetSyncPointClientState(namespace_id,
                                                    command_buffer_id);
   if (!release_state)
     return true;
 
   // GLManager does not support being multithreaded at this point, so the fence
   // sync must be released by the time wait is called.
   DCHECK(release_state->IsFenceSyncReleased(release));
   return true;
 }
 
 void GLManager::MakeCurrent() {
   ::gles2::SetGLContext(gles2_implementation_.get());
 }
 
 void GLManager::SetSurface(gl::GLSurface* surface) {
   decoder_->SetSurface(surface);
 }
 
+void GLManager::PerformIdleWork() {
+  executor_->PerformIdleWork();
+}
+
 void GLManager::Destroy() {
   if (gles2_implementation_.get()) {
     MakeCurrent();
     EXPECT_TRUE(glGetError() == GL_NONE);
     gles2_implementation_->Flush();
     gles2_implementation_.reset();
   }
   transfer_buffer_.reset();
   gles2_helper_.reset();
   command_buffer_.reset();
@@ skipping 158 matching lines @@
 }
 
 bool GLManager::IsFenceSyncFlushed(uint64_t release) {
   return IsFenceSyncRelease(release);
 }
 
 bool GLManager::IsFenceSyncFlushReceived(uint64_t release) {
   return IsFenceSyncRelease(release);
 }
 
+bool GLManager::IsFenceSyncReleased(uint64_t release) {
+  return release <= command_buffer_->GetLastState().release_count;
+}
+
 void GLManager::SignalSyncToken(const gpu::SyncToken& sync_token,
                                 const base::Closure& callback) {
   if (sync_point_manager_) {
     scoped_refptr<gpu::SyncPointClientState> release_state =
         sync_point_manager_->GetSyncPointClientState(
             sync_token.namespace_id(), sync_token.command_buffer_id());
 
     if (release_state) {
       sync_point_client_->WaitOutOfOrder(release_state.get(),
                                          sync_token.release_count(), callback);
       return;
     }
   }
 
   // Something went wrong, just run the callback now.
   callback.Run();
 }
 
 bool GLManager::CanWaitUnverifiedSyncToken(const gpu::SyncToken* sync_token) {
   return false;
 }
 
 }  // namespace gpu