OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 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/common/gpu/media/gpu_video_encode_accelerator.h" | 5 #include "content/common/gpu/media/gpu_video_encode_accelerator.h" |
6 | 6 |
7 #include "base/callback.h" | 7 #include "base/callback.h" |
8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "base/memory/shared_memory.h" | 10 #include "base/memory/shared_memory.h" |
11 #include "base/message_loop/message_loop_proxy.h" | 11 #include "base/message_loop/message_loop_proxy.h" |
| 12 #include "base/sys_info.h" |
12 #include "build/build_config.h" | 13 #include "build/build_config.h" |
13 #include "content/common/gpu/gpu_channel.h" | 14 #include "content/common/gpu/gpu_channel.h" |
14 #include "content/common/gpu/gpu_messages.h" | 15 #include "content/common/gpu/gpu_messages.h" |
15 #include "content/public/common/content_switches.h" | 16 #include "content/public/common/content_switches.h" |
16 #include "ipc/ipc_message_macros.h" | 17 #include "ipc/ipc_message_macros.h" |
17 #include "media/base/limits.h" | 18 #include "media/base/limits.h" |
18 #include "media/base/video_frame.h" | 19 #include "media/base/video_frame.h" |
19 | 20 |
20 #if defined(OS_CHROMEOS) | 21 #if defined(OS_CHROMEOS) |
21 #if defined(ARCH_CPU_ARMEL) || (defined(USE_OZONE) && defined(USE_V4L2_CODEC)) | 22 #if defined(ARCH_CPU_ARMEL) || (defined(USE_OZONE) && defined(USE_V4L2_CODEC)) |
(...skipping 216 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
238 GpuVideoEncodeAccelerator::CreateAndroidVEA() { | 239 GpuVideoEncodeAccelerator::CreateAndroidVEA() { |
239 scoped_ptr<media::VideoEncodeAccelerator> encoder; | 240 scoped_ptr<media::VideoEncodeAccelerator> encoder; |
240 #if defined(OS_ANDROID) && defined(ENABLE_WEBRTC) | 241 #if defined(OS_ANDROID) && defined(ENABLE_WEBRTC) |
241 encoder.reset(new AndroidVideoEncodeAccelerator()); | 242 encoder.reset(new AndroidVideoEncodeAccelerator()); |
242 #endif | 243 #endif |
243 return encoder.Pass(); | 244 return encoder.Pass(); |
244 } | 245 } |
245 | 246 |
246 void GpuVideoEncodeAccelerator::OnEncode(int32 frame_id, | 247 void GpuVideoEncodeAccelerator::OnEncode(int32 frame_id, |
247 base::SharedMemoryHandle buffer_handle, | 248 base::SharedMemoryHandle buffer_handle, |
| 249 uint32 buffer_offset, |
248 uint32 buffer_size, | 250 uint32 buffer_size, |
249 bool force_keyframe) { | 251 bool force_keyframe) { |
250 DVLOG(3) << "GpuVideoEncodeAccelerator::OnEncode(): frame_id=" << frame_id | 252 DVLOG(3) << "GpuVideoEncodeAccelerator::OnEncode(): frame_id=" << frame_id |
251 << ", buffer_size=" << buffer_size | 253 << ", buffer_size=" << buffer_size |
252 << ", force_keyframe=" << force_keyframe; | 254 << ", force_keyframe=" << force_keyframe; |
253 if (!encoder_) | 255 if (!encoder_) |
254 return; | 256 return; |
255 if (frame_id < 0) { | 257 if (frame_id < 0) { |
256 DLOG(ERROR) << "GpuVideoEncodeAccelerator::OnEncode(): invalid frame_id=" | 258 DLOG(ERROR) << "GpuVideoEncodeAccelerator::OnEncode(): invalid frame_id=" |
257 << frame_id; | 259 << frame_id; |
258 NotifyError(media::VideoEncodeAccelerator::kPlatformFailureError); | 260 NotifyError(media::VideoEncodeAccelerator::kPlatformFailureError); |
259 return; | 261 return; |
260 } | 262 } |
261 | 263 |
| 264 off_t map_offset = buffer_offset - |
| 265 (buffer_offset % base::SysInfo::VMAllocationGranularity()); |
| 266 size_t map_size = buffer_size + (buffer_offset - map_offset); |
| 267 |
262 scoped_ptr<base::SharedMemory> shm( | 268 scoped_ptr<base::SharedMemory> shm( |
263 new base::SharedMemory(buffer_handle, true)); | 269 new base::SharedMemory(buffer_handle, true)); |
264 if (!shm->Map(buffer_size)) { | 270 if (!shm->MapAt(map_offset, map_size)) { |
265 DLOG(ERROR) << "GpuVideoEncodeAccelerator::OnEncode(): " | 271 DLOG(ERROR) << "GpuVideoEncodeAccelerator::OnEncode(): " |
266 "could not map frame_id=" << frame_id; | 272 "could not map frame_id=" << frame_id; |
267 NotifyError(media::VideoEncodeAccelerator::kPlatformFailureError); | 273 NotifyError(media::VideoEncodeAccelerator::kPlatformFailureError); |
268 return; | 274 return; |
269 } | 275 } |
270 | 276 |
271 uint8* shm_memory = reinterpret_cast<uint8*>(shm->memory()); | 277 LOG(ERROR) << "GpuVideoEncodeAccelerator::OnEncode" |
| 278 << " buffer_offset=" << buffer_offset |
| 279 << " buffer_size=" << buffer_size |
| 280 << " map_offset=" << map_offset |
| 281 << " map_size=" << map_size |
| 282 << " ptr_offset=" << (buffer_offset - map_offset); |
| 283 |
| 284 uint8* shm_memory = reinterpret_cast<uint8*>(shm->memory()) + |
| 285 (buffer_offset - map_offset); |
272 scoped_refptr<media::VideoFrame> frame = | 286 scoped_refptr<media::VideoFrame> frame = |
273 media::VideoFrame::WrapExternalPackedMemory( | 287 media::VideoFrame::WrapExternalPackedMemory( |
274 input_format_, | 288 input_format_, |
275 input_coded_size_, | 289 input_coded_size_, |
276 gfx::Rect(input_visible_size_), | 290 gfx::Rect(input_visible_size_), |
277 input_visible_size_, | 291 input_visible_size_, |
278 shm_memory, | 292 shm_memory, |
279 buffer_size, | 293 buffer_size, |
280 buffer_handle, | 294 buffer_handle, |
| 295 buffer_offset, |
281 base::TimeDelta(), | 296 base::TimeDelta(), |
282 // It's turtles all the way down... | 297 // It's turtles all the way down... |
283 base::Bind(base::IgnoreResult(&base::MessageLoopProxy::PostTask), | 298 base::Bind(base::IgnoreResult(&base::MessageLoopProxy::PostTask), |
284 base::MessageLoopProxy::current(), | 299 base::MessageLoopProxy::current(), |
285 FROM_HERE, | 300 FROM_HERE, |
286 base::Bind(&GpuVideoEncodeAccelerator::EncodeFrameFinished, | 301 base::Bind(&GpuVideoEncodeAccelerator::EncodeFrameFinished, |
287 weak_this_factory_.GetWeakPtr(), | 302 weak_this_factory_.GetWeakPtr(), |
288 frame_id, | 303 frame_id, |
289 base::Passed(&shm)))); | 304 base::Passed(&shm)))); |
290 | 305 |
(...skipping 60 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
351 stub_->channel()->Send(message); | 366 stub_->channel()->Send(message); |
352 } | 367 } |
353 | 368 |
354 void GpuVideoEncodeAccelerator::SendCreateEncoderReply(IPC::Message* message, | 369 void GpuVideoEncodeAccelerator::SendCreateEncoderReply(IPC::Message* message, |
355 bool succeeded) { | 370 bool succeeded) { |
356 GpuCommandBufferMsg_CreateVideoEncoder::WriteReplyParams(message, succeeded); | 371 GpuCommandBufferMsg_CreateVideoEncoder::WriteReplyParams(message, succeeded); |
357 Send(message); | 372 Send(message); |
358 } | 373 } |
359 | 374 |
360 } // namespace content | 375 } // namespace content |
OLD | NEW |