mustash: gpu: implement SignalQuery in CommandBufferLocal

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 44 matching lines @@
 
   result = mojo::MapBuffer(handle->get(), 0, size, memory,
                            MOJO_MAP_BUFFER_FLAG_NONE);
   if (result != MOJO_RESULT_OK)
     return false;
   DCHECK(*memory);
 
   return true;
 }
 
+void PostTask(const scoped_refptr<base::SingleThreadTaskRunner>& task_runner,
+              const base::Closure& callback) {
+  task_runner->PostTask(FROM_HERE, callback);
+}
 }
 
 const unsigned int GL_READ_WRITE_CHROMIUM = 0x78F2;
 
 CommandBufferLocal::CommandBufferLocal(CommandBufferLocalClient* client,
                                        gfx::AcceleratedWidget widget,
                                        const scoped_refptr<GpuState>& gpu_state)
     : widget_(widget),
       gpu_state_(gpu_state),
       client_(client),
@@ skipping 226 matching lines @@
 
 void CommandBufferLocal::RetireSyncPoint(uint32_t sync_point) {
   NOTREACHED();
 }
 
 void CommandBufferLocal::SignalSyncPoint(uint32_t sync_point,
                                          const base::Closure& callback) {
   NOTREACHED();
 }
 
-void CommandBufferLocal::SignalQuery(uint32_t query,
+void CommandBufferLocal::SignalQuery(uint32_t query_id,
                                      const base::Closure& callback) {
   DCHECK(CalledOnValidThread());
-  // TODO(piman)
-  NOTIMPLEMENTED();
+
+  gpu_state_->command_buffer_task_runner()->PostTask(
+      driver_.get(), base::Bind(&CommandBufferLocal::SignalQueryOnGpuThread,
+                                base::Unretained(this), query_id, callback));
 }
 
 void CommandBufferLocal::SetLock(base::Lock* lock) {
   DCHECK(CalledOnValidThread());
   NOTIMPLEMENTED();
 }
 
 bool CommandBufferLocal::IsGpuChannelLost() {
   DCHECK(CalledOnValidThread());
   // This is only possible for out-of-process command buffers.
@@ skipping 191 matching lines @@
   *state = driver_->GetLastState();
   event->Signal();
   return true;
 }
 
 bool CommandBufferLocal::DeleteOnGpuThread() {
   delete this;
   return true;
 }
 
+bool CommandBufferLocal::SignalQueryOnGpuThread(uint32_t query_id,
+                                                const base::Closure& callback) {
+  // |callback| should run on the client thread.
+  driver_->SignalQuery(
+      query_id, base::Bind(&PostTask, client_thread_task_runner_, callback));
+  return true;
+}
+
 void CommandBufferLocal::DidLoseContextOnClientThread(uint32_t reason) {
   if (client_)
     client_->DidLoseContext();
 }
 
 void CommandBufferLocal::UpdateVSyncParametersOnClientThread(int64_t timebase,
                                                              int64_t interval) {
   if (client_)
     client_->UpdateVSyncParameters(timebase, interval);
 }
 
 }  // namespace mus