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
VideoDecoder(const HostResource & decoder)59 VideoDecoder::VideoDecoder(const HostResource& decoder)
60 : PPB_VideoDecoder_Shared(decoder) {
61 }
62
~VideoDecoder()63 VideoDecoder::~VideoDecoder() {
64 FlushCommandBuffer();
65 PPB_VideoDecoder_Shared::Destroy();
66 }
67
Decode(const PP_VideoBitstreamBuffer_Dev * bitstream_buffer,scoped_refptr<TrackedCallback> callback)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
AssignPictureBuffers(uint32_t no_of_buffers,const PP_PictureBuffer_Dev * buffers)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
ReusePictureBuffer(int32_t picture_buffer_id)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
Flush(scoped_refptr<TrackedCallback> callback)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
Reset(scoped_refptr<TrackedCallback> callback)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
Destroy()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
GetDispatcher() const134 PluginDispatcher* VideoDecoder::GetDispatcher() const {
135 return PluginDispatcher::GetForResource(this);
136 }
137
ResetACK(int32_t result)138 void VideoDecoder::ResetACK(int32_t result) {
139 RunResetCallback(result);
140 }
141
FlushACK(int32_t result)142 void VideoDecoder::FlushACK(int32_t result) {
143 RunFlushCallback(result);
144 }
145
EndOfBitstreamACK(int32_t bitstream_buffer_id,int32_t result)146 void VideoDecoder::EndOfBitstreamACK(
147 int32_t bitstream_buffer_id, int32_t result) {
148 RunBitstreamBufferCallback(bitstream_buffer_id, result);
149 }
150
PPB_VideoDecoder_Proxy(Dispatcher * dispatcher)151 PPB_VideoDecoder_Proxy::PPB_VideoDecoder_Proxy(Dispatcher* dispatcher)
152 : InterfaceProxy(dispatcher),
153 callback_factory_(this) {
154 }
155
~PPB_VideoDecoder_Proxy()156 PPB_VideoDecoder_Proxy::~PPB_VideoDecoder_Proxy() {
157 }
158
OnMessageReceived(const IPC::Message & msg)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
CreateProxyResource(PP_Instance instance,PP_Resource graphics_context,PP_VideoDecoder_Profile profile)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
OnMsgCreate(PP_Instance instance,const HostResource & graphics_context,PP_VideoDecoder_Profile profile,HostResource * result)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
OnMsgDecode(const HostResource & decoder,const HostResource & buffer,int32 id,uint32 size)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
OnMsgAssignPictureBuffers(const HostResource & decoder,const std::vector<PP_PictureBuffer_Dev> & buffers)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
OnMsgReusePictureBuffer(const HostResource & decoder,int32 picture_buffer_id)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
OnMsgFlush(const HostResource & decoder)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
OnMsgReset(const HostResource & decoder)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
OnMsgDestroy(const HostResource & decoder)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
SendMsgEndOfBitstreamACKToPlugin(int32_t result,const HostResource & decoder,int32 id)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
SendMsgFlushACKToPlugin(int32_t result,const HostResource & decoder)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
SendMsgResetACKToPlugin(int32_t result,const HostResource & decoder)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
OnMsgEndOfBitstreamACK(const HostResource & decoder,int32_t id,int32_t result)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
OnMsgFlushACK(const HostResource & decoder,int32_t result)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
OnMsgResetACK(const HostResource & decoder,int32_t result)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