blob: 8c0905c67bfd0b3f63f023081faa996125cff77b [file] [log] [blame]
Andreas Hubere2b10282010-11-23 11:41:34 -08001/*
2 * Copyright (C) 2010 The Android Open Source Project
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17//#define LOG_NDEBUG 0
18#define LOG_TAG "IStreamSource"
19#include <utils/Log.h>
20
21#include <media/IStreamSource.h>
Andreas Huber14acc732010-12-06 10:36:06 -080022#include <media/stagefright/foundation/AMessage.h>
Andreas Hubere2b10282010-11-23 11:41:34 -080023
24#include <binder/IMemory.h>
25#include <binder/Parcel.h>
26
27namespace android {
28
Andreas Huber32f3cef2011-03-02 15:34:46 -080029// static
30const char *const IStreamListener::kKeyResumeAtPTS = "resume-at-PTS";
31
Andreas Huber42e549e2011-07-13 09:36:11 -070032// static
Andreas Huberbfcc8d82011-11-29 11:57:35 -080033const char *const IStreamListener::kKeyDiscontinuityMask = "discontinuity-mask";
Andreas Huber42e549e2011-07-13 09:36:11 -070034
Andreas Hubera4c5bc02012-11-27 15:02:53 -080035// static
36const char *const IStreamListener::kKeyMediaTimeUs = "media-time-us";
37
Chong Zhangd47dfcb2015-03-27 15:53:45 -070038// static
39const char *const IStreamListener::kKeyRecentMediaTimeUs = "recent-media-time-us";
40
Andreas Hubere2b10282010-11-23 11:41:34 -080041enum {
42 // IStreamSource
43 SET_LISTENER = IBinder::FIRST_CALL_TRANSACTION,
44 SET_BUFFERS,
45 ON_BUFFER_AVAILABLE,
Andreas Huber330accb2012-08-31 13:40:12 -070046 FLAGS,
Andreas Hubere2b10282010-11-23 11:41:34 -080047
48 // IStreamListener
49 QUEUE_BUFFER,
Andreas Huber14acc732010-12-06 10:36:06 -080050 ISSUE_COMMAND,
Andreas Hubere2b10282010-11-23 11:41:34 -080051};
52
53struct BpStreamSource : public BpInterface<IStreamSource> {
54 BpStreamSource(const sp<IBinder> &impl)
55 : BpInterface<IStreamSource>(impl) {
56 }
57
58 virtual void setListener(const sp<IStreamListener> &listener) {
59 Parcel data, reply;
60 data.writeInterfaceToken(IStreamSource::getInterfaceDescriptor());
Marco Nelissen06b46062014-11-14 07:58:25 -080061 data.writeStrongBinder(IInterface::asBinder(listener));
Andreas Hubere2b10282010-11-23 11:41:34 -080062 remote()->transact(SET_LISTENER, data, &reply);
63 }
64
65 virtual void setBuffers(const Vector<sp<IMemory> > &buffers) {
66 Parcel data, reply;
67 data.writeInterfaceToken(IStreamSource::getInterfaceDescriptor());
Glenn Kastene03dd222014-01-28 11:04:39 -080068 data.writeInt64(static_cast<int64_t>(buffers.size()));
Andreas Hubere2b10282010-11-23 11:41:34 -080069 for (size_t i = 0; i < buffers.size(); ++i) {
Marco Nelissen06b46062014-11-14 07:58:25 -080070 data.writeStrongBinder(IInterface::asBinder(buffers.itemAt(i)));
Andreas Hubere2b10282010-11-23 11:41:34 -080071 }
72 remote()->transact(SET_BUFFERS, data, &reply);
73 }
74
75 virtual void onBufferAvailable(size_t index) {
76 Parcel data, reply;
77 data.writeInterfaceToken(IStreamSource::getInterfaceDescriptor());
Glenn Kastene03dd222014-01-28 11:04:39 -080078 data.writeInt64(static_cast<int64_t>(index));
Andreas Hubere2b10282010-11-23 11:41:34 -080079 remote()->transact(
80 ON_BUFFER_AVAILABLE, data, &reply, IBinder::FLAG_ONEWAY);
81 }
Andreas Huber330accb2012-08-31 13:40:12 -070082
83 virtual uint32_t flags() const {
84 Parcel data, reply;
85 data.writeInterfaceToken(IStreamSource::getInterfaceDescriptor());
86 remote()->transact(FLAGS, data, &reply);
87
88 return reply.readInt32();
89 }
Andreas Hubere2b10282010-11-23 11:41:34 -080090};
91
92IMPLEMENT_META_INTERFACE(StreamSource, "android.hardware.IStreamSource");
93
94status_t BnStreamSource::onTransact(
95 uint32_t code, const Parcel &data, Parcel *reply, uint32_t flags) {
96 switch (code) {
97 case SET_LISTENER:
98 {
99 CHECK_INTERFACE(IStreamSource, data, reply);
100 setListener(
101 interface_cast<IStreamListener>(data.readStrongBinder()));
102 break;
103 }
104
105 case SET_BUFFERS:
106 {
107 CHECK_INTERFACE(IStreamSource, data, reply);
Glenn Kastene03dd222014-01-28 11:04:39 -0800108 size_t n = static_cast<size_t>(data.readInt64());
Andreas Hubere2b10282010-11-23 11:41:34 -0800109 Vector<sp<IMemory> > buffers;
110 for (size_t i = 0; i < n; ++i) {
111 sp<IMemory> mem =
112 interface_cast<IMemory>(data.readStrongBinder());
113
Wei Jia2afac0c2016-01-07 12:13:07 -0800114 if (mem != NULL) {
115 buffers.push(mem);
116 } else if (data.dataAvail() == 0) {
117 break;
118 }
Andreas Hubere2b10282010-11-23 11:41:34 -0800119 }
120 setBuffers(buffers);
121 break;
122 }
123
124 case ON_BUFFER_AVAILABLE:
125 {
126 CHECK_INTERFACE(IStreamSource, data, reply);
Glenn Kastene03dd222014-01-28 11:04:39 -0800127 onBufferAvailable(static_cast<size_t>(data.readInt64()));
Andreas Hubere2b10282010-11-23 11:41:34 -0800128 break;
129 }
130
Andreas Huber330accb2012-08-31 13:40:12 -0700131 case FLAGS:
132 {
133 CHECK_INTERFACE(IStreamSource, data, reply);
134 reply->writeInt32(this->flags());
135 break;
136 }
137
Andreas Hubere2b10282010-11-23 11:41:34 -0800138 default:
139 return BBinder::onTransact(code, data, reply, flags);
140 }
141
142 return OK;
143}
144
145////////////////////////////////////////////////////////////////////////////////
146
147struct BpStreamListener : public BpInterface<IStreamListener> {
148 BpStreamListener(const sp<IBinder> &impl)
149 : BpInterface<IStreamListener>(impl) {
150 }
151
152 virtual void queueBuffer(size_t index, size_t size) {
153 Parcel data, reply;
154 data.writeInterfaceToken(IStreamListener::getInterfaceDescriptor());
Glenn Kastene03dd222014-01-28 11:04:39 -0800155 data.writeInt64(static_cast<int64_t>(index));
156 data.writeInt64(static_cast<int64_t>(size));
Andreas Hubere2b10282010-11-23 11:41:34 -0800157
158 remote()->transact(QUEUE_BUFFER, data, &reply, IBinder::FLAG_ONEWAY);
159 }
160
Andreas Huber14acc732010-12-06 10:36:06 -0800161 virtual void issueCommand(
162 Command cmd, bool synchronous, const sp<AMessage> &msg) {
Andreas Hubere2b10282010-11-23 11:41:34 -0800163 Parcel data, reply;
164 data.writeInterfaceToken(IStreamListener::getInterfaceDescriptor());
165 data.writeInt32(static_cast<int32_t>(cmd));
Andreas Huber14acc732010-12-06 10:36:06 -0800166 data.writeInt32(static_cast<int32_t>(synchronous));
Andreas Hubere2b10282010-11-23 11:41:34 -0800167
Andreas Huber14acc732010-12-06 10:36:06 -0800168 if (msg != NULL) {
169 data.writeInt32(1);
170 msg->writeToParcel(&data);
171 } else {
172 data.writeInt32(0);
173 }
174
175 remote()->transact(ISSUE_COMMAND, data, &reply, IBinder::FLAG_ONEWAY);
Andreas Hubere2b10282010-11-23 11:41:34 -0800176 }
177};
178
179IMPLEMENT_META_INTERFACE(StreamListener, "android.hardware.IStreamListener");
180
181status_t BnStreamListener::onTransact(
182 uint32_t code, const Parcel &data, Parcel *reply, uint32_t flags) {
183 switch (code) {
184 case QUEUE_BUFFER:
185 {
186 CHECK_INTERFACE(IStreamListener, data, reply);
Glenn Kastene03dd222014-01-28 11:04:39 -0800187 size_t index = static_cast<size_t>(data.readInt64());
188 size_t size = static_cast<size_t>(data.readInt64());
Andreas Hubere2b10282010-11-23 11:41:34 -0800189
190 queueBuffer(index, size);
191 break;
192 }
193
Andreas Huber14acc732010-12-06 10:36:06 -0800194 case ISSUE_COMMAND:
Andreas Hubere2b10282010-11-23 11:41:34 -0800195 {
196 CHECK_INTERFACE(IStreamListener, data, reply);
197 Command cmd = static_cast<Command>(data.readInt32());
198
Andreas Huber14acc732010-12-06 10:36:06 -0800199 bool synchronous = static_cast<bool>(data.readInt32());
200
201 sp<AMessage> msg;
202
203 if (data.readInt32()) {
204 msg = AMessage::FromParcel(data);
205 }
206
207 issueCommand(cmd, synchronous, msg);
Andreas Hubere2b10282010-11-23 11:41:34 -0800208 break;
209 }
210
211 default:
212 return BBinder::onTransact(code, data, reply, flags);
213 }
214
215 return OK;
216}
217
218} // namespace android