blob: 9ea734b8e1fdd694bbc40d6756c652730406bc23 [file] [log] [blame]
Robert Shih0df451b2017-12-08 14:16:50 -08001/*
2 * Copyright (C) 2018 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 "NdkMediaDataSource"
19
20#include "NdkMediaDataSourcePriv.h"
21
22#include <inttypes.h>
23#include <jni.h>
24#include <unistd.h>
25
Robert Shih730af222018-09-14 14:02:57 -070026#include <android_runtime/AndroidRuntime.h>
27#include <android_util_Binder.h>
Robert Shih0df451b2017-12-08 14:16:50 -080028#include <binder/IServiceManager.h>
29#include <cutils/properties.h>
30#include <utils/Log.h>
31#include <utils/StrongPointer.h>
Robert Shih730af222018-09-14 14:02:57 -070032#include <media/IMediaHTTPService.h>
Robert Shih0df451b2017-12-08 14:16:50 -080033#include <media/NdkMediaError.h>
34#include <media/NdkMediaDataSource.h>
Robert Shih2568eb92018-09-19 10:00:46 -070035#include <media/stagefright/DataSourceFactory.h>
Robert Shih0df451b2017-12-08 14:16:50 -080036#include <media/stagefright/InterfaceUtils.h>
Robert Shih730af222018-09-14 14:02:57 -070037#include <mediaplayer2/JavaVMHelper.h>
38#include <mediaplayer2/JMedia2HTTPService.h>
Robert Shih0df451b2017-12-08 14:16:50 -080039
40#include "../../libstagefright/include/HTTPBase.h"
41#include "../../libstagefright/include/NuCachedSource2.h"
Robert Shih2568eb92018-09-19 10:00:46 -070042#include "NdkMediaDataSourceCallbacksPriv.h"
Robert Shih0df451b2017-12-08 14:16:50 -080043
44using namespace android;
45
46struct AMediaDataSource {
47 void *userdata;
48 AMediaDataSourceReadAt readAt;
49 AMediaDataSourceGetSize getSize;
Robert Shih45b88d22018-02-05 13:52:39 -080050 AMediaDataSourceClose close;
Robert Shih0df451b2017-12-08 14:16:50 -080051};
52
53NdkDataSource::NdkDataSource(AMediaDataSource *dataSource)
Robert Shihd4faf9e2018-01-21 17:52:25 -080054 : mDataSource(AMediaDataSource_new()) {
55 AMediaDataSource_setReadAt(mDataSource, dataSource->readAt);
56 AMediaDataSource_setGetSize(mDataSource, dataSource->getSize);
57 AMediaDataSource_setClose(mDataSource, dataSource->close);
58 AMediaDataSource_setUserdata(mDataSource, dataSource->userdata);
59}
60
61NdkDataSource::~NdkDataSource() {
62 AMediaDataSource_delete(mDataSource);
Robert Shih0df451b2017-12-08 14:16:50 -080063}
64
65status_t NdkDataSource::initCheck() const {
66 return OK;
67}
68
69ssize_t NdkDataSource::readAt(off64_t offset, void *data, size_t size) {
70 Mutex::Autolock l(mLock);
71 if (mDataSource->getSize == NULL || mDataSource->userdata == NULL) {
72 return -1;
73 }
74 return mDataSource->readAt(mDataSource->userdata, offset, data, size);
75}
76
77status_t NdkDataSource::getSize(off64_t *size) {
78 Mutex::Autolock l(mLock);
79 if (mDataSource->getSize == NULL || mDataSource->userdata == NULL) {
80 return NO_INIT;
81 }
82 if (size != NULL) {
83 *size = mDataSource->getSize(mDataSource->userdata);
84 }
85 return OK;
86}
87
88String8 NdkDataSource::toString() {
89 return String8::format("NdkDataSource(pid %d, uid %d)", getpid(), getuid());
90}
91
92String8 NdkDataSource::getMIMEType() const {
93 return String8("application/octet-stream");
94}
95
Robert Shih45b88d22018-02-05 13:52:39 -080096void NdkDataSource::close() {
97 if (mDataSource->close != NULL && mDataSource->userdata != NULL) {
98 mDataSource->close(mDataSource->userdata);
99 }
100}
101
Robert Shih730af222018-09-14 14:02:57 -0700102static sp<MediaHTTPService> createMediaHttpServiceFromJavaObj(JNIEnv *env, jobject obj, int version) {
103 if (obj == NULL) {
104 return NULL;
105 }
106 switch (version) {
107 case 1:
108 return interface_cast<IMediaHTTPService>(ibinderForJavaObject(env, obj));
109 case 2:
110 return new JMedia2HTTPService(env, obj);
111 default:
112 return NULL;
113 }
114}
115
116static sp<MediaHTTPService> createMediaHttpServiceTemplate(
117 JNIEnv *env,
118 const char *uri,
119 const char *clazz,
120 const char *method,
121 const char *signature,
122 int version) {
123 jobject service = NULL;
124 if (env == NULL) {
125 ALOGE("http service must be created from Java thread");
126 return NULL;
127 }
128
129 jclass mediahttpclass = env->FindClass(clazz);
130 if (mediahttpclass == NULL) {
131 ALOGE("can't find Media(2)HttpService");
132 env->ExceptionClear();
133 return NULL;
134 }
135
136 jmethodID mediaHttpCreateMethod = env->GetStaticMethodID(mediahttpclass, method, signature);
137 if (mediaHttpCreateMethod == NULL) {
138 ALOGE("can't find method");
139 env->ExceptionClear();
140 return NULL;
141 }
142
143 jstring juri = env->NewStringUTF(uri);
144
145 service = env->CallStaticObjectMethod(mediahttpclass, mediaHttpCreateMethod, juri);
146 env->DeleteLocalRef(juri);
147
148 env->ExceptionClear();
149 sp<MediaHTTPService> httpService = createMediaHttpServiceFromJavaObj(env, service, version);
150 return httpService;
151
152}
153
154sp<MediaHTTPService> createMediaHttpService(const char *uri, int version) {
155
156 JNIEnv *env;
157 const char *clazz, *method, *signature;
158
159 switch (version) {
160 case 1:
161 env = AndroidRuntime::getJNIEnv();
162 clazz = "android/media/MediaHTTPService";
163 method = "createHttpServiceBinderIfNecessary";
164 signature = "(Ljava/lang/String;)Landroid/os/IBinder;";
165 break;
166 case 2:
167 env = JavaVMHelper::getJNIEnv();
168 clazz = "android/media/Media2HTTPService";
169 method = "createHTTPService";
170 signature = "(Ljava/lang/String;)Landroid/media/Media2HTTPService;";
171 break;
172 default:
173 return NULL;
174 }
175
176 return createMediaHttpServiceTemplate(env, uri, clazz, method, signature, version);
177
178}
179
Robert Shih0df451b2017-12-08 14:16:50 -0800180extern "C" {
181
182EXPORT
183AMediaDataSource* AMediaDataSource_new() {
184 AMediaDataSource *mSource = new AMediaDataSource();
185 mSource->userdata = NULL;
186 mSource->readAt = NULL;
187 mSource->getSize = NULL;
Robert Shih45b88d22018-02-05 13:52:39 -0800188 mSource->close = NULL;
Robert Shih0df451b2017-12-08 14:16:50 -0800189 return mSource;
190}
191
192EXPORT
Robert Shih2568eb92018-09-19 10:00:46 -0700193AMediaDataSource* AMediaDataSource_newUri(
194 const char *uri,
195 int numheaders,
196 const char * const *key_values) {
197
198 sp<MediaHTTPService> service = createMediaHttpService(uri, /* version = */ 1);
199 KeyedVector<String8, String8> headers;
200 for (int i = 0; i < numheaders; ++i) {
201 String8 key8(key_values[i * 2]);
202 String8 value8(key_values[i * 2 + 1]);
203 headers.add(key8, value8);
204 }
205
206 sp<DataSource> source = DataSourceFactory::CreateFromURI(service, uri, &headers);
207 return convertDataSourceToAMediaDataSource(source);
208}
209
210EXPORT
Robert Shih0df451b2017-12-08 14:16:50 -0800211void AMediaDataSource_delete(AMediaDataSource *mSource) {
212 ALOGV("dtor");
213 if (mSource != NULL) {
214 delete mSource;
215 }
216}
217
218EXPORT
219void AMediaDataSource_setUserdata(AMediaDataSource *mSource, void *userdata) {
220 mSource->userdata = userdata;
221}
222
223EXPORT
224void AMediaDataSource_setReadAt(AMediaDataSource *mSource, AMediaDataSourceReadAt readAt) {
225 mSource->readAt = readAt;
226}
227
228EXPORT
229void AMediaDataSource_setGetSize(AMediaDataSource *mSource, AMediaDataSourceGetSize getSize) {
230 mSource->getSize = getSize;
231}
232
Robert Shih45b88d22018-02-05 13:52:39 -0800233EXPORT
234void AMediaDataSource_setClose(AMediaDataSource *mSource, AMediaDataSourceClose close) {
235 mSource->close = close;
236}
237
Robert Shih0df451b2017-12-08 14:16:50 -0800238} // extern "C"
239