Camera2Client.cpp revision 25a0aef19e170d2695f64b4c48296e7914155a88
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 &params, 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 &params, 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->deleteStream();
829    }
830
831    outputStreams.push(getPreviewStreamId());
832
833    if (!params.recordingHint) {
834        if (!restart) {
835            res = mStreamingProcessor->updatePreviewRequest(params);
836            if (res != OK) {
837                ALOGE("%s: Camera %d: Can't set up preview request: "
838                        "%s (%d)", __FUNCTION__, mCameraId,
839                        strerror(-res), res);
840                return res;
841            }
842        }
843        res = mStreamingProcessor->startStream(StreamingProcessor::PREVIEW,
844                outputStreams);
845    } else {
846        if (!restart) {
847            res = mStreamingProcessor->updateRecordingRequest(params);
848            if (res != OK) {
849                ALOGE("%s: Camera %d: Can't set up preview request with "
850                        "record hint: %s (%d)", __FUNCTION__, mCameraId,
851                        strerror(-res), res);
852                return res;
853            }
854        }
855        res = mStreamingProcessor->startStream(StreamingProcessor::RECORD,
856                outputStreams);
857    }
858    if (res != OK) {
859        ALOGE("%s: Camera %d: Unable to start streaming preview: %s (%d)",
860                __FUNCTION__, mCameraId, strerror(-res), res);
861        return res;
862    }
863
864    params.state = Parameters::PREVIEW;
865    return OK;
866}
867
868void Camera2Client::stopPreview() {
869    ATRACE_CALL();
870    ALOGV("%s: E", __FUNCTION__);
871    Mutex::Autolock icl(mBinderSerializationLock);
872    status_t res;
873    if ( (res = checkPid(__FUNCTION__) ) != OK) return;
874    stopPreviewL();
875}
876
877void Camera2Client::stopPreviewL() {
878    ATRACE_CALL();
879    status_t res;
880    const nsecs_t kStopCaptureTimeout = 3000000000LL; // 3 seconds
881    Parameters::State state;
882    {
883        SharedParameters::Lock l(mParameters);
884        state = l.mParameters.state;
885    }
886
887    switch (state) {
888        case Parameters::DISCONNECTED:
889            // Nothing to do.
890            break;
891        case Parameters::STOPPED:
892        case Parameters::VIDEO_SNAPSHOT:
893        case Parameters::STILL_CAPTURE:
894            mCaptureSequencer->waitUntilIdle(kStopCaptureTimeout);
895            // no break
896        case Parameters::RECORD:
897        case Parameters::PREVIEW:
898            syncWithDevice();
899            res = stopStream();
900            if (res != OK) {
901                ALOGE("%s: Camera %d: Can't stop streaming: %s (%d)",
902                        __FUNCTION__, mCameraId, strerror(-res), res);
903            }
904            res = mDevice->waitUntilDrained();
905            if (res != OK) {
906                ALOGE("%s: Camera %d: Waiting to stop streaming failed: %s (%d)",
907                        __FUNCTION__, mCameraId, strerror(-res), res);
908            }
909            // no break
910        case Parameters::WAITING_FOR_PREVIEW_WINDOW: {
911            SharedParameters::Lock l(mParameters);
912            l.mParameters.state = Parameters::STOPPED;
913            commandStopFaceDetectionL(l.mParameters);
914            break;
915        }
916        default:
917            ALOGE("%s: Camera %d: Unknown state %d", __FUNCTION__, mCameraId,
918                    state);
919    }
920}
921
922bool Camera2Client::previewEnabled() {
923    ATRACE_CALL();
924    Mutex::Autolock icl(mBinderSerializationLock);
925    status_t res;
926    if ( (res = checkPid(__FUNCTION__) ) != OK) return false;
927
928    SharedParameters::Lock l(mParameters);
929    return l.mParameters.state == Parameters::PREVIEW;
930}
931
932status_t Camera2Client::storeMetaDataInBuffers(bool enabled) {
933    ATRACE_CALL();
934    Mutex::Autolock icl(mBinderSerializationLock);
935    status_t res;
936    if ( (res = checkPid(__FUNCTION__) ) != OK) return res;
937
938    SharedParameters::Lock l(mParameters);
939    switch (l.mParameters.state) {
940        case Parameters::RECORD:
941        case Parameters::VIDEO_SNAPSHOT:
942            ALOGE("%s: Camera %d: Can't be called in state %s",
943                    __FUNCTION__, mCameraId,
944                    Parameters::getStateName(l.mParameters.state));
945            return INVALID_OPERATION;
946        default:
947            // OK
948            break;
949    }
950
951    l.mParameters.storeMetadataInBuffers = enabled;
952
953    return OK;
954}
955
956status_t Camera2Client::startRecording() {
957    ATRACE_CALL();
958    ALOGV("%s: E", __FUNCTION__);
959    Mutex::Autolock icl(mBinderSerializationLock);
960    status_t res;
961    if ( (res = checkPid(__FUNCTION__) ) != OK) return res;
962    SharedParameters::Lock l(mParameters);
963
964    return startRecordingL(l.mParameters, false);
965}
966
967status_t Camera2Client::startRecordingL(Parameters &params, bool restart) {
968    status_t res;
969
970    ALOGV("%s: state == %d, restart = %d", __FUNCTION__, params.state, restart);
971
972    switch (params.state) {
973        case Parameters::STOPPED:
974            res = startPreviewL(params, false);
975            if (res != OK) return res;
976            break;
977        case Parameters::PREVIEW:
978            // Ready to go
979            break;
980        case Parameters::RECORD:
981        case Parameters::VIDEO_SNAPSHOT:
982            // OK to call this when recording is already on, just skip unless
983            // we're looking to restart
984            if (!restart) return OK;
985            break;
986        default:
987            ALOGE("%s: Camera %d: Can't start recording in state %s",
988                    __FUNCTION__, mCameraId,
989                    Parameters::getStateName(params.state));
990            return INVALID_OPERATION;
991    };
992
993    if (!params.storeMetadataInBuffers) {
994        ALOGE("%s: Camera %d: Recording only supported in metadata mode, but "
995                "non-metadata recording mode requested!", __FUNCTION__,
996                mCameraId);
997        return INVALID_OPERATION;
998    }
999
1000    if (!restart) {
1001        mCameraService->playSound(CameraService::SOUND_RECORDING);
1002        mStreamingProcessor->updateRecordingRequest(params);
1003        if (res != OK) {
1004            ALOGE("%s: Camera %d: Unable to update recording request: %s (%d)",
1005                    __FUNCTION__, mCameraId, strerror(-res), res);
1006            return res;
1007        }
1008    }
1009
1010    // Not all devices can support a preview callback stream and a recording
1011    // stream at the same time, so assume none of them can.
1012    if (mCallbackProcessor->getStreamId() != NO_STREAM) {
1013        ALOGV("%s: Camera %d: Clearing out callback stream before "
1014                "creating recording stream", __FUNCTION__, mCameraId);
1015        res = mStreamingProcessor->stopStream();
1016        if (res != OK) {
1017            ALOGE("%s: Camera %d: Can't stop streaming to delete callback stream",
1018                    __FUNCTION__, mCameraId);
1019            return res;
1020        }
1021        res = mCallbackProcessor->deleteStream();
1022        if (res != OK) {
1023            ALOGE("%s: Camera %d: Unable to delete callback stream before "
1024                    "record: %s (%d)", __FUNCTION__, mCameraId,
1025                    strerror(-res), res);
1026            return res;
1027        }
1028    }
1029    // Disable callbacks if they're enabled; can't record and use callbacks,
1030    // and we can't fail record start without stagefright asserting.
1031    params.previewCallbackFlags = 0;
1032
1033    res = updateProcessorStream<
1034            StreamingProcessor,
1035            &StreamingProcessor::updateRecordingStream>(mStreamingProcessor,
1036                                                        params);
1037    if (res != OK) {
1038        ALOGE("%s: Camera %d: Unable to update recording stream: %s (%d)",
1039                __FUNCTION__, mCameraId, strerror(-res), res);
1040        return res;
1041    }
1042
1043    Vector<int32_t> outputStreams;
1044    outputStreams.push(getPreviewStreamId());
1045    outputStreams.push(getRecordingStreamId());
1046
1047    res = mStreamingProcessor->startStream(StreamingProcessor::RECORD,
1048            outputStreams);
1049    if (res != OK) {
1050        ALOGE("%s: Camera %d: Unable to start recording stream: %s (%d)",
1051                __FUNCTION__, mCameraId, strerror(-res), res);
1052        return res;
1053    }
1054
1055    if (params.state < Parameters::RECORD) {
1056        params.state = Parameters::RECORD;
1057    }
1058
1059    return OK;
1060}
1061
1062void Camera2Client::stopRecording() {
1063    ATRACE_CALL();
1064    ALOGV("%s: E", __FUNCTION__);
1065    Mutex::Autolock icl(mBinderSerializationLock);
1066    SharedParameters::Lock l(mParameters);
1067
1068    status_t res;
1069    if ( (res = checkPid(__FUNCTION__) ) != OK) return;
1070
1071    switch (l.mParameters.state) {
1072        case Parameters::RECORD:
1073            // OK to stop
1074            break;
1075        case Parameters::STOPPED:
1076        case Parameters::PREVIEW:
1077        case Parameters::STILL_CAPTURE:
1078        case Parameters::VIDEO_SNAPSHOT:
1079        default:
1080            ALOGE("%s: Camera %d: Can't stop recording in state %s",
1081                    __FUNCTION__, mCameraId,
1082                    Parameters::getStateName(l.mParameters.state));
1083            return;
1084    };
1085
1086    mCameraService->playSound(CameraService::SOUND_RECORDING);
1087
1088    res = startPreviewL(l.mParameters, true);
1089    if (res != OK) {
1090        ALOGE("%s: Camera %d: Unable to return to preview",
1091                __FUNCTION__, mCameraId);
1092    }
1093}
1094
1095bool Camera2Client::recordingEnabled() {
1096    ATRACE_CALL();
1097    Mutex::Autolock icl(mBinderSerializationLock);
1098
1099    if ( checkPid(__FUNCTION__) != OK) return false;
1100
1101    return recordingEnabledL();
1102}
1103
1104bool Camera2Client::recordingEnabledL() {
1105    ATRACE_CALL();
1106    SharedParameters::Lock l(mParameters);
1107
1108    return (l.mParameters.state == Parameters::RECORD
1109            || l.mParameters.state == Parameters::VIDEO_SNAPSHOT);
1110}
1111
1112void Camera2Client::releaseRecordingFrame(const sp<IMemory>& mem) {
1113    ATRACE_CALL();
1114    Mutex::Autolock icl(mBinderSerializationLock);
1115    if ( checkPid(__FUNCTION__) != OK) return;
1116
1117    mStreamingProcessor->releaseRecordingFrame(mem);
1118}
1119
1120status_t Camera2Client::autoFocus() {
1121    ATRACE_CALL();
1122    Mutex::Autolock icl(mBinderSerializationLock);
1123    ALOGV("%s: Camera %d", __FUNCTION__, mCameraId);
1124    status_t res;
1125    if ( (res = checkPid(__FUNCTION__) ) != OK) return res;
1126
1127    int triggerId;
1128    bool notifyImmediately = false;
1129    bool notifySuccess = false;
1130    {
1131        SharedParameters::Lock l(mParameters);
1132        if (l.mParameters.state < Parameters::PREVIEW) {
1133            return INVALID_OPERATION;
1134        }
1135
1136        /**
1137          * If the camera does not support auto-focus, it is a no-op and
1138          * onAutoFocus(boolean, Camera) callback will be called immediately
1139          * with a fake value of success set to true.
1140          *
1141          * Similarly, if focus mode is set to INFINITY, there's no reason to
1142          * bother the HAL.
1143          */
1144        if (l.mParameters.focusMode == Parameters::FOCUS_MODE_FIXED ||
1145                l.mParameters.focusMode == Parameters::FOCUS_MODE_INFINITY) {
1146            notifyImmediately = true;
1147            notifySuccess = true;
1148        }
1149        /**
1150         * If we're in CAF mode, and AF has already been locked, just fire back
1151         * the callback right away; the HAL would not send a notification since
1152         * no state change would happen on a AF trigger.
1153         */
1154        if ( (l.mParameters.focusMode == Parameters::FOCUS_MODE_CONTINUOUS_PICTURE ||
1155                l.mParameters.focusMode == Parameters::FOCUS_MODE_CONTINUOUS_VIDEO) &&
1156                l.mParameters.focusState == ANDROID_CONTROL_AF_STATE_FOCUSED_LOCKED ) {
1157            notifyImmediately = true;
1158            notifySuccess = true;
1159        }
1160        /**
1161         * Send immediate notification back to client
1162         */
1163        if (notifyImmediately) {
1164            SharedCameraCallbacks::Lock l(mSharedCameraCallbacks);
1165            if (l.mRemoteCallback != 0) {
1166                l.mRemoteCallback->notifyCallback(CAMERA_MSG_FOCUS,
1167                        notifySuccess ? 1 : 0, 0);
1168            }
1169            return OK;
1170        }
1171        /**
1172         * Handle quirk mode for AF in scene modes
1173         */
1174        if (l.mParameters.quirks.triggerAfWithAuto &&
1175                l.mParameters.sceneMode != ANDROID_CONTROL_SCENE_MODE_DISABLED &&
1176                l.mParameters.focusMode != Parameters::FOCUS_MODE_AUTO &&
1177                !l.mParameters.focusingAreas[0].isEmpty()) {
1178            ALOGV("%s: Quirk: Switching from focusMode %d to AUTO",
1179                    __FUNCTION__, l.mParameters.focusMode);
1180            l.mParameters.shadowFocusMode = l.mParameters.focusMode;
1181            l.mParameters.focusMode = Parameters::FOCUS_MODE_AUTO;
1182            updateRequests(l.mParameters);
1183        }
1184
1185        l.mParameters.currentAfTriggerId = ++l.mParameters.afTriggerCounter;
1186        triggerId = l.mParameters.currentAfTriggerId;
1187    }
1188    ATRACE_ASYNC_BEGIN(kAutofocusLabel, triggerId);
1189
1190    syncWithDevice();
1191
1192    mDevice->triggerAutofocus(triggerId);
1193
1194    return OK;
1195}
1196
1197status_t Camera2Client::cancelAutoFocus() {
1198    ATRACE_CALL();
1199    Mutex::Autolock icl(mBinderSerializationLock);
1200    ALOGV("%s: Camera %d", __FUNCTION__, mCameraId);
1201    status_t res;
1202    if ( (res = checkPid(__FUNCTION__) ) != OK) return res;
1203
1204    int triggerId;
1205    {
1206        SharedParameters::Lock l(mParameters);
1207        // Canceling does nothing in FIXED or INFINITY modes
1208        if (l.mParameters.focusMode == Parameters::FOCUS_MODE_FIXED ||
1209                l.mParameters.focusMode == Parameters::FOCUS_MODE_INFINITY) {
1210            return OK;
1211        }
1212
1213        // An active AF trigger is canceled
1214        if (l.mParameters.afTriggerCounter == l.mParameters.currentAfTriggerId) {
1215            ATRACE_ASYNC_END(kAutofocusLabel, l.mParameters.currentAfTriggerId);
1216        }
1217
1218        triggerId = ++l.mParameters.afTriggerCounter;
1219
1220        // When using triggerAfWithAuto quirk, may need to reset focus mode to
1221        // the real state at this point. No need to cancel explicitly if
1222        // changing the AF mode.
1223        if (l.mParameters.shadowFocusMode != Parameters::FOCUS_MODE_INVALID) {
1224            ALOGV("%s: Quirk: Restoring focus mode to %d", __FUNCTION__,
1225                    l.mParameters.shadowFocusMode);
1226            l.mParameters.focusMode = l.mParameters.shadowFocusMode;
1227            l.mParameters.shadowFocusMode = Parameters::FOCUS_MODE_INVALID;
1228            updateRequests(l.mParameters);
1229
1230            return OK;
1231        }
1232    }
1233    syncWithDevice();
1234
1235    mDevice->triggerCancelAutofocus(triggerId);
1236
1237    return OK;
1238}
1239
1240status_t Camera2Client::takePicture(int msgType) {
1241    ATRACE_CALL();
1242    Mutex::Autolock icl(mBinderSerializationLock);
1243    status_t res;
1244    if ( (res = checkPid(__FUNCTION__) ) != OK) return res;
1245
1246    int takePictureCounter;
1247    {
1248        SharedParameters::Lock l(mParameters);
1249        switch (l.mParameters.state) {
1250            case Parameters::DISCONNECTED:
1251            case Parameters::STOPPED:
1252            case Parameters::WAITING_FOR_PREVIEW_WINDOW:
1253                ALOGE("%s: Camera %d: Cannot take picture without preview enabled",
1254                        __FUNCTION__, mCameraId);
1255                return INVALID_OPERATION;
1256            case Parameters::PREVIEW:
1257                // Good to go for takePicture
1258                res = commandStopFaceDetectionL(l.mParameters);
1259                if (res != OK) {
1260                    ALOGE("%s: Camera %d: Unable to stop face detection for still capture",
1261                            __FUNCTION__, mCameraId);
1262                    return res;
1263                }
1264                l.mParameters.state = Parameters::STILL_CAPTURE;
1265                break;
1266            case Parameters::RECORD:
1267                // Good to go for video snapshot
1268                l.mParameters.state = Parameters::VIDEO_SNAPSHOT;
1269                break;
1270            case Parameters::STILL_CAPTURE:
1271            case Parameters::VIDEO_SNAPSHOT:
1272                ALOGE("%s: Camera %d: Already taking a picture",
1273                        __FUNCTION__, mCameraId);
1274                return INVALID_OPERATION;
1275        }
1276
1277        ALOGV("%s: Camera %d: Starting picture capture", __FUNCTION__, mCameraId);
1278
1279        int lastJpegStreamId = mJpegProcessor->getStreamId();
1280        res = updateProcessorStream(mJpegProcessor, l.mParameters);
1281        if (res != OK) {
1282            ALOGE("%s: Camera %d: Can't set up still image stream: %s (%d)",
1283                    __FUNCTION__, mCameraId, strerror(-res), res);
1284            return res;
1285        }
1286        takePictureCounter = ++l.mParameters.takePictureCounter;
1287
1288        // Clear ZSL buffer queue when Jpeg size is changed.
1289        bool jpegStreamChanged = mJpegProcessor->getStreamId() != lastJpegStreamId;
1290        if (l.mParameters.zslMode && jpegStreamChanged) {
1291            ALOGV("%s: Camera %d: Clear ZSL buffer queue when Jpeg size is changed",
1292                    __FUNCTION__, mCameraId);
1293            mZslProcessor->clearZslQueue();
1294        }
1295    }
1296
1297    ATRACE_ASYNC_BEGIN(kTakepictureLabel, takePictureCounter);
1298
1299    // Need HAL to have correct settings before (possibly) triggering precapture
1300    syncWithDevice();
1301
1302    res = mCaptureSequencer->startCapture(msgType);
1303    if (res != OK) {
1304        ALOGE("%s: Camera %d: Unable to start capture: %s (%d)",
1305                __FUNCTION__, mCameraId, strerror(-res), res);
1306    }
1307
1308    return res;
1309}
1310
1311status_t Camera2Client::setParameters(const String8& params) {
1312    ATRACE_CALL();
1313    ALOGV("%s: Camera %d", __FUNCTION__, mCameraId);
1314    Mutex::Autolock icl(mBinderSerializationLock);
1315    status_t res;
1316    if ( (res = checkPid(__FUNCTION__) ) != OK) return res;
1317
1318    SharedParameters::Lock l(mParameters);
1319
1320    res = l.mParameters.set(params);
1321    if (res != OK) return res;
1322
1323    res = updateRequests(l.mParameters);
1324
1325    return res;
1326}
1327
1328String8 Camera2Client::getParameters() const {
1329    ATRACE_CALL();
1330    ALOGV("%s: Camera %d", __FUNCTION__, mCameraId);
1331    Mutex::Autolock icl(mBinderSerializationLock);
1332    if ( checkPid(__FUNCTION__) != OK) return String8();
1333
1334    SharedParameters::ReadLock l(mParameters);
1335
1336    return l.mParameters.get();
1337}
1338
1339status_t Camera2Client::sendCommand(int32_t cmd, int32_t arg1, int32_t arg2) {
1340    ATRACE_CALL();
1341    Mutex::Autolock icl(mBinderSerializationLock);
1342    status_t res;
1343    if ( (res = checkPid(__FUNCTION__) ) != OK) return res;
1344
1345    ALOGV("%s: Camera %d: Command %d (%d, %d)", __FUNCTION__, mCameraId,
1346            cmd, arg1, arg2);
1347
1348    switch (cmd) {
1349        case CAMERA_CMD_START_SMOOTH_ZOOM:
1350            return commandStartSmoothZoomL();
1351        case CAMERA_CMD_STOP_SMOOTH_ZOOM:
1352            return commandStopSmoothZoomL();
1353        case CAMERA_CMD_SET_DISPLAY_ORIENTATION:
1354            return commandSetDisplayOrientationL(arg1);
1355        case CAMERA_CMD_ENABLE_SHUTTER_SOUND:
1356            return commandEnableShutterSoundL(arg1 == 1);
1357        case CAMERA_CMD_PLAY_RECORDING_SOUND:
1358            return commandPlayRecordingSoundL();
1359        case CAMERA_CMD_START_FACE_DETECTION:
1360            return commandStartFaceDetectionL(arg1);
1361        case CAMERA_CMD_STOP_FACE_DETECTION: {
1362            SharedParameters::Lock l(mParameters);
1363            return commandStopFaceDetectionL(l.mParameters);
1364        }
1365        case CAMERA_CMD_ENABLE_FOCUS_MOVE_MSG:
1366            return commandEnableFocusMoveMsgL(arg1 == 1);
1367        case CAMERA_CMD_PING:
1368            return commandPingL();
1369        case CAMERA_CMD_SET_VIDEO_BUFFER_COUNT:
1370            return commandSetVideoBufferCountL(arg1);
1371        default:
1372            ALOGE("%s: Unknown command %d (arguments %d, %d)",
1373                    __FUNCTION__, cmd, arg1, arg2);
1374            return BAD_VALUE;
1375    }
1376}
1377
1378status_t Camera2Client::commandStartSmoothZoomL() {
1379    ALOGE("%s: Unimplemented!", __FUNCTION__);
1380    return OK;
1381}
1382
1383status_t Camera2Client::commandStopSmoothZoomL() {
1384    ALOGE("%s: Unimplemented!", __FUNCTION__);
1385    return OK;
1386}
1387
1388status_t Camera2Client::commandSetDisplayOrientationL(int degrees) {
1389    int transform = Parameters::degToTransform(degrees,
1390            mCameraFacing == CAMERA_FACING_FRONT);
1391    if (transform == -1) {
1392        ALOGE("%s: Camera %d: Error setting %d as display orientation value",
1393                __FUNCTION__, mCameraId, degrees);
1394        return BAD_VALUE;
1395    }
1396    SharedParameters::Lock l(mParameters);
1397    if (transform != l.mParameters.previewTransform &&
1398            getPreviewStreamId() != NO_STREAM) {
1399        mDevice->setStreamTransform(getPreviewStreamId(), transform);
1400    }
1401    l.mParameters.previewTransform = transform;
1402    return OK;
1403}
1404
1405status_t Camera2Client::commandEnableShutterSoundL(bool enable) {
1406    SharedParameters::Lock l(mParameters);
1407    if (enable) {
1408        l.mParameters.playShutterSound = true;
1409        return OK;
1410    }
1411
1412    // Disabling shutter sound may not be allowed. In that case only
1413    // allow the mediaserver process to disable the sound.
1414    char value[PROPERTY_VALUE_MAX];
1415    property_get("ro.camera.sound.forced", value, "0");
1416    if (strncmp(value, "0", 2) != 0) {
1417        // Disabling shutter sound is not allowed. Deny if the current
1418        // process is not mediaserver.
1419        if (getCallingPid() != getpid()) {
1420            ALOGE("Failed to disable shutter sound. Permission denied (pid %d)",
1421                    getCallingPid());
1422            return PERMISSION_DENIED;
1423        }
1424    }
1425
1426    l.mParameters.playShutterSound = false;
1427    return OK;
1428}
1429
1430status_t Camera2Client::commandPlayRecordingSoundL() {
1431    mCameraService->playSound(CameraService::SOUND_RECORDING);
1432    return OK;
1433}
1434
1435status_t Camera2Client::commandStartFaceDetectionL(int /*type*/) {
1436    ALOGV("%s: Camera %d: Starting face detection",
1437          __FUNCTION__, mCameraId);
1438    status_t res;
1439    SharedParameters::Lock l(mParameters);
1440    switch (l.mParameters.state) {
1441        case Parameters::DISCONNECTED:
1442        case Parameters::STOPPED:
1443        case Parameters::WAITING_FOR_PREVIEW_WINDOW:
1444        case Parameters::STILL_CAPTURE:
1445            ALOGE("%s: Camera %d: Cannot start face detection without preview active",
1446                    __FUNCTION__, mCameraId);
1447            return INVALID_OPERATION;
1448        case Parameters::PREVIEW:
1449        case Parameters::RECORD:
1450        case Parameters::VIDEO_SNAPSHOT:
1451            // Good to go for starting face detect
1452            break;
1453    }
1454    // Ignoring type
1455    if (l.mParameters.fastInfo.bestFaceDetectMode ==
1456            ANDROID_STATISTICS_FACE_DETECT_MODE_OFF) {
1457        ALOGE("%s: Camera %d: Face detection not supported",
1458                __FUNCTION__, mCameraId);
1459        return BAD_VALUE;
1460    }
1461    if (l.mParameters.enableFaceDetect) return OK;
1462
1463    l.mParameters.enableFaceDetect = true;
1464
1465    res = updateRequests(l.mParameters);
1466
1467    return res;
1468}
1469
1470status_t Camera2Client::commandStopFaceDetectionL(Parameters &params) {
1471    status_t res = OK;
1472    ALOGV("%s: Camera %d: Stopping face detection",
1473          __FUNCTION__, mCameraId);
1474
1475    if (!params.enableFaceDetect) return OK;
1476
1477    params.enableFaceDetect = false;
1478
1479    if (params.state == Parameters::PREVIEW
1480            || params.state == Parameters::RECORD
1481            || params.state == Parameters::VIDEO_SNAPSHOT) {
1482        res = updateRequests(params);
1483    }
1484
1485    return res;
1486}
1487
1488status_t Camera2Client::commandEnableFocusMoveMsgL(bool enable) {
1489    SharedParameters::Lock l(mParameters);
1490    l.mParameters.enableFocusMoveMessages = enable;
1491
1492    return OK;
1493}
1494
1495status_t Camera2Client::commandPingL() {
1496    // Always ping back if access is proper and device is alive
1497    SharedParameters::Lock l(mParameters);
1498    if (l.mParameters.state != Parameters::DISCONNECTED) {
1499        return OK;
1500    } else {
1501        return NO_INIT;
1502    }
1503}
1504
1505status_t Camera2Client::commandSetVideoBufferCountL(size_t count) {
1506    if (recordingEnabledL()) {
1507        ALOGE("%s: Camera %d: Error setting video buffer count after "
1508                "recording was started", __FUNCTION__, mCameraId);
1509        return INVALID_OPERATION;
1510    }
1511
1512    return mStreamingProcessor->setRecordingBufferCount(count);
1513}
1514
1515/** Device-related methods */
1516void Camera2Client::notifyAutoFocus(uint8_t newState, int triggerId) {
1517    ALOGV("%s: Autofocus state now %d, last trigger %d",
1518            __FUNCTION__, newState, triggerId);
1519    bool sendCompletedMessage = false;
1520    bool sendMovingMessage = false;
1521
1522    bool success = false;
1523    bool afInMotion = false;
1524    {
1525        SharedParameters::Lock l(mParameters);
1526        // Trace end of AF state
1527        char tmp[32];
1528        if (l.mParameters.afStateCounter > 0) {
1529            camera_metadata_enum_snprint(
1530                ANDROID_CONTROL_AF_STATE, l.mParameters.focusState, tmp, sizeof(tmp));
1531            ATRACE_ASYNC_END(tmp, l.mParameters.afStateCounter);
1532        }
1533
1534        // Update state
1535        l.mParameters.focusState = newState;
1536        l.mParameters.afStateCounter++;
1537
1538        // Trace start of AF state
1539
1540        camera_metadata_enum_snprint(
1541            ANDROID_CONTROL_AF_STATE, l.mParameters.focusState, tmp, sizeof(tmp));
1542        ATRACE_ASYNC_BEGIN(tmp, l.mParameters.afStateCounter);
1543
1544        switch (l.mParameters.focusMode) {
1545            case Parameters::FOCUS_MODE_AUTO:
1546            case Parameters::FOCUS_MODE_MACRO:
1547                // Don't send notifications upstream if they're not for the current AF
1548                // trigger. For example, if cancel was called in between, or if we
1549                // already sent a notification about this AF call.
1550                if (triggerId != l.mParameters.currentAfTriggerId) break;
1551                switch (newState) {
1552                    case ANDROID_CONTROL_AF_STATE_FOCUSED_LOCKED:
1553                        success = true;
1554                        // no break
1555                    case ANDROID_CONTROL_AF_STATE_NOT_FOCUSED_LOCKED:
1556                        sendCompletedMessage = true;
1557                        l.mParameters.currentAfTriggerId = -1;
1558                        break;
1559                    case ANDROID_CONTROL_AF_STATE_ACTIVE_SCAN:
1560                        // Just starting focusing, ignore
1561                        break;
1562                    case ANDROID_CONTROL_AF_STATE_INACTIVE:
1563                    case ANDROID_CONTROL_AF_STATE_PASSIVE_SCAN:
1564                    case ANDROID_CONTROL_AF_STATE_PASSIVE_FOCUSED:
1565                    case ANDROID_CONTROL_AF_STATE_PASSIVE_UNFOCUSED:
1566                    default:
1567                        // Unexpected in AUTO/MACRO mode
1568                        ALOGE("%s: Unexpected AF state transition in AUTO/MACRO mode: %d",
1569                                __FUNCTION__, newState);
1570                        break;
1571                }
1572                break;
1573            case Parameters::FOCUS_MODE_CONTINUOUS_VIDEO:
1574            case Parameters::FOCUS_MODE_CONTINUOUS_PICTURE:
1575                switch (newState) {
1576                    case ANDROID_CONTROL_AF_STATE_FOCUSED_LOCKED:
1577                        success = true;
1578                        // no break
1579                    case ANDROID_CONTROL_AF_STATE_NOT_FOCUSED_LOCKED:
1580                        // Don't send notifications upstream if they're not for
1581                        // the current AF trigger. For example, if cancel was
1582                        // called in between, or if we already sent a
1583                        // notification about this AF call.
1584                        // Send both a 'AF done' callback and a 'AF move' callback
1585                        if (triggerId != l.mParameters.currentAfTriggerId) break;
1586                        sendCompletedMessage = true;
1587                        afInMotion = false;
1588                        if (l.mParameters.enableFocusMoveMessages &&
1589                                l.mParameters.afInMotion) {
1590                            sendMovingMessage = true;
1591                        }
1592                        l.mParameters.currentAfTriggerId = -1;
1593                        break;
1594                    case ANDROID_CONTROL_AF_STATE_INACTIVE:
1595                        // Cancel was called, or we switched state; care if
1596                        // currently moving
1597                        afInMotion = false;
1598                        if (l.mParameters.enableFocusMoveMessages &&
1599                                l.mParameters.afInMotion) {
1600                            sendMovingMessage = true;
1601                        }
1602                        break;
1603                    case ANDROID_CONTROL_AF_STATE_PASSIVE_SCAN:
1604                        // Start passive scan, inform upstream
1605                        afInMotion = true;
1606                        // no break
1607                    case ANDROID_CONTROL_AF_STATE_PASSIVE_FOCUSED:
1608                    case ANDROID_CONTROL_AF_STATE_PASSIVE_UNFOCUSED:
1609                        // Stop passive scan, inform upstream
1610                        if (l.mParameters.enableFocusMoveMessages) {
1611                            sendMovingMessage = true;
1612                        }
1613                        break;
1614                }
1615                l.mParameters.afInMotion = afInMotion;
1616                break;
1617            case Parameters::FOCUS_MODE_EDOF:
1618            case Parameters::FOCUS_MODE_INFINITY:
1619            case Parameters::FOCUS_MODE_FIXED:
1620            default:
1621                if (newState != ANDROID_CONTROL_AF_STATE_INACTIVE) {
1622                    ALOGE("%s: Unexpected AF state change %d "
1623                            "(ID %d) in focus mode %d",
1624                          __FUNCTION__, newState, triggerId,
1625                            l.mParameters.focusMode);
1626                }
1627        }
1628    }
1629    if (sendMovingMessage) {
1630        SharedCameraCallbacks::Lock l(mSharedCameraCallbacks);
1631        if (l.mRemoteCallback != 0) {
1632            l.mRemoteCallback->notifyCallback(CAMERA_MSG_FOCUS_MOVE,
1633                    afInMotion ? 1 : 0, 0);
1634        }
1635    }
1636    if (sendCompletedMessage) {
1637        ATRACE_ASYNC_END(kAutofocusLabel, triggerId);
1638        SharedCameraCallbacks::Lock l(mSharedCameraCallbacks);
1639        if (l.mRemoteCallback != 0) {
1640            l.mRemoteCallback->notifyCallback(CAMERA_MSG_FOCUS,
1641                    success ? 1 : 0, 0);
1642        }
1643    }
1644}
1645
1646void Camera2Client::notifyAutoExposure(uint8_t newState, int triggerId) {
1647    ALOGV("%s: Autoexposure state now %d, last trigger %d",
1648            __FUNCTION__, newState, triggerId);
1649    mCaptureSequencer->notifyAutoExposure(newState, triggerId);
1650}
1651
1652camera2::SharedParameters& Camera2Client::getParameters() {
1653    return mParameters;
1654}
1655
1656int Camera2Client::getPreviewStreamId() const {
1657    return mStreamingProcessor->getPreviewStreamId();
1658}
1659
1660int Camera2Client::getCaptureStreamId() const {
1661    return mJpegProcessor->getStreamId();
1662}
1663
1664int Camera2Client::getCallbackStreamId() const {
1665    return mCallbackProcessor->getStreamId();
1666}
1667
1668int Camera2Client::getRecordingStreamId() const {
1669    return mStreamingProcessor->getRecordingStreamId();
1670}
1671
1672int Camera2Client::getZslStreamId() const {
1673    return mZslProcessor->getStreamId();
1674}
1675
1676status_t Camera2Client::registerFrameListener(int32_t minId, int32_t maxId,
1677        wp<camera2::FrameProcessor::FilteredListener> listener, bool sendPartials) {
1678    return mFrameProcessor->registerListener(minId, maxId, listener, sendPartials);
1679}
1680
1681status_t Camera2Client::removeFrameListener(int32_t minId, int32_t maxId,
1682        wp<camera2::FrameProcessor::FilteredListener> listener) {
1683    return mFrameProcessor->removeListener(minId, maxId, listener);
1684}
1685
1686status_t Camera2Client::stopStream() {
1687    return mStreamingProcessor->stopStream();
1688}
1689
1690const int32_t Camera2Client::kPreviewRequestIdStart;
1691const int32_t Camera2Client::kPreviewRequestIdEnd;
1692const int32_t Camera2Client::kRecordingRequestIdStart;
1693const int32_t Camera2Client::kRecordingRequestIdEnd;
1694const int32_t Camera2Client::kCaptureRequestIdStart;
1695const int32_t Camera2Client::kCaptureRequestIdEnd;
1696
1697/** Utility methods */
1698
1699status_t Camera2Client::updateRequests(Parameters &params) {
1700    status_t res;
1701
1702    ALOGV("%s: Camera %d: state = %d", __FUNCTION__, getCameraId(), params.state);
1703
1704    res = mStreamingProcessor->incrementStreamingIds();
1705    if (res != OK) {
1706        ALOGE("%s: Camera %d: Unable to increment request IDs: %s (%d)",
1707                __FUNCTION__, mCameraId, strerror(-res), res);
1708        return res;
1709    }
1710
1711    res = mStreamingProcessor->updatePreviewRequest(params);
1712    if (res != OK) {
1713        ALOGE("%s: Camera %d: Unable to update preview request: %s (%d)",
1714                __FUNCTION__, mCameraId, strerror(-res), res);
1715        return res;
1716    }
1717    res = mStreamingProcessor->updateRecordingRequest(params);
1718    if (res != OK) {
1719        ALOGE("%s: Camera %d: Unable to update recording request: %s (%d)",
1720                __FUNCTION__, mCameraId, strerror(-res), res);
1721        return res;
1722    }
1723
1724    if (params.state == Parameters::PREVIEW) {
1725        res = startPreviewL(params, true);
1726        if (res != OK) {
1727            ALOGE("%s: Camera %d: Error streaming new preview request: %s (%d)",
1728                    __FUNCTION__, mCameraId, strerror(-res), res);
1729            return res;
1730        }
1731    } else if (params.state == Parameters::RECORD ||
1732            params.state == Parameters::VIDEO_SNAPSHOT) {
1733        res = startRecordingL(params, true);
1734        if (res != OK) {
1735            ALOGE("%s: Camera %d: Error streaming new record request: %s (%d)",
1736                    __FUNCTION__, mCameraId, strerror(-res), res);
1737            return res;
1738        }
1739    }
1740    return res;
1741}
1742
1743
1744size_t Camera2Client::calculateBufferSize(int width, int height,
1745        int format, int stride) {
1746    switch (format) {
1747        case HAL_PIXEL_FORMAT_YCbCr_422_SP: // NV16
1748            return width * height * 2;
1749        case HAL_PIXEL_FORMAT_YCrCb_420_SP: // NV21
1750            return width * height * 3 / 2;
1751        case HAL_PIXEL_FORMAT_YCbCr_422_I: // YUY2
1752            return width * height * 2;
1753        case HAL_PIXEL_FORMAT_YV12: {      // YV12
1754            size_t ySize = stride * height;
1755            size_t uvStride = (stride / 2 + 0xF) & ~0xF;
1756            size_t uvSize = uvStride * height / 2;
1757            return ySize + uvSize * 2;
1758        }
1759        case HAL_PIXEL_FORMAT_RGB_565:
1760            return width * height * 2;
1761        case HAL_PIXEL_FORMAT_RGBA_8888:
1762            return width * height * 4;
1763        case HAL_PIXEL_FORMAT_RAW_SENSOR:
1764            return width * height * 2;
1765        default:
1766            ALOGE("%s: Unknown preview format: %x",
1767                    __FUNCTION__,  format);
1768            return 0;
1769    }
1770}
1771
1772status_t Camera2Client::syncWithDevice() {
1773    ATRACE_CALL();
1774    const nsecs_t kMaxSyncTimeout = 500000000; // 500 ms
1775    status_t res;
1776
1777    int32_t activeRequestId = mStreamingProcessor->getActiveRequestId();
1778    if (activeRequestId == 0) return OK;
1779
1780    res = mDevice->waitUntilRequestReceived(activeRequestId, kMaxSyncTimeout);
1781    if (res == TIMED_OUT) {
1782        ALOGE("%s: Camera %d: Timed out waiting sync with HAL",
1783                __FUNCTION__, mCameraId);
1784    } else if (res != OK) {
1785        ALOGE("%s: Camera %d: Error while waiting to sync with HAL",
1786                __FUNCTION__, mCameraId);
1787    }
1788    return res;
1789}
1790
1791template <typename ProcessorT>
1792status_t Camera2Client::updateProcessorStream(sp<ProcessorT> processor,
1793                                              camera2::Parameters params) {
1794    // No default template arguments until C++11, so we need this overload
1795    return updateProcessorStream<ProcessorT, &ProcessorT::updateStream>(
1796            processor, params);
1797}
1798
1799template <typename ProcessorT,
1800          status_t (ProcessorT::*updateStreamF)(const Parameters &)>
1801status_t Camera2Client::updateProcessorStream(sp<ProcessorT> processor,
1802                                              Parameters params) {
1803    status_t res;
1804
1805    // Get raw pointer since sp<T> doesn't have operator->*
1806    ProcessorT *processorPtr = processor.get();
1807    res = (processorPtr->*updateStreamF)(params);
1808
1809    /**
1810     * Can't update the stream if it's busy?
1811     *
1812     * Then we need to stop the device (by temporarily clearing the request
1813     * queue) and then try again. Resume streaming once we're done.
1814     */
1815    if (res == -EBUSY) {
1816        ALOGV("%s: Camera %d: Pausing to update stream", __FUNCTION__,
1817                mCameraId);
1818        res = mStreamingProcessor->togglePauseStream(/*pause*/true);
1819        if (res != OK) {
1820            ALOGE("%s: Camera %d: Can't pause streaming: %s (%d)",
1821                    __FUNCTION__, mCameraId, strerror(-res), res);
1822        }
1823
1824        res = mDevice->waitUntilDrained();
1825        if (res != OK) {
1826            ALOGE("%s: Camera %d: Waiting to stop streaming failed: %s (%d)",
1827                    __FUNCTION__, mCameraId, strerror(-res), res);
1828        }
1829
1830        res = (processorPtr->*updateStreamF)(params);
1831        if (res != OK) {
1832            ALOGE("%s: Camera %d: Failed to update processing stream "
1833                  " despite having halted streaming first: %s (%d)",
1834                  __FUNCTION__, mCameraId, strerror(-res), res);
1835        }
1836
1837        res = mStreamingProcessor->togglePauseStream(/*pause*/false);
1838        if (res != OK) {
1839            ALOGE("%s: Camera %d: Can't unpause streaming: %s (%d)",
1840                    __FUNCTION__, mCameraId, strerror(-res), res);
1841        }
1842    }
1843
1844    return res;
1845}
1846
1847const char* Camera2Client::kAutofocusLabel = "autofocus";
1848const char* Camera2Client::kTakepictureLabel = "take_picture";
1849
1850} // namespace android
1851