Sample code: IPC Transport object for GPU

content/common/gpu/client/command_buffer_proxy_impl.h

 // 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.
 
 #ifndef CONTENT_COMMON_GPU_CLIENT_COMMAND_BUFFER_PROXY_IMPL_H_
 #define CONTENT_COMMON_GPU_CLIENT_COMMAND_BUFFER_PROXY_IMPL_H_
 
 #include <stddef.h>
 #include <stdint.h>
 
 #include <map>
 #include <queue>
 #include <string>
 
 #include "base/callback.h"
 #include "base/compiler_specific.h"
 #include "base/containers/hash_tables.h"
 #include "base/containers/scoped_ptr_hash_map.h"
 #include "base/macros.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/weak_ptr.h"
 #include "base/observer_list.h"
+#include "content/common/gpu/client/ipc/command_buffer_ipc_transport.h"
 #include "gpu/command_buffer/client/gpu_control.h"
 #include "gpu/command_buffer/common/command_buffer.h"
 #include "gpu/command_buffer/common/command_buffer_shared.h"
 #include "gpu/command_buffer/common/gpu_memory_allocation.h"
-#include "ipc/ipc_listener.h"
 #include "ui/events/latency_info.h"
 #include "ui/gfx/swap_result.h"
 
-struct GPUCommandBufferConsoleMessage;
-
 namespace base {
 class SharedMemory;
 }
 
 namespace gpu {
 struct Mailbox;
 struct SyncToken;
 }
 
 namespace media {
 class VideoDecodeAccelerator;
 class VideoEncodeAccelerator;
 }
 
 namespace content {
+
 class GpuChannelHost;
+struct CommandBufferConsoleMessage;
 
 // Client side proxy that forwards messages synchronously to a
 // CommandBufferStub.
 class CommandBufferProxyImpl
     : public gpu::CommandBuffer,
       public gpu::GpuControl,
-      public IPC::Listener,
+      public CommandBufferIPCTransport::Client,
       public base::SupportsWeakPtr<CommandBufferProxyImpl> {
  public:
   class DeletionObserver {
    public:
     // Called during the destruction of the CommandBufferProxyImpl.
     virtual void OnWillDeleteImpl() = 0;
 
    protected:
     virtual ~DeletionObserver() {}
   };
 
   typedef base::Callback<void(
       const std::string& msg, int id)> GpuConsoleMessageCallback;
 
   CommandBufferProxyImpl(GpuChannelHost* channel,
-                         int32_t route_id,
+                         scoped_ptr<CommandBufferIPCTransport> transport,
                          int32_t stream_id);
   ~CommandBufferProxyImpl() override;
 
+  // TODO(fsamuel): It's a little unfortunate that we have to expose this. Let's
+  // see if there's a way to hide this.
+  const CommandBufferIPCTransport* transport() const {
+    return transport_.get();
+  }
+
+  CommandBufferIPCTransport* transport() { return transport_.get(); }
+
   // Sends an IPC message to create a GpuVideoDecodeAccelerator. Creates and
   // returns it as an owned pointer to a media::VideoDecodeAccelerator.  Returns
   // NULL on failure to create the GpuVideoDecodeAcceleratorHost.
   // Note that the GpuVideoDecodeAccelerator may still fail to be created in
   // the GPU process, even if this returns non-NULL. In this case the VDA client
   // is notified of an error later, after Initialize().
   scoped_ptr<media::VideoDecodeAccelerator> CreateVideoDecoder();
 
   // Sends an IPC message to create a GpuVideoEncodeAccelerator. Creates and
   // returns it as an owned pointer to a media::VideoEncodeAccelerator.  Returns
   // NULL on failure to create the GpuVideoEncodeAcceleratorHost.
   // Note that the GpuVideoEncodeAccelerator may still fail to be created in
   // the GPU process, even if this returns non-NULL. In this case the VEA client
   // is notified of an error later, after Initialize();
   scoped_ptr<media::VideoEncodeAccelerator> CreateVideoEncoder();
 
-  // IPC::Listener implementation:
-  bool OnMessageReceived(const IPC::Message& message) override;
-  void OnChannelError() override;
-
   // CommandBuffer implementation:
   bool Initialize() override;
   State GetLastState() override;
   int32_t GetLastToken() override;
   void Flush(int32_t put_offset) override;
   void OrderingBarrier(int32_t put_offset) override;
   void WaitForTokenInRange(int32_t start, int32_t end) override;
   void WaitForGetOffsetInRange(int32_t start, int32_t end) override;
   void SetGetBuffer(int32_t shm_id) override;
   scoped_refptr<gpu::Buffer> CreateTransferBuffer(size_t size,
@@ skipping 48 matching lines @@
       base::Callback<void(base::TimeTicks timebase, base::TimeDelta interval)>;
   void SetUpdateVSyncParametersCallback(
       const UpdateVSyncParametersCallback& callback);
 
   // TODO(apatrick): this is a temporary optimization while skia is calling
   // ContentGLContext::MakeCurrent prior to every GL call. It saves returning 6
   // ints redundantly when only the error is needed for the
   // CommandBufferProxyImpl implementation.
   gpu::error::Error GetLastError() override;
 
-  int32_t route_id() const { return route_id_; }
-
   int32_t stream_id() const { return stream_id_; }
 
   GpuChannelHost* channel() const { return channel_; }
 
   base::SharedMemoryHandle GetSharedStateHandle() const {
     return shared_state_shm_->handle();
   }
   uint32_t CreateStreamTexture(uint32_t texture_id);
 
  private:
   typedef std::map<int32_t, scoped_refptr<gpu::Buffer>> TransferBufferMap;
   typedef base::hash_map<uint32_t, base::Closure> SignalTaskMap;
 
   void CheckLock() {
     if (lock_)
       lock_->AssertAcquired();
   }
 
-  // Send an IPC message over the GPU channel. This is private to fully
-  // encapsulate the channel; all callers of this function must explicitly
-  // verify that the context has not been lost.
-  bool Send(IPC::Message* msg);
-
-  // Message handlers:
-  void OnUpdateState(const gpu::CommandBuffer::State& state);
+  // CommandBufferIPCTransport::Client implementation.
+  void OnChannelError() override;
+  void OnConsoleMessage(const CommandBufferConsoleMessage& message) override;
   void OnDestroyed(gpu::error::ContextLostReason reason,
-                   gpu::error::Error error);
-  void OnConsoleMessage(const GPUCommandBufferConsoleMessage& message);
-  void OnSignalAck(uint32_t id);
+                   gpu::error::Error error) override;
+  void OnDidHandleMessage() override;
+  void OnSignalAck(uint32_t id) override;
   void OnSwapBuffersCompleted(const std::vector<ui::LatencyInfo>& latency_info,
-                              gfx::SwapResult result);
+                              gfx::SwapResult result) override;
+  void OnUpdateState(const gpu::CommandBuffer::State& state) override;
   void OnUpdateVSyncParameters(base::TimeTicks timebase,
-                               base::TimeDelta interval);
+                               base::TimeDelta interval) override;
+  void OnWillHandleMessage() override;
 
   // Try to read an updated copy of the state from shared memory.
   void TryUpdateState();
 
   // Updates the highest verified release fence sync.
   void UpdateVerifiedReleases(uint32_t verified_flush);
 
   // Loses the context after we received an invalid message from the GPU
   // process. Will call the lost context callback reentrantly if any.
   void InvalidGpuMessage();
