OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "content/renderer/pepper/pepper_video_source_host.h" | 5 #include "content/renderer/pepper/pepper_video_source_host.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/numerics/safe_conversions.h" | 8 #include "base/numerics/safe_conversions.h" |
9 #include "content/public/renderer/renderer_ppapi_host.h" | 9 #include "content/public/renderer/renderer_ppapi_host.h" |
10 #include "content/renderer/pepper/ppb_image_data_impl.h" | 10 #include "content/renderer/pepper/ppb_image_data_impl.h" |
(...skipping 11 matching lines...) Expand all Loading... |
22 #include "third_party/skia/include/core/SkBitmap.h" | 22 #include "third_party/skia/include/core/SkBitmap.h" |
23 | 23 |
24 using ppapi::host::HostMessageContext; | 24 using ppapi::host::HostMessageContext; |
25 using ppapi::host::ReplyMessageContext; | 25 using ppapi::host::ReplyMessageContext; |
26 | 26 |
27 namespace content { | 27 namespace content { |
28 | 28 |
29 PepperVideoSourceHost::FrameReceiver::FrameReceiver( | 29 PepperVideoSourceHost::FrameReceiver::FrameReceiver( |
30 const base::WeakPtr<PepperVideoSourceHost>& host) | 30 const base::WeakPtr<PepperVideoSourceHost>& host) |
31 : host_(host), | 31 : host_(host), |
32 main_message_loop_proxy_(base::MessageLoopProxy::current()) { | 32 main_message_loop_proxy_(base::MessageLoopProxy::current()) {} |
33 } | |
34 | 33 |
35 PepperVideoSourceHost::FrameReceiver::~FrameReceiver() { | 34 PepperVideoSourceHost::FrameReceiver::~FrameReceiver() {} |
36 } | |
37 | 35 |
38 bool PepperVideoSourceHost::FrameReceiver::GotFrame( | 36 bool PepperVideoSourceHost::FrameReceiver::GotFrame( |
39 cricket::VideoFrame* frame) { | 37 cricket::VideoFrame* frame) { |
40 // It's not safe to access the host from this thread, so post a task to our | 38 // It's not safe to access the host from this thread, so post a task to our |
41 // main thread to transfer the new frame. | 39 // main thread to transfer the new frame. |
42 main_message_loop_proxy_->PostTask( | 40 main_message_loop_proxy_->PostTask( |
43 FROM_HERE, | 41 FROM_HERE, |
44 base::Bind(&FrameReceiver::OnGotFrame, | 42 base::Bind(&FrameReceiver::OnGotFrame, |
45 this, | 43 this, |
46 base::Passed(scoped_ptr<cricket::VideoFrame>(frame)))); | 44 base::Passed(scoped_ptr<cricket::VideoFrame>(frame)))); |
47 | 45 |
48 return true; | 46 return true; |
49 } | 47 } |
50 | 48 |
51 void PepperVideoSourceHost::FrameReceiver::OnGotFrame( | 49 void PepperVideoSourceHost::FrameReceiver::OnGotFrame( |
52 scoped_ptr<cricket::VideoFrame> frame) { | 50 scoped_ptr<cricket::VideoFrame> frame) { |
53 if (host_.get()) { | 51 if (host_.get()) { |
54 // Take ownership of the new frame, and possibly delete any unsent one. | 52 // Take ownership of the new frame, and possibly delete any unsent one. |
55 host_->last_frame_.swap(frame); | 53 host_->last_frame_.swap(frame); |
56 | 54 |
57 if (host_->get_frame_pending_) | 55 if (host_->get_frame_pending_) |
58 host_->SendGetFrameReply(); | 56 host_->SendGetFrameReply(); |
59 } | 57 } |
60 } | 58 } |
61 | 59 |
62 PepperVideoSourceHost::PepperVideoSourceHost( | 60 PepperVideoSourceHost::PepperVideoSourceHost(RendererPpapiHost* host, |
63 RendererPpapiHost* host, | 61 PP_Instance instance, |
64 PP_Instance instance, | 62 PP_Resource resource) |
65 PP_Resource resource) | |
66 : ResourceHost(host->GetPpapiHost(), instance, resource), | 63 : ResourceHost(host->GetPpapiHost(), instance, resource), |
67 renderer_ppapi_host_(host), | 64 renderer_ppapi_host_(host), |
68 source_handler_(new VideoSourceHandler(NULL)), | 65 source_handler_(new VideoSourceHandler(NULL)), |
69 get_frame_pending_(false), | 66 get_frame_pending_(false), |
70 weak_factory_(this) { | 67 weak_factory_(this) { |
71 frame_receiver_ = new FrameReceiver(weak_factory_.GetWeakPtr()); | 68 frame_receiver_ = new FrameReceiver(weak_factory_.GetWeakPtr()); |
72 } | 69 } |
73 | 70 |
74 PepperVideoSourceHost::~PepperVideoSourceHost() { | 71 PepperVideoSourceHost::~PepperVideoSourceHost() { Close(); } |
75 Close(); | |
76 } | |
77 | 72 |
78 int32_t PepperVideoSourceHost::OnResourceMessageReceived( | 73 int32_t PepperVideoSourceHost::OnResourceMessageReceived( |
79 const IPC::Message& msg, | 74 const IPC::Message& msg, |
80 HostMessageContext* context) { | 75 HostMessageContext* context) { |
81 IPC_BEGIN_MESSAGE_MAP(PepperVideoSourceHost, msg) | 76 IPC_BEGIN_MESSAGE_MAP(PepperVideoSourceHost, msg) |
82 PPAPI_DISPATCH_HOST_RESOURCE_CALL(PpapiHostMsg_VideoSource_Open, | 77 PPAPI_DISPATCH_HOST_RESOURCE_CALL(PpapiHostMsg_VideoSource_Open, |
83 OnHostMsgOpen) | 78 OnHostMsgOpen) |
84 PPAPI_DISPATCH_HOST_RESOURCE_CALL_0(PpapiHostMsg_VideoSource_GetFrame, | 79 PPAPI_DISPATCH_HOST_RESOURCE_CALL_0(PpapiHostMsg_VideoSource_GetFrame, |
85 OnHostMsgGetFrame) | 80 OnHostMsgGetFrame) |
86 PPAPI_DISPATCH_HOST_RESOURCE_CALL_0(PpapiHostMsg_VideoSource_Close, | 81 PPAPI_DISPATCH_HOST_RESOURCE_CALL_0(PpapiHostMsg_VideoSource_Close, |
87 OnHostMsgClose) | 82 OnHostMsgClose) |
88 IPC_END_MESSAGE_MAP() | 83 IPC_END_MESSAGE_MAP() |
89 return PP_ERROR_FAILED; | 84 return PP_ERROR_FAILED; |
90 } | 85 } |
91 | 86 |
92 int32_t PepperVideoSourceHost::OnHostMsgOpen(HostMessageContext* context, | 87 int32_t PepperVideoSourceHost::OnHostMsgOpen(HostMessageContext* context, |
93 const std::string& stream_url) { | 88 const std::string& stream_url) { |
94 GURL gurl(stream_url); | 89 GURL gurl(stream_url); |
95 if (!gurl.is_valid()) | 90 if (!gurl.is_valid()) |
96 return PP_ERROR_BADARGUMENT; | 91 return PP_ERROR_BADARGUMENT; |
97 | 92 |
(...skipping 42 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
140 IPC::PlatformFileForTransit image_handle; | 135 IPC::PlatformFileForTransit image_handle; |
141 uint32_t byte_count; | 136 uint32_t byte_count; |
142 ppapi::ScopedPPResource resource( | 137 ppapi::ScopedPPResource resource( |
143 ppapi::ScopedPPResource::PassRef(), | 138 ppapi::ScopedPPResource::PassRef(), |
144 ppapi::proxy::PPB_ImageData_Proxy::CreateImageData( | 139 ppapi::proxy::PPB_ImageData_Proxy::CreateImageData( |
145 pp_instance(), | 140 pp_instance(), |
146 ppapi::PPB_ImageData_Shared::SIMPLE, | 141 ppapi::PPB_ImageData_Shared::SIMPLE, |
147 PP_IMAGEDATAFORMAT_BGRA_PREMUL, | 142 PP_IMAGEDATAFORMAT_BGRA_PREMUL, |
148 PP_MakeSize(width, height), | 143 PP_MakeSize(width, height), |
149 false /* init_to_zero */, | 144 false /* init_to_zero */, |
150 &image_desc, &image_handle, &byte_count)); | 145 &image_desc, |
| 146 &image_handle, |
| 147 &byte_count)); |
151 if (!resource.get()) { | 148 if (!resource.get()) { |
152 SendGetFrameErrorReply(PP_ERROR_FAILED); | 149 SendGetFrameErrorReply(PP_ERROR_FAILED); |
153 return; | 150 return; |
154 } | 151 } |
155 | 152 |
156 ppapi::thunk::EnterResourceNoLock<ppapi::thunk::PPB_ImageData_API> | 153 ppapi::thunk::EnterResourceNoLock<ppapi::thunk::PPB_ImageData_API> |
157 enter_resource(resource, false); | 154 enter_resource(resource, false); |
158 if (enter_resource.failed()) { | 155 if (enter_resource.failed()) { |
159 SendGetFrameErrorReply(PP_ERROR_FAILED); | 156 SendGetFrameErrorReply(PP_ERROR_FAILED); |
160 return; | 157 return; |
(...skipping 12 matching lines...) Expand all Loading... |
173 SendGetFrameErrorReply(PP_ERROR_FAILED); | 170 SendGetFrameErrorReply(PP_ERROR_FAILED); |
174 return; | 171 return; |
175 } | 172 } |
176 uint8_t* bitmap_pixels = static_cast<uint8_t*>(bitmap->getPixels()); | 173 uint8_t* bitmap_pixels = static_cast<uint8_t*>(bitmap->getPixels()); |
177 if (!bitmap_pixels) { | 174 if (!bitmap_pixels) { |
178 SendGetFrameErrorReply(PP_ERROR_FAILED); | 175 SendGetFrameErrorReply(PP_ERROR_FAILED); |
179 return; | 176 return; |
180 } | 177 } |
181 | 178 |
182 size_t bitmap_size = bitmap->getSize(); | 179 size_t bitmap_size = bitmap->getSize(); |
183 frame->ConvertToRgbBuffer(cricket::FOURCC_BGRA, | 180 frame->ConvertToRgbBuffer( |
184 bitmap_pixels, | 181 cricket::FOURCC_BGRA, bitmap_pixels, bitmap_size, bitmap->rowBytes()); |
185 bitmap_size, | |
186 bitmap->rowBytes()); | |
187 | 182 |
188 ppapi::HostResource host_resource; | 183 ppapi::HostResource host_resource; |
189 host_resource.SetHostResource(pp_instance(), resource.get()); | 184 host_resource.SetHostResource(pp_instance(), resource.get()); |
190 | 185 |
191 // Convert a video timestamp (int64, in nanoseconds) to a time delta (int64, | 186 // Convert a video timestamp (int64, in nanoseconds) to a time delta (int64, |
192 // microseconds) and then to a PP_TimeTicks (a double, in seconds). All times | 187 // microseconds) and then to a PP_TimeTicks (a double, in seconds). All times |
193 // are relative to the Unix Epoch. | 188 // are relative to the Unix Epoch. |
194 base::TimeDelta time_delta = base::TimeDelta::FromMicroseconds( | 189 base::TimeDelta time_delta = base::TimeDelta::FromMicroseconds( |
195 frame->GetTimeStamp() / base::Time::kNanosecondsPerMicrosecond); | 190 frame->GetTimeStamp() / base::Time::kNanosecondsPerMicrosecond); |
196 PP_TimeTicks timestamp = time_delta.InSecondsF(); | 191 PP_TimeTicks timestamp = time_delta.InSecondsF(); |
197 | 192 |
198 ppapi::proxy::SerializedHandle serialized_handle; | 193 ppapi::proxy::SerializedHandle serialized_handle; |
199 serialized_handle.set_shmem(image_handle, byte_count); | 194 serialized_handle.set_shmem(image_handle, byte_count); |
200 reply_context_.params.AppendHandle(serialized_handle); | 195 reply_context_.params.AppendHandle(serialized_handle); |
201 | 196 |
202 host()->SendReply(reply_context_, | 197 host()->SendReply(reply_context_, |
203 PpapiPluginMsg_VideoSource_GetFrameReply(host_resource, | 198 PpapiPluginMsg_VideoSource_GetFrameReply( |
204 image_desc, | 199 host_resource, image_desc, timestamp)); |
205 timestamp)); | |
206 | 200 |
207 reply_context_ = ppapi::host::ReplyMessageContext(); | 201 reply_context_ = ppapi::host::ReplyMessageContext(); |
208 | 202 |
209 // Keep a reference once we know this method succeeds. | 203 // Keep a reference once we know this method succeeds. |
210 resource.Release(); | 204 resource.Release(); |
211 } | 205 } |
212 | 206 |
213 void PepperVideoSourceHost::SendGetFrameErrorReply(int32_t error) { | 207 void PepperVideoSourceHost::SendGetFrameErrorReply(int32_t error) { |
214 reply_context_.params.set_result(error); | 208 reply_context_.params.set_result(error); |
215 host()->SendReply( | 209 host()->SendReply( |
216 reply_context_, | 210 reply_context_, |
217 PpapiPluginMsg_VideoSource_GetFrameReply(ppapi::HostResource(), | 211 PpapiPluginMsg_VideoSource_GetFrameReply( |
218 PP_ImageDataDesc(), | 212 ppapi::HostResource(), PP_ImageDataDesc(), 0.0 /* timestamp */)); |
219 0.0 /* timestamp */)); | |
220 reply_context_ = ppapi::host::ReplyMessageContext(); | 213 reply_context_ = ppapi::host::ReplyMessageContext(); |
221 } | 214 } |
222 | 215 |
223 void PepperVideoSourceHost::Close() { | 216 void PepperVideoSourceHost::Close() { |
224 if (source_handler_.get() && !stream_url_.empty()) | 217 if (source_handler_.get() && !stream_url_.empty()) |
225 source_handler_->Close(frame_receiver_.get()); | 218 source_handler_->Close(frame_receiver_.get()); |
226 | 219 |
227 source_handler_.reset(NULL); | 220 source_handler_.reset(NULL); |
228 stream_url_.clear(); | 221 stream_url_.clear(); |
229 } | 222 } |
230 | 223 |
231 } // namespace content | 224 } // namespace content |
OLD | NEW |