ppapi/proxy/ppapi_command_buffer_proxy.cc

   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
   3 // found in the LICENSE file.
   4
   5 #include "ppapi/proxy/ppapi_command_buffer_proxy.h"
   6
   7 #include "base/numerics/safe_conversions.h"
   8 #include "ppapi/proxy/plugin_dispatcher.h"
   9 #include "ppapi/proxy/ppapi_messages.h"
  10 #include "ppapi/shared_impl/api_id.h"
  11 #include "ppapi/shared_impl/host_resource.h"
  12 #include "ppapi/shared_impl/proxy_lock.h"
  13
  14 namespace ppapi {
  15 namespace proxy {
  16
  17 PpapiCommandBufferProxy::PpapiCommandBufferProxy(
  18     const ppapi::HostResource& resource,
  19     PluginDispatcher* dispatcher,
  20     const gpu::Capabilities& capabilities,
  21     const SerializedHandle& shared_state)
  22     : capabilities_(capabilities),
  23       resource_(resource),
  24       dispatcher_(dispatcher) {
  25   shared_state_shm_.reset(
  26       new base::SharedMemory(shared_state.shmem(), false));
  27   shared_state_shm_->Map(shared_state.size());
  28 }
  29
  30 PpapiCommandBufferProxy::~PpapiCommandBufferProxy() {
  31   // gpu::Buffers are no longer referenced, allowing shared memory objects to be
  32   // deleted, closing the handle in this process.
  33 }
  34
  35 bool PpapiCommandBufferProxy::Initialize() {
  36   return true;
  37 }
  38
  39 gpu::CommandBuffer::State PpapiCommandBufferProxy::GetLastState() {
  40   ppapi::ProxyLock::AssertAcquiredDebugOnly();
  41   return last_state_;
  42 }
  43
  44 int32 PpapiCommandBufferProxy::GetLastToken() {
  45   ppapi::ProxyLock::AssertAcquiredDebugOnly();
  46   TryUpdateState();
  47   return last_state_.token;
  48 }
  49
  50 void PpapiCommandBufferProxy::Flush(int32 put_offset) {
  51   if (last_state_.error != gpu::error::kNoError)
  52     return;
  53
  54   IPC::Message* message = new PpapiHostMsg_PPBGraphics3D_AsyncFlush(
  55       ppapi::API_ID_PPB_GRAPHICS_3D, resource_, put_offset);
  56
  57   // Do not let a synchronous flush hold up this message. If this handler is
  58   // deferred until after the synchronous flush completes, it will overwrite the
  59   // cached last_state_ with out-of-date data.
  60   message->set_unblock(true);
  61   Send(message);
  62 }
  63
  64 void PpapiCommandBufferProxy::OrderingBarrier(int32 put_offset) {
  65   Flush(put_offset);
  66 }
  67
  68 void PpapiCommandBufferProxy::WaitForTokenInRange(int32 start, int32 end) {
  69   TryUpdateState();
  70   if (!InRange(start, end, last_state_.token) &&
  71       last_state_.error == gpu::error::kNoError) {
  72     bool success = false;
  73     gpu::CommandBuffer::State state;
  74     if (Send(new PpapiHostMsg_PPBGraphics3D_WaitForTokenInRange(
  75              ppapi::API_ID_PPB_GRAPHICS_3D,
  76              resource_,
  77              start,
  78              end,
  79              &state,
  80              &success)))
  81       UpdateState(state, success);
  82   }
  83   DCHECK(InRange(start, end, last_state_.token) ||
  84          last_state_.error != gpu::error::kNoError);
  85 }
  86
  87 void PpapiCommandBufferProxy::WaitForGetOffsetInRange(int32 start, int32 end) {
  88   TryUpdateState();
  89   if (!InRange(start, end, last_state_.get_offset) &&
  90       last_state_.error == gpu::error::kNoError) {
  91     bool success = false;
  92     gpu::CommandBuffer::State state;
  93     if (Send(new PpapiHostMsg_PPBGraphics3D_WaitForGetOffsetInRange(
  94              ppapi::API_ID_PPB_GRAPHICS_3D,
  95              resource_,
  96              start,
  97              end,
  98              &state,
  99              &success)))
 100       UpdateState(state, success);
 101   }
 102   DCHECK(InRange(start, end, last_state_.get_offset) ||
 103          last_state_.error != gpu::error::kNoError);
 104 }
 105
 106 void PpapiCommandBufferProxy::SetGetBuffer(int32 transfer_buffer_id) {
 107   if (last_state_.error == gpu::error::kNoError) {
 108     Send(new PpapiHostMsg_PPBGraphics3D_SetGetBuffer(
 109          ppapi::API_ID_PPB_GRAPHICS_3D, resource_, transfer_buffer_id));
 110   }
 111 }
 112
 113 scoped_refptr<gpu::Buffer> PpapiCommandBufferProxy::CreateTransferBuffer(
 114     size_t size,
 115     int32* id) {
 116   *id = -1;
 117
 118   if (last_state_.error != gpu::error::kNoError)
 119     return NULL;
 120
 121   // Assuming we are in the renderer process, the service is responsible for
 122   // duplicating the handle. This might not be true for NaCl.
 123   ppapi::proxy::SerializedHandle handle(
 124       ppapi::proxy::SerializedHandle::SHARED_MEMORY);
 125   if (!Send(new PpapiHostMsg_PPBGraphics3D_CreateTransferBuffer(
 126             ppapi::API_ID_PPB_GRAPHICS_3D, resource_,
 127             base::checked_cast<uint32_t>(size), id, &handle))) {
 128     return NULL;
 129   }
 130
 131   if (*id <= 0 || !handle.is_shmem())
 132     return NULL;
 133
 134   scoped_ptr<base::SharedMemory> shared_memory(
 135       new base::SharedMemory(handle.shmem(), false));
 136
 137   // Map the shared memory on demand.
 138   if (!shared_memory->memory()) {
 139     if (!shared_memory->Map(handle.size())) {
 140       *id = -1;
 141       return NULL;
 142     }
 143   }
 144
 145   return gpu::MakeBufferFromSharedMemory(shared_memory.Pass(), handle.size());
 146 }
 147
 148 void PpapiCommandBufferProxy::DestroyTransferBuffer(int32 id) {
 149   if (last_state_.error != gpu::error::kNoError)
 150     return;
 151
 152   Send(new PpapiHostMsg_PPBGraphics3D_DestroyTransferBuffer(
 153       ppapi::API_ID_PPB_GRAPHICS_3D, resource_, id));
 154 }
 155
 156 uint32 PpapiCommandBufferProxy::CreateStreamTexture(uint32 texture_id) {
 157   NOTREACHED();
 158   return 0;
 159 }
 160
 161 void PpapiCommandBufferProxy::SetLock(base::Lock*) {
 162   NOTIMPLEMENTED();
 163 }
 164
 165 uint32 PpapiCommandBufferProxy::InsertSyncPoint() {
 166   uint32 sync_point = 0;
 167   if (last_state_.error == gpu::error::kNoError) {
 168     Send(new PpapiHostMsg_PPBGraphics3D_InsertSyncPoint(
 169          ppapi::API_ID_PPB_GRAPHICS_3D, resource_, &sync_point));
 170   }
 171   return sync_point;
 172 }
 173
 174 uint32 PpapiCommandBufferProxy::InsertFutureSyncPoint() {
 175   uint32 sync_point = 0;
 176   if (last_state_.error == gpu::error::kNoError) {
 177     Send(new PpapiHostMsg_PPBGraphics3D_InsertFutureSyncPoint(
 178         ppapi::API_ID_PPB_GRAPHICS_3D, resource_, &sync_point));
 179   }
 180   return sync_point;
 181 }
 182
 183 void PpapiCommandBufferProxy::RetireSyncPoint(uint32 sync_point) {
 184   if (last_state_.error == gpu::error::kNoError) {
 185     Send(new PpapiHostMsg_PPBGraphics3D_RetireSyncPoint(
 186         ppapi::API_ID_PPB_GRAPHICS_3D, resource_, sync_point));
 187   }
 188 }
 189
 190 void PpapiCommandBufferProxy::SignalSyncPoint(uint32 sync_point,
 191                                               const base::Closure& callback) {
 192   NOTREACHED();
 193 }
 194
 195 void PpapiCommandBufferProxy::SignalQuery(uint32 query,
 196                                           const base::Closure& callback) {
 197   NOTREACHED();
 198 }
 199
 200 void PpapiCommandBufferProxy::SetSurfaceVisible(bool visible) {
 201   NOTREACHED();
 202 }
 203
 204 gpu::Capabilities PpapiCommandBufferProxy::GetCapabilities() {
 205   return capabilities_;
 206 }
 207
 208 int32 PpapiCommandBufferProxy::CreateImage(ClientBuffer buffer,
 209                                            size_t width,
 210                                            size_t height,
 211                                            unsigned internalformat) {
 212   NOTREACHED();
 213   return -1;
 214 }
 215
 216 void PpapiCommandBufferProxy::DestroyImage(int32 id) {
 217   NOTREACHED();
 218 }
 219
 220 int32 PpapiCommandBufferProxy::CreateGpuMemoryBufferImage(
 221     size_t width,
 222     size_t height,
 223     unsigned internalformat,
 224     unsigned usage) {
 225   NOTREACHED();
 226   return -1;
 227 }
 228
 229 bool PpapiCommandBufferProxy::Send(IPC::Message* msg) {
 230   DCHECK(last_state_.error == gpu::error::kNoError);
 231
 232   // We need to hold the Pepper proxy lock for sync IPC, because the GPU command
 233   // buffer may use a sync IPC with another lock held which could lead to lock
 234   // and deadlock if we dropped the proxy lock here.
 235   // http://crbug.com/418651
 236   if (dispatcher_->SendAndStayLocked(msg))
 237     return true;
 238
 239   last_state_.error = gpu::error::kLostContext;
 240   return false;
 241 }
 242
 243 void PpapiCommandBufferProxy::UpdateState(
 244     const gpu::CommandBuffer::State& state,
 245     bool success) {
 246   // Handle wraparound. It works as long as we don't have more than 2B state
 247   // updates in flight across which reordering occurs.
 248   if (success) {
 249     if (state.generation - last_state_.generation < 0x80000000U) {
 250       last_state_ = state;
 251     }
 252   } else {
 253     last_state_.error = gpu::error::kLostContext;
 254     ++last_state_.generation;
 255   }
 256 }
 257
 258 void PpapiCommandBufferProxy::TryUpdateState() {
 259   if (last_state_.error == gpu::error::kNoError)
 260     shared_state()->Read(&last_state_);
 261 }
 262
 263 gpu::CommandBufferSharedState* PpapiCommandBufferProxy::shared_state() const {
 264   return reinterpret_cast<gpu::CommandBufferSharedState*>(
 265       shared_state_shm_->memory());
 266 }
 267
 268 }  // namespace proxy
 269 }  // namespace ppapi