@@ skipping 14 matching lines @@
 
   // The last cached state received from the service.
   State last_state_;
 
   // The shared memory area used to update state.
   scoped_ptr<base::SharedMemory> shared_state_shm_;
 
   // |*this| is owned by |*channel_| and so is always outlived by it, so using a
   // raw pointer is ok.
   GpuChannelHost* channel_;
-  const uint64_t command_buffer_id_;
-  const int32_t route_id_;
+  scoped_ptr<CommandBufferIPCTransport> transport_;
   const int32_t stream_id_;
   uint32_t flush_count_;
   int32_t last_put_offset_;
   int32_t last_barrier_put_offset_;
 
   // Next generated fence sync.
   uint64_t next_fence_sync_release_;
 
   // Unverified flushed fence syncs with their corresponding flush id.
   std::queue<std::pair<uint64_t, uint32_t>> flushed_release_flush_id_;
@@ skipping 21 matching lines @@
 
   base::WeakPtr<CommandBufferProxyImpl> weak_this_;
   scoped_refptr<base::SequencedTaskRunner> callback_thread_;
 
   DISALLOW_COPY_AND_ASSIGN(CommandBufferProxyImpl);
 };
 
 }  // namespace content
 
 #endif  // CONTENT_COMMON_GPU_CLIENT_COMMAND_BUFFER_PROXY_IMPL_H_