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/ppb_video_decoder_proxy.h" 6 7 #include "base/logging.h" 8 #include "gpu/command_buffer/client/gles2_implementation.h" 9 #include "ppapi/proxy/enter_proxy.h" 10 #include "ppapi/proxy/plugin_dispatcher.h" 11 #include "ppapi/proxy/ppapi_messages.h" 12 #include "ppapi/proxy/ppb_buffer_proxy.h" 13 #include "ppapi/proxy/ppb_graphics_3d_proxy.h" 14 #include "ppapi/thunk/enter.h" 15 #include "ppapi/thunk/resource_creation_api.h" 16 #include "ppapi/thunk/thunk.h" 17 18 using ppapi::thunk::EnterResourceNoLock; 19 using ppapi::thunk::PPB_Buffer_API; 20 using ppapi::thunk::PPB_Graphics3D_API; 21 using ppapi::thunk::PPB_VideoDecoder_API; 22 23 namespace ppapi { 24 namespace proxy { 25 26 class VideoDecoder : public PPB_VideoDecoder_Shared { 27 public: 28 // You must call Init() before using this class. 29 explicit VideoDecoder(const HostResource& resource); 30 virtual ~VideoDecoder(); 31 32 static VideoDecoder* Create(const HostResource& resource, 33 PP_Resource graphics_context, 34 PP_VideoDecoder_Profile profile); 35 36 // PPB_VideoDecoder_API implementation. 37 virtual int32_t Decode(const PP_VideoBitstreamBuffer_Dev* bitstream_buffer, 38 scoped_refptr<TrackedCallback> callback) OVERRIDE; 39 virtual void AssignPictureBuffers( 40 uint32_t no_of_buffers, const PP_PictureBuffer_Dev* buffers) OVERRIDE; 41 virtual void ReusePictureBuffer(int32_t picture_buffer_id) OVERRIDE; 42 virtual int32_t Flush(scoped_refptr<TrackedCallback> callback) OVERRIDE; 43 virtual int32_t Reset(scoped_refptr<TrackedCallback> callback) OVERRIDE; 44 virtual void Destroy() OVERRIDE; 45 46 private: 47 friend class PPB_VideoDecoder_Proxy; 48 49 PluginDispatcher* GetDispatcher() const; 50 51 // Run the callbacks that were passed into the plugin interface. 52 void FlushACK(int32_t result); 53 void ResetACK(int32_t result); 54 void EndOfBitstreamACK(int32_t buffer_id, int32_t result); 55 56 DISALLOW_COPY_AND_ASSIGN(VideoDecoder); 57 }; 58 59 VideoDecoder::VideoDecoder(const HostResource& decoder) 60 : PPB_VideoDecoder_Shared(decoder) { 61 } 62 63 VideoDecoder::~VideoDecoder() { 64 FlushCommandBuffer(); 65 PPB_VideoDecoder_Shared::Destroy(); 66 } 67 68 int32_t VideoDecoder::Decode( 69 const PP_VideoBitstreamBuffer_Dev* bitstream_buffer, 70 scoped_refptr<TrackedCallback> callback) { 71 EnterResourceNoLock<PPB_Buffer_API> 72 enter_buffer(bitstream_buffer->data, true); 73 if (enter_buffer.failed()) 74 return PP_ERROR_BADRESOURCE; 75 76 if (!SetBitstreamBufferCallback(bitstream_buffer->id, callback)) 77 return PP_ERROR_BADARGUMENT; 78 79 Buffer* ppb_buffer = 80 static_cast<Buffer*>(enter_buffer.object()); 81 HostResource host_buffer = ppb_buffer->host_resource(); 82 83 FlushCommandBuffer(); 84 GetDispatcher()->Send(new PpapiHostMsg_PPBVideoDecoder_Decode( 85 API_ID_PPB_VIDEO_DECODER_DEV, host_resource(), 86 host_buffer, bitstream_buffer->id, 87 bitstream_buffer->size)); 88 return PP_OK_COMPLETIONPENDING; 89 } 90 91 void VideoDecoder::AssignPictureBuffers(uint32_t no_of_buffers, 92 const PP_PictureBuffer_Dev* buffers) { 93 std::vector<PP_PictureBuffer_Dev> buffer_list( 94 buffers, buffers + no_of_buffers); 95 FlushCommandBuffer(); 96 GetDispatcher()->Send( 97 new PpapiHostMsg_PPBVideoDecoder_AssignPictureBuffers( 98 API_ID_PPB_VIDEO_DECODER_DEV, host_resource(), buffer_list)); 99 } 100 101 void VideoDecoder::ReusePictureBuffer(int32_t picture_buffer_id) { 102 FlushCommandBuffer(); 103 GetDispatcher()->Send(new PpapiHostMsg_PPBVideoDecoder_ReusePictureBuffer( 104 API_ID_PPB_VIDEO_DECODER_DEV, host_resource(), picture_buffer_id)); 105 } 106 107 int32_t VideoDecoder::Flush(scoped_refptr<TrackedCallback> callback) { 108 if (!SetFlushCallback(callback)) 109 return PP_ERROR_INPROGRESS; 110 111 FlushCommandBuffer(); 112 GetDispatcher()->Send(new PpapiHostMsg_PPBVideoDecoder_Flush( 113 API_ID_PPB_VIDEO_DECODER_DEV, host_resource())); 114 return PP_OK_COMPLETIONPENDING; 115 } 116 117 int32_t VideoDecoder::Reset(scoped_refptr<TrackedCallback> callback) { 118 if (!SetResetCallback(callback)) 119 return PP_ERROR_INPROGRESS; 120 121 FlushCommandBuffer(); 122 GetDispatcher()->Send(new PpapiHostMsg_PPBVideoDecoder_Reset( 123 API_ID_PPB_VIDEO_DECODER_DEV, host_resource())); 124 return PP_OK_COMPLETIONPENDING; 125 } 126 127 void VideoDecoder::Destroy() { 128 FlushCommandBuffer(); 129 GetDispatcher()->Send(new PpapiHostMsg_PPBVideoDecoder_Destroy( 130 API_ID_PPB_VIDEO_DECODER_DEV, host_resource())); 131 PPB_VideoDecoder_Shared::Destroy(); 132 } 133 134 PluginDispatcher* VideoDecoder::GetDispatcher() const { 135 return PluginDispatcher::GetForResource(this); 136 } 137 138 void VideoDecoder::ResetACK(int32_t result) { 139 RunResetCallback(result); 140 } 141 142 void VideoDecoder::FlushACK(int32_t result) { 143 RunFlushCallback(result); 144 } 145 146 void VideoDecoder::EndOfBitstreamACK( 147 int32_t bitstream_buffer_id, int32_t result) { 148 RunBitstreamBufferCallback(bitstream_buffer_id, result); 149 } 150 151 PPB_VideoDecoder_Proxy::PPB_VideoDecoder_Proxy(Dispatcher* dispatcher) 152 : InterfaceProxy(dispatcher), 153 callback_factory_(this) { 154 } 155 156 PPB_VideoDecoder_Proxy::~PPB_VideoDecoder_Proxy() { 157 } 158 159 bool PPB_VideoDecoder_Proxy::OnMessageReceived(const IPC::Message& msg) { 160 if (!dispatcher()->permissions().HasPermission(PERMISSION_DEV)) 161 return false; 162 163 bool handled = true; 164 IPC_BEGIN_MESSAGE_MAP(PPB_VideoDecoder_Proxy, msg) 165 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBVideoDecoder_Create, 166 OnMsgCreate) 167 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBVideoDecoder_Decode, OnMsgDecode) 168 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBVideoDecoder_AssignPictureBuffers, 169 OnMsgAssignPictureBuffers) 170 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBVideoDecoder_ReusePictureBuffer, 171 OnMsgReusePictureBuffer) 172 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBVideoDecoder_Flush, OnMsgFlush) 173 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBVideoDecoder_Reset, OnMsgReset) 174 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBVideoDecoder_Destroy, OnMsgDestroy) 175 IPC_MESSAGE_HANDLER(PpapiMsg_PPBVideoDecoder_ResetACK, OnMsgResetACK) 176 IPC_MESSAGE_HANDLER(PpapiMsg_PPBVideoDecoder_EndOfBitstreamACK, 177 OnMsgEndOfBitstreamACK) 178 IPC_MESSAGE_HANDLER(PpapiMsg_PPBVideoDecoder_FlushACK, OnMsgFlushACK) 179 IPC_MESSAGE_UNHANDLED(handled = false) 180 IPC_END_MESSAGE_MAP() 181 DCHECK(handled); 182 return handled; 183 } 184 185 PP_Resource PPB_VideoDecoder_Proxy::CreateProxyResource( 186 PP_Instance instance, 187 PP_Resource graphics_context, 188 PP_VideoDecoder_Profile profile) { 189 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); 190 // Dispatcher is null if it cannot find the instance passed to it (i.e. if the 191 // client passes in an invalid instance). 192 if (!dispatcher) 193 return 0; 194 195 EnterResourceNoLock<PPB_Graphics3D_API> enter_context(graphics_context, 196 true); 197 if (enter_context.failed()) 198 return 0; 199 200 Graphics3D* context = static_cast<Graphics3D*>(enter_context.object()); 201 202 HostResource result; 203 dispatcher->Send(new PpapiHostMsg_PPBVideoDecoder_Create( 204 API_ID_PPB_VIDEO_DECODER_DEV, instance, 205 context->host_resource(), profile, &result)); 206 if (result.is_null()) 207 return 0; 208 209 // Need a scoped_refptr to keep the object alive during the Init call. 210 scoped_refptr<VideoDecoder> decoder(new VideoDecoder(result)); 211 decoder->InitCommon(graphics_context, context->gles2_impl()); 212 return decoder->GetReference(); 213 } 214 215 void PPB_VideoDecoder_Proxy::OnMsgCreate( 216 PP_Instance instance, const HostResource& graphics_context, 217 PP_VideoDecoder_Profile profile, 218 HostResource* result) { 219 thunk::EnterResourceCreation resource_creation(instance); 220 if (resource_creation.failed()) 221 return; 222 223 // Make the resource and get the API pointer to its interface. 224 result->SetHostResource( 225 instance, resource_creation.functions()->CreateVideoDecoder( 226 instance, graphics_context.host_resource(), profile)); 227 } 228 229 void PPB_VideoDecoder_Proxy::OnMsgDecode( 230 const HostResource& decoder, 231 const HostResource& buffer, int32 id, uint32 size) { 232 EnterHostFromHostResourceForceCallback<PPB_VideoDecoder_API> enter( 233 decoder, callback_factory_, 234 &PPB_VideoDecoder_Proxy::SendMsgEndOfBitstreamACKToPlugin, decoder, id); 235 if (enter.failed()) 236 return; 237 PP_VideoBitstreamBuffer_Dev bitstream = { id, buffer.host_resource(), size }; 238 enter.SetResult(enter.object()->Decode(&bitstream, enter.callback())); 239 } 240 241 void PPB_VideoDecoder_Proxy::OnMsgAssignPictureBuffers( 242 const HostResource& decoder, 243 const std::vector<PP_PictureBuffer_Dev>& buffers) { 244 EnterHostFromHostResource<PPB_VideoDecoder_API> enter(decoder); 245 if (enter.succeeded() && !buffers.empty()) { 246 const PP_PictureBuffer_Dev* buffer_array = &buffers.front(); 247 enter.object()->AssignPictureBuffers(buffers.size(), buffer_array); 248 } 249 } 250 251 void PPB_VideoDecoder_Proxy::OnMsgReusePictureBuffer( 252 const HostResource& decoder, int32 picture_buffer_id) { 253 EnterHostFromHostResource<PPB_VideoDecoder_API> enter(decoder); 254 if (enter.succeeded()) 255 enter.object()->ReusePictureBuffer(picture_buffer_id); 256 } 257 258 void PPB_VideoDecoder_Proxy::OnMsgFlush(const HostResource& decoder) { 259 EnterHostFromHostResourceForceCallback<PPB_VideoDecoder_API> enter( 260 decoder, callback_factory_, 261 &PPB_VideoDecoder_Proxy::SendMsgFlushACKToPlugin, decoder); 262 if (enter.succeeded()) 263 enter.SetResult(enter.object()->Flush(enter.callback())); 264 } 265 266 void PPB_VideoDecoder_Proxy::OnMsgReset(const HostResource& decoder) { 267 EnterHostFromHostResourceForceCallback<PPB_VideoDecoder_API> enter( 268 decoder, callback_factory_, 269 &PPB_VideoDecoder_Proxy::SendMsgResetACKToPlugin, decoder); 270 if (enter.succeeded()) 271 enter.SetResult(enter.object()->Reset(enter.callback())); 272 } 273 274 void PPB_VideoDecoder_Proxy::OnMsgDestroy(const HostResource& decoder) { 275 EnterHostFromHostResource<PPB_VideoDecoder_API> enter(decoder); 276 if (enter.succeeded()) 277 enter.object()->Destroy(); 278 } 279 280 void PPB_VideoDecoder_Proxy::SendMsgEndOfBitstreamACKToPlugin( 281 int32_t result, const HostResource& decoder, int32 id) { 282 dispatcher()->Send(new PpapiMsg_PPBVideoDecoder_EndOfBitstreamACK( 283 API_ID_PPB_VIDEO_DECODER_DEV, decoder, id, result)); 284 } 285 286 void PPB_VideoDecoder_Proxy::SendMsgFlushACKToPlugin( 287 int32_t result, const HostResource& decoder) { 288 dispatcher()->Send(new PpapiMsg_PPBVideoDecoder_FlushACK( 289 API_ID_PPB_VIDEO_DECODER_DEV, decoder, result)); 290 } 291 292 void PPB_VideoDecoder_Proxy::SendMsgResetACKToPlugin( 293 int32_t result, const HostResource& decoder) { 294 dispatcher()->Send(new PpapiMsg_PPBVideoDecoder_ResetACK( 295 API_ID_PPB_VIDEO_DECODER_DEV, decoder, result)); 296 } 297 298 void PPB_VideoDecoder_Proxy::OnMsgEndOfBitstreamACK( 299 const HostResource& decoder, int32_t id, int32_t result) { 300 EnterPluginFromHostResource<PPB_VideoDecoder_API> enter(decoder); 301 if (enter.succeeded()) 302 static_cast<VideoDecoder*>(enter.object())->EndOfBitstreamACK(id, result); 303 } 304 305 void PPB_VideoDecoder_Proxy::OnMsgFlushACK( 306 const HostResource& decoder, int32_t result) { 307 EnterPluginFromHostResource<PPB_VideoDecoder_API> enter(decoder); 308 if (enter.succeeded()) 309 static_cast<VideoDecoder*>(enter.object())->FlushACK(result); 310 } 311 312 void PPB_VideoDecoder_Proxy::OnMsgResetACK( 313 const HostResource& decoder, int32_t result) { 314 EnterPluginFromHostResource<PPB_VideoDecoder_API> enter(decoder); 315 if (enter.succeeded()) 316 static_cast<VideoDecoder*>(enter.object())->ResetACK(result); 317 } 318 319 } // namespace proxy 320 } // namespace ppapi 321
