Camera2Client.cpp revision 0be123df1897fd3fe1b7ba30f24d8ae4c91b4dc7
1/* 2 * Copyright (C) 2012 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 "Camera2Client" 18#define ATRACE_TAG ATRACE_TAG_CAMERA 19//#define LOG_NDEBUG 0 20 21#include <inttypes.h> 22#include <utils/Log.h> 23#include <utils/Trace.h> 24 25#include <cutils/properties.h> 26#include <gui/Surface.h> 27 28#include "api1/Camera2Client.h" 29 30#include "api1/client2/StreamingProcessor.h" 31#include "api1/client2/JpegProcessor.h" 32#include "api1/client2/CaptureSequencer.h" 33#include "api1/client2/CallbackProcessor.h" 34#include "api1/client2/ZslProcessor.h" 35#include "api1/client2/ZslProcessor3.h" 36 37#define ALOG1(...) ALOGD_IF(gLogLevel >= 1, __VA_ARGS__); 38#define ALOG2(...) ALOGD_IF(gLogLevel >= 2, __VA_ARGS__); 39 40namespace android { 41using namespace camera2; 42 43static int getCallingPid() { 44 return IPCThreadState::self()->getCallingPid(); 45} 46 47// Interface used by CameraService 48 49Camera2Client::Camera2Client(const sp<CameraService>& cameraService, 50 const sp<ICameraClient>& cameraClient, 51 const String16& clientPackageName, 52 int cameraId, 53 int cameraFacing, 54 int clientPid, 55 uid_t clientUid, 56 int servicePid): 57 Camera2ClientBase(cameraService, cameraClient, clientPackageName, 58 cameraId, cameraFacing, clientPid, clientUid, servicePid), 59 mParameters(cameraId, cameraFacing) 60{ 61 ATRACE_CALL(); 62 63 SharedParameters::Lock l(mParameters); 64 l.mParameters.state = Parameters::DISCONNECTED; 65} 66 67status_t Camera2Client::initialize(camera_module_t *module) 68{ 69 ATRACE_CALL(); 70 ALOGV("%s: Initializing client for camera %d", __FUNCTION__, mCameraId); 71 status_t res; 72 73 res = Camera2ClientBase::initialize(module); 74 if (res != OK) { 75 return res; 76 } 77 78 { 79 SharedParameters::Lock l(mParameters); 80 81 res = l.mParameters.initialize(&(mDevice->info()), mDeviceVersion); 82 if (res != OK) { 83 ALOGE("%s: Camera %d: unable to build defaults: %s (%d)", 84 __FUNCTION__, mCameraId, strerror(-res), res); 85 return NO_INIT; 86 } 87 } 88 89 String8 threadName; 90 91 mStreamingProcessor = new StreamingProcessor(this); 92 threadName = String8::format("C2-%d-StreamProc", 93 mCameraId); 94 mStreamingProcessor->run(threadName.string()); 95 96 mFrameProcessor = new FrameProcessor(mDevice, this); 97 threadName = String8::format("C2-%d-FrameProc", 98 mCameraId); 99 mFrameProcessor->run(threadName.string()); 100 101 mCaptureSequencer = new CaptureSequencer(this); 102 threadName = String8::format("C2-%d-CaptureSeq", 103 mCameraId); 104 mCaptureSequencer->run(threadName.string()); 105 106 mJpegProcessor = new JpegProcessor(this, mCaptureSequencer); 107 threadName = String8::format("C2-%d-JpegProc", 108 mCameraId); 109 mJpegProcessor->run(threadName.string()); 110 111 switch (mDeviceVersion) { 112 case CAMERA_DEVICE_API_VERSION_2_0: { 113 sp<ZslProcessor> zslProc = 114 new ZslProcessor(this, mCaptureSequencer); 115 mZslProcessor = zslProc; 116 mZslProcessorThread = zslProc; 117 break; 118 } 119 case CAMERA_DEVICE_API_VERSION_3_0: 120 case CAMERA_DEVICE_API_VERSION_3_1: 121 case CAMERA_DEVICE_API_VERSION_3_2: { 122 sp<ZslProcessor3> zslProc = 123 new ZslProcessor3(this, mCaptureSequencer); 124 mZslProcessor = zslProc; 125 mZslProcessorThread = zslProc; 126 break; 127 } 128 default: 129 break; 130 } 131 threadName = String8::format("C2-%d-ZslProc", 132 mCameraId); 133 mZslProcessorThread->run(threadName.string()); 134 135 mCallbackProcessor = new CallbackProcessor(this); 136 threadName = String8::format("C2-%d-CallbkProc", 137 mCameraId); 138 mCallbackProcessor->run(threadName.string()); 139 140 if (gLogLevel >= 1) { 141 SharedParameters::Lock l(mParameters); 142 ALOGD("%s: Default parameters converted from camera %d:", __FUNCTION__, 143 mCameraId); 144 ALOGD("%s", l.mParameters.paramsFlattened.string()); 145 } 146 147 return OK; 148} 149 150Camera2Client::~Camera2Client() { 151 ATRACE_CALL(); 152 ALOGV("~Camera2Client"); 153 154 mDestructionStarted = true; 155 156 disconnect(); 157 158 ALOGI("Camera %d: Closed", mCameraId); 159} 160 161status_t Camera2Client::dump(int fd, const Vector<String16>& args) { 162 String8 result; 163 result.appendFormat("Client2[%d] (%p) Client: %s PID: %d, dump:\n", 164 mCameraId, 165 getRemoteCallback()->asBinder().get(), 166 String8(mClientPackageName).string(), 167 mClientPid); 168 result.append(" State: "); 169#define CASE_APPEND_ENUM(x) case x: result.append(#x "\n"); break; 170 171 const Parameters& p = mParameters.unsafeAccess(); 172 173 result.append(Parameters::getStateName(p.state)); 174 175 result.append("\n Current parameters:\n"); 176 result.appendFormat(" Preview size: %d x %d\n", 177 p.previewWidth, p.previewHeight); 178 result.appendFormat(" Preview FPS range: %d - %d\n", 179 p.previewFpsRange[0], p.previewFpsRange[1]); 180 result.appendFormat(" Preview HAL pixel format: 0x%x\n", 181 p.previewFormat); 182 result.appendFormat(" Preview transform: %x\n", 183 p.previewTransform); 184 result.appendFormat(" Picture size: %d x %d\n", 185 p.pictureWidth, p.pictureHeight); 186 result.appendFormat(" Jpeg thumbnail size: %d x %d\n", 187 p.jpegThumbSize[0], p.jpegThumbSize[1]); 188 result.appendFormat(" Jpeg quality: %d, thumbnail quality: %d\n", 189 p.jpegQuality, p.jpegThumbQuality); 190 result.appendFormat(" Jpeg rotation: %d\n", p.jpegRotation); 191 result.appendFormat(" GPS tags %s\n", 192 p.gpsEnabled ? "enabled" : "disabled"); 193 if (p.gpsEnabled) { 194 result.appendFormat(" GPS lat x long x alt: %f x %f x %f\n", 195 p.gpsCoordinates[0], p.gpsCoordinates[1], 196 p.gpsCoordinates[2]); 197 result.appendFormat(" GPS timestamp: %" PRId64 "\n", 198 p.gpsTimestamp); 199 result.appendFormat(" GPS processing method: %s\n", 200 p.gpsProcessingMethod.string()); 201 } 202 203 result.append(" White balance mode: "); 204 switch (p.wbMode) { 205 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_AUTO) 206 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_INCANDESCENT) 207 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_FLUORESCENT) 208 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_WARM_FLUORESCENT) 209 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_DAYLIGHT) 210 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_CLOUDY_DAYLIGHT) 211 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_TWILIGHT) 212 CASE_APPEND_ENUM(ANDROID_CONTROL_AWB_MODE_SHADE) 213 default: result.append("UNKNOWN\n"); 214 } 215 216 result.append(" Effect mode: "); 217 switch (p.effectMode) { 218 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_OFF) 219 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_MONO) 220 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_NEGATIVE) 221 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_SOLARIZE) 222 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_SEPIA) 223 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_POSTERIZE) 224 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_WHITEBOARD) 225 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_BLACKBOARD) 226 CASE_APPEND_ENUM(ANDROID_CONTROL_EFFECT_MODE_AQUA) 227 default: result.append("UNKNOWN\n"); 228 } 229 230 result.append(" Antibanding mode: "); 231 switch (p.antibandingMode) { 232 CASE_APPEND_ENUM(ANDROID_CONTROL_AE_ANTIBANDING_MODE_AUTO) 233 CASE_APPEND_ENUM(ANDROID_CONTROL_AE_ANTIBANDING_MODE_OFF) 234 CASE_APPEND_ENUM(ANDROID_CONTROL_AE_ANTIBANDING_MODE_50HZ) 235 CASE_APPEND_ENUM(ANDROID_CONTROL_AE_ANTIBANDING_MODE_60HZ) 236 default: result.append("UNKNOWN\n"); 237 } 238 239 result.append(" Scene mode: "); 240 switch (p.sceneMode) { 241 case ANDROID_CONTROL_SCENE_MODE_DISABLED: 242 result.append("AUTO\n"); break; 243 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_ACTION) 244 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_PORTRAIT) 245 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_LANDSCAPE) 246 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_NIGHT) 247 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_NIGHT_PORTRAIT) 248 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_THEATRE) 249 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_BEACH) 250 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_SNOW) 251 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_SUNSET) 252 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_STEADYPHOTO) 253 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_FIREWORKS) 254 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_SPORTS) 255 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_PARTY) 256 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_CANDLELIGHT) 257 CASE_APPEND_ENUM(ANDROID_CONTROL_SCENE_MODE_BARCODE) 258 default: result.append("UNKNOWN\n"); 259 } 260 261 result.append(" Flash mode: "); 262 switch (p.flashMode) { 263 CASE_APPEND_ENUM(Parameters::FLASH_MODE_OFF) 264 CASE_APPEND_ENUM(Parameters::FLASH_MODE_AUTO) 265 CASE_APPEND_ENUM(Parameters::FLASH_MODE_ON) 266 CASE_APPEND_ENUM(Parameters::FLASH_MODE_TORCH) 267 CASE_APPEND_ENUM(Parameters::FLASH_MODE_RED_EYE) 268 CASE_APPEND_ENUM(Parameters::FLASH_MODE_INVALID) 269 default: result.append("UNKNOWN\n"); 270 } 271 272 result.append(" Focus mode: "); 273 switch (p.focusMode) { 274 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_AUTO) 275 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_MACRO) 276 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_CONTINUOUS_VIDEO) 277 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_CONTINUOUS_PICTURE) 278 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_EDOF) 279 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_INFINITY) 280 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_FIXED) 281 CASE_APPEND_ENUM(Parameters::FOCUS_MODE_INVALID) 282 default: result.append("UNKNOWN\n"); 283 } 284 285 result.append(" Focus state: "); 286 switch (p.focusState) { 287 CASE_APPEND_ENUM(ANDROID_CONTROL_AF_STATE_INACTIVE) 288 CASE_APPEND_ENUM(ANDROID_CONTROL_AF_STATE_PASSIVE_SCAN) 289 CASE_APPEND_ENUM(ANDROID_CONTROL_AF_STATE_PASSIVE_FOCUSED) 290 CASE_APPEND_ENUM(ANDROID_CONTROL_AF_STATE_PASSIVE_UNFOCUSED) 291 CASE_APPEND_ENUM(ANDROID_CONTROL_AF_STATE_ACTIVE_SCAN) 292 CASE_APPEND_ENUM(ANDROID_CONTROL_AF_STATE_FOCUSED_LOCKED) 293 CASE_APPEND_ENUM(ANDROID_CONTROL_AF_STATE_NOT_FOCUSED_LOCKED) 294 default: result.append("UNKNOWN\n"); 295 } 296 297 result.append(" Focusing areas:\n"); 298 for (size_t i = 0; i < p.focusingAreas.size(); i++) { 299 result.appendFormat(" [ (%d, %d, %d, %d), weight %d ]\n", 300 p.focusingAreas[i].left, 301 p.focusingAreas[i].top, 302 p.focusingAreas[i].right, 303 p.focusingAreas[i].bottom, 304 p.focusingAreas[i].weight); 305 } 306 307 result.appendFormat(" Exposure compensation index: %d\n", 308 p.exposureCompensation); 309 310 result.appendFormat(" AE lock %s, AWB lock %s\n", 311 p.autoExposureLock ? "enabled" : "disabled", 312 p.autoWhiteBalanceLock ? "enabled" : "disabled" ); 313 314 result.appendFormat(" Metering areas:\n"); 315 for (size_t i = 0; i < p.meteringAreas.size(); i++) { 316 result.appendFormat(" [ (%d, %d, %d, %d), weight %d ]\n", 317 p.meteringAreas[i].left, 318 p.meteringAreas[i].top, 319 p.meteringAreas[i].right, 320 p.meteringAreas[i].bottom, 321 p.meteringAreas[i].weight); 322 } 323 324 result.appendFormat(" Zoom index: %d\n", p.zoom); 325 result.appendFormat(" Video size: %d x %d\n", p.videoWidth, 326 p.videoHeight); 327 328 result.appendFormat(" Recording hint is %s\n", 329 p.recordingHint ? "set" : "not set"); 330 331 result.appendFormat(" Video stabilization is %s\n", 332 p.videoStabilization ? "enabled" : "disabled"); 333 334 result.appendFormat(" Selected still capture FPS range: %d - %d\n", 335 p.fastInfo.bestStillCaptureFpsRange[0], 336 p.fastInfo.bestStillCaptureFpsRange[1]); 337 338 result.append(" Current streams:\n"); 339 result.appendFormat(" Preview stream ID: %d\n", 340 getPreviewStreamId()); 341 result.appendFormat(" Capture stream ID: %d\n", 342 getCaptureStreamId()); 343 result.appendFormat(" Recording stream ID: %d\n", 344 getRecordingStreamId()); 345 346 result.append(" Quirks for this camera:\n"); 347 bool haveQuirk = false; 348 if (p.quirks.triggerAfWithAuto) { 349 result.appendFormat(" triggerAfWithAuto\n"); 350 haveQuirk = true; 351 } 352 if (p.quirks.useZslFormat) { 353 result.appendFormat(" useZslFormat\n"); 354 haveQuirk = true; 355 } 356 if (p.quirks.meteringCropRegion) { 357 result.appendFormat(" meteringCropRegion\n"); 358 haveQuirk = true; 359 } 360 if (p.quirks.partialResults) { 361 result.appendFormat(" usePartialResult\n"); 362 haveQuirk = true; 363 } 364 if (!haveQuirk) { 365 result.appendFormat(" none\n"); 366 } 367 368 write(fd, result.string(), result.size()); 369 370 mStreamingProcessor->dump(fd, args); 371 372 mCaptureSequencer->dump(fd, args); 373 374 mFrameProcessor->dump(fd, args); 375 376 mZslProcessor->dump(fd, args); 377 378 return dumpDevice(fd, args); 379#undef CASE_APPEND_ENUM 380} 381 382// ICamera interface 383 384void Camera2Client::disconnect() { 385 ATRACE_CALL(); 386 Mutex::Autolock icl(mBinderSerializationLock); 387 388 // Allow both client and the media server to disconnect at all times 389 int callingPid = getCallingPid(); 390 if (callingPid != mClientPid && callingPid != mServicePid) return; 391 392 if (mDevice == 0) return; 393 394 ALOGV("Camera %d: Shutting down", mCameraId); 395 396 /** 397 * disconnect() cannot call any methods that might need to promote a 398 * wp<Camera2Client>, since disconnect can be called from the destructor, at 399 * which point all such promotions will fail. 400 */ 401 402 stopPreviewL(); 403 404 { 405 SharedParameters::Lock l(mParameters); 406 if (l.mParameters.state == Parameters::DISCONNECTED) return; 407 l.mParameters.state = Parameters::DISCONNECTED; 408 } 409 410 mStreamingProcessor->requestExit(); 411 mFrameProcessor->requestExit(); 412 mCaptureSequencer->requestExit(); 413 mJpegProcessor->requestExit(); 414 mZslProcessorThread->requestExit(); 415 mCallbackProcessor->requestExit(); 416 417 ALOGV("Camera %d: Waiting for threads", mCameraId); 418 419 mStreamingProcessor->join(); 420 mFrameProcessor->join(); 421 mCaptureSequencer->join(); 422 mJpegProcessor->join(); 423 mZslProcessorThread->join(); 424 mCallbackProcessor->join(); 425 426 ALOGV("Camera %d: Deleting streams", mCameraId); 427 428 mStreamingProcessor->deletePreviewStream(); 429 mStreamingProcessor->deleteRecordingStream(); 430 mJpegProcessor->deleteStream(); 431 mCallbackProcessor->deleteStream(); 432 mZslProcessor->deleteStream(); 433 434 ALOGV("Camera %d: Disconnecting device", mCameraId); 435 436 mDevice->disconnect(); 437 438 mDevice.clear(); 439 440 CameraService::Client::disconnect(); 441} 442 443status_t Camera2Client::connect(const sp<ICameraClient>& client) { 444 ATRACE_CALL(); 445 ALOGV("%s: E", __FUNCTION__); 446 Mutex::Autolock icl(mBinderSerializationLock); 447 448 if (mClientPid != 0 && getCallingPid() != mClientPid) { 449 ALOGE("%s: Camera %d: Connection attempt from pid %d; " 450 "current locked to pid %d", __FUNCTION__, 451 mCameraId, getCallingPid(), mClientPid); 452 return BAD_VALUE; 453 } 454 455 mClientPid = getCallingPid(); 456 457 mRemoteCallback = client; 458 mSharedCameraCallbacks = client; 459 460 return OK; 461} 462 463status_t Camera2Client::lock() { 464 ATRACE_CALL(); 465 ALOGV("%s: E", __FUNCTION__); 466 Mutex::Autolock icl(mBinderSerializationLock); 467 ALOGV("%s: Camera %d: Lock call from pid %d; current client pid %d", 468 __FUNCTION__, mCameraId, getCallingPid(), mClientPid); 469 470 if (mClientPid == 0) { 471 mClientPid = getCallingPid(); 472 return OK; 473 } 474 475 if (mClientPid != getCallingPid()) { 476 ALOGE("%s: Camera %d: Lock call from pid %d; currently locked to pid %d", 477 __FUNCTION__, mCameraId, getCallingPid(), mClientPid); 478 return EBUSY; 479 } 480 481 return OK; 482} 483 484status_t Camera2Client::unlock() { 485 ATRACE_CALL(); 486 ALOGV("%s: E", __FUNCTION__); 487 Mutex::Autolock icl(mBinderSerializationLock); 488 ALOGV("%s: Camera %d: Unlock call from pid %d; current client pid %d", 489 __FUNCTION__, mCameraId, getCallingPid(), mClientPid); 490 491 if (mClientPid == getCallingPid()) { 492 SharedParameters::Lock l(mParameters); 493 if (l.mParameters.state == Parameters::RECORD || 494 l.mParameters.state == Parameters::VIDEO_SNAPSHOT) { 495 ALOGD("Not allowed to unlock camera during recording."); 496 return INVALID_OPERATION; 497 } 498 mClientPid = 0; 499 mRemoteCallback.clear(); 500 mSharedCameraCallbacks.clear(); 501 return OK; 502 } 503 504 ALOGE("%s: Camera %d: Unlock call from pid %d; currently locked to pid %d", 505 __FUNCTION__, mCameraId, getCallingPid(), mClientPid); 506 return EBUSY; 507} 508 509status_t Camera2Client::setPreviewTarget( 510 const sp<IGraphicBufferProducer>& bufferProducer) { 511 ATRACE_CALL(); 512 ALOGV("%s: E", __FUNCTION__); 513 Mutex::Autolock icl(mBinderSerializationLock); 514 status_t res; 515 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 516 517 sp<IBinder> binder; 518 sp<ANativeWindow> window; 519 if (bufferProducer != 0) { 520 binder = bufferProducer->asBinder(); 521 // Using controlledByApp flag to ensure that the buffer queue remains in 522 // async mode for the old camera API, where many applications depend 523 // on that behavior. 524 window = new Surface(bufferProducer, /*controlledByApp*/ true); 525 } 526 return setPreviewWindowL(binder, window); 527} 528 529status_t Camera2Client::setPreviewWindowL(const sp<IBinder>& binder, 530 sp<ANativeWindow> window) { 531 ATRACE_CALL(); 532 status_t res; 533 534 if (binder == mPreviewSurface) { 535 ALOGV("%s: Camera %d: New window is same as old window", 536 __FUNCTION__, mCameraId); 537 return NO_ERROR; 538 } 539 540 Parameters::State state; 541 { 542 SharedParameters::Lock l(mParameters); 543 state = l.mParameters.state; 544 } 545 switch (state) { 546 case Parameters::DISCONNECTED: 547 case Parameters::RECORD: 548 case Parameters::STILL_CAPTURE: 549 case Parameters::VIDEO_SNAPSHOT: 550 ALOGE("%s: Camera %d: Cannot set preview display while in state %s", 551 __FUNCTION__, mCameraId, 552 Parameters::getStateName(state)); 553 return INVALID_OPERATION; 554 case Parameters::STOPPED: 555 case Parameters::WAITING_FOR_PREVIEW_WINDOW: 556 // OK 557 break; 558 case Parameters::PREVIEW: 559 // Already running preview - need to stop and create a new stream 560 res = stopStream(); 561 if (res != OK) { 562 ALOGE("%s: Unable to stop preview to swap windows: %s (%d)", 563 __FUNCTION__, strerror(-res), res); 564 return res; 565 } 566 state = Parameters::WAITING_FOR_PREVIEW_WINDOW; 567 break; 568 } 569 570 mPreviewSurface = binder; 571 res = mStreamingProcessor->setPreviewWindow(window); 572 if (res != OK) { 573 ALOGE("%s: Unable to set new preview window: %s (%d)", 574 __FUNCTION__, strerror(-res), res); 575 return res; 576 } 577 578 if (state == Parameters::WAITING_FOR_PREVIEW_WINDOW) { 579 SharedParameters::Lock l(mParameters); 580 l.mParameters.state = state; 581 return startPreviewL(l.mParameters, false); 582 } 583 584 return OK; 585} 586 587void Camera2Client::setPreviewCallbackFlag(int flag) { 588 ATRACE_CALL(); 589 ALOGV("%s: Camera %d: Flag 0x%x", __FUNCTION__, mCameraId, flag); 590 Mutex::Autolock icl(mBinderSerializationLock); 591 592 if ( checkPid(__FUNCTION__) != OK) return; 593 594 SharedParameters::Lock l(mParameters); 595 setPreviewCallbackFlagL(l.mParameters, flag); 596} 597 598void Camera2Client::setPreviewCallbackFlagL(Parameters ¶ms, int flag) { 599 status_t res = OK; 600 601 switch(params.state) { 602 case Parameters::STOPPED: 603 case Parameters::WAITING_FOR_PREVIEW_WINDOW: 604 case Parameters::PREVIEW: 605 case Parameters::STILL_CAPTURE: 606 // OK 607 break; 608 default: 609 if (flag & CAMERA_FRAME_CALLBACK_FLAG_ENABLE_MASK) { 610 ALOGE("%s: Camera %d: Can't use preview callbacks " 611 "in state %d", __FUNCTION__, mCameraId, params.state); 612 return; 613 } 614 } 615 616 if (flag & CAMERA_FRAME_CALLBACK_FLAG_ONE_SHOT_MASK) { 617 ALOGV("%s: setting oneshot", __FUNCTION__); 618 params.previewCallbackOneShot = true; 619 } 620 if (params.previewCallbackFlags != (uint32_t)flag) { 621 622 if (params.previewCallbackSurface && flag != CAMERA_FRAME_CALLBACK_FLAG_NOOP) { 623 // Disable any existing preview callback window when enabling 624 // preview callback flags 625 res = mCallbackProcessor->setCallbackWindow(NULL); 626 if (res != OK) { 627 ALOGE("%s: Camera %d: Unable to clear preview callback surface:" 628 " %s (%d)", __FUNCTION__, mCameraId, strerror(-res), res); 629 return; 630 } 631 params.previewCallbackSurface = false; 632 } 633 634 params.previewCallbackFlags = flag; 635 636 if (params.state == Parameters::PREVIEW) { 637 res = startPreviewL(params, true); 638 if (res != OK) { 639 ALOGE("%s: Camera %d: Unable to refresh request in state %s", 640 __FUNCTION__, mCameraId, 641 Parameters::getStateName(params.state)); 642 } 643 } 644 } 645} 646 647status_t Camera2Client::setPreviewCallbackTarget( 648 const sp<IGraphicBufferProducer>& callbackProducer) { 649 ATRACE_CALL(); 650 ALOGV("%s: E", __FUNCTION__); 651 Mutex::Autolock icl(mBinderSerializationLock); 652 status_t res; 653 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 654 655 sp<ANativeWindow> window; 656 if (callbackProducer != 0) { 657 window = new Surface(callbackProducer); 658 } 659 660 res = mCallbackProcessor->setCallbackWindow(window); 661 if (res != OK) { 662 ALOGE("%s: Camera %d: Unable to set preview callback surface: %s (%d)", 663 __FUNCTION__, mCameraId, strerror(-res), res); 664 return res; 665 } 666 667 SharedParameters::Lock l(mParameters); 668 669 if (window != NULL) { 670 // Disable traditional callbacks when a valid callback target is given 671 l.mParameters.previewCallbackFlags = CAMERA_FRAME_CALLBACK_FLAG_NOOP; 672 l.mParameters.previewCallbackOneShot = false; 673 l.mParameters.previewCallbackSurface = true; 674 } else { 675 // Disable callback target if given a NULL interface. 676 l.mParameters.previewCallbackSurface = false; 677 } 678 679 switch(l.mParameters.state) { 680 case Parameters::PREVIEW: 681 res = startPreviewL(l.mParameters, true); 682 break; 683 case Parameters::RECORD: 684 case Parameters::VIDEO_SNAPSHOT: 685 res = startRecordingL(l.mParameters, true); 686 break; 687 default: 688 break; 689 } 690 if (res != OK) { 691 ALOGE("%s: Camera %d: Unable to refresh request in state %s", 692 __FUNCTION__, mCameraId, 693 Parameters::getStateName(l.mParameters.state)); 694 } 695 696 return OK; 697} 698 699 700status_t Camera2Client::startPreview() { 701 ATRACE_CALL(); 702 ALOGV("%s: E", __FUNCTION__); 703 Mutex::Autolock icl(mBinderSerializationLock); 704 status_t res; 705 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 706 SharedParameters::Lock l(mParameters); 707 return startPreviewL(l.mParameters, false); 708} 709 710status_t Camera2Client::startPreviewL(Parameters ¶ms, bool restart) { 711 ATRACE_CALL(); 712 status_t res; 713 714 ALOGV("%s: state == %d, restart = %d", __FUNCTION__, params.state, restart); 715 716 if ( (params.state == Parameters::PREVIEW || 717 params.state == Parameters::RECORD || 718 params.state == Parameters::VIDEO_SNAPSHOT) 719 && !restart) { 720 // Succeed attempt to re-enter a streaming state 721 ALOGI("%s: Camera %d: Preview already active, ignoring restart", 722 __FUNCTION__, mCameraId); 723 return OK; 724 } 725 if (params.state > Parameters::PREVIEW && !restart) { 726 ALOGE("%s: Can't start preview in state %s", 727 __FUNCTION__, 728 Parameters::getStateName(params.state)); 729 return INVALID_OPERATION; 730 } 731 732 if (!mStreamingProcessor->haveValidPreviewWindow()) { 733 params.state = Parameters::WAITING_FOR_PREVIEW_WINDOW; 734 return OK; 735 } 736 params.state = Parameters::STOPPED; 737 int lastPreviewStreamId = mStreamingProcessor->getPreviewStreamId(); 738 739 res = mStreamingProcessor->updatePreviewStream(params); 740 if (res != OK) { 741 ALOGE("%s: Camera %d: Unable to update preview stream: %s (%d)", 742 __FUNCTION__, mCameraId, strerror(-res), res); 743 return res; 744 } 745 746 bool previewStreamChanged = mStreamingProcessor->getPreviewStreamId() != lastPreviewStreamId; 747 748 // We could wait to create the JPEG output stream until first actual use 749 // (first takePicture call). However, this would substantially increase the 750 // first capture latency on HAL3 devices, and potentially on some HAL2 751 // devices. So create it unconditionally at preview start. As a drawback, 752 // this increases gralloc memory consumption for applications that don't 753 // ever take a picture. 754 // TODO: Find a better compromise, though this likely would involve HAL 755 // changes. 756 int lastJpegStreamId = mJpegProcessor->getStreamId(); 757 res = updateProcessorStream(mJpegProcessor, params); 758 if (res != OK) { 759 ALOGE("%s: Camera %d: Can't pre-configure still image " 760 "stream: %s (%d)", 761 __FUNCTION__, mCameraId, strerror(-res), res); 762 return res; 763 } 764 bool jpegStreamChanged = mJpegProcessor->getStreamId() != lastJpegStreamId; 765 766 Vector<int32_t> outputStreams; 767 bool callbacksEnabled = (params.previewCallbackFlags & 768 CAMERA_FRAME_CALLBACK_FLAG_ENABLE_MASK) || 769 params.previewCallbackSurface; 770 771 if (callbacksEnabled) { 772 // Can't have recording stream hanging around when enabling callbacks, 773 // since it exceeds the max stream count on some devices. 774 if (mStreamingProcessor->getRecordingStreamId() != NO_STREAM) { 775 ALOGV("%s: Camera %d: Clearing out recording stream before " 776 "creating callback stream", __FUNCTION__, mCameraId); 777 res = mStreamingProcessor->stopStream(); 778 if (res != OK) { 779 ALOGE("%s: Camera %d: Can't stop streaming to delete " 780 "recording stream", __FUNCTION__, mCameraId); 781 return res; 782 } 783 res = mStreamingProcessor->deleteRecordingStream(); 784 if (res != OK) { 785 ALOGE("%s: Camera %d: Unable to delete recording stream before " 786 "enabling callbacks: %s (%d)", __FUNCTION__, mCameraId, 787 strerror(-res), res); 788 return res; 789 } 790 } 791 792 res = mCallbackProcessor->updateStream(params); 793 if (res != OK) { 794 ALOGE("%s: Camera %d: Unable to update callback stream: %s (%d)", 795 __FUNCTION__, mCameraId, strerror(-res), res); 796 return res; 797 } 798 outputStreams.push(getCallbackStreamId()); 799 } else if (previewStreamChanged && mCallbackProcessor->getStreamId() != NO_STREAM) { 800 /** 801 * Delete the unused callback stream when preview stream is changed and 802 * preview is not enabled. Don't need stop preview stream as preview is in 803 * STOPPED state now. 804 */ 805 ALOGV("%s: Camera %d: Delete unused preview callback stream.", __FUNCTION__, mCameraId); 806 res = mCallbackProcessor->deleteStream(); 807 if (res != OK) { 808 ALOGE("%s: Camera %d: Unable to delete callback stream %s (%d)", 809 __FUNCTION__, mCameraId, strerror(-res), res); 810 return res; 811 } 812 } 813 if (params.zslMode && !params.recordingHint) { 814 res = updateProcessorStream(mZslProcessor, params); 815 if (res != OK) { 816 ALOGE("%s: Camera %d: Unable to update ZSL stream: %s (%d)", 817 __FUNCTION__, mCameraId, strerror(-res), res); 818 return res; 819 } 820 821 if (jpegStreamChanged) { 822 ALOGV("%s: Camera %d: Clear ZSL buffer queue when Jpeg size is changed", 823 __FUNCTION__, mCameraId); 824 mZslProcessor->clearZslQueue(); 825 } 826 outputStreams.push(getZslStreamId()); 827 } else { 828 mZslProcessor->clearZslQueue(); 829 mZslProcessor->deleteStream(); 830 } 831 832 outputStreams.push(getPreviewStreamId()); 833 834 if (!params.recordingHint) { 835 if (!restart) { 836 res = mStreamingProcessor->updatePreviewRequest(params); 837 if (res != OK) { 838 ALOGE("%s: Camera %d: Can't set up preview request: " 839 "%s (%d)", __FUNCTION__, mCameraId, 840 strerror(-res), res); 841 return res; 842 } 843 } 844 res = mStreamingProcessor->startStream(StreamingProcessor::PREVIEW, 845 outputStreams); 846 } else { 847 if (!restart) { 848 res = mStreamingProcessor->updateRecordingRequest(params); 849 if (res != OK) { 850 ALOGE("%s: Camera %d: Can't set up preview request with " 851 "record hint: %s (%d)", __FUNCTION__, mCameraId, 852 strerror(-res), res); 853 return res; 854 } 855 } 856 res = mStreamingProcessor->startStream(StreamingProcessor::RECORD, 857 outputStreams); 858 } 859 if (res != OK) { 860 ALOGE("%s: Camera %d: Unable to start streaming preview: %s (%d)", 861 __FUNCTION__, mCameraId, strerror(-res), res); 862 return res; 863 } 864 865 params.state = Parameters::PREVIEW; 866 return OK; 867} 868 869void Camera2Client::stopPreview() { 870 ATRACE_CALL(); 871 ALOGV("%s: E", __FUNCTION__); 872 Mutex::Autolock icl(mBinderSerializationLock); 873 status_t res; 874 if ( (res = checkPid(__FUNCTION__) ) != OK) return; 875 stopPreviewL(); 876} 877 878void Camera2Client::stopPreviewL() { 879 ATRACE_CALL(); 880 status_t res; 881 const nsecs_t kStopCaptureTimeout = 3000000000LL; // 3 seconds 882 Parameters::State state; 883 { 884 SharedParameters::Lock l(mParameters); 885 state = l.mParameters.state; 886 } 887 888 switch (state) { 889 case Parameters::DISCONNECTED: 890 // Nothing to do. 891 break; 892 case Parameters::STOPPED: 893 case Parameters::VIDEO_SNAPSHOT: 894 case Parameters::STILL_CAPTURE: 895 mCaptureSequencer->waitUntilIdle(kStopCaptureTimeout); 896 // no break 897 case Parameters::RECORD: 898 case Parameters::PREVIEW: 899 syncWithDevice(); 900 res = stopStream(); 901 if (res != OK) { 902 ALOGE("%s: Camera %d: Can't stop streaming: %s (%d)", 903 __FUNCTION__, mCameraId, strerror(-res), res); 904 } 905 res = mDevice->waitUntilDrained(); 906 if (res != OK) { 907 ALOGE("%s: Camera %d: Waiting to stop streaming failed: %s (%d)", 908 __FUNCTION__, mCameraId, strerror(-res), res); 909 } 910 // Clean up recording stream 911 res = mStreamingProcessor->deleteRecordingStream(); 912 if (res != OK) { 913 ALOGE("%s: Camera %d: Unable to delete recording stream before " 914 "stop preview: %s (%d)", 915 __FUNCTION__, mCameraId, strerror(-res), res); 916 } 917 // no break 918 case Parameters::WAITING_FOR_PREVIEW_WINDOW: { 919 SharedParameters::Lock l(mParameters); 920 l.mParameters.state = Parameters::STOPPED; 921 commandStopFaceDetectionL(l.mParameters); 922 break; 923 } 924 default: 925 ALOGE("%s: Camera %d: Unknown state %d", __FUNCTION__, mCameraId, 926 state); 927 } 928} 929 930bool Camera2Client::previewEnabled() { 931 ATRACE_CALL(); 932 Mutex::Autolock icl(mBinderSerializationLock); 933 status_t res; 934 if ( (res = checkPid(__FUNCTION__) ) != OK) return false; 935 936 SharedParameters::Lock l(mParameters); 937 return l.mParameters.state == Parameters::PREVIEW; 938} 939 940status_t Camera2Client::storeMetaDataInBuffers(bool enabled) { 941 ATRACE_CALL(); 942 Mutex::Autolock icl(mBinderSerializationLock); 943 status_t res; 944 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 945 946 SharedParameters::Lock l(mParameters); 947 switch (l.mParameters.state) { 948 case Parameters::RECORD: 949 case Parameters::VIDEO_SNAPSHOT: 950 ALOGE("%s: Camera %d: Can't be called in state %s", 951 __FUNCTION__, mCameraId, 952 Parameters::getStateName(l.mParameters.state)); 953 return INVALID_OPERATION; 954 default: 955 // OK 956 break; 957 } 958 959 l.mParameters.storeMetadataInBuffers = enabled; 960 961 return OK; 962} 963 964status_t Camera2Client::startRecording() { 965 ATRACE_CALL(); 966 ALOGV("%s: E", __FUNCTION__); 967 Mutex::Autolock icl(mBinderSerializationLock); 968 status_t res; 969 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 970 SharedParameters::Lock l(mParameters); 971 972 return startRecordingL(l.mParameters, false); 973} 974 975status_t Camera2Client::startRecordingL(Parameters ¶ms, bool restart) { 976 status_t res; 977 978 ALOGV("%s: state == %d, restart = %d", __FUNCTION__, params.state, restart); 979 980 switch (params.state) { 981 case Parameters::STOPPED: 982 res = startPreviewL(params, false); 983 if (res != OK) return res; 984 break; 985 case Parameters::PREVIEW: 986 // Ready to go 987 break; 988 case Parameters::RECORD: 989 case Parameters::VIDEO_SNAPSHOT: 990 // OK to call this when recording is already on, just skip unless 991 // we're looking to restart 992 if (!restart) return OK; 993 break; 994 default: 995 ALOGE("%s: Camera %d: Can't start recording in state %s", 996 __FUNCTION__, mCameraId, 997 Parameters::getStateName(params.state)); 998 return INVALID_OPERATION; 999 }; 1000 1001 if (!params.storeMetadataInBuffers) { 1002 ALOGE("%s: Camera %d: Recording only supported in metadata mode, but " 1003 "non-metadata recording mode requested!", __FUNCTION__, 1004 mCameraId); 1005 return INVALID_OPERATION; 1006 } 1007 1008 if (!restart) { 1009 mCameraService->playSound(CameraService::SOUND_RECORDING); 1010 mStreamingProcessor->updateRecordingRequest(params); 1011 if (res != OK) { 1012 ALOGE("%s: Camera %d: Unable to update recording request: %s (%d)", 1013 __FUNCTION__, mCameraId, strerror(-res), res); 1014 return res; 1015 } 1016 } 1017 1018 // Not all devices can support a preview callback stream and a recording 1019 // stream at the same time, so assume none of them can. 1020 if (mCallbackProcessor->getStreamId() != NO_STREAM) { 1021 ALOGV("%s: Camera %d: Clearing out callback stream before " 1022 "creating recording stream", __FUNCTION__, mCameraId); 1023 res = mStreamingProcessor->stopStream(); 1024 if (res != OK) { 1025 ALOGE("%s: Camera %d: Can't stop streaming to delete callback stream", 1026 __FUNCTION__, mCameraId); 1027 return res; 1028 } 1029 res = mCallbackProcessor->deleteStream(); 1030 if (res != OK) { 1031 ALOGE("%s: Camera %d: Unable to delete callback stream before " 1032 "record: %s (%d)", __FUNCTION__, mCameraId, 1033 strerror(-res), res); 1034 return res; 1035 } 1036 } 1037 // Disable callbacks if they're enabled; can't record and use callbacks, 1038 // and we can't fail record start without stagefright asserting. 1039 params.previewCallbackFlags = 0; 1040 1041 res = updateProcessorStream< 1042 StreamingProcessor, 1043 &StreamingProcessor::updateRecordingStream>(mStreamingProcessor, 1044 params); 1045 if (res != OK) { 1046 ALOGE("%s: Camera %d: Unable to update recording stream: %s (%d)", 1047 __FUNCTION__, mCameraId, strerror(-res), res); 1048 return res; 1049 } 1050 1051 Vector<int32_t> outputStreams; 1052 outputStreams.push(getPreviewStreamId()); 1053 outputStreams.push(getRecordingStreamId()); 1054 1055 res = mStreamingProcessor->startStream(StreamingProcessor::RECORD, 1056 outputStreams); 1057 if (res != OK) { 1058 ALOGE("%s: Camera %d: Unable to start recording stream: %s (%d)", 1059 __FUNCTION__, mCameraId, strerror(-res), res); 1060 return res; 1061 } 1062 1063 if (params.state < Parameters::RECORD) { 1064 params.state = Parameters::RECORD; 1065 } 1066 1067 return OK; 1068} 1069 1070void Camera2Client::stopRecording() { 1071 ATRACE_CALL(); 1072 ALOGV("%s: E", __FUNCTION__); 1073 Mutex::Autolock icl(mBinderSerializationLock); 1074 SharedParameters::Lock l(mParameters); 1075 1076 status_t res; 1077 if ( (res = checkPid(__FUNCTION__) ) != OK) return; 1078 1079 switch (l.mParameters.state) { 1080 case Parameters::RECORD: 1081 // OK to stop 1082 break; 1083 case Parameters::STOPPED: 1084 case Parameters::PREVIEW: 1085 case Parameters::STILL_CAPTURE: 1086 case Parameters::VIDEO_SNAPSHOT: 1087 default: 1088 ALOGE("%s: Camera %d: Can't stop recording in state %s", 1089 __FUNCTION__, mCameraId, 1090 Parameters::getStateName(l.mParameters.state)); 1091 return; 1092 }; 1093 1094 mCameraService->playSound(CameraService::SOUND_RECORDING); 1095 1096 res = startPreviewL(l.mParameters, true); 1097 if (res != OK) { 1098 ALOGE("%s: Camera %d: Unable to return to preview", 1099 __FUNCTION__, mCameraId); 1100 } 1101} 1102 1103bool Camera2Client::recordingEnabled() { 1104 ATRACE_CALL(); 1105 Mutex::Autolock icl(mBinderSerializationLock); 1106 1107 if ( checkPid(__FUNCTION__) != OK) return false; 1108 1109 return recordingEnabledL(); 1110} 1111 1112bool Camera2Client::recordingEnabledL() { 1113 ATRACE_CALL(); 1114 SharedParameters::Lock l(mParameters); 1115 1116 return (l.mParameters.state == Parameters::RECORD 1117 || l.mParameters.state == Parameters::VIDEO_SNAPSHOT); 1118} 1119 1120void Camera2Client::releaseRecordingFrame(const sp<IMemory>& mem) { 1121 ATRACE_CALL(); 1122 Mutex::Autolock icl(mBinderSerializationLock); 1123 if ( checkPid(__FUNCTION__) != OK) return; 1124 1125 mStreamingProcessor->releaseRecordingFrame(mem); 1126} 1127 1128status_t Camera2Client::autoFocus() { 1129 ATRACE_CALL(); 1130 Mutex::Autolock icl(mBinderSerializationLock); 1131 ALOGV("%s: Camera %d", __FUNCTION__, mCameraId); 1132 status_t res; 1133 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 1134 1135 int triggerId; 1136 bool notifyImmediately = false; 1137 bool notifySuccess = false; 1138 { 1139 SharedParameters::Lock l(mParameters); 1140 if (l.mParameters.state < Parameters::PREVIEW) { 1141 return INVALID_OPERATION; 1142 } 1143 1144 /** 1145 * If the camera does not support auto-focus, it is a no-op and 1146 * onAutoFocus(boolean, Camera) callback will be called immediately 1147 * with a fake value of success set to true. 1148 * 1149 * Similarly, if focus mode is set to INFINITY, there's no reason to 1150 * bother the HAL. 1151 */ 1152 if (l.mParameters.focusMode == Parameters::FOCUS_MODE_FIXED || 1153 l.mParameters.focusMode == Parameters::FOCUS_MODE_INFINITY) { 1154 notifyImmediately = true; 1155 notifySuccess = true; 1156 } 1157 /** 1158 * If we're in CAF mode, and AF has already been locked, just fire back 1159 * the callback right away; the HAL would not send a notification since 1160 * no state change would happen on a AF trigger. 1161 */ 1162 if ( (l.mParameters.focusMode == Parameters::FOCUS_MODE_CONTINUOUS_PICTURE || 1163 l.mParameters.focusMode == Parameters::FOCUS_MODE_CONTINUOUS_VIDEO) && 1164 l.mParameters.focusState == ANDROID_CONTROL_AF_STATE_FOCUSED_LOCKED ) { 1165 notifyImmediately = true; 1166 notifySuccess = true; 1167 } 1168 /** 1169 * Send immediate notification back to client 1170 */ 1171 if (notifyImmediately) { 1172 SharedCameraCallbacks::Lock l(mSharedCameraCallbacks); 1173 if (l.mRemoteCallback != 0) { 1174 l.mRemoteCallback->notifyCallback(CAMERA_MSG_FOCUS, 1175 notifySuccess ? 1 : 0, 0); 1176 } 1177 return OK; 1178 } 1179 /** 1180 * Handle quirk mode for AF in scene modes 1181 */ 1182 if (l.mParameters.quirks.triggerAfWithAuto && 1183 l.mParameters.sceneMode != ANDROID_CONTROL_SCENE_MODE_DISABLED && 1184 l.mParameters.focusMode != Parameters::FOCUS_MODE_AUTO && 1185 !l.mParameters.focusingAreas[0].isEmpty()) { 1186 ALOGV("%s: Quirk: Switching from focusMode %d to AUTO", 1187 __FUNCTION__, l.mParameters.focusMode); 1188 l.mParameters.shadowFocusMode = l.mParameters.focusMode; 1189 l.mParameters.focusMode = Parameters::FOCUS_MODE_AUTO; 1190 updateRequests(l.mParameters); 1191 } 1192 1193 l.mParameters.currentAfTriggerId = ++l.mParameters.afTriggerCounter; 1194 triggerId = l.mParameters.currentAfTriggerId; 1195 } 1196 ATRACE_ASYNC_BEGIN(kAutofocusLabel, triggerId); 1197 1198 syncWithDevice(); 1199 1200 mDevice->triggerAutofocus(triggerId); 1201 1202 return OK; 1203} 1204 1205status_t Camera2Client::cancelAutoFocus() { 1206 ATRACE_CALL(); 1207 Mutex::Autolock icl(mBinderSerializationLock); 1208 ALOGV("%s: Camera %d", __FUNCTION__, mCameraId); 1209 status_t res; 1210 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 1211 1212 int triggerId; 1213 { 1214 SharedParameters::Lock l(mParameters); 1215 // Canceling does nothing in FIXED or INFINITY modes 1216 if (l.mParameters.focusMode == Parameters::FOCUS_MODE_FIXED || 1217 l.mParameters.focusMode == Parameters::FOCUS_MODE_INFINITY) { 1218 return OK; 1219 } 1220 1221 // An active AF trigger is canceled 1222 if (l.mParameters.afTriggerCounter == l.mParameters.currentAfTriggerId) { 1223 ATRACE_ASYNC_END(kAutofocusLabel, l.mParameters.currentAfTriggerId); 1224 } 1225 1226 triggerId = ++l.mParameters.afTriggerCounter; 1227 1228 // When using triggerAfWithAuto quirk, may need to reset focus mode to 1229 // the real state at this point. No need to cancel explicitly if 1230 // changing the AF mode. 1231 if (l.mParameters.shadowFocusMode != Parameters::FOCUS_MODE_INVALID) { 1232 ALOGV("%s: Quirk: Restoring focus mode to %d", __FUNCTION__, 1233 l.mParameters.shadowFocusMode); 1234 l.mParameters.focusMode = l.mParameters.shadowFocusMode; 1235 l.mParameters.shadowFocusMode = Parameters::FOCUS_MODE_INVALID; 1236 updateRequests(l.mParameters); 1237 1238 return OK; 1239 } 1240 } 1241 syncWithDevice(); 1242 1243 mDevice->triggerCancelAutofocus(triggerId); 1244 1245 return OK; 1246} 1247 1248status_t Camera2Client::takePicture(int msgType) { 1249 ATRACE_CALL(); 1250 Mutex::Autolock icl(mBinderSerializationLock); 1251 status_t res; 1252 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 1253 1254 int takePictureCounter; 1255 { 1256 SharedParameters::Lock l(mParameters); 1257 switch (l.mParameters.state) { 1258 case Parameters::DISCONNECTED: 1259 case Parameters::STOPPED: 1260 case Parameters::WAITING_FOR_PREVIEW_WINDOW: 1261 ALOGE("%s: Camera %d: Cannot take picture without preview enabled", 1262 __FUNCTION__, mCameraId); 1263 return INVALID_OPERATION; 1264 case Parameters::PREVIEW: 1265 // Good to go for takePicture 1266 res = commandStopFaceDetectionL(l.mParameters); 1267 if (res != OK) { 1268 ALOGE("%s: Camera %d: Unable to stop face detection for still capture", 1269 __FUNCTION__, mCameraId); 1270 return res; 1271 } 1272 l.mParameters.state = Parameters::STILL_CAPTURE; 1273 break; 1274 case Parameters::RECORD: 1275 // Good to go for video snapshot 1276 l.mParameters.state = Parameters::VIDEO_SNAPSHOT; 1277 break; 1278 case Parameters::STILL_CAPTURE: 1279 case Parameters::VIDEO_SNAPSHOT: 1280 ALOGE("%s: Camera %d: Already taking a picture", 1281 __FUNCTION__, mCameraId); 1282 return INVALID_OPERATION; 1283 } 1284 1285 ALOGV("%s: Camera %d: Starting picture capture", __FUNCTION__, mCameraId); 1286 1287 int lastJpegStreamId = mJpegProcessor->getStreamId(); 1288 res = updateProcessorStream(mJpegProcessor, l.mParameters); 1289 if (res != OK) { 1290 ALOGE("%s: Camera %d: Can't set up still image stream: %s (%d)", 1291 __FUNCTION__, mCameraId, strerror(-res), res); 1292 return res; 1293 } 1294 takePictureCounter = ++l.mParameters.takePictureCounter; 1295 1296 // Clear ZSL buffer queue when Jpeg size is changed. 1297 bool jpegStreamChanged = mJpegProcessor->getStreamId() != lastJpegStreamId; 1298 if (l.mParameters.zslMode && jpegStreamChanged) { 1299 ALOGV("%s: Camera %d: Clear ZSL buffer queue when Jpeg size is changed", 1300 __FUNCTION__, mCameraId); 1301 mZslProcessor->clearZslQueue(); 1302 } 1303 } 1304 1305 ATRACE_ASYNC_BEGIN(kTakepictureLabel, takePictureCounter); 1306 1307 // Need HAL to have correct settings before (possibly) triggering precapture 1308 syncWithDevice(); 1309 1310 res = mCaptureSequencer->startCapture(msgType); 1311 if (res != OK) { 1312 ALOGE("%s: Camera %d: Unable to start capture: %s (%d)", 1313 __FUNCTION__, mCameraId, strerror(-res), res); 1314 } 1315 1316 return res; 1317} 1318 1319status_t Camera2Client::setParameters(const String8& params) { 1320 ATRACE_CALL(); 1321 ALOGV("%s: Camera %d", __FUNCTION__, mCameraId); 1322 Mutex::Autolock icl(mBinderSerializationLock); 1323 status_t res; 1324 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 1325 1326 SharedParameters::Lock l(mParameters); 1327 1328 res = l.mParameters.set(params); 1329 if (res != OK) return res; 1330 1331 res = updateRequests(l.mParameters); 1332 1333 return res; 1334} 1335 1336String8 Camera2Client::getParameters() const { 1337 ATRACE_CALL(); 1338 ALOGV("%s: Camera %d", __FUNCTION__, mCameraId); 1339 Mutex::Autolock icl(mBinderSerializationLock); 1340 if ( checkPid(__FUNCTION__) != OK) return String8(); 1341 1342 SharedParameters::ReadLock l(mParameters); 1343 1344 return l.mParameters.get(); 1345} 1346 1347status_t Camera2Client::sendCommand(int32_t cmd, int32_t arg1, int32_t arg2) { 1348 ATRACE_CALL(); 1349 Mutex::Autolock icl(mBinderSerializationLock); 1350 status_t res; 1351 if ( (res = checkPid(__FUNCTION__) ) != OK) return res; 1352 1353 ALOGV("%s: Camera %d: Command %d (%d, %d)", __FUNCTION__, mCameraId, 1354 cmd, arg1, arg2); 1355 1356 switch (cmd) { 1357 case CAMERA_CMD_START_SMOOTH_ZOOM: 1358 return commandStartSmoothZoomL(); 1359 case CAMERA_CMD_STOP_SMOOTH_ZOOM: 1360 return commandStopSmoothZoomL(); 1361 case CAMERA_CMD_SET_DISPLAY_ORIENTATION: 1362 return commandSetDisplayOrientationL(arg1); 1363 case CAMERA_CMD_ENABLE_SHUTTER_SOUND: 1364 return commandEnableShutterSoundL(arg1 == 1); 1365 case CAMERA_CMD_PLAY_RECORDING_SOUND: 1366 return commandPlayRecordingSoundL(); 1367 case CAMERA_CMD_START_FACE_DETECTION: 1368 return commandStartFaceDetectionL(arg1); 1369 case CAMERA_CMD_STOP_FACE_DETECTION: { 1370 SharedParameters::Lock l(mParameters); 1371 return commandStopFaceDetectionL(l.mParameters); 1372 } 1373 case CAMERA_CMD_ENABLE_FOCUS_MOVE_MSG: 1374 return commandEnableFocusMoveMsgL(arg1 == 1); 1375 case CAMERA_CMD_PING: 1376 return commandPingL(); 1377 case CAMERA_CMD_SET_VIDEO_BUFFER_COUNT: 1378 return commandSetVideoBufferCountL(arg1); 1379 default: 1380 ALOGE("%s: Unknown command %d (arguments %d, %d)", 1381 __FUNCTION__, cmd, arg1, arg2); 1382 return BAD_VALUE; 1383 } 1384} 1385 1386status_t Camera2Client::commandStartSmoothZoomL() { 1387 ALOGE("%s: Unimplemented!", __FUNCTION__); 1388 return OK; 1389} 1390 1391status_t Camera2Client::commandStopSmoothZoomL() { 1392 ALOGE("%s: Unimplemented!", __FUNCTION__); 1393 return OK; 1394} 1395 1396status_t Camera2Client::commandSetDisplayOrientationL(int degrees) { 1397 int transform = Parameters::degToTransform(degrees, 1398 mCameraFacing == CAMERA_FACING_FRONT); 1399 if (transform == -1) { 1400 ALOGE("%s: Camera %d: Error setting %d as display orientation value", 1401 __FUNCTION__, mCameraId, degrees); 1402 return BAD_VALUE; 1403 } 1404 SharedParameters::Lock l(mParameters); 1405 if (transform != l.mParameters.previewTransform && 1406 getPreviewStreamId() != NO_STREAM) { 1407 mDevice->setStreamTransform(getPreviewStreamId(), transform); 1408 } 1409 l.mParameters.previewTransform = transform; 1410 return OK; 1411} 1412 1413status_t Camera2Client::commandEnableShutterSoundL(bool enable) { 1414 SharedParameters::Lock l(mParameters); 1415 if (enable) { 1416 l.mParameters.playShutterSound = true; 1417 return OK; 1418 } 1419 1420 // Disabling shutter sound may not be allowed. In that case only 1421 // allow the mediaserver process to disable the sound. 1422 char value[PROPERTY_VALUE_MAX]; 1423 property_get("ro.camera.sound.forced", value, "0"); 1424 if (strncmp(value, "0", 2) != 0) { 1425 // Disabling shutter sound is not allowed. Deny if the current 1426 // process is not mediaserver. 1427 if (getCallingPid() != getpid()) { 1428 ALOGE("Failed to disable shutter sound. Permission denied (pid %d)", 1429 getCallingPid()); 1430 return PERMISSION_DENIED; 1431 } 1432 } 1433 1434 l.mParameters.playShutterSound = false; 1435 return OK; 1436} 1437 1438status_t Camera2Client::commandPlayRecordingSoundL() { 1439 mCameraService->playSound(CameraService::SOUND_RECORDING); 1440 return OK; 1441} 1442 1443status_t Camera2Client::commandStartFaceDetectionL(int /*type*/) { 1444 ALOGV("%s: Camera %d: Starting face detection", 1445 __FUNCTION__, mCameraId); 1446 status_t res; 1447 SharedParameters::Lock l(mParameters); 1448 switch (l.mParameters.state) { 1449 case Parameters::DISCONNECTED: 1450 case Parameters::STOPPED: 1451 case Parameters::WAITING_FOR_PREVIEW_WINDOW: 1452 case Parameters::STILL_CAPTURE: 1453 ALOGE("%s: Camera %d: Cannot start face detection without preview active", 1454 __FUNCTION__, mCameraId); 1455 return INVALID_OPERATION; 1456 case Parameters::PREVIEW: 1457 case Parameters::RECORD: 1458 case Parameters::VIDEO_SNAPSHOT: 1459 // Good to go for starting face detect 1460 break; 1461 } 1462 // Ignoring type 1463 if (l.mParameters.fastInfo.bestFaceDetectMode == 1464 ANDROID_STATISTICS_FACE_DETECT_MODE_OFF) { 1465 ALOGE("%s: Camera %d: Face detection not supported", 1466 __FUNCTION__, mCameraId); 1467 return BAD_VALUE; 1468 } 1469 if (l.mParameters.enableFaceDetect) return OK; 1470 1471 l.mParameters.enableFaceDetect = true; 1472 1473 res = updateRequests(l.mParameters); 1474 1475 return res; 1476} 1477 1478status_t Camera2Client::commandStopFaceDetectionL(Parameters ¶ms) { 1479 status_t res = OK; 1480 ALOGV("%s: Camera %d: Stopping face detection", 1481 __FUNCTION__, mCameraId); 1482 1483 if (!params.enableFaceDetect) return OK; 1484 1485 params.enableFaceDetect = false; 1486 1487 if (params.state == Parameters::PREVIEW 1488 || params.state == Parameters::RECORD 1489 || params.state == Parameters::VIDEO_SNAPSHOT) { 1490 res = updateRequests(params); 1491 } 1492 1493 return res; 1494} 1495 1496status_t Camera2Client::commandEnableFocusMoveMsgL(bool enable) { 1497 SharedParameters::Lock l(mParameters); 1498 l.mParameters.enableFocusMoveMessages = enable; 1499 1500 return OK; 1501} 1502 1503status_t Camera2Client::commandPingL() { 1504 // Always ping back if access is proper and device is alive 1505 SharedParameters::Lock l(mParameters); 1506 if (l.mParameters.state != Parameters::DISCONNECTED) { 1507 return OK; 1508 } else { 1509 return NO_INIT; 1510 } 1511} 1512 1513status_t Camera2Client::commandSetVideoBufferCountL(size_t count) { 1514 if (recordingEnabledL()) { 1515 ALOGE("%s: Camera %d: Error setting video buffer count after " 1516 "recording was started", __FUNCTION__, mCameraId); 1517 return INVALID_OPERATION; 1518 } 1519 1520 return mStreamingProcessor->setRecordingBufferCount(count); 1521} 1522 1523/** Device-related methods */ 1524void Camera2Client::notifyAutoFocus(uint8_t newState, int triggerId) { 1525 ALOGV("%s: Autofocus state now %d, last trigger %d", 1526 __FUNCTION__, newState, triggerId); 1527 bool sendCompletedMessage = false; 1528 bool sendMovingMessage = false; 1529 1530 bool success = false; 1531 bool afInMotion = false; 1532 { 1533 SharedParameters::Lock l(mParameters); 1534 // Trace end of AF state 1535 char tmp[32]; 1536 if (l.mParameters.afStateCounter > 0) { 1537 camera_metadata_enum_snprint( 1538 ANDROID_CONTROL_AF_STATE, l.mParameters.focusState, tmp, sizeof(tmp)); 1539 ATRACE_ASYNC_END(tmp, l.mParameters.afStateCounter); 1540 } 1541 1542 // Update state 1543 l.mParameters.focusState = newState; 1544 l.mParameters.afStateCounter++; 1545 1546 // Trace start of AF state 1547 1548 camera_metadata_enum_snprint( 1549 ANDROID_CONTROL_AF_STATE, l.mParameters.focusState, tmp, sizeof(tmp)); 1550 ATRACE_ASYNC_BEGIN(tmp, l.mParameters.afStateCounter); 1551 1552 switch (l.mParameters.focusMode) { 1553 case Parameters::FOCUS_MODE_AUTO: 1554 case Parameters::FOCUS_MODE_MACRO: 1555 // Don't send notifications upstream if they're not for the current AF 1556 // trigger. For example, if cancel was called in between, or if we 1557 // already sent a notification about this AF call. 1558 if (triggerId != l.mParameters.currentAfTriggerId) break; 1559 switch (newState) { 1560 case ANDROID_CONTROL_AF_STATE_FOCUSED_LOCKED: 1561 success = true; 1562 // no break 1563 case ANDROID_CONTROL_AF_STATE_NOT_FOCUSED_LOCKED: 1564 sendCompletedMessage = true; 1565 l.mParameters.currentAfTriggerId = -1; 1566 break; 1567 case ANDROID_CONTROL_AF_STATE_ACTIVE_SCAN: 1568 // Just starting focusing, ignore 1569 break; 1570 case ANDROID_CONTROL_AF_STATE_INACTIVE: 1571 case ANDROID_CONTROL_AF_STATE_PASSIVE_SCAN: 1572 case ANDROID_CONTROL_AF_STATE_PASSIVE_FOCUSED: 1573 case ANDROID_CONTROL_AF_STATE_PASSIVE_UNFOCUSED: 1574 default: 1575 // Unexpected in AUTO/MACRO mode 1576 ALOGE("%s: Unexpected AF state transition in AUTO/MACRO mode: %d", 1577 __FUNCTION__, newState); 1578 break; 1579 } 1580 break; 1581 case Parameters::FOCUS_MODE_CONTINUOUS_VIDEO: 1582 case Parameters::FOCUS_MODE_CONTINUOUS_PICTURE: 1583 switch (newState) { 1584 case ANDROID_CONTROL_AF_STATE_FOCUSED_LOCKED: 1585 success = true; 1586 // no break 1587 case ANDROID_CONTROL_AF_STATE_NOT_FOCUSED_LOCKED: 1588 // Don't send notifications upstream if they're not for 1589 // the current AF trigger. For example, if cancel was 1590 // called in between, or if we already sent a 1591 // notification about this AF call. 1592 // Send both a 'AF done' callback and a 'AF move' callback 1593 if (triggerId != l.mParameters.currentAfTriggerId) break; 1594 sendCompletedMessage = true; 1595 afInMotion = false; 1596 if (l.mParameters.enableFocusMoveMessages && 1597 l.mParameters.afInMotion) { 1598 sendMovingMessage = true; 1599 } 1600 l.mParameters.currentAfTriggerId = -1; 1601 break; 1602 case ANDROID_CONTROL_AF_STATE_INACTIVE: 1603 // Cancel was called, or we switched state; care if 1604 // currently moving 1605 afInMotion = false; 1606 if (l.mParameters.enableFocusMoveMessages && 1607 l.mParameters.afInMotion) { 1608 sendMovingMessage = true; 1609 } 1610 break; 1611 case ANDROID_CONTROL_AF_STATE_PASSIVE_SCAN: 1612 // Start passive scan, inform upstream 1613 afInMotion = true; 1614 // no break 1615 case ANDROID_CONTROL_AF_STATE_PASSIVE_FOCUSED: 1616 case ANDROID_CONTROL_AF_STATE_PASSIVE_UNFOCUSED: 1617 // Stop passive scan, inform upstream 1618 if (l.mParameters.enableFocusMoveMessages) { 1619 sendMovingMessage = true; 1620 } 1621 break; 1622 } 1623 l.mParameters.afInMotion = afInMotion; 1624 break; 1625 case Parameters::FOCUS_MODE_EDOF: 1626 case Parameters::FOCUS_MODE_INFINITY: 1627 case Parameters::FOCUS_MODE_FIXED: 1628 default: 1629 if (newState != ANDROID_CONTROL_AF_STATE_INACTIVE) { 1630 ALOGE("%s: Unexpected AF state change %d " 1631 "(ID %d) in focus mode %d", 1632 __FUNCTION__, newState, triggerId, 1633 l.mParameters.focusMode); 1634 } 1635 } 1636 } 1637 if (sendMovingMessage) { 1638 SharedCameraCallbacks::Lock l(mSharedCameraCallbacks); 1639 if (l.mRemoteCallback != 0) { 1640 l.mRemoteCallback->notifyCallback(CAMERA_MSG_FOCUS_MOVE, 1641 afInMotion ? 1 : 0, 0); 1642 } 1643 } 1644 if (sendCompletedMessage) { 1645 ATRACE_ASYNC_END(kAutofocusLabel, triggerId); 1646 SharedCameraCallbacks::Lock l(mSharedCameraCallbacks); 1647 if (l.mRemoteCallback != 0) { 1648 l.mRemoteCallback->notifyCallback(CAMERA_MSG_FOCUS, 1649 success ? 1 : 0, 0); 1650 } 1651 } 1652} 1653 1654void Camera2Client::notifyAutoExposure(uint8_t newState, int triggerId) { 1655 ALOGV("%s: Autoexposure state now %d, last trigger %d", 1656 __FUNCTION__, newState, triggerId); 1657 mCaptureSequencer->notifyAutoExposure(newState, triggerId); 1658} 1659 1660camera2::SharedParameters& Camera2Client::getParameters() { 1661 return mParameters; 1662} 1663 1664int Camera2Client::getPreviewStreamId() const { 1665 return mStreamingProcessor->getPreviewStreamId(); 1666} 1667 1668int Camera2Client::getCaptureStreamId() const { 1669 return mJpegProcessor->getStreamId(); 1670} 1671 1672int Camera2Client::getCallbackStreamId() const { 1673 return mCallbackProcessor->getStreamId(); 1674} 1675 1676int Camera2Client::getRecordingStreamId() const { 1677 return mStreamingProcessor->getRecordingStreamId(); 1678} 1679 1680int Camera2Client::getZslStreamId() const { 1681 return mZslProcessor->getStreamId(); 1682} 1683 1684status_t Camera2Client::registerFrameListener(int32_t minId, int32_t maxId, 1685 wp<camera2::FrameProcessor::FilteredListener> listener, bool sendPartials) { 1686 return mFrameProcessor->registerListener(minId, maxId, listener, sendPartials); 1687} 1688 1689status_t Camera2Client::removeFrameListener(int32_t minId, int32_t maxId, 1690 wp<camera2::FrameProcessor::FilteredListener> listener) { 1691 return mFrameProcessor->removeListener(minId, maxId, listener); 1692} 1693 1694status_t Camera2Client::stopStream() { 1695 return mStreamingProcessor->stopStream(); 1696} 1697 1698const int32_t Camera2Client::kPreviewRequestIdStart; 1699const int32_t Camera2Client::kPreviewRequestIdEnd; 1700const int32_t Camera2Client::kRecordingRequestIdStart; 1701const int32_t Camera2Client::kRecordingRequestIdEnd; 1702const int32_t Camera2Client::kCaptureRequestIdStart; 1703const int32_t Camera2Client::kCaptureRequestIdEnd; 1704 1705/** Utility methods */ 1706 1707status_t Camera2Client::updateRequests(Parameters ¶ms) { 1708 status_t res; 1709 1710 ALOGV("%s: Camera %d: state = %d", __FUNCTION__, getCameraId(), params.state); 1711 1712 res = mStreamingProcessor->incrementStreamingIds(); 1713 if (res != OK) { 1714 ALOGE("%s: Camera %d: Unable to increment request IDs: %s (%d)", 1715 __FUNCTION__, mCameraId, strerror(-res), res); 1716 return res; 1717 } 1718 1719 res = mStreamingProcessor->updatePreviewRequest(params); 1720 if (res != OK) { 1721 ALOGE("%s: Camera %d: Unable to update preview request: %s (%d)", 1722 __FUNCTION__, mCameraId, strerror(-res), res); 1723 return res; 1724 } 1725 res = mStreamingProcessor->updateRecordingRequest(params); 1726 if (res != OK) { 1727 ALOGE("%s: Camera %d: Unable to update recording request: %s (%d)", 1728 __FUNCTION__, mCameraId, strerror(-res), res); 1729 return res; 1730 } 1731 1732 if (params.state == Parameters::PREVIEW) { 1733 res = startPreviewL(params, true); 1734 if (res != OK) { 1735 ALOGE("%s: Camera %d: Error streaming new preview request: %s (%d)", 1736 __FUNCTION__, mCameraId, strerror(-res), res); 1737 return res; 1738 } 1739 } else if (params.state == Parameters::RECORD || 1740 params.state == Parameters::VIDEO_SNAPSHOT) { 1741 res = startRecordingL(params, true); 1742 if (res != OK) { 1743 ALOGE("%s: Camera %d: Error streaming new record request: %s (%d)", 1744 __FUNCTION__, mCameraId, strerror(-res), res); 1745 return res; 1746 } 1747 } 1748 return res; 1749} 1750 1751 1752size_t Camera2Client::calculateBufferSize(int width, int height, 1753 int format, int stride) { 1754 switch (format) { 1755 case HAL_PIXEL_FORMAT_YCbCr_422_SP: // NV16 1756 return width * height * 2; 1757 case HAL_PIXEL_FORMAT_YCrCb_420_SP: // NV21 1758 return width * height * 3 / 2; 1759 case HAL_PIXEL_FORMAT_YCbCr_422_I: // YUY2 1760 return width * height * 2; 1761 case HAL_PIXEL_FORMAT_YV12: { // YV12 1762 size_t ySize = stride * height; 1763 size_t uvStride = (stride / 2 + 0xF) & ~0xF; 1764 size_t uvSize = uvStride * height / 2; 1765 return ySize + uvSize * 2; 1766 } 1767 case HAL_PIXEL_FORMAT_RGB_565: 1768 return width * height * 2; 1769 case HAL_PIXEL_FORMAT_RGBA_8888: 1770 return width * height * 4; 1771 case HAL_PIXEL_FORMAT_RAW_SENSOR: 1772 return width * height * 2; 1773 default: 1774 ALOGE("%s: Unknown preview format: %x", 1775 __FUNCTION__, format); 1776 return 0; 1777 } 1778} 1779 1780status_t Camera2Client::syncWithDevice() { 1781 ATRACE_CALL(); 1782 const nsecs_t kMaxSyncTimeout = 500000000; // 500 ms 1783 status_t res; 1784 1785 int32_t activeRequestId = mStreamingProcessor->getActiveRequestId(); 1786 if (activeRequestId == 0) return OK; 1787 1788 res = mDevice->waitUntilRequestReceived(activeRequestId, kMaxSyncTimeout); 1789 if (res == TIMED_OUT) { 1790 ALOGE("%s: Camera %d: Timed out waiting sync with HAL", 1791 __FUNCTION__, mCameraId); 1792 } else if (res != OK) { 1793 ALOGE("%s: Camera %d: Error while waiting to sync with HAL", 1794 __FUNCTION__, mCameraId); 1795 } 1796 return res; 1797} 1798 1799template <typename ProcessorT> 1800status_t Camera2Client::updateProcessorStream(sp<ProcessorT> processor, 1801 camera2::Parameters params) { 1802 // No default template arguments until C++11, so we need this overload 1803 return updateProcessorStream<ProcessorT, &ProcessorT::updateStream>( 1804 processor, params); 1805} 1806 1807template <typename ProcessorT, 1808 status_t (ProcessorT::*updateStreamF)(const Parameters &)> 1809status_t Camera2Client::updateProcessorStream(sp<ProcessorT> processor, 1810 Parameters params) { 1811 status_t res; 1812 1813 // Get raw pointer since sp<T> doesn't have operator->* 1814 ProcessorT *processorPtr = processor.get(); 1815 res = (processorPtr->*updateStreamF)(params); 1816 1817 /** 1818 * Can't update the stream if it's busy? 1819 * 1820 * Then we need to stop the device (by temporarily clearing the request 1821 * queue) and then try again. Resume streaming once we're done. 1822 */ 1823 if (res == -EBUSY) { 1824 ALOGV("%s: Camera %d: Pausing to update stream", __FUNCTION__, 1825 mCameraId); 1826 res = mStreamingProcessor->togglePauseStream(/*pause*/true); 1827 if (res != OK) { 1828 ALOGE("%s: Camera %d: Can't pause streaming: %s (%d)", 1829 __FUNCTION__, mCameraId, strerror(-res), res); 1830 } 1831 1832 res = mDevice->waitUntilDrained(); 1833 if (res != OK) { 1834 ALOGE("%s: Camera %d: Waiting to stop streaming failed: %s (%d)", 1835 __FUNCTION__, mCameraId, strerror(-res), res); 1836 } 1837 1838 res = (processorPtr->*updateStreamF)(params); 1839 if (res != OK) { 1840 ALOGE("%s: Camera %d: Failed to update processing stream " 1841 " despite having halted streaming first: %s (%d)", 1842 __FUNCTION__, mCameraId, strerror(-res), res); 1843 } 1844 1845 res = mStreamingProcessor->togglePauseStream(/*pause*/false); 1846 if (res != OK) { 1847 ALOGE("%s: Camera %d: Can't unpause streaming: %s (%d)", 1848 __FUNCTION__, mCameraId, strerror(-res), res); 1849 } 1850 } 1851 1852 return res; 1853} 1854 1855const char* Camera2Client::kAutofocusLabel = "autofocus"; 1856const char* Camera2Client::kTakepictureLabel = "take_picture"; 1857 1858} // namespace android 1859