Plumb GpuSwapBuffers completion from Mus GPU thread to WS thread

components/mus/gles2/command_buffer_local.cc

 // Copyright 2015 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 "components/mus/gles2/command_buffer_local.h"
 
 #include "base/atomic_sequence_num.h"
 #include "base/bind.h"
 #include "base/memory/shared_memory.h"
 #include "base/synchronization/waitable_event.h"
@@ skipping 388 matching lines @@
 void CommandBufferLocal::UpdateVSyncParameters(int64_t timebase,
                                                int64_t interval) {
   if (client_) {
     client_thread_task_runner_->PostTask(
         FROM_HERE,
         base::Bind(&CommandBufferLocal::UpdateVSyncParametersOnClientThread,
                    weak_ptr_, timebase, interval));
   }
 }
 
+void CommandBufferLocal::OnGpuCompletedSwapBuffers(gfx::SwapResult result) {
+  if (client_) {
+    client_thread_task_runner_->PostTask(
+        FROM_HERE,
+        base::Bind(&CommandBufferLocal::OnGpuCompletedSwapBuffersOnClientThread,
+                   weak_ptr_, result));
+  }
+}
+
 CommandBufferLocal::~CommandBufferLocal() {}
 
 void CommandBufferLocal::TryUpdateState() {
   if (last_state_.error == gpu::error::kNoError)
     shared_state()->Read(&last_state_);
 }
 
 void CommandBufferLocal::MakeProgressAndUpdateState() {
   base::ThreadRestrictions::ScopedAllowWait allow_wait;
   base::WaitableEvent event(true, false);
   gpu::CommandBuffer::State state;
   gpu_state_->command_buffer_task_runner()->PostTask(
       driver_.get(),
       base::Bind(&CommandBufferLocal::MakeProgressOnGpuThread,
                  base::Unretained(this), base::Unretained(&event),
                  base::Unretained(&state)));
   event.Wait();
   if (state.generation - last_state_.generation < 0x80000000U)
     last_state_ = state;
 }
 
 void CommandBufferLocal::InitializeOnGpuThread(base::WaitableEvent* event,
                                                bool* result) {
   driver_.reset(new CommandBufferDriver(
       gpu::CommandBufferNamespace::MOJO_LOCAL,
       gpu::CommandBufferId::FromUnsafeValue(++g_next_command_buffer_id),
       widget_, gpu_state_));
+  driver_->set_client(this);
   const size_t kSharedStateSize = sizeof(gpu::CommandBufferSharedState);
   void* memory = nullptr;
   mojo::ScopedSharedBufferHandle duped;
   *result = CreateMapAndDupSharedBuffer(kSharedStateSize, &memory,
                                         &shared_state_handle_, &duped);
 
   if (!*result) {
     event->Signal();
     return;
   }
@@ skipping 88 matching lines @@
   if (client_)
     client_->DidLoseContext();
 }
 
 void CommandBufferLocal::UpdateVSyncParametersOnClientThread(int64_t timebase,
                                                              int64_t interval) {
   if (client_)
     client_->UpdateVSyncParameters(timebase, interval);
 }
 
+void CommandBufferLocal::OnGpuCompletedSwapBuffersOnClientThread(
+    gfx::SwapResult result) {
+  if (client_)
+    client_->GpuCompletedSwapBuffers(result);
+}
+
 }  // namespace mus