1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "content/renderer/pepper/pepper_media_stream_track_host_base.h"
#include <utility>
#include "base/logging.h"
#include "base/numerics/safe_math.h"
#include "content/common/pepper_file_util.h"
#include "content/public/renderer/render_thread.h"
#include "content/public/renderer/renderer_ppapi_host.h"
#include "ppapi/c/pp_errors.h"
#include "ppapi/host/dispatch_host_message.h"
#include "ppapi/host/host_message_context.h"
#include "ppapi/host/ppapi_host.h"
#include "ppapi/proxy/ppapi_messages.h"
#include "ppapi/shared_impl/media_stream_buffer.h"
using ppapi::host::HostMessageContext;
using ppapi::proxy::SerializedHandle;
namespace content {
PepperMediaStreamTrackHostBase::PepperMediaStreamTrackHostBase(
RendererPpapiHost* host,
PP_Instance instance,
PP_Resource resource)
: ResourceHost(host->GetPpapiHost(), instance, resource),
host_(host),
buffer_manager_(this) {}
PepperMediaStreamTrackHostBase::~PepperMediaStreamTrackHostBase() {}
bool PepperMediaStreamTrackHostBase::InitBuffers(int32_t number_of_buffers,
int32_t buffer_size,
TrackType track_type) {
DCHECK_GT(number_of_buffers, 0);
DCHECK_GT(buffer_size,
static_cast<int32_t>(sizeof(ppapi::MediaStreamBuffer::Header)));
// Make each buffer 4 byte aligned.
base::CheckedNumeric<int32_t> buffer_size_aligned = buffer_size;
// TODO(amistry): "buffer size" might not == "buffer stride", in the same way
// that width != stride in an image buffer.
buffer_size_aligned += (4 - buffer_size % 4);
// TODO(penghuang): |HostAllocateSharedMemoryBuffer| uses sync IPC. We should
// avoid it.
base::CheckedNumeric<uint32_t> size = number_of_buffers * buffer_size_aligned;
if (!size.IsValid())
return false;
content::RenderThread* render_thread = content::RenderThread::Get();
std::unique_ptr<base::SharedMemory> shm(
render_thread->HostAllocateSharedMemoryBuffer(size.ValueOrDie()));
if (!shm)
return false;
base::SharedMemoryHandle shm_handle = shm->handle();
if (!buffer_manager_.SetBuffers(number_of_buffers,
buffer_size_aligned.ValueOrDie(),
std::move(shm), true)) {
return false;
}
SerializedHandle handle(host_->ShareSharedMemoryHandleWithRemote(shm_handle),
size.ValueOrDie());
bool readonly = (track_type == kRead);
host()->SendUnsolicitedReplyWithHandles(
pp_resource(),
PpapiPluginMsg_MediaStreamTrack_InitBuffers(
number_of_buffers,
buffer_size_aligned.ValueOrDie(),
readonly),
std::vector<SerializedHandle>(1, handle));
return true;
}
void PepperMediaStreamTrackHostBase::SendEnqueueBufferMessageToPlugin(
int32_t index) {
DCHECK_GE(index, 0);
DCHECK_LT(index, buffer_manager_.number_of_buffers());
host()->SendUnsolicitedReply(
pp_resource(), PpapiPluginMsg_MediaStreamTrack_EnqueueBuffer(index));
}
void PepperMediaStreamTrackHostBase::SendEnqueueBuffersMessageToPlugin(
const std::vector<int32_t>& indices) {
DCHECK_GE(indices.size(), 0U);
host()->SendUnsolicitedReply(pp_resource(),
PpapiPluginMsg_MediaStreamTrack_EnqueueBuffers(indices));
}
int32_t PepperMediaStreamTrackHostBase::OnResourceMessageReceived(
const IPC::Message& msg,
HostMessageContext* context) {
PPAPI_BEGIN_MESSAGE_MAP(PepperMediaStreamTrackHostBase, msg)
PPAPI_DISPATCH_HOST_RESOURCE_CALL(
PpapiHostMsg_MediaStreamTrack_EnqueueBuffer, OnHostMsgEnqueueBuffer)
PPAPI_DISPATCH_HOST_RESOURCE_CALL_0(PpapiHostMsg_MediaStreamTrack_Close,
OnHostMsgClose)
PPAPI_END_MESSAGE_MAP()
return ppapi::host::ResourceHost::OnResourceMessageReceived(msg, context);
}
int32_t PepperMediaStreamTrackHostBase::OnHostMsgEnqueueBuffer(
HostMessageContext* context,
int32_t index) {
buffer_manager_.EnqueueBuffer(index);
return PP_OK;
}
int32_t PepperMediaStreamTrackHostBase::OnHostMsgClose(
HostMessageContext* context) {
OnClose();
return PP_OK;
}
} // namespace content
|
