blob: e4b717bbf9170c16542787add90a17fde4e52af4 [file] [log] [blame]
Andreas Huber1b86fe02014-01-29 11:13:26 -08001/*
2 * Copyright (C) 2013 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 "IMediaHTTPConnection"
19#include <utils/Log.h>
20
21#include <media/IMediaHTTPConnection.h>
22
23#include <binder/IMemory.h>
24#include <binder/Parcel.h>
25#include <utils/String8.h>
26#include <media/stagefright/foundation/ADebug.h>
Marco Nelissen59cea262015-04-20 11:08:59 -070027#include <media/stagefright/MediaErrors.h>
Andreas Huber1b86fe02014-01-29 11:13:26 -080028
29namespace android {
30
31enum {
32 CONNECT = IBinder::FIRST_CALL_TRANSACTION,
33 DISCONNECT,
34 READ_AT,
35 GET_SIZE,
36 GET_MIME_TYPE,
Marco Nelissenc9c7e252014-02-21 12:01:23 -080037 GET_URI
Andreas Huber1b86fe02014-01-29 11:13:26 -080038};
39
40struct BpMediaHTTPConnection : public BpInterface<IMediaHTTPConnection> {
Chih-Hung Hsieh090ef602016-04-27 10:39:54 -070041 explicit BpMediaHTTPConnection(const sp<IBinder> &impl)
Andreas Huber1b86fe02014-01-29 11:13:26 -080042 : BpInterface<IMediaHTTPConnection>(impl) {
43 }
44
45 virtual bool connect(
46 const char *uri, const KeyedVector<String8, String8> *headers) {
47 Parcel data, reply;
48 data.writeInterfaceToken(
49 IMediaHTTPConnection::getInterfaceDescriptor());
50
51 String16 tmp(uri);
52 data.writeString16(tmp);
53
54 tmp = String16("");
55 if (headers != NULL) {
56 for (size_t i = 0; i < headers->size(); ++i) {
57 String16 key(headers->keyAt(i).string());
58 String16 val(headers->valueAt(i).string());
59
60 tmp.append(key);
61 tmp.append(String16(": "));
62 tmp.append(val);
63 tmp.append(String16("\r\n"));
64 }
65 }
66 data.writeString16(tmp);
67
68 remote()->transact(CONNECT, data, &reply);
69
70 int32_t exceptionCode = reply.readExceptionCode();
71
72 if (exceptionCode) {
Marco Nelissen8cecf012015-06-11 14:08:44 -070073 return false;
Andreas Huber1b86fe02014-01-29 11:13:26 -080074 }
75
76 sp<IBinder> binder = reply.readStrongBinder();
77 mMemory = interface_cast<IMemory>(binder);
78
79 return mMemory != NULL;
80 }
81
82 virtual void disconnect() {
83 Parcel data, reply;
84 data.writeInterfaceToken(
85 IMediaHTTPConnection::getInterfaceDescriptor());
86
87 remote()->transact(DISCONNECT, data, &reply);
88 }
89
90 virtual ssize_t readAt(off64_t offset, void *buffer, size_t size) {
91 Parcel data, reply;
92 data.writeInterfaceToken(
93 IMediaHTTPConnection::getInterfaceDescriptor());
94
95 data.writeInt64(offset);
96 data.writeInt32(size);
97
98 status_t err = remote()->transact(READ_AT, data, &reply);
Marco Nelissen19a9fef2014-02-27 13:20:07 -080099 if (err != OK) {
100 ALOGE("remote readAt failed");
101 return UNKNOWN_ERROR;
102 }
Andreas Huber1b86fe02014-01-29 11:13:26 -0800103
104 int32_t exceptionCode = reply.readExceptionCode();
105
106 if (exceptionCode) {
107 return UNKNOWN_ERROR;
108 }
109
Alex Klyubin61c83312015-06-18 12:39:44 -0700110 int32_t lenOrErrorCode = reply.readInt32();
111
112 // Negative values are error codes
113 if (lenOrErrorCode < 0) {
114 return lenOrErrorCode;
115 }
116
117 size_t len = lenOrErrorCode;
Andreas Huber1b86fe02014-01-29 11:13:26 -0800118
Marco Nelissen59cea262015-04-20 11:08:59 -0700119 if (len > size) {
120 ALOGE("requested %zu, got %zu", size, len);
121 return ERROR_OUT_OF_RANGE;
Andreas Huber1b86fe02014-01-29 11:13:26 -0800122 }
Marco Nelissen59cea262015-04-20 11:08:59 -0700123 if (len > mMemory->size()) {
124 ALOGE("got %zu, but memory has %zu", len, mMemory->size());
125 return ERROR_OUT_OF_RANGE;
126 }
127
128 memcpy(buffer, mMemory->pointer(), len);
Andreas Huber1b86fe02014-01-29 11:13:26 -0800129
130 return len;
131 }
132
133 virtual off64_t getSize() {
134 Parcel data, reply;
135 data.writeInterfaceToken(
136 IMediaHTTPConnection::getInterfaceDescriptor());
137
138 remote()->transact(GET_SIZE, data, &reply);
139
140 int32_t exceptionCode = reply.readExceptionCode();
141
142 if (exceptionCode) {
143 return UNKNOWN_ERROR;
144 }
145
146 return reply.readInt64();
147 }
148
149 virtual status_t getMIMEType(String8 *mimeType) {
150 *mimeType = String8("");
151
152 Parcel data, reply;
153 data.writeInterfaceToken(
154 IMediaHTTPConnection::getInterfaceDescriptor());
155
156 remote()->transact(GET_MIME_TYPE, data, &reply);
157
158 int32_t exceptionCode = reply.readExceptionCode();
159
160 if (exceptionCode) {
161 return UNKNOWN_ERROR;
162 }
163
164 *mimeType = String8(reply.readString16());
165
166 return OK;
167 }
168
Marco Nelissenc9c7e252014-02-21 12:01:23 -0800169 virtual status_t getUri(String8 *uri) {
170 *uri = String8("");
171
172 Parcel data, reply;
173 data.writeInterfaceToken(
174 IMediaHTTPConnection::getInterfaceDescriptor());
175
176 remote()->transact(GET_URI, data, &reply);
177
178 int32_t exceptionCode = reply.readExceptionCode();
179
180 if (exceptionCode) {
181 return UNKNOWN_ERROR;
182 }
183
184 *uri = String8(reply.readString16());
185
186 return OK;
187 }
188
Andreas Huber1b86fe02014-01-29 11:13:26 -0800189private:
190 sp<IMemory> mMemory;
191};
192
193IMPLEMENT_META_INTERFACE(
194 MediaHTTPConnection, "android.media.IMediaHTTPConnection");
195
Glenn Kastend2027332015-03-20 08:59:18 -0700196} // namespace android