Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 1 | /* |
| 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_TAG "CameraDeviceClient" |
| 18 | #define ATRACE_TAG ATRACE_TAG_CAMERA |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 19 | //#define LOG_NDEBUG 0 |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 20 | |
Eino-Ville Talvala | 7b82efe | 2013-07-25 17:12:35 -0700 | [diff] [blame] | 21 | #include <cutils/properties.h> |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 22 | #include <utils/Log.h> |
| 23 | #include <utils/Trace.h> |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 24 | #include <gui/Surface.h> |
Eino-Ville Talvala | 7b82efe | 2013-07-25 17:12:35 -0700 | [diff] [blame] | 25 | #include <camera/camera2/CaptureRequest.h> |
Ruben Brunk | 5698d44 | 2014-06-18 10:39:40 -0700 | [diff] [blame] | 26 | #include <camera/CameraUtils.h> |
Eino-Ville Talvala | 7b82efe | 2013-07-25 17:12:35 -0700 | [diff] [blame] | 27 | |
| 28 | #include "common/CameraDeviceBase.h" |
| 29 | #include "api2/CameraDeviceClient.h" |
| 30 | |
| 31 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 32 | |
| 33 | namespace android { |
| 34 | using namespace camera2; |
| 35 | |
| 36 | CameraDeviceClientBase::CameraDeviceClientBase( |
| 37 | const sp<CameraService>& cameraService, |
| 38 | const sp<ICameraDeviceCallbacks>& remoteCallback, |
| 39 | const String16& clientPackageName, |
| 40 | int cameraId, |
| 41 | int cameraFacing, |
| 42 | int clientPid, |
| 43 | uid_t clientUid, |
| 44 | int servicePid) : |
Eino-Ville Talvala | e992e75 | 2014-11-07 16:17:48 -0800 | [diff] [blame] | 45 | BasicClient(cameraService, |
Marco Nelissen | f888020 | 2014-11-14 07:58:25 -0800 | [diff] [blame] | 46 | IInterface::asBinder(remoteCallback), |
Eino-Ville Talvala | e992e75 | 2014-11-07 16:17:48 -0800 | [diff] [blame] | 47 | clientPackageName, |
| 48 | cameraId, |
| 49 | cameraFacing, |
| 50 | clientPid, |
| 51 | clientUid, |
| 52 | servicePid), |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 53 | mRemoteCallback(remoteCallback) { |
| 54 | } |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 55 | |
| 56 | // Interface used by CameraService |
| 57 | |
| 58 | CameraDeviceClient::CameraDeviceClient(const sp<CameraService>& cameraService, |
| 59 | const sp<ICameraDeviceCallbacks>& remoteCallback, |
| 60 | const String16& clientPackageName, |
| 61 | int cameraId, |
| 62 | int cameraFacing, |
| 63 | int clientPid, |
| 64 | uid_t clientUid, |
| 65 | int servicePid) : |
| 66 | Camera2ClientBase(cameraService, remoteCallback, clientPackageName, |
| 67 | cameraId, cameraFacing, clientPid, clientUid, servicePid), |
| 68 | mRequestIdCounter(0) { |
| 69 | |
| 70 | ATRACE_CALL(); |
| 71 | ALOGI("CameraDeviceClient %d: Opened", cameraId); |
| 72 | } |
| 73 | |
Yin-Chia Yeh | e074a93 | 2015-01-30 10:29:02 -0800 | [diff] [blame] | 74 | status_t CameraDeviceClient::initialize(CameraModule *module) |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 75 | { |
| 76 | ATRACE_CALL(); |
| 77 | status_t res; |
| 78 | |
| 79 | res = Camera2ClientBase::initialize(module); |
| 80 | if (res != OK) { |
| 81 | return res; |
| 82 | } |
| 83 | |
| 84 | String8 threadName; |
Eino-Ville Talvala | 7b82efe | 2013-07-25 17:12:35 -0700 | [diff] [blame] | 85 | mFrameProcessor = new FrameProcessorBase(mDevice); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 86 | threadName = String8::format("CDU-%d-FrameProc", mCameraId); |
| 87 | mFrameProcessor->run(threadName.string()); |
| 88 | |
| 89 | mFrameProcessor->registerListener(FRAME_PROCESSOR_LISTENER_MIN_ID, |
| 90 | FRAME_PROCESSOR_LISTENER_MAX_ID, |
Eino-Ville Talvala | 184dfe4 | 2013-11-07 15:13:16 -0800 | [diff] [blame] | 91 | /*listener*/this, |
Zhijun He | 25a0aef | 2014-06-25 11:40:02 -0700 | [diff] [blame] | 92 | /*sendPartials*/true); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 93 | |
| 94 | return OK; |
| 95 | } |
| 96 | |
| 97 | CameraDeviceClient::~CameraDeviceClient() { |
| 98 | } |
| 99 | |
| 100 | status_t CameraDeviceClient::submitRequest(sp<CaptureRequest> request, |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 101 | bool streaming, |
| 102 | /*out*/ |
| 103 | int64_t* lastFrameNumber) { |
| 104 | List<sp<CaptureRequest> > requestList; |
| 105 | requestList.push_back(request); |
| 106 | return submitRequestList(requestList, streaming, lastFrameNumber); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 107 | } |
| 108 | |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 109 | status_t CameraDeviceClient::submitRequestList(List<sp<CaptureRequest> > requests, |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 110 | bool streaming, int64_t* lastFrameNumber) { |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 111 | ATRACE_CALL(); |
Mark Salyzyn | 5046841 | 2014-06-18 16:33:43 -0700 | [diff] [blame] | 112 | ALOGV("%s-start of function. Request list size %zu", __FUNCTION__, requests.size()); |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 113 | |
| 114 | status_t res; |
| 115 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 116 | |
| 117 | Mutex::Autolock icl(mBinderSerializationLock); |
| 118 | |
| 119 | if (!mDevice.get()) return DEAD_OBJECT; |
| 120 | |
| 121 | if (requests.empty()) { |
| 122 | ALOGE("%s: Camera %d: Sent null request. Rejecting request.", |
| 123 | __FUNCTION__, mCameraId); |
| 124 | return BAD_VALUE; |
| 125 | } |
| 126 | |
| 127 | List<const CameraMetadata> metadataRequestList; |
| 128 | int32_t requestId = mRequestIdCounter; |
| 129 | uint32_t loopCounter = 0; |
| 130 | |
| 131 | for (List<sp<CaptureRequest> >::iterator it = requests.begin(); it != requests.end(); ++it) { |
| 132 | sp<CaptureRequest> request = *it; |
| 133 | if (request == 0) { |
| 134 | ALOGE("%s: Camera %d: Sent null request.", |
| 135 | __FUNCTION__, mCameraId); |
| 136 | return BAD_VALUE; |
| 137 | } |
| 138 | |
| 139 | CameraMetadata metadata(request->mMetadata); |
| 140 | if (metadata.isEmpty()) { |
| 141 | ALOGE("%s: Camera %d: Sent empty metadata packet. Rejecting request.", |
| 142 | __FUNCTION__, mCameraId); |
| 143 | return BAD_VALUE; |
| 144 | } else if (request->mSurfaceList.isEmpty()) { |
| 145 | ALOGE("%s: Camera %d: Requests must have at least one surface target. " |
| 146 | "Rejecting request.", __FUNCTION__, mCameraId); |
| 147 | return BAD_VALUE; |
| 148 | } |
| 149 | |
| 150 | if (!enforceRequestPermissions(metadata)) { |
| 151 | // Callee logs |
| 152 | return PERMISSION_DENIED; |
| 153 | } |
| 154 | |
| 155 | /** |
| 156 | * Write in the output stream IDs which we calculate from |
| 157 | * the capture request's list of surface targets |
| 158 | */ |
| 159 | Vector<int32_t> outputStreamIds; |
| 160 | outputStreamIds.setCapacity(request->mSurfaceList.size()); |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 161 | for (size_t i = 0; i < request->mSurfaceList.size(); ++i) { |
| 162 | sp<Surface> surface = request->mSurfaceList[i]; |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 163 | if (surface == 0) continue; |
| 164 | |
| 165 | sp<IGraphicBufferProducer> gbp = surface->getIGraphicBufferProducer(); |
Marco Nelissen | f888020 | 2014-11-14 07:58:25 -0800 | [diff] [blame] | 166 | int idx = mStreamMap.indexOfKey(IInterface::asBinder(gbp)); |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 167 | |
| 168 | // Trying to submit request with surface that wasn't created |
| 169 | if (idx == NAME_NOT_FOUND) { |
| 170 | ALOGE("%s: Camera %d: Tried to submit a request with a surface that" |
| 171 | " we have not called createStream on", |
| 172 | __FUNCTION__, mCameraId); |
| 173 | return BAD_VALUE; |
| 174 | } |
| 175 | |
| 176 | int streamId = mStreamMap.valueAt(idx); |
| 177 | outputStreamIds.push_back(streamId); |
| 178 | ALOGV("%s: Camera %d: Appending output stream %d to request", |
| 179 | __FUNCTION__, mCameraId, streamId); |
| 180 | } |
| 181 | |
| 182 | metadata.update(ANDROID_REQUEST_OUTPUT_STREAMS, &outputStreamIds[0], |
| 183 | outputStreamIds.size()); |
| 184 | |
| 185 | metadata.update(ANDROID_REQUEST_ID, &requestId, /*size*/1); |
| 186 | loopCounter++; // loopCounter starts from 1 |
Mark Salyzyn | 5046841 | 2014-06-18 16:33:43 -0700 | [diff] [blame] | 187 | ALOGV("%s: Camera %d: Creating request with ID %d (%d of %zu)", |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 188 | __FUNCTION__, mCameraId, requestId, loopCounter, requests.size()); |
| 189 | |
| 190 | metadataRequestList.push_back(metadata); |
| 191 | } |
| 192 | mRequestIdCounter++; |
| 193 | |
| 194 | if (streaming) { |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 195 | res = mDevice->setStreamingRequestList(metadataRequestList, lastFrameNumber); |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 196 | if (res != OK) { |
| 197 | ALOGE("%s: Camera %d: Got error %d after trying to set streaming " |
| 198 | "request", __FUNCTION__, mCameraId, res); |
| 199 | } else { |
| 200 | mStreamingRequestList.push_back(requestId); |
| 201 | } |
| 202 | } else { |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 203 | res = mDevice->captureList(metadataRequestList, lastFrameNumber); |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 204 | if (res != OK) { |
| 205 | ALOGE("%s: Camera %d: Got error %d after trying to set capture", |
| 206 | __FUNCTION__, mCameraId, res); |
| 207 | } |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 208 | ALOGV("%s: requestId = %d ", __FUNCTION__, requestId); |
Jianing Wei | 90e59c9 | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 209 | } |
| 210 | |
| 211 | ALOGV("%s: Camera %d: End of function", __FUNCTION__, mCameraId); |
| 212 | if (res == OK) { |
| 213 | return requestId; |
| 214 | } |
| 215 | |
| 216 | return res; |
| 217 | } |
| 218 | |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 219 | status_t CameraDeviceClient::cancelRequest(int requestId, int64_t* lastFrameNumber) { |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 220 | ATRACE_CALL(); |
| 221 | ALOGV("%s, requestId = %d", __FUNCTION__, requestId); |
| 222 | |
| 223 | status_t res; |
| 224 | |
| 225 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 226 | |
| 227 | Mutex::Autolock icl(mBinderSerializationLock); |
| 228 | |
| 229 | if (!mDevice.get()) return DEAD_OBJECT; |
| 230 | |
| 231 | Vector<int>::iterator it, end; |
| 232 | for (it = mStreamingRequestList.begin(), end = mStreamingRequestList.end(); |
| 233 | it != end; ++it) { |
| 234 | if (*it == requestId) { |
| 235 | break; |
| 236 | } |
| 237 | } |
| 238 | |
| 239 | if (it == end) { |
| 240 | ALOGE("%s: Camera%d: Did not find request id %d in list of streaming " |
| 241 | "requests", __FUNCTION__, mCameraId, requestId); |
| 242 | return BAD_VALUE; |
| 243 | } |
| 244 | |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 245 | res = mDevice->clearStreamingRequest(lastFrameNumber); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 246 | |
| 247 | if (res == OK) { |
| 248 | ALOGV("%s: Camera %d: Successfully cleared streaming request", |
| 249 | __FUNCTION__, mCameraId); |
| 250 | mStreamingRequestList.erase(it); |
| 251 | } |
| 252 | |
| 253 | return res; |
| 254 | } |
| 255 | |
Ruben Brunk | b2119af | 2014-05-09 19:57:56 -0700 | [diff] [blame] | 256 | status_t CameraDeviceClient::beginConfigure() { |
| 257 | // TODO: Implement this. |
| 258 | ALOGE("%s: Not implemented yet.", __FUNCTION__); |
| 259 | return OK; |
| 260 | } |
| 261 | |
| 262 | status_t CameraDeviceClient::endConfigure() { |
Igor Murashkin | e2d167e | 2014-08-19 16:19:59 -0700 | [diff] [blame] | 263 | ALOGV("%s: ending configure (%zu streams)", |
| 264 | __FUNCTION__, mStreamMap.size()); |
| 265 | |
| 266 | status_t res; |
| 267 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 268 | |
| 269 | Mutex::Autolock icl(mBinderSerializationLock); |
| 270 | |
| 271 | if (!mDevice.get()) return DEAD_OBJECT; |
| 272 | |
| 273 | return mDevice->configureStreams(); |
Ruben Brunk | b2119af | 2014-05-09 19:57:56 -0700 | [diff] [blame] | 274 | } |
| 275 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 276 | status_t CameraDeviceClient::deleteStream(int streamId) { |
| 277 | ATRACE_CALL(); |
| 278 | ALOGV("%s (streamId = 0x%x)", __FUNCTION__, streamId); |
| 279 | |
| 280 | status_t res; |
| 281 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 282 | |
| 283 | Mutex::Autolock icl(mBinderSerializationLock); |
| 284 | |
| 285 | if (!mDevice.get()) return DEAD_OBJECT; |
| 286 | |
| 287 | // Guard against trying to delete non-created streams |
| 288 | ssize_t index = NAME_NOT_FOUND; |
| 289 | for (size_t i = 0; i < mStreamMap.size(); ++i) { |
| 290 | if (streamId == mStreamMap.valueAt(i)) { |
| 291 | index = i; |
| 292 | break; |
| 293 | } |
| 294 | } |
| 295 | |
| 296 | if (index == NAME_NOT_FOUND) { |
| 297 | ALOGW("%s: Camera %d: Invalid stream ID (%d) specified, no stream " |
| 298 | "created yet", __FUNCTION__, mCameraId, streamId); |
| 299 | return BAD_VALUE; |
| 300 | } |
| 301 | |
| 302 | // Also returns BAD_VALUE if stream ID was not valid |
| 303 | res = mDevice->deleteStream(streamId); |
| 304 | |
| 305 | if (res == BAD_VALUE) { |
| 306 | ALOGE("%s: Camera %d: Unexpected BAD_VALUE when deleting stream, but we" |
| 307 | " already checked and the stream ID (%d) should be valid.", |
| 308 | __FUNCTION__, mCameraId, streamId); |
| 309 | } else if (res == OK) { |
| 310 | mStreamMap.removeItemsAt(index); |
| 311 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 312 | } |
| 313 | |
| 314 | return res; |
| 315 | } |
| 316 | |
| 317 | status_t CameraDeviceClient::createStream(int width, int height, int format, |
| 318 | const sp<IGraphicBufferProducer>& bufferProducer) |
| 319 | { |
| 320 | ATRACE_CALL(); |
| 321 | ALOGV("%s (w = %d, h = %d, f = 0x%x)", __FUNCTION__, width, height, format); |
| 322 | |
| 323 | status_t res; |
| 324 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 325 | |
| 326 | Mutex::Autolock icl(mBinderSerializationLock); |
| 327 | |
Yin-Chia Yeh | 89f14da | 2014-06-10 16:05:44 -0700 | [diff] [blame] | 328 | if (bufferProducer == NULL) { |
| 329 | ALOGE("%s: bufferProducer must not be null", __FUNCTION__); |
| 330 | return BAD_VALUE; |
| 331 | } |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 332 | if (!mDevice.get()) return DEAD_OBJECT; |
| 333 | |
| 334 | // Don't create multiple streams for the same target surface |
| 335 | { |
Marco Nelissen | f888020 | 2014-11-14 07:58:25 -0800 | [diff] [blame] | 336 | ssize_t index = mStreamMap.indexOfKey(IInterface::asBinder(bufferProducer)); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 337 | if (index != NAME_NOT_FOUND) { |
| 338 | ALOGW("%s: Camera %d: Buffer producer already has a stream for it " |
Colin Cross | e5729fa | 2014-03-21 15:04:25 -0700 | [diff] [blame] | 339 | "(ID %zd)", |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 340 | __FUNCTION__, mCameraId, index); |
| 341 | return ALREADY_EXISTS; |
| 342 | } |
| 343 | } |
| 344 | |
Eino-Ville Talvala | 1da3b60 | 2013-09-26 15:28:55 -0700 | [diff] [blame] | 345 | // HACK b/10949105 |
| 346 | // Query consumer usage bits to set async operation mode for |
| 347 | // GLConsumer using controlledByApp parameter. |
| 348 | bool useAsync = false; |
| 349 | int32_t consumerUsage; |
| 350 | if ((res = bufferProducer->query(NATIVE_WINDOW_CONSUMER_USAGE_BITS, |
| 351 | &consumerUsage)) != OK) { |
| 352 | ALOGE("%s: Camera %d: Failed to query consumer usage", __FUNCTION__, |
| 353 | mCameraId); |
| 354 | return res; |
| 355 | } |
| 356 | if (consumerUsage & GraphicBuffer::USAGE_HW_TEXTURE) { |
| 357 | ALOGW("%s: Camera %d: Forcing asynchronous mode for stream", |
| 358 | __FUNCTION__, mCameraId); |
| 359 | useAsync = true; |
| 360 | } |
| 361 | |
Ruben Brunk | bba7557 | 2014-11-20 17:29:50 -0800 | [diff] [blame] | 362 | int32_t disallowedFlags = GraphicBuffer::USAGE_HW_VIDEO_ENCODER | |
| 363 | GRALLOC_USAGE_RENDERSCRIPT; |
| 364 | int32_t allowedFlags = GraphicBuffer::USAGE_SW_READ_MASK | |
| 365 | GraphicBuffer::USAGE_HW_TEXTURE | |
| 366 | GraphicBuffer::USAGE_HW_COMPOSER; |
| 367 | bool flexibleConsumer = (consumerUsage & disallowedFlags) == 0 && |
| 368 | (consumerUsage & allowedFlags) != 0; |
| 369 | |
Marco Nelissen | f888020 | 2014-11-14 07:58:25 -0800 | [diff] [blame] | 370 | sp<IBinder> binder = IInterface::asBinder(bufferProducer); |
Eino-Ville Talvala | e992e75 | 2014-11-07 16:17:48 -0800 | [diff] [blame] | 371 | sp<ANativeWindow> anw = new Surface(bufferProducer, useAsync); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 372 | |
| 373 | // TODO: remove w,h,f since we are ignoring them |
| 374 | |
| 375 | if ((res = anw->query(anw.get(), NATIVE_WINDOW_WIDTH, &width)) != OK) { |
| 376 | ALOGE("%s: Camera %d: Failed to query Surface width", __FUNCTION__, |
| 377 | mCameraId); |
| 378 | return res; |
| 379 | } |
| 380 | if ((res = anw->query(anw.get(), NATIVE_WINDOW_HEIGHT, &height)) != OK) { |
| 381 | ALOGE("%s: Camera %d: Failed to query Surface height", __FUNCTION__, |
| 382 | mCameraId); |
| 383 | return res; |
| 384 | } |
| 385 | if ((res = anw->query(anw.get(), NATIVE_WINDOW_FORMAT, &format)) != OK) { |
| 386 | ALOGE("%s: Camera %d: Failed to query Surface format", __FUNCTION__, |
| 387 | mCameraId); |
| 388 | return res; |
| 389 | } |
| 390 | |
| 391 | // FIXME: remove this override since the default format should be |
| 392 | // IMPLEMENTATION_DEFINED. b/9487482 |
Igor Murashkin | 1581101 | 2013-07-29 12:25:59 -0700 | [diff] [blame] | 393 | if (format >= HAL_PIXEL_FORMAT_RGBA_8888 && |
| 394 | format <= HAL_PIXEL_FORMAT_BGRA_8888) { |
Ruben Brunk | bba7557 | 2014-11-20 17:29:50 -0800 | [diff] [blame] | 395 | ALOGW("%s: Camera %d: Overriding format %#x to IMPLEMENTATION_DEFINED", |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 396 | __FUNCTION__, mCameraId, format); |
| 397 | format = HAL_PIXEL_FORMAT_IMPLEMENTATION_DEFINED; |
| 398 | } |
| 399 | |
Ruben Brunk | bba7557 | 2014-11-20 17:29:50 -0800 | [diff] [blame] | 400 | // Round dimensions to the nearest dimensions available for this format |
| 401 | if (flexibleConsumer && !CameraDeviceClient::roundBufferDimensionNearest(width, height, |
| 402 | format, mDevice->info(), /*out*/&width, /*out*/&height)) { |
| 403 | ALOGE("%s: No stream configurations with the format %#x defined, failed to create stream.", |
| 404 | __FUNCTION__, format); |
| 405 | return BAD_VALUE; |
| 406 | } |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 407 | |
| 408 | int streamId = -1; |
Zhijun He | 28c9b6f | 2014-08-08 12:00:47 -0700 | [diff] [blame] | 409 | res = mDevice->createStream(anw, width, height, format, &streamId); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 410 | |
| 411 | if (res == OK) { |
Eino-Ville Talvala | e992e75 | 2014-11-07 16:17:48 -0800 | [diff] [blame] | 412 | mStreamMap.add(binder, streamId); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 413 | |
| 414 | ALOGV("%s: Camera %d: Successfully created a new stream ID %d", |
| 415 | __FUNCTION__, mCameraId, streamId); |
Igor Murashkin | f8b2a6f | 2013-09-17 17:03:28 -0700 | [diff] [blame] | 416 | |
| 417 | /** |
| 418 | * Set the stream transform flags to automatically |
| 419 | * rotate the camera stream for preview use cases. |
| 420 | */ |
| 421 | int32_t transform = 0; |
| 422 | res = getRotationTransformLocked(&transform); |
| 423 | |
| 424 | if (res != OK) { |
| 425 | // Error logged by getRotationTransformLocked. |
| 426 | return res; |
| 427 | } |
| 428 | |
| 429 | res = mDevice->setStreamTransform(streamId, transform); |
| 430 | if (res != OK) { |
| 431 | ALOGE("%s: Failed to set stream transform (stream id %d)", |
| 432 | __FUNCTION__, streamId); |
| 433 | return res; |
| 434 | } |
| 435 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 436 | return streamId; |
| 437 | } |
| 438 | |
| 439 | return res; |
| 440 | } |
| 441 | |
Ruben Brunk | bba7557 | 2014-11-20 17:29:50 -0800 | [diff] [blame] | 442 | |
| 443 | bool CameraDeviceClient::roundBufferDimensionNearest(int32_t width, int32_t height, |
| 444 | int32_t format, const CameraMetadata& info, |
| 445 | /*out*/int32_t* outWidth, /*out*/int32_t* outHeight) { |
| 446 | |
| 447 | camera_metadata_ro_entry streamConfigs = |
| 448 | info.find(ANDROID_SCALER_AVAILABLE_STREAM_CONFIGURATIONS); |
| 449 | |
| 450 | int32_t bestWidth = -1; |
| 451 | int32_t bestHeight = -1; |
| 452 | |
| 453 | // Iterate through listed stream configurations and find the one with the smallest euclidean |
| 454 | // distance from the given dimensions for the given format. |
| 455 | for (size_t i = 0; i < streamConfigs.count; i += 4) { |
| 456 | int32_t fmt = streamConfigs.data.i32[i]; |
| 457 | int32_t w = streamConfigs.data.i32[i + 1]; |
| 458 | int32_t h = streamConfigs.data.i32[i + 2]; |
| 459 | |
| 460 | // Ignore input/output type for now |
| 461 | if (fmt == format) { |
| 462 | if (w == width && h == height) { |
| 463 | bestWidth = width; |
| 464 | bestHeight = height; |
| 465 | break; |
| 466 | } else if (w <= ROUNDING_WIDTH_CAP && (bestWidth == -1 || |
| 467 | CameraDeviceClient::euclidDistSquare(w, h, width, height) < |
| 468 | CameraDeviceClient::euclidDistSquare(bestWidth, bestHeight, width, height))) { |
| 469 | bestWidth = w; |
| 470 | bestHeight = h; |
| 471 | } |
| 472 | } |
| 473 | } |
| 474 | |
| 475 | if (bestWidth == -1) { |
| 476 | // Return false if no configurations for this format were listed |
| 477 | return false; |
| 478 | } |
| 479 | |
| 480 | // Set the outputs to the closet width/height |
| 481 | if (outWidth != NULL) { |
| 482 | *outWidth = bestWidth; |
| 483 | } |
| 484 | if (outHeight != NULL) { |
| 485 | *outHeight = bestHeight; |
| 486 | } |
| 487 | |
| 488 | // Return true if at least one configuration for this format was listed |
| 489 | return true; |
| 490 | } |
| 491 | |
| 492 | int64_t CameraDeviceClient::euclidDistSquare(int32_t x0, int32_t y0, int32_t x1, int32_t y1) { |
| 493 | int64_t d0 = x0 - x1; |
| 494 | int64_t d1 = y0 - y1; |
| 495 | return d0 * d0 + d1 * d1; |
| 496 | } |
| 497 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 498 | // Create a request object from a template. |
| 499 | status_t CameraDeviceClient::createDefaultRequest(int templateId, |
| 500 | /*out*/ |
| 501 | CameraMetadata* request) |
| 502 | { |
| 503 | ATRACE_CALL(); |
| 504 | ALOGV("%s (templateId = 0x%x)", __FUNCTION__, templateId); |
| 505 | |
| 506 | status_t res; |
| 507 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 508 | |
| 509 | Mutex::Autolock icl(mBinderSerializationLock); |
| 510 | |
| 511 | if (!mDevice.get()) return DEAD_OBJECT; |
| 512 | |
| 513 | CameraMetadata metadata; |
| 514 | if ( (res = mDevice->createDefaultRequest(templateId, &metadata) ) == OK && |
| 515 | request != NULL) { |
| 516 | |
| 517 | request->swap(metadata); |
| 518 | } |
| 519 | |
| 520 | return res; |
| 521 | } |
| 522 | |
Igor Murashkin | 099b457 | 2013-07-12 17:52:16 -0700 | [diff] [blame] | 523 | status_t CameraDeviceClient::getCameraInfo(/*out*/CameraMetadata* info) |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 524 | { |
| 525 | ATRACE_CALL(); |
| 526 | ALOGV("%s", __FUNCTION__); |
| 527 | |
| 528 | status_t res = OK; |
| 529 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 530 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 531 | |
| 532 | Mutex::Autolock icl(mBinderSerializationLock); |
| 533 | |
| 534 | if (!mDevice.get()) return DEAD_OBJECT; |
| 535 | |
Igor Murashkin | 099b457 | 2013-07-12 17:52:16 -0700 | [diff] [blame] | 536 | if (info != NULL) { |
| 537 | *info = mDevice->info(); // static camera metadata |
| 538 | // TODO: merge with device-specific camera metadata |
| 539 | } |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 540 | |
| 541 | return res; |
| 542 | } |
| 543 | |
Zhijun He | 2ab500c | 2013-07-23 08:02:53 -0700 | [diff] [blame] | 544 | status_t CameraDeviceClient::waitUntilIdle() |
| 545 | { |
| 546 | ATRACE_CALL(); |
| 547 | ALOGV("%s", __FUNCTION__); |
| 548 | |
| 549 | status_t res = OK; |
| 550 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 551 | |
| 552 | Mutex::Autolock icl(mBinderSerializationLock); |
| 553 | |
| 554 | if (!mDevice.get()) return DEAD_OBJECT; |
| 555 | |
| 556 | // FIXME: Also need check repeating burst. |
| 557 | if (!mStreamingRequestList.isEmpty()) { |
| 558 | ALOGE("%s: Camera %d: Try to waitUntilIdle when there are active streaming requests", |
| 559 | __FUNCTION__, mCameraId); |
| 560 | return INVALID_OPERATION; |
| 561 | } |
| 562 | res = mDevice->waitUntilDrained(); |
| 563 | ALOGV("%s Done", __FUNCTION__); |
| 564 | |
| 565 | return res; |
| 566 | } |
| 567 | |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 568 | status_t CameraDeviceClient::flush(int64_t* lastFrameNumber) { |
Eino-Ville Talvala | abaa51d | 2013-08-14 11:37:00 -0700 | [diff] [blame] | 569 | ATRACE_CALL(); |
| 570 | ALOGV("%s", __FUNCTION__); |
| 571 | |
| 572 | status_t res = OK; |
| 573 | if ( (res = checkPid(__FUNCTION__) ) != OK) return res; |
| 574 | |
| 575 | Mutex::Autolock icl(mBinderSerializationLock); |
| 576 | |
| 577 | if (!mDevice.get()) return DEAD_OBJECT; |
| 578 | |
Jianing Wei | 3c76fa3 | 2014-04-21 11:34:34 -0700 | [diff] [blame] | 579 | mStreamingRequestList.clear(); |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 580 | return mDevice->flush(lastFrameNumber); |
Eino-Ville Talvala | abaa51d | 2013-08-14 11:37:00 -0700 | [diff] [blame] | 581 | } |
| 582 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 583 | status_t CameraDeviceClient::dump(int fd, const Vector<String16>& args) { |
| 584 | String8 result; |
Eino-Ville Talvala | 67489d2 | 2014-09-18 15:52:02 -0700 | [diff] [blame] | 585 | result.appendFormat("CameraDeviceClient[%d] (%p) dump:\n", |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 586 | mCameraId, |
Eino-Ville Talvala | e992e75 | 2014-11-07 16:17:48 -0800 | [diff] [blame] | 587 | (getRemoteCallback() != NULL ? |
Marco Nelissen | f888020 | 2014-11-14 07:58:25 -0800 | [diff] [blame] | 588 | IInterface::asBinder(getRemoteCallback()).get() : NULL) ); |
Eino-Ville Talvala | 67489d2 | 2014-09-18 15:52:02 -0700 | [diff] [blame] | 589 | result.appendFormat(" Current client: %s (PID %d, UID %u)\n", |
| 590 | String8(mClientPackageName).string(), |
| 591 | mClientPid, mClientUid); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 592 | |
Eino-Ville Talvala | 67489d2 | 2014-09-18 15:52:02 -0700 | [diff] [blame] | 593 | result.append(" State:\n"); |
| 594 | result.appendFormat(" Request ID counter: %d\n", mRequestIdCounter); |
| 595 | if (!mStreamMap.isEmpty()) { |
| 596 | result.append(" Current stream IDs:\n"); |
| 597 | for (size_t i = 0; i < mStreamMap.size(); i++) { |
| 598 | result.appendFormat(" Stream %d\n", mStreamMap.valueAt(i)); |
| 599 | } |
| 600 | } else { |
| 601 | result.append(" No streams configured.\n"); |
| 602 | } |
| 603 | write(fd, result.string(), result.size()); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 604 | // TODO: print dynamic/request section from most recent requests |
| 605 | mFrameProcessor->dump(fd, args); |
| 606 | |
| 607 | return dumpDevice(fd, args); |
| 608 | } |
| 609 | |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 610 | void CameraDeviceClient::notifyError(ICameraDeviceCallbacks::CameraErrorCode errorCode, |
| 611 | const CaptureResultExtras& resultExtras) { |
Eino-Ville Talvala | f1e98d8 | 2013-09-06 09:32:43 -0700 | [diff] [blame] | 612 | // Thread safe. Don't bother locking. |
| 613 | sp<ICameraDeviceCallbacks> remoteCb = getRemoteCallback(); |
| 614 | |
| 615 | if (remoteCb != 0) { |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 616 | remoteCb->onDeviceError(errorCode, resultExtras); |
Eino-Ville Talvala | f1e98d8 | 2013-09-06 09:32:43 -0700 | [diff] [blame] | 617 | } |
| 618 | } |
| 619 | |
| 620 | void CameraDeviceClient::notifyIdle() { |
| 621 | // Thread safe. Don't bother locking. |
| 622 | sp<ICameraDeviceCallbacks> remoteCb = getRemoteCallback(); |
| 623 | |
| 624 | if (remoteCb != 0) { |
| 625 | remoteCb->onDeviceIdle(); |
| 626 | } |
| 627 | } |
| 628 | |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 629 | void CameraDeviceClient::notifyShutter(const CaptureResultExtras& resultExtras, |
Eino-Ville Talvala | f1e98d8 | 2013-09-06 09:32:43 -0700 | [diff] [blame] | 630 | nsecs_t timestamp) { |
| 631 | // Thread safe. Don't bother locking. |
| 632 | sp<ICameraDeviceCallbacks> remoteCb = getRemoteCallback(); |
| 633 | if (remoteCb != 0) { |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 634 | remoteCb->onCaptureStarted(resultExtras, timestamp); |
Eino-Ville Talvala | f1e98d8 | 2013-09-06 09:32:43 -0700 | [diff] [blame] | 635 | } |
| 636 | } |
| 637 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 638 | // TODO: refactor the code below this with IProCameraUser. |
| 639 | // it's 100% copy-pasted, so lets not change it right now to make it easier. |
| 640 | |
| 641 | void CameraDeviceClient::detachDevice() { |
| 642 | if (mDevice == 0) return; |
| 643 | |
| 644 | ALOGV("Camera %d: Stopping processors", mCameraId); |
| 645 | |
| 646 | mFrameProcessor->removeListener(FRAME_PROCESSOR_LISTENER_MIN_ID, |
| 647 | FRAME_PROCESSOR_LISTENER_MAX_ID, |
| 648 | /*listener*/this); |
| 649 | mFrameProcessor->requestExit(); |
| 650 | ALOGV("Camera %d: Waiting for threads", mCameraId); |
| 651 | mFrameProcessor->join(); |
| 652 | ALOGV("Camera %d: Disconnecting device", mCameraId); |
| 653 | |
| 654 | // WORKAROUND: HAL refuses to disconnect while there's streams in flight |
| 655 | { |
| 656 | mDevice->clearStreamingRequest(); |
| 657 | |
| 658 | status_t code; |
| 659 | if ((code = mDevice->waitUntilDrained()) != OK) { |
| 660 | ALOGE("%s: waitUntilDrained failed with code 0x%x", __FUNCTION__, |
| 661 | code); |
| 662 | } |
| 663 | } |
| 664 | |
| 665 | Camera2ClientBase::detachDevice(); |
| 666 | } |
| 667 | |
| 668 | /** Device-related methods */ |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 669 | void CameraDeviceClient::onResultAvailable(const CaptureResult& result) { |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 670 | ATRACE_CALL(); |
| 671 | ALOGV("%s", __FUNCTION__); |
| 672 | |
Igor Murashkin | 4fb55c1 | 2013-08-29 17:43:01 -0700 | [diff] [blame] | 673 | // Thread-safe. No lock necessary. |
| 674 | sp<ICameraDeviceCallbacks> remoteCb = mRemoteCallback; |
| 675 | if (remoteCb != NULL) { |
Jianing Wei | cb0652e | 2014-03-12 18:29:36 -0700 | [diff] [blame] | 676 | remoteCb->onResultReceived(result.mMetadata, result.mResultExtras); |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 677 | } |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 678 | } |
| 679 | |
| 680 | // TODO: move to Camera2ClientBase |
| 681 | bool CameraDeviceClient::enforceRequestPermissions(CameraMetadata& metadata) { |
| 682 | |
| 683 | const int pid = IPCThreadState::self()->getCallingPid(); |
| 684 | const int selfPid = getpid(); |
| 685 | camera_metadata_entry_t entry; |
| 686 | |
| 687 | /** |
| 688 | * Mixin default important security values |
| 689 | * - android.led.transmit = defaulted ON |
| 690 | */ |
| 691 | CameraMetadata staticInfo = mDevice->info(); |
| 692 | entry = staticInfo.find(ANDROID_LED_AVAILABLE_LEDS); |
| 693 | for(size_t i = 0; i < entry.count; ++i) { |
| 694 | uint8_t led = entry.data.u8[i]; |
| 695 | |
| 696 | switch(led) { |
| 697 | case ANDROID_LED_AVAILABLE_LEDS_TRANSMIT: { |
| 698 | uint8_t transmitDefault = ANDROID_LED_TRANSMIT_ON; |
| 699 | if (!metadata.exists(ANDROID_LED_TRANSMIT)) { |
| 700 | metadata.update(ANDROID_LED_TRANSMIT, |
| 701 | &transmitDefault, 1); |
| 702 | } |
| 703 | break; |
| 704 | } |
| 705 | } |
| 706 | } |
| 707 | |
| 708 | // We can do anything! |
| 709 | if (pid == selfPid) { |
| 710 | return true; |
| 711 | } |
| 712 | |
| 713 | /** |
| 714 | * Permission check special fields in the request |
| 715 | * - android.led.transmit = android.permission.CAMERA_DISABLE_TRANSMIT |
| 716 | */ |
| 717 | entry = metadata.find(ANDROID_LED_TRANSMIT); |
| 718 | if (entry.count > 0 && entry.data.u8[0] != ANDROID_LED_TRANSMIT_ON) { |
| 719 | String16 permissionString = |
| 720 | String16("android.permission.CAMERA_DISABLE_TRANSMIT_LED"); |
| 721 | if (!checkCallingPermission(permissionString)) { |
| 722 | const int uid = IPCThreadState::self()->getCallingUid(); |
| 723 | ALOGE("Permission Denial: " |
| 724 | "can't disable transmit LED pid=%d, uid=%d", pid, uid); |
| 725 | return false; |
| 726 | } |
| 727 | } |
| 728 | |
| 729 | return true; |
| 730 | } |
| 731 | |
Igor Murashkin | f8b2a6f | 2013-09-17 17:03:28 -0700 | [diff] [blame] | 732 | status_t CameraDeviceClient::getRotationTransformLocked(int32_t* transform) { |
| 733 | ALOGV("%s: begin", __FUNCTION__); |
| 734 | |
Igor Murashkin | f8b2a6f | 2013-09-17 17:03:28 -0700 | [diff] [blame] | 735 | const CameraMetadata& staticInfo = mDevice->info(); |
Ruben Brunk | 5698d44 | 2014-06-18 10:39:40 -0700 | [diff] [blame] | 736 | return CameraUtils::getRotationTransform(staticInfo, transform); |
Igor Murashkin | f8b2a6f | 2013-09-17 17:03:28 -0700 | [diff] [blame] | 737 | } |
| 738 | |
Igor Murashkin | e7ee763 | 2013-06-11 18:10:18 -0700 | [diff] [blame] | 739 | } // namespace android |