CameraService.cpp revision 0dea57fd9fc4b2ccaab97d9477359fbd5a626f5c 
1/*
2 * Copyright (C) 2008 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 "CameraService"
18#define ATRACE_TAG ATRACE_TAG_CAMERA
19//#define LOG_NDEBUG 0
20
21#include <algorithm>
22#include <climits>
23#include <stdio.h>
24#include <cstring>
25#include <ctime>
26#include <string>
27#include <sys/types.h>
28#include <inttypes.h>
29#include <pthread.h>
30
31#include <binder/AppOpsManager.h>
32#include <binder/IPCThreadState.h>
33#include <binder/IServiceManager.h>
34#include <binder/MemoryBase.h>
35#include <binder/MemoryHeapBase.h>
36#include <binder/ProcessInfoService.h>
37#include <cutils/atomic.h>
38#include <cutils/properties.h>
39#include <gui/Surface.h>
40#include <hardware/hardware.h>
41#include <media/AudioSystem.h>
42#include <media/IMediaHTTPService.h>
43#include <media/mediaplayer.h>
44#include <mediautils/BatteryNotifier.h>
45#include <utils/Errors.h>
46#include <utils/Log.h>
47#include <utils/String16.h>
48#include <utils/Trace.h>
49#include <system/camera_vendor_tags.h>
50#include <system/camera_metadata.h>
51#include <system/camera.h>
52
53#include "CameraService.h"
54#include "api1/CameraClient.h"
55#include "api1/Camera2Client.h"
56#include "api2/CameraDeviceClient.h"
57#include "utils/CameraTraces.h"
58
59namespace {
60    const char* kPermissionServiceName = "permission";
61}; // namespace anonymous
62
63namespace android {
64
65// ----------------------------------------------------------------------------
66// Logging support -- this is for debugging only
67// Use "adb shell dumpsys media.camera -v 1" to change it.
68volatile int32_t gLogLevel = 0;
69
70#define LOG1(...) ALOGD_IF(gLogLevel >= 1, __VA_ARGS__);
71#define LOG2(...) ALOGD_IF(gLogLevel >= 2, __VA_ARGS__);
72
73static void setLogLevel(int level) {
74    android_atomic_write(level, &gLogLevel);
75}
76
77// ----------------------------------------------------------------------------
78
79extern "C" {
80static void camera_device_status_change(
81        const struct camera_module_callbacks* callbacks,
82        int camera_id,
83        int new_status) {
84    sp<CameraService> cs = const_cast<CameraService*>(
85            static_cast<const CameraService*>(callbacks));
86
87    cs->onDeviceStatusChanged(static_cast<camera_device_status_t>(camera_id),
88            static_cast<camera_device_status_t>(new_status));
89}
90
91static void torch_mode_status_change(
92        const struct camera_module_callbacks* callbacks,
93        const char* camera_id,
94        int new_status) {
95    if (!callbacks || !camera_id) {
96        ALOGE("%s invalid parameters. callbacks %p, camera_id %p", __FUNCTION__,
97                callbacks, camera_id);
98    }
99    sp<CameraService> cs = const_cast<CameraService*>(
100                                static_cast<const CameraService*>(callbacks));
101
102    ICameraServiceListener::TorchStatus status;
103    switch (new_status) {
104        case TORCH_MODE_STATUS_NOT_AVAILABLE:
105            status = ICameraServiceListener::TORCH_STATUS_NOT_AVAILABLE;
106            break;
107        case TORCH_MODE_STATUS_AVAILABLE_OFF:
108            status = ICameraServiceListener::TORCH_STATUS_AVAILABLE_OFF;
109            break;
110        case TORCH_MODE_STATUS_AVAILABLE_ON:
111            status = ICameraServiceListener::TORCH_STATUS_AVAILABLE_ON;
112            break;
113        default:
114            ALOGE("Unknown torch status %d", new_status);
115            return;
116    }
117
118    cs->onTorchStatusChanged(
119        String8(camera_id),
120        status);
121}
122} // extern "C"
123
124// ----------------------------------------------------------------------------
125
126// This is ugly and only safe if we never re-create the CameraService, but
127// should be ok for now.
128static CameraService *gCameraService;
129
130CameraService::CameraService() :
131        mEventLog(DEFAULT_EVENT_LOG_LENGTH),
132        mSoundRef(0), mModule(nullptr),
133        mNumberOfCameras(0), mNumberOfNormalCameras(0) {
134    ALOGI("CameraService started (pid=%d)", getpid());
135    gCameraService = this;
136
137    this->camera_device_status_change = android::camera_device_status_change;
138    this->torch_mode_status_change = android::torch_mode_status_change;
139
140    mServiceLockWrapper = std::make_shared<WaitableMutexWrapper>(&mServiceLock);
141}
142
143void CameraService::onFirstRef()
144{
145    ALOGI("CameraService process starting");
146
147    BnCameraService::onFirstRef();
148
149    // Update battery life tracking if service is restarting
150    BatteryNotifier& notifier(BatteryNotifier::getInstance());
151    notifier.noteResetCamera();
152    notifier.noteResetFlashlight();
153
154    camera_module_t *rawModule;
155    int err = hw_get_module(CAMERA_HARDWARE_MODULE_ID,
156            (const hw_module_t **)&rawModule);
157    if (err < 0) {
158        ALOGE("Could not load camera HAL module: %d (%s)", err, strerror(-err));
159        logServiceError("Could not load camera HAL module", err);
160        return;
161    }
162
163    mModule = new CameraModule(rawModule);
164    err = mModule->init();
165    if (err != OK) {
166        ALOGE("Could not initialize camera HAL module: %d (%s)", err,
167            strerror(-err));
168        logServiceError("Could not initialize camera HAL module", err);
169
170        delete mModule;
171        mModule = nullptr;
172        return;
173    }
174    ALOGI("Loaded \"%s\" camera module", mModule->getModuleName());
175
176    mNumberOfCameras = mModule->getNumberOfCameras();
177    mNumberOfNormalCameras = mNumberOfCameras;
178
179    // Setup vendor tags before we call get_camera_info the first time
180    // because HAL might need to setup static vendor keys in get_camera_info
181    VendorTagDescriptor::clearGlobalVendorTagDescriptor();
182    if (mModule->getModuleApiVersion() >= CAMERA_MODULE_API_VERSION_2_2) {
183        setUpVendorTags();
184    }
185
186    mFlashlight = new CameraFlashlight(*mModule, *this);
187    status_t res = mFlashlight->findFlashUnits();
188    if (res) {
189        // impossible because we haven't open any camera devices.
190        ALOGE("Failed to find flash units.");
191    }
192
193    int latestStrangeCameraId = INT_MAX;
194    for (int i = 0; i < mNumberOfCameras; i++) {
195        String8 cameraId = String8::format("%d", i);
196
197        // Get camera info
198
199        struct camera_info info;
200        bool haveInfo = true;
201        status_t rc = mModule->getCameraInfo(i, &info);
202        if (rc != NO_ERROR) {
203            ALOGE("%s: Received error loading camera info for device %d, cost and"
204                    " conflicting devices fields set to defaults for this device.",
205                    __FUNCTION__, i);
206            haveInfo = false;
207        }
208
209        // Check for backwards-compatibility support
210        if (haveInfo) {
211            if (checkCameraCapabilities(i, info, &latestStrangeCameraId) != OK) {
212                delete mModule;
213                mModule = nullptr;
214                return;
215            }
216        }
217
218        // Defaults to use for cost and conflicting devices
219        int cost = 100;
220        char** conflicting_devices = nullptr;
221        size_t conflicting_devices_length = 0;
222
223        // If using post-2.4 module version, query the cost + conflicting devices from the HAL
224        if (mModule->getModuleApiVersion() >= CAMERA_MODULE_API_VERSION_2_4 && haveInfo) {
225            cost = info.resource_cost;
226            conflicting_devices = info.conflicting_devices;
227            conflicting_devices_length = info.conflicting_devices_length;
228        }
229
230        std::set<String8> conflicting;
231        for (size_t i = 0; i < conflicting_devices_length; i++) {
232            conflicting.emplace(String8(conflicting_devices[i]));
233        }
234
235        // Initialize state for each camera device
236        {
237            Mutex::Autolock lock(mCameraStatesLock);
238            mCameraStates.emplace(cameraId, std::make_shared<CameraState>(cameraId, cost,
239                    conflicting));
240        }
241
242        if (mFlashlight->hasFlashUnit(cameraId)) {
243            mTorchStatusMap.add(cameraId,
244                    ICameraServiceListener::TORCH_STATUS_AVAILABLE_OFF);
245        }
246    }
247
248    if (mModule->getModuleApiVersion() >= CAMERA_MODULE_API_VERSION_2_1) {
249        mModule->setCallbacks(this);
250    }
251
252    CameraService::pingCameraServiceProxy();
253}
254
255sp<ICameraServiceProxy> CameraService::getCameraServiceProxy() {
256    sp<IServiceManager> sm = defaultServiceManager();
257    sp<IBinder> binder = sm->getService(String16("media.camera.proxy"));
258    if (binder == nullptr) {
259        return nullptr;
260    }
261    sp<ICameraServiceProxy> proxyBinder = interface_cast<ICameraServiceProxy>(binder);
262    return proxyBinder;
263}
264
265void CameraService::pingCameraServiceProxy() {
266    sp<ICameraServiceProxy> proxyBinder = getCameraServiceProxy();
267    if (proxyBinder == nullptr) return;
268    proxyBinder->pingForUserUpdate();
269}
270
271CameraService::~CameraService() {
272    if (mModule) {
273        delete mModule;
274        mModule = nullptr;
275    }
276    VendorTagDescriptor::clearGlobalVendorTagDescriptor();
277    gCameraService = nullptr;
278}
279
280void CameraService::onDeviceStatusChanged(camera_device_status_t  cameraId,
281        camera_device_status_t newStatus) {
282    ALOGI("%s: Status changed for cameraId=%d, newStatus=%d", __FUNCTION__,
283          cameraId, newStatus);
284
285    String8 id = String8::format("%d", cameraId);
286    std::shared_ptr<CameraState> state = getCameraState(id);
287
288    if (state == nullptr) {
289        ALOGE("%s: Bad camera ID %d", __FUNCTION__, cameraId);
290        return;
291    }
292
293    ICameraServiceListener::Status oldStatus = state->getStatus();
294
295    if (oldStatus == static_cast<ICameraServiceListener::Status>(newStatus)) {
296        ALOGE("%s: State transition to the same status %#x not allowed", __FUNCTION__, newStatus);
297        return;
298    }
299
300    if (newStatus == CAMERA_DEVICE_STATUS_NOT_PRESENT) {
301        logDeviceRemoved(id, String8::format("Device status changed from %d to %d", oldStatus,
302                newStatus));
303        sp<BasicClient> clientToDisconnect;
304        {
305            // Don't do this in updateStatus to avoid deadlock over mServiceLock
306            Mutex::Autolock lock(mServiceLock);
307
308            // Set the device status to NOT_PRESENT, clients will no longer be able to connect
309            // to this device until the status changes
310            updateStatus(ICameraServiceListener::STATUS_NOT_PRESENT, id);
311
312            // Remove cached shim parameters
313            state->setShimParams(CameraParameters());
314
315            // Remove the client from the list of active clients
316            clientToDisconnect = removeClientLocked(id);
317
318            // Notify the client of disconnection
319            clientToDisconnect->notifyError(ICameraDeviceCallbacks::ERROR_CAMERA_DISCONNECTED,
320                    CaptureResultExtras{});
321        }
322
323        ALOGI("%s: Client for camera ID %s evicted due to device status change from HAL",
324                __FUNCTION__, id.string());
325
326        // Disconnect client
327        if (clientToDisconnect.get() != nullptr) {
328            // Ensure not in binder RPC so client disconnect PID checks work correctly
329            LOG_ALWAYS_FATAL_IF(getCallingPid() != getpid(),
330                    "onDeviceStatusChanged must be called from the camera service process!");
331            clientToDisconnect->disconnect();
332        }
333
334    } else {
335        if (oldStatus == ICameraServiceListener::Status::STATUS_NOT_PRESENT) {
336            logDeviceAdded(id, String8::format("Device status changed from %d to %d", oldStatus,
337                    newStatus));
338        }
339        updateStatus(static_cast<ICameraServiceListener::Status>(newStatus), id);
340    }
341
342}
343
344void CameraService::onTorchStatusChanged(const String8& cameraId,
345        ICameraServiceListener::TorchStatus newStatus) {
346    Mutex::Autolock al(mTorchStatusMutex);
347    onTorchStatusChangedLocked(cameraId, newStatus);
348}
349
350void CameraService::onTorchStatusChangedLocked(const String8& cameraId,
351        ICameraServiceListener::TorchStatus newStatus) {
352    ALOGI("%s: Torch status changed for cameraId=%s, newStatus=%d",
353            __FUNCTION__, cameraId.string(), newStatus);
354
355    ICameraServiceListener::TorchStatus status;
356    status_t res = getTorchStatusLocked(cameraId, &status);
357    if (res) {
358        ALOGE("%s: cannot get torch status of camera %s: %s (%d)",
359                __FUNCTION__, cameraId.string(), strerror(-res), res);
360        return;
361    }
362    if (status == newStatus) {
363        return;
364    }
365
366    res = setTorchStatusLocked(cameraId, newStatus);
367    if (res) {
368        ALOGE("%s: Failed to set the torch status to %d: %s (%d)", __FUNCTION__,
369                (uint32_t)newStatus, strerror(-res), res);
370        return;
371    }
372
373    {
374        // Update battery life logging for flashlight
375        Mutex::Autolock al(mTorchUidMapMutex);
376        auto iter = mTorchUidMap.find(cameraId);
377        if (iter != mTorchUidMap.end()) {
378            int oldUid = iter->second.second;
379            int newUid = iter->second.first;
380            BatteryNotifier& notifier(BatteryNotifier::getInstance());
381            if (oldUid != newUid) {
382                // If the UID has changed, log the status and update current UID in mTorchUidMap
383                if (status == ICameraServiceListener::TORCH_STATUS_AVAILABLE_ON) {
384                    notifier.noteFlashlightOff(cameraId, oldUid);
385                }
386                if (newStatus == ICameraServiceListener::TORCH_STATUS_AVAILABLE_ON) {
387                    notifier.noteFlashlightOn(cameraId, newUid);
388                }
389                iter->second.second = newUid;
390            } else {
391                // If the UID has not changed, log the status
392                if (newStatus == ICameraServiceListener::TORCH_STATUS_AVAILABLE_ON) {
393                    notifier.noteFlashlightOn(cameraId, oldUid);
394                } else {
395                    notifier.noteFlashlightOff(cameraId, oldUid);
396                }
397            }
398        }
399    }
400
401    {
402        Mutex::Autolock lock(mStatusListenerLock);
403        for (auto& i : mListenerList) {
404            i->onTorchStatusChanged(newStatus, String16{cameraId});
405        }
406    }
407}
408
409int32_t CameraService::getNumberOfCameras() {
410    ATRACE_CALL();
411    return getNumberOfCameras(CAMERA_TYPE_BACKWARD_COMPATIBLE);
412}
413
414int32_t CameraService::getNumberOfCameras(int type) {
415    ATRACE_CALL();
416    switch (type) {
417        case CAMERA_TYPE_BACKWARD_COMPATIBLE:
418            return mNumberOfNormalCameras;
419        case CAMERA_TYPE_ALL:
420            return mNumberOfCameras;
421        default:
422            ALOGW("%s: Unknown camera type %d, returning 0",
423                    __FUNCTION__, type);
424            return 0;
425    }
426}
427
428status_t CameraService::getCameraInfo(int cameraId,
429                                      struct CameraInfo* cameraInfo) {
430    ATRACE_CALL();
431    if (!mModule) {
432        return -ENODEV;
433    }
434
435    if (cameraId < 0 || cameraId >= mNumberOfCameras) {
436        return BAD_VALUE;
437    }
438
439    struct camera_info info;
440    status_t rc = filterGetInfoErrorCode(
441        mModule->getCameraInfo(cameraId, &info));
442    cameraInfo->facing = info.facing;
443    cameraInfo->orientation = info.orientation;
444    return rc;
445}
446
447int CameraService::cameraIdToInt(const String8& cameraId) {
448    errno = 0;
449    size_t pos = 0;
450    int ret = stoi(std::string{cameraId.string()}, &pos);
451    if (errno != 0 || pos != cameraId.size()) {
452        return -1;
453    }
454    return ret;
455}
456
457status_t CameraService::generateShimMetadata(int cameraId, /*out*/CameraMetadata* cameraInfo) {
458    ATRACE_CALL();
459    status_t ret = OK;
460    struct CameraInfo info;
461    if ((ret = getCameraInfo(cameraId, &info)) != OK) {
462        return ret;
463    }
464
465    CameraMetadata shimInfo;
466    int32_t orientation = static_cast<int32_t>(info.orientation);
467    if ((ret = shimInfo.update(ANDROID_SENSOR_ORIENTATION, &orientation, 1)) != OK) {
468        return ret;
469    }
470
471    uint8_t facing = (info.facing == CAMERA_FACING_FRONT) ?
472            ANDROID_LENS_FACING_FRONT : ANDROID_LENS_FACING_BACK;
473    if ((ret = shimInfo.update(ANDROID_LENS_FACING, &facing, 1)) != OK) {
474        return ret;
475    }
476
477    CameraParameters shimParams;
478    if ((ret = getLegacyParametersLazy(cameraId, /*out*/&shimParams)) != OK) {
479        // Error logged by callee
480        return ret;
481    }
482
483    Vector<Size> sizes;
484    Vector<Size> jpegSizes;
485    Vector<int32_t> formats;
486    {
487        shimParams.getSupportedPreviewSizes(/*out*/sizes);
488        shimParams.getSupportedPreviewFormats(/*out*/formats);
489        shimParams.getSupportedPictureSizes(/*out*/jpegSizes);
490    }
491
492    // Always include IMPLEMENTATION_DEFINED
493    formats.add(HAL_PIXEL_FORMAT_IMPLEMENTATION_DEFINED);
494
495    const size_t INTS_PER_CONFIG = 4;
496
497    // Build available stream configurations metadata
498    size_t streamConfigSize = (sizes.size() * formats.size() + jpegSizes.size()) * INTS_PER_CONFIG;
499
500    Vector<int32_t> streamConfigs;
501    streamConfigs.setCapacity(streamConfigSize);
502
503    for (size_t i = 0; i < formats.size(); ++i) {
504        for (size_t j = 0; j < sizes.size(); ++j) {
505            streamConfigs.add(formats[i]);
506            streamConfigs.add(sizes[j].width);
507            streamConfigs.add(sizes[j].height);
508            streamConfigs.add(ANDROID_SCALER_AVAILABLE_STREAM_CONFIGURATIONS_OUTPUT);
509        }
510    }
511
512    for (size_t i = 0; i < jpegSizes.size(); ++i) {
513        streamConfigs.add(HAL_PIXEL_FORMAT_BLOB);
514        streamConfigs.add(jpegSizes[i].width);
515        streamConfigs.add(jpegSizes[i].height);
516        streamConfigs.add(ANDROID_SCALER_AVAILABLE_STREAM_CONFIGURATIONS_OUTPUT);
517    }
518
519    if ((ret = shimInfo.update(ANDROID_SCALER_AVAILABLE_STREAM_CONFIGURATIONS,
520            streamConfigs.array(), streamConfigSize)) != OK) {
521        return ret;
522    }
523
524    int64_t fakeMinFrames[0];
525    // TODO: Fixme, don't fake min frame durations.
526    if ((ret = shimInfo.update(ANDROID_SCALER_AVAILABLE_MIN_FRAME_DURATIONS,
527            fakeMinFrames, 0)) != OK) {
528        return ret;
529    }
530
531    int64_t fakeStalls[0];
532    // TODO: Fixme, don't fake stall durations.
533    if ((ret = shimInfo.update(ANDROID_SCALER_AVAILABLE_STALL_DURATIONS,
534            fakeStalls, 0)) != OK) {
535        return ret;
536    }
537
538    *cameraInfo = shimInfo;
539    return OK;
540}
541
542status_t CameraService::getCameraCharacteristics(int cameraId,
543                                                CameraMetadata* cameraInfo) {
544    ATRACE_CALL();
545    if (!cameraInfo) {
546        ALOGE("%s: cameraInfo is NULL", __FUNCTION__);
547        return BAD_VALUE;
548    }
549
550    if (!mModule) {
551        ALOGE("%s: camera hardware module doesn't exist", __FUNCTION__);
552        return -ENODEV;
553    }
554
555    if (cameraId < 0 || cameraId >= mNumberOfCameras) {
556        ALOGE("%s: Invalid camera id: %d", __FUNCTION__, cameraId);
557        return BAD_VALUE;
558    }
559
560    int facing;
561    status_t ret = OK;
562    if (mModule->getModuleApiVersion() < CAMERA_MODULE_API_VERSION_2_0 ||
563            getDeviceVersion(cameraId, &facing) < CAMERA_DEVICE_API_VERSION_3_0) {
564        /**
565         * Backwards compatibility mode for old HALs:
566         * - Convert CameraInfo into static CameraMetadata properties.
567         * - Retrieve cached CameraParameters for this camera.  If none exist,
568         *   attempt to open CameraClient and retrieve the CameraParameters.
569         * - Convert cached CameraParameters into static CameraMetadata
570         *   properties.
571         */
572        ALOGI("%s: Switching to HAL1 shim implementation...", __FUNCTION__);
573
574        if ((ret = generateShimMetadata(cameraId, cameraInfo)) != OK) {
575            return ret;
576        }
577
578    } else {
579        /**
580         * Normal HAL 2.1+ codepath.
581         */
582        struct camera_info info;
583        ret = filterGetInfoErrorCode(mModule->getCameraInfo(cameraId, &info));
584        *cameraInfo = info.static_camera_characteristics;
585    }
586
587    return ret;
588}
589
590int CameraService::getCallingPid() {
591    return IPCThreadState::self()->getCallingPid();
592}
593
594int CameraService::getCallingUid() {
595    return IPCThreadState::self()->getCallingUid();
596}
597
598String8 CameraService::getFormattedCurrentTime() {
599    time_t now = time(nullptr);
600    char formattedTime[64];
601    strftime(formattedTime, sizeof(formattedTime), "%m-%d %H:%M:%S", localtime(&now));
602    return String8(formattedTime);
603}
604
605int CameraService::getCameraPriorityFromProcState(int procState) {
606    // Find the priority for the camera usage based on the process state.  Higher priority clients
607    // win for evictions.
608    if (procState < 0) {
609        ALOGE("%s: Received invalid process state %d from ActivityManagerService!", __FUNCTION__,
610                procState);
611        return -1;
612    }
613    // Treat sleeping TOP processes the same as regular TOP processes, for
614    // access priority.  This is important for lock-screen camera launch scenarios
615    if (procState == PROCESS_STATE_TOP_SLEEPING) {
616        procState = PROCESS_STATE_TOP;
617    }
618    return INT_MAX - procState;
619}
620
621status_t CameraService::getCameraVendorTagDescriptor(/*out*/sp<VendorTagDescriptor>& desc) {
622    ATRACE_CALL();
623    if (!mModule) {
624        ALOGE("%s: camera hardware module doesn't exist", __FUNCTION__);
625        return -ENODEV;
626    }
627
628    desc = VendorTagDescriptor::getGlobalVendorTagDescriptor();
629    return OK;
630}
631
632int CameraService::getDeviceVersion(int cameraId, int* facing) {
633    ATRACE_CALL();
634    struct camera_info info;
635    if (mModule->getCameraInfo(cameraId, &info) != OK) {
636        return -1;
637    }
638
639    int deviceVersion;
640    if (mModule->getModuleApiVersion() >= CAMERA_MODULE_API_VERSION_2_0) {
641        deviceVersion = info.device_version;
642    } else {
643        deviceVersion = CAMERA_DEVICE_API_VERSION_1_0;
644    }
645
646    if (facing) {
647        *facing = info.facing;
648    }
649
650    return deviceVersion;
651}
652
653status_t CameraService::filterGetInfoErrorCode(status_t err) {
654    switch(err) {
655        case NO_ERROR:
656        case -EINVAL:
657            return err;
658        default:
659            break;
660    }
661    return -ENODEV;
662}
663
664bool CameraService::setUpVendorTags() {
665    ATRACE_CALL();
666    vendor_tag_ops_t vOps = vendor_tag_ops_t();
667
668    // Check if vendor operations have been implemented
669    if (!mModule->isVendorTagDefined()) {
670        ALOGI("%s: No vendor tags defined for this device.", __FUNCTION__);
671        return false;
672    }
673
674    mModule->getVendorTagOps(&vOps);
675
676    // Ensure all vendor operations are present
677    if (vOps.get_tag_count == NULL || vOps.get_all_tags == NULL ||
678            vOps.get_section_name == NULL || vOps.get_tag_name == NULL ||
679            vOps.get_tag_type == NULL) {
680        ALOGE("%s: Vendor tag operations not fully defined. Ignoring definitions."
681               , __FUNCTION__);
682        return false;
683    }
684
685    // Read all vendor tag definitions into a descriptor
686    sp<VendorTagDescriptor> desc;
687    status_t res;
688    if ((res = VendorTagDescriptor::createDescriptorFromOps(&vOps, /*out*/desc))
689            != OK) {
690        ALOGE("%s: Could not generate descriptor from vendor tag operations,"
691              "received error %s (%d). Camera clients will not be able to use"
692              "vendor tags", __FUNCTION__, strerror(res), res);
693        return false;
694    }
695
696    // Set the global descriptor to use with camera metadata
697    VendorTagDescriptor::setAsGlobalVendorTagDescriptor(desc);
698    return true;
699}
700
701status_t CameraService::makeClient(const sp<CameraService>& cameraService,
702        const sp<IInterface>& cameraCb, const String16& packageName, const String8& cameraId,
703        int facing, int clientPid, uid_t clientUid, int servicePid, bool legacyMode,
704        int halVersion, int deviceVersion, apiLevel effectiveApiLevel,
705        /*out*/sp<BasicClient>* client) {
706
707    // TODO: Update CameraClients + HAL interface to use strings for Camera IDs
708    int id = cameraIdToInt(cameraId);
709    if (id == -1) {
710        ALOGE("%s: Invalid camera ID %s, cannot convert to integer.", __FUNCTION__,
711                cameraId.string());
712        return BAD_VALUE;
713    }
714
715    if (halVersion < 0 || halVersion == deviceVersion) {
716        // Default path: HAL version is unspecified by caller, create CameraClient
717        // based on device version reported by the HAL.
718        switch(deviceVersion) {
719          case CAMERA_DEVICE_API_VERSION_1_0:
720            if (effectiveApiLevel == API_1) {  // Camera1 API route
721                sp<ICameraClient> tmp = static_cast<ICameraClient*>(cameraCb.get());
722                *client = new CameraClient(cameraService, tmp, packageName, id, facing,
723                        clientPid, clientUid, getpid(), legacyMode);
724            } else { // Camera2 API route
725                ALOGW("Camera using old HAL version: %d", deviceVersion);
726                return -EOPNOTSUPP;
727            }
728            break;
729          case CAMERA_DEVICE_API_VERSION_3_0:
730          case CAMERA_DEVICE_API_VERSION_3_1:
731          case CAMERA_DEVICE_API_VERSION_3_2:
732          case CAMERA_DEVICE_API_VERSION_3_3:
733            if (effectiveApiLevel == API_1) { // Camera1 API route
734                sp<ICameraClient> tmp = static_cast<ICameraClient*>(cameraCb.get());
735                *client = new Camera2Client(cameraService, tmp, packageName, id, facing,
736                        clientPid, clientUid, servicePid, legacyMode);
737            } else { // Camera2 API route
738                sp<ICameraDeviceCallbacks> tmp =
739                        static_cast<ICameraDeviceCallbacks*>(cameraCb.get());
740                *client = new CameraDeviceClient(cameraService, tmp, packageName, id,
741                        facing, clientPid, clientUid, servicePid);
742            }
743            break;
744          default:
745            // Should not be reachable
746            ALOGE("Unknown camera device HAL version: %d", deviceVersion);
747            return INVALID_OPERATION;
748        }
749    } else {
750        // A particular HAL version is requested by caller. Create CameraClient
751        // based on the requested HAL version.
752        if (deviceVersion > CAMERA_DEVICE_API_VERSION_1_0 &&
753            halVersion == CAMERA_DEVICE_API_VERSION_1_0) {
754            // Only support higher HAL version device opened as HAL1.0 device.
755            sp<ICameraClient> tmp = static_cast<ICameraClient*>(cameraCb.get());
756            *client = new CameraClient(cameraService, tmp, packageName, id, facing,
757                    clientPid, clientUid, servicePid, legacyMode);
758        } else {
759            // Other combinations (e.g. HAL3.x open as HAL2.x) are not supported yet.
760            ALOGE("Invalid camera HAL version %x: HAL %x device can only be"
761                    " opened as HAL %x device", halVersion, deviceVersion,
762                    CAMERA_DEVICE_API_VERSION_1_0);
763            return INVALID_OPERATION;
764        }
765    }
766    return NO_ERROR;
767}
768
769String8 CameraService::toString(std::set<userid_t> intSet) {
770    String8 s("");
771    bool first = true;
772    for (userid_t i : intSet) {
773        if (first) {
774            s.appendFormat("%d", i);
775            first = false;
776        } else {
777            s.appendFormat(", %d", i);
778        }
779    }
780    return s;
781}
782
783status_t CameraService::initializeShimMetadata(int cameraId) {
784    int uid = getCallingUid();
785
786    String16 internalPackageName("media");
787    String8 id = String8::format("%d", cameraId);
788    status_t ret = NO_ERROR;
789    sp<Client> tmp = nullptr;
790    if ((ret = connectHelper<ICameraClient,Client>(sp<ICameraClient>{nullptr}, id,
791            static_cast<int>(CAMERA_HAL_API_VERSION_UNSPECIFIED), internalPackageName, uid, API_1,
792            false, true, tmp)) != NO_ERROR) {
793        ALOGE("%s: Error %d (%s) initializing shim metadata.", __FUNCTION__, ret, strerror(ret));
794        return ret;
795    }
796    return NO_ERROR;
797}
798
799status_t CameraService::getLegacyParametersLazy(int cameraId,
800        /*out*/
801        CameraParameters* parameters) {
802
803    ALOGV("%s: for cameraId: %d", __FUNCTION__, cameraId);
804
805    status_t ret = 0;
806
807    if (parameters == NULL) {
808        ALOGE("%s: parameters must not be null", __FUNCTION__);
809        return BAD_VALUE;
810    }
811
812    String8 id = String8::format("%d", cameraId);
813
814    // Check if we already have parameters
815    {
816        // Scope for service lock
817        Mutex::Autolock lock(mServiceLock);
818        auto cameraState = getCameraState(id);
819        if (cameraState == nullptr) {
820            ALOGE("%s: Invalid camera ID: %s", __FUNCTION__, id.string());
821            return BAD_VALUE;
822        }
823        CameraParameters p = cameraState->getShimParams();
824        if (!p.isEmpty()) {
825            *parameters = p;
826            return NO_ERROR;
827        }
828    }
829
830    int64_t token = IPCThreadState::self()->clearCallingIdentity();
831    ret = initializeShimMetadata(cameraId);
832    IPCThreadState::self()->restoreCallingIdentity(token);
833    if (ret != NO_ERROR) {
834        // Error already logged by callee
835        return ret;
836    }
837
838    // Check for parameters again
839    {
840        // Scope for service lock
841        Mutex::Autolock lock(mServiceLock);
842        auto cameraState = getCameraState(id);
843        if (cameraState == nullptr) {
844            ALOGE("%s: Invalid camera ID: %s", __FUNCTION__, id.string());
845            return BAD_VALUE;
846        }
847        CameraParameters p = cameraState->getShimParams();
848        if (!p.isEmpty()) {
849            *parameters = p;
850            return NO_ERROR;
851        }
852    }
853
854    ALOGE("%s: Parameters were not initialized, or were empty.  Device may not be present.",
855            __FUNCTION__);
856    return INVALID_OPERATION;
857}
858
859status_t CameraService::validateConnectLocked(const String8& cameraId, /*inout*/int& clientUid)
860        const {
861
862    int callingPid = getCallingPid();
863
864    if (clientUid == USE_CALLING_UID) {
865        clientUid = getCallingUid();
866    } else {
867        // We only trust our own process to forward client UIDs
868        if (callingPid != getpid()) {
869            ALOGE("CameraService::connect X (PID %d) rejected (don't trust clientUid %d)",
870                    callingPid, clientUid);
871            return PERMISSION_DENIED;
872        }
873    }
874
875    if (!mModule) {
876        ALOGE("CameraService::connect X (PID %d) rejected (camera HAL module not loaded)",
877                callingPid);
878        return -ENODEV;
879    }
880
881    if (getCameraState(cameraId) == nullptr) {
882        ALOGE("CameraService::connect X (PID %d) rejected (invalid camera ID %s)", callingPid,
883                cameraId.string());
884        return -ENODEV;
885    }
886
887    userid_t clientUserId = multiuser_get_user_id(clientUid);
888
889    // Only allow clients who are being used by the current foreground device user, unless calling
890    // from our own process.
891    if (callingPid != getpid() && (mAllowedUsers.find(clientUserId) == mAllowedUsers.end())) {
892        ALOGE("CameraService::connect X (PID %d) rejected (cannot connect from "
893                "device user %d, currently allowed device users: %s)", callingPid, clientUserId,
894                toString(mAllowedUsers).string());
895        return PERMISSION_DENIED;
896    }
897
898    return checkIfDeviceIsUsable(cameraId);
899}
900
901status_t CameraService::checkIfDeviceIsUsable(const String8& cameraId) const {
902    auto cameraState = getCameraState(cameraId);
903    int callingPid = getCallingPid();
904    if (cameraState == nullptr) {
905        ALOGE("CameraService::connect X (PID %d) rejected (invalid camera ID %s)", callingPid,
906                cameraId.string());
907        return -ENODEV;
908    }
909
910    ICameraServiceListener::Status currentStatus = cameraState->getStatus();
911    if (currentStatus == ICameraServiceListener::STATUS_NOT_PRESENT) {
912        ALOGE("CameraService::connect X (PID %d) rejected (camera %s is not connected)",
913                callingPid, cameraId.string());
914        return -ENODEV;
915    } else if (currentStatus == ICameraServiceListener::STATUS_ENUMERATING) {
916        ALOGE("CameraService::connect X (PID %d) rejected, (camera %s is initializing)",
917                callingPid, cameraId.string());
918        return -EBUSY;
919    }
920
921    return NO_ERROR;
922}
923
924void CameraService::finishConnectLocked(const sp<BasicClient>& client,
925        const CameraService::DescriptorPtr& desc) {
926
927    // Make a descriptor for the incoming client
928    auto clientDescriptor = CameraService::CameraClientManager::makeClientDescriptor(client, desc);
929    auto evicted = mActiveClientManager.addAndEvict(clientDescriptor);
930
931    logConnected(desc->getKey(), static_cast<int>(desc->getOwnerId()),
932            String8(client->getPackageName()));
933
934    if (evicted.size() > 0) {
935        // This should never happen - clients should already have been removed in disconnect
936        for (auto& i : evicted) {
937            ALOGE("%s: Invalid state: Client for camera %s was not removed in disconnect",
938                    __FUNCTION__, i->getKey().string());
939        }
940
941        LOG_ALWAYS_FATAL("%s: Invalid state for CameraService, clients not evicted properly",
942                __FUNCTION__);
943    }
944
945    // And register a death notification for the client callback. Do
946    // this last to avoid Binder policy where a nested Binder
947    // transaction might be pre-empted to service the client death
948    // notification if the client process dies before linkToDeath is
949    // invoked.
950    sp<IBinder> remoteCallback = client->getRemote();
951    if (remoteCallback != nullptr) {
952        remoteCallback->linkToDeath(this);
953    }
954}
955
956status_t CameraService::handleEvictionsLocked(const String8& cameraId, int clientPid,
957        apiLevel effectiveApiLevel, const sp<IBinder>& remoteCallback, const String8& packageName,
958        /*out*/
959        sp<BasicClient>* client,
960        std::shared_ptr<resource_policy::ClientDescriptor<String8, sp<BasicClient>>>* partial) {
961    ATRACE_CALL();
962    status_t ret = NO_ERROR;
963    std::vector<DescriptorPtr> evictedClients;
964    DescriptorPtr clientDescriptor;
965    {
966        if (effectiveApiLevel == API_1) {
967            // If we are using API1, any existing client for this camera ID with the same remote
968            // should be returned rather than evicted to allow MediaRecorder to work properly.
969
970            auto current = mActiveClientManager.get(cameraId);
971            if (current != nullptr) {
972                auto clientSp = current->getValue();
973                if (clientSp.get() != nullptr) { // should never be needed
974                    if (!clientSp->canCastToApiClient(effectiveApiLevel)) {
975                        ALOGW("CameraService connect called from same client, but with a different"
976                                " API level, evicting prior client...");
977                    } else if (clientSp->getRemote() == remoteCallback) {
978                        ALOGI("CameraService::connect X (PID %d) (second call from same"
979                                " app binder, returning the same client)", clientPid);
980                        *client = clientSp;
981                        return NO_ERROR;
982                    }
983                }
984            }
985        }
986
987        // Return error if the device was unplugged or removed by the HAL for some reason
988        if ((ret = checkIfDeviceIsUsable(cameraId)) != NO_ERROR) {
989            return ret;
990        }
991
992        // Get current active client PIDs
993        std::vector<int> ownerPids(mActiveClientManager.getAllOwners());
994        ownerPids.push_back(clientPid);
995
996        // Use the value +PROCESS_STATE_NONEXISTENT, to avoid taking
997        // address of PROCESS_STATE_NONEXISTENT as a reference argument
998        // for the vector constructor. PROCESS_STATE_NONEXISTENT does
999        // not have an out-of-class definition.
1000        std::vector<int> priorities(ownerPids.size(), +PROCESS_STATE_NONEXISTENT);
1001
1002        // Get priorites of all active PIDs
1003        ProcessInfoService::getProcessStatesFromPids(ownerPids.size(), &ownerPids[0],
1004                /*out*/&priorities[0]);
1005
1006        // Update all active clients' priorities
1007        std::map<int,int> pidToPriorityMap;
1008        for (size_t i = 0; i < ownerPids.size() - 1; i++) {
1009            pidToPriorityMap.emplace(ownerPids[i], getCameraPriorityFromProcState(priorities[i]));
1010        }
1011        mActiveClientManager.updatePriorities(pidToPriorityMap);
1012
1013        // Get state for the given cameraId
1014        auto state = getCameraState(cameraId);
1015        if (state == nullptr) {
1016            ALOGE("CameraService::connect X (PID %d) rejected (no camera device with ID %s)",
1017                clientPid, cameraId.string());
1018            return BAD_VALUE;
1019        }
1020
1021        // Make descriptor for incoming client
1022        clientDescriptor = CameraClientManager::makeClientDescriptor(cameraId,
1023                sp<BasicClient>{nullptr}, static_cast<int32_t>(state->getCost()),
1024                state->getConflicting(),
1025                getCameraPriorityFromProcState(priorities[priorities.size() - 1]), clientPid);
1026
1027        // Find clients that would be evicted
1028        auto evicted = mActiveClientManager.wouldEvict(clientDescriptor);
1029
1030        // If the incoming client was 'evicted,' higher priority clients have the camera in the
1031        // background, so we cannot do evictions
1032        if (std::find(evicted.begin(), evicted.end(), clientDescriptor) != evicted.end()) {
1033            ALOGE("CameraService::connect X (PID %d) rejected (existing client(s) with higher"
1034                    " priority).", clientPid);
1035
1036            sp<BasicClient> clientSp = clientDescriptor->getValue();
1037            String8 curTime = getFormattedCurrentTime();
1038            auto incompatibleClients =
1039                    mActiveClientManager.getIncompatibleClients(clientDescriptor);
1040
1041            String8 msg = String8::format("%s : DENIED connect device %s client for package %s "
1042                    "(PID %d, priority %d) due to eviction policy", curTime.string(),
1043                    cameraId.string(), packageName.string(), clientPid,
1044                    getCameraPriorityFromProcState(priorities[priorities.size() - 1]));
1045
1046            for (auto& i : incompatibleClients) {
1047                msg.appendFormat("\n   - Blocked by existing device %s client for package %s"
1048                        "(PID %" PRId32 ", priority %" PRId32 ")", i->getKey().string(),
1049                        String8{i->getValue()->getPackageName()}.string(), i->getOwnerId(),
1050                        i->getPriority());
1051                ALOGE("   Conflicts with: Device %s, client package %s (PID %"
1052                        PRId32 ", priority %" PRId32 ")", i->getKey().string(),
1053                        String8{i->getValue()->getPackageName()}.string(), i->getOwnerId(),
1054                        i->getPriority());
1055            }
1056
1057            // Log the client's attempt
1058            Mutex::Autolock l(mLogLock);
1059            mEventLog.add(msg);
1060
1061            return -EBUSY;
1062        }
1063
1064        for (auto& i : evicted) {
1065            sp<BasicClient> clientSp = i->getValue();
1066            if (clientSp.get() == nullptr) {
1067                ALOGE("%s: Invalid state: Null client in active client list.", __FUNCTION__);
1068
1069                // TODO: Remove this
1070                LOG_ALWAYS_FATAL("%s: Invalid state for CameraService, null client in active list",
1071                        __FUNCTION__);
1072                mActiveClientManager.remove(i);
1073                continue;
1074            }
1075
1076            ALOGE("CameraService::connect evicting conflicting client for camera ID %s",
1077                    i->getKey().string());
1078            evictedClients.push_back(i);
1079
1080            // Log the clients evicted
1081            logEvent(String8::format("EVICT device %s client held by package %s (PID"
1082                    " %" PRId32 ", priority %" PRId32 ")\n   - Evicted by device %s client for"
1083                    " package %s (PID %d, priority %" PRId32 ")",
1084                    i->getKey().string(), String8{clientSp->getPackageName()}.string(),
1085                    i->getOwnerId(), i->getPriority(), cameraId.string(),
1086                    packageName.string(), clientPid,
1087                    getCameraPriorityFromProcState(priorities[priorities.size() - 1])));
1088
1089            // Notify the client of disconnection
1090            clientSp->notifyError(ICameraDeviceCallbacks::ERROR_CAMERA_DISCONNECTED,
1091                    CaptureResultExtras());
1092        }
1093    }
1094
1095    // Do not hold mServiceLock while disconnecting clients, but retain the condition blocking
1096    // other clients from connecting in mServiceLockWrapper if held
1097    mServiceLock.unlock();
1098
1099    // Clear caller identity temporarily so client disconnect PID checks work correctly
1100    int64_t token = IPCThreadState::self()->clearCallingIdentity();
1101
1102    // Destroy evicted clients
1103    for (auto& i : evictedClients) {
1104        // Disconnect is blocking, and should only have returned when HAL has cleaned up
1105        i->getValue()->disconnect(); // Clients will remove themselves from the active client list
1106    }
1107
1108    IPCThreadState::self()->restoreCallingIdentity(token);
1109
1110    for (const auto& i : evictedClients) {
1111        ALOGV("%s: Waiting for disconnect to complete for client for device %s (PID %" PRId32 ")",
1112                __FUNCTION__, i->getKey().string(), i->getOwnerId());
1113        ret = mActiveClientManager.waitUntilRemoved(i, DEFAULT_DISCONNECT_TIMEOUT_NS);
1114        if (ret == TIMED_OUT) {
1115            ALOGE("%s: Timed out waiting for client for device %s to disconnect, "
1116                    "current clients:\n%s", __FUNCTION__, i->getKey().string(),
1117                    mActiveClientManager.toString().string());
1118            return -EBUSY;
1119        }
1120        if (ret != NO_ERROR) {
1121            ALOGE("%s: Received error waiting for client for device %s to disconnect: %s (%d), "
1122                    "current clients:\n%s", __FUNCTION__, i->getKey().string(), strerror(-ret),
1123                    ret, mActiveClientManager.toString().string());
1124            return ret;
1125        }
1126    }
1127
1128    evictedClients.clear();
1129
1130    // Once clients have been disconnected, relock
1131    mServiceLock.lock();
1132
1133    // Check again if the device was unplugged or something while we weren't holding mServiceLock
1134    if ((ret = checkIfDeviceIsUsable(cameraId)) != NO_ERROR) {
1135        return ret;
1136    }
1137
1138    *partial = clientDescriptor;
1139    return NO_ERROR;
1140}
1141
1142status_t CameraService::connect(
1143        const sp<ICameraClient>& cameraClient,
1144        int cameraId,
1145        const String16& clientPackageName,
1146        int clientUid,
1147        /*out*/
1148        sp<ICamera>& device) {
1149
1150    ATRACE_CALL();
1151    status_t ret = NO_ERROR;
1152    String8 id = String8::format("%d", cameraId);
1153    sp<Client> client = nullptr;
1154    ret = connectHelper<ICameraClient,Client>(cameraClient, id, CAMERA_HAL_API_VERSION_UNSPECIFIED,
1155            clientPackageName, clientUid, API_1, false, false, /*out*/client);
1156
1157    if(ret != NO_ERROR) {
1158        logRejected(id, getCallingPid(), String8(clientPackageName),
1159                String8::format("%s (%d)", strerror(-ret), ret));
1160        return ret;
1161    }
1162
1163    device = client;
1164    return NO_ERROR;
1165}
1166
1167status_t CameraService::connectLegacy(
1168        const sp<ICameraClient>& cameraClient,
1169        int cameraId, int halVersion,
1170        const String16& clientPackageName,
1171        int clientUid,
1172        /*out*/
1173        sp<ICamera>& device) {
1174
1175    ATRACE_CALL();
1176    String8 id = String8::format("%d", cameraId);
1177    int apiVersion = mModule->getModuleApiVersion();
1178    if (halVersion != CAMERA_HAL_API_VERSION_UNSPECIFIED &&
1179            apiVersion < CAMERA_MODULE_API_VERSION_2_3) {
1180        /*
1181         * Either the HAL version is unspecified in which case this just creates
1182         * a camera client selected by the latest device version, or
1183         * it's a particular version in which case the HAL must supported
1184         * the open_legacy call
1185         */
1186        ALOGE("%s: camera HAL module version %x doesn't support connecting to legacy HAL devices!",
1187                __FUNCTION__, apiVersion);
1188        logRejected(id, getCallingPid(), String8(clientPackageName),
1189                String8("HAL module version doesn't support legacy HAL connections"));
1190        return INVALID_OPERATION;
1191    }
1192
1193    status_t ret = NO_ERROR;
1194    sp<Client> client = nullptr;
1195    ret = connectHelper<ICameraClient,Client>(cameraClient, id, halVersion, clientPackageName,
1196            clientUid, API_1, true, false, /*out*/client);
1197
1198    if(ret != NO_ERROR) {
1199        logRejected(id, getCallingPid(), String8(clientPackageName),
1200                String8::format("%s (%d)", strerror(-ret), ret));
1201        return ret;
1202    }
1203
1204    device = client;
1205    return NO_ERROR;
1206}
1207
1208status_t CameraService::connectDevice(
1209        const sp<ICameraDeviceCallbacks>& cameraCb,
1210        int cameraId,
1211        const String16& clientPackageName,
1212        int clientUid,
1213        /*out*/
1214        sp<ICameraDeviceUser>& device) {
1215
1216    ATRACE_CALL();
1217    status_t ret = NO_ERROR;
1218    String8 id = String8::format("%d", cameraId);
1219    sp<CameraDeviceClient> client = nullptr;
1220    ret = connectHelper<ICameraDeviceCallbacks,CameraDeviceClient>(cameraCb, id,
1221            CAMERA_HAL_API_VERSION_UNSPECIFIED, clientPackageName, clientUid, API_2, false, false,
1222            /*out*/client);
1223
1224    if(ret != NO_ERROR) {
1225        logRejected(id, getCallingPid(), String8(clientPackageName),
1226                String8::format("%s (%d)", strerror(-ret), ret));
1227        return ret;
1228    }
1229
1230    device = client;
1231    return NO_ERROR;
1232}
1233
1234status_t CameraService::setTorchMode(const String16& cameraId, bool enabled,
1235        const sp<IBinder>& clientBinder) {
1236
1237    ATRACE_CALL();
1238    if (enabled && clientBinder == nullptr) {
1239        ALOGE("%s: torch client binder is NULL", __FUNCTION__);
1240        return -EINVAL;
1241    }
1242
1243    String8 id = String8(cameraId.string());
1244    int uid = getCallingUid();
1245
1246    // verify id is valid.
1247    auto state = getCameraState(id);
1248    if (state == nullptr) {
1249        ALOGE("%s: camera id is invalid %s", __FUNCTION__, id.string());
1250        return -EINVAL;
1251    }
1252
1253    ICameraServiceListener::Status cameraStatus = state->getStatus();
1254    if (cameraStatus != ICameraServiceListener::STATUS_PRESENT &&
1255            cameraStatus != ICameraServiceListener::STATUS_NOT_AVAILABLE) {
1256        ALOGE("%s: camera id is invalid %s", __FUNCTION__, id.string());
1257        return -EINVAL;
1258    }
1259
1260    {
1261        Mutex::Autolock al(mTorchStatusMutex);
1262        ICameraServiceListener::TorchStatus status;
1263        status_t res = getTorchStatusLocked(id, &status);
1264        if (res) {
1265            ALOGE("%s: getting current torch status failed for camera %s",
1266                    __FUNCTION__, id.string());
1267            return -EINVAL;
1268        }
1269
1270        if (status == ICameraServiceListener::TORCH_STATUS_NOT_AVAILABLE) {
1271            if (cameraStatus == ICameraServiceListener::STATUS_NOT_AVAILABLE) {
1272                ALOGE("%s: torch mode of camera %s is not available because "
1273                        "camera is in use", __FUNCTION__, id.string());
1274                return -EBUSY;
1275            } else {
1276                ALOGE("%s: torch mode of camera %s is not available due to "
1277                        "insufficient resources", __FUNCTION__, id.string());
1278                return -EUSERS;
1279            }
1280        }
1281    }
1282
1283    {
1284        // Update UID map - this is used in the torch status changed callbacks, so must be done
1285        // before setTorchMode
1286        Mutex::Autolock al(mTorchUidMapMutex);
1287        if (mTorchUidMap.find(id) == mTorchUidMap.end()) {
1288            mTorchUidMap[id].first = uid;
1289            mTorchUidMap[id].second = uid;
1290        } else {
1291            // Set the pending UID
1292            mTorchUidMap[id].first = uid;
1293        }
1294    }
1295
1296    status_t res = mFlashlight->setTorchMode(id, enabled);
1297
1298    if (res) {
1299        ALOGE("%s: setting torch mode of camera %s to %d failed. %s (%d)",
1300                __FUNCTION__, id.string(), enabled, strerror(-res), res);
1301        return res;
1302    }
1303
1304    {
1305        // update the link to client's death
1306        Mutex::Autolock al(mTorchClientMapMutex);
1307        ssize_t index = mTorchClientMap.indexOfKey(id);
1308        if (enabled) {
1309            if (index == NAME_NOT_FOUND) {
1310                mTorchClientMap.add(id, clientBinder);
1311            } else {
1312                mTorchClientMap.valueAt(index)->unlinkToDeath(this);
1313                mTorchClientMap.replaceValueAt(index, clientBinder);
1314            }
1315            clientBinder->linkToDeath(this);
1316        } else if (index != NAME_NOT_FOUND) {
1317            mTorchClientMap.valueAt(index)->unlinkToDeath(this);
1318        }
1319    }
1320
1321    return OK;
1322}
1323
1324void CameraService::notifySystemEvent(int32_t eventId, const int32_t* args, size_t length) {
1325    ATRACE_CALL();
1326
1327    switch(eventId) {
1328        case ICameraService::USER_SWITCHED: {
1329            doUserSwitch(/*newUserIds*/args, /*length*/length);
1330            break;
1331        }
1332        case ICameraService::NO_EVENT:
1333        default: {
1334            ALOGW("%s: Received invalid system event from system_server: %d", __FUNCTION__,
1335                    eventId);
1336            break;
1337        }
1338    }
1339}
1340
1341status_t CameraService::addListener(const sp<ICameraServiceListener>& listener) {
1342    ATRACE_CALL();
1343
1344    ALOGV("%s: Add listener %p", __FUNCTION__, listener.get());
1345
1346    if (listener == nullptr) {
1347        ALOGE("%s: Listener must not be null", __FUNCTION__);
1348        return BAD_VALUE;
1349    }
1350
1351    Mutex::Autolock lock(mServiceLock);
1352
1353    {
1354        Mutex::Autolock lock(mStatusListenerLock);
1355        for (auto& it : mListenerList) {
1356            if (IInterface::asBinder(it) == IInterface::asBinder(listener)) {
1357                ALOGW("%s: Tried to add listener %p which was already subscribed",
1358                      __FUNCTION__, listener.get());
1359                return ALREADY_EXISTS;
1360            }
1361        }
1362
1363        mListenerList.push_back(listener);
1364    }
1365
1366
1367    /* Immediately signal current status to this listener only */
1368    {
1369        Mutex::Autolock lock(mCameraStatesLock);
1370        for (auto& i : mCameraStates) {
1371            // TODO: Update binder to use String16 for camera IDs and remove;
1372            int id = cameraIdToInt(i.first);
1373            if (id == -1) continue;
1374
1375            listener->onStatusChanged(i.second->getStatus(), id);
1376        }
1377    }
1378
1379    /* Immediately signal current torch status to this listener only */
1380    {
1381        Mutex::Autolock al(mTorchStatusMutex);
1382        for (size_t i = 0; i < mTorchStatusMap.size(); i++ ) {
1383            String16 id = String16(mTorchStatusMap.keyAt(i).string());
1384            listener->onTorchStatusChanged(mTorchStatusMap.valueAt(i), id);
1385        }
1386    }
1387
1388    return OK;
1389}
1390
1391status_t CameraService::removeListener(const sp<ICameraServiceListener>& listener) {
1392    ATRACE_CALL();
1393
1394    ALOGV("%s: Remove listener %p", __FUNCTION__, listener.get());
1395
1396    if (listener == 0) {
1397        ALOGE("%s: Listener must not be null", __FUNCTION__);
1398        return BAD_VALUE;
1399    }
1400
1401    Mutex::Autolock lock(mServiceLock);
1402
1403    {
1404        Mutex::Autolock lock(mStatusListenerLock);
1405        for (auto it = mListenerList.begin(); it != mListenerList.end(); it++) {
1406            if (IInterface::asBinder(*it) == IInterface::asBinder(listener)) {
1407                mListenerList.erase(it);
1408                return OK;
1409            }
1410        }
1411    }
1412
1413    ALOGW("%s: Tried to remove a listener %p which was not subscribed",
1414          __FUNCTION__, listener.get());
1415
1416    return BAD_VALUE;
1417}
1418
1419status_t CameraService::getLegacyParameters(int cameraId, /*out*/String16* parameters) {
1420
1421    ATRACE_CALL();
1422    ALOGV("%s: for camera ID = %d", __FUNCTION__, cameraId);
1423
1424    if (parameters == NULL) {
1425        ALOGE("%s: parameters must not be null", __FUNCTION__);
1426        return BAD_VALUE;
1427    }
1428
1429    status_t ret = 0;
1430
1431    CameraParameters shimParams;
1432    if ((ret = getLegacyParametersLazy(cameraId, /*out*/&shimParams)) != OK) {
1433        // Error logged by caller
1434        return ret;
1435    }
1436
1437    String8 shimParamsString8 = shimParams.flatten();
1438    String16 shimParamsString16 = String16(shimParamsString8);
1439
1440    *parameters = shimParamsString16;
1441
1442    return OK;
1443}
1444
1445status_t CameraService::supportsCameraApi(int cameraId, int apiVersion) {
1446    ATRACE_CALL();
1447
1448    ALOGV("%s: for camera ID = %d", __FUNCTION__, cameraId);
1449
1450    switch (apiVersion) {
1451        case API_VERSION_1:
1452        case API_VERSION_2:
1453            break;
1454        default:
1455            ALOGE("%s: Bad API version %d", __FUNCTION__, apiVersion);
1456            return BAD_VALUE;
1457    }
1458
1459    int facing = -1;
1460    int deviceVersion = getDeviceVersion(cameraId, &facing);
1461
1462    switch(deviceVersion) {
1463      case CAMERA_DEVICE_API_VERSION_1_0:
1464      case CAMERA_DEVICE_API_VERSION_3_0:
1465      case CAMERA_DEVICE_API_VERSION_3_1:
1466        if (apiVersion == API_VERSION_2) {
1467            ALOGV("%s: Camera id %d uses HAL prior to HAL3.2, doesn't support api2 without shim",
1468                    __FUNCTION__, cameraId);
1469            return -EOPNOTSUPP;
1470        } else { // if (apiVersion == API_VERSION_1) {
1471            ALOGV("%s: Camera id %d uses older HAL before 3.2, but api1 is always supported",
1472                    __FUNCTION__, cameraId);
1473            return OK;
1474        }
1475      case CAMERA_DEVICE_API_VERSION_3_2:
1476      case CAMERA_DEVICE_API_VERSION_3_3:
1477        ALOGV("%s: Camera id %d uses HAL3.2 or newer, supports api1/api2 directly",
1478                __FUNCTION__, cameraId);
1479        return OK;
1480      case -1:
1481        ALOGE("%s: Invalid camera id %d", __FUNCTION__, cameraId);
1482        return BAD_VALUE;
1483      default:
1484        ALOGE("%s: Unknown camera device HAL version: %d", __FUNCTION__, deviceVersion);
1485        return INVALID_OPERATION;
1486    }
1487
1488    return OK;
1489}
1490
1491void CameraService::removeByClient(const BasicClient* client) {
1492    Mutex::Autolock lock(mServiceLock);
1493    for (auto& i : mActiveClientManager.getAll()) {
1494        auto clientSp = i->getValue();
1495        if (clientSp.get() == client) {
1496            mActiveClientManager.remove(i);
1497        }
1498    }
1499}
1500
1501bool CameraService::evictClientIdByRemote(const wp<IBinder>& remote) {
1502    const int callingPid = getCallingPid();
1503    const int servicePid = getpid();
1504    bool ret = false;
1505    {
1506        // Acquire mServiceLock and prevent other clients from connecting
1507        std::unique_ptr<AutoConditionLock> lock =
1508                AutoConditionLock::waitAndAcquire(mServiceLockWrapper);
1509
1510
1511        std::vector<sp<BasicClient>> evicted;
1512        for (auto& i : mActiveClientManager.getAll()) {
1513            auto clientSp = i->getValue();
1514            if (clientSp.get() == nullptr) {
1515                ALOGE("%s: Dead client still in mActiveClientManager.", __FUNCTION__);
1516                mActiveClientManager.remove(i);
1517                continue;
1518            }
1519            if (remote == clientSp->getRemote() && (callingPid == servicePid ||
1520                    callingPid == clientSp->getClientPid())) {
1521                mActiveClientManager.remove(i);
1522                evicted.push_back(clientSp);
1523
1524                // Notify the client of disconnection
1525                clientSp->notifyError(ICameraDeviceCallbacks::ERROR_CAMERA_DISCONNECTED,
1526                        CaptureResultExtras());
1527            }
1528        }
1529
1530        // Do not hold mServiceLock while disconnecting clients, but retain the condition blocking
1531        // other clients from connecting in mServiceLockWrapper if held
1532        mServiceLock.unlock();
1533
1534        // Do not clear caller identity, remote caller should be client proccess
1535
1536        for (auto& i : evicted) {
1537            if (i.get() != nullptr) {
1538                i->disconnect();
1539                ret = true;
1540            }
1541        }
1542
1543        // Reacquire mServiceLock
1544        mServiceLock.lock();
1545
1546    } // lock is destroyed, allow further connect calls
1547
1548    return ret;
1549}
1550
1551
1552/**
1553 * Check camera capabilities, such as support for basic color operation
1554 * Also check that the device HAL version is still in support
1555 */
1556int CameraService::checkCameraCapabilities(int id, camera_info info, int *latestStrangeCameraId) {
1557    // device_version undefined in CAMERA_MODULE_API_VERSION_1_0,
1558    // All CAMERA_MODULE_API_VERSION_1_0 devices are backward-compatible
1559    if (mModule->getModuleApiVersion() >= CAMERA_MODULE_API_VERSION_2_0) {
1560        // Verify the device version is in the supported range
1561        switch (info.device_version) {
1562            case CAMERA_DEVICE_API_VERSION_1_0:
1563            case CAMERA_DEVICE_API_VERSION_3_0:
1564            case CAMERA_DEVICE_API_VERSION_3_1:
1565            case CAMERA_DEVICE_API_VERSION_3_2:
1566            case CAMERA_DEVICE_API_VERSION_3_3:
1567                // in support
1568                break;
1569            case CAMERA_DEVICE_API_VERSION_2_0:
1570            case CAMERA_DEVICE_API_VERSION_2_1:
1571                // no longer supported
1572            default:
1573                ALOGE("%s: Device %d has HAL version %x, which is not supported",
1574                        __FUNCTION__, id, info.device_version);
1575                String8 msg = String8::format(
1576                        "Unsupported device HAL version %x for device %d",
1577                        info.device_version, id);
1578                logServiceError(msg.string(), NO_INIT);
1579                return NO_INIT;
1580        }
1581    }
1582
1583    // Assume all devices pre-v3.3 are backward-compatible
1584    bool isBackwardCompatible = true;
1585    if (mModule->getModuleApiVersion() >= CAMERA_MODULE_API_VERSION_2_0
1586            && info.device_version >= CAMERA_DEVICE_API_VERSION_3_3) {
1587        isBackwardCompatible = false;
1588        status_t res;
1589        camera_metadata_ro_entry_t caps;
1590        res = find_camera_metadata_ro_entry(
1591            info.static_camera_characteristics,
1592            ANDROID_REQUEST_AVAILABLE_CAPABILITIES,
1593            &caps);
1594        if (res != 0) {
1595            ALOGW("%s: Unable to find camera capabilities for camera device %d",
1596                    __FUNCTION__, id);
1597            caps.count = 0;
1598        }
1599        for (size_t i = 0; i < caps.count; i++) {
1600            if (caps.data.u8[i] ==
1601                    ANDROID_REQUEST_AVAILABLE_CAPABILITIES_BACKWARD_COMPATIBLE) {
1602                isBackwardCompatible = true;
1603                break;
1604            }
1605        }
1606    }
1607
1608    if (!isBackwardCompatible) {
1609        mNumberOfNormalCameras--;
1610        *latestStrangeCameraId = id;
1611    } else {
1612        if (id > *latestStrangeCameraId) {
1613            ALOGE("%s: Normal camera ID %d higher than strange camera ID %d. "
1614                    "This is not allowed due backward-compatibility requirements",
1615                    __FUNCTION__, id, *latestStrangeCameraId);
1616            logServiceError("Invalid order of camera devices", NO_INIT);
1617            mNumberOfCameras = 0;
1618            mNumberOfNormalCameras = 0;
1619            return NO_INIT;
1620        }
1621    }
1622    return OK;
1623}
1624
1625std::shared_ptr<CameraService::CameraState> CameraService::getCameraState(
1626        const String8& cameraId) const {
1627    std::shared_ptr<CameraState> state;
1628    {
1629        Mutex::Autolock lock(mCameraStatesLock);
1630        auto iter = mCameraStates.find(cameraId);
1631        if (iter != mCameraStates.end()) {
1632            state = iter->second;
1633        }
1634    }
1635    return state;
1636}
1637
1638sp<CameraService::BasicClient> CameraService::removeClientLocked(const String8& cameraId) {
1639    // Remove from active clients list
1640    auto clientDescriptorPtr = mActiveClientManager.remove(cameraId);
1641    if (clientDescriptorPtr == nullptr) {
1642        ALOGW("%s: Could not evict client, no client for camera ID %s", __FUNCTION__,
1643                cameraId.string());
1644        return sp<BasicClient>{nullptr};
1645    }
1646
1647    return clientDescriptorPtr->getValue();
1648}
1649
1650void CameraService::doUserSwitch(const int32_t* newUserId, size_t length) {
1651    // Acquire mServiceLock and prevent other clients from connecting
1652    std::unique_ptr<AutoConditionLock> lock =
1653            AutoConditionLock::waitAndAcquire(mServiceLockWrapper);
1654
1655    std::set<userid_t> newAllowedUsers;
1656    for (size_t i = 0; i < length; i++) {
1657        if (newUserId[i] < 0) {
1658            ALOGE("%s: Bad user ID %d given during user switch, ignoring.",
1659                    __FUNCTION__, newUserId[i]);
1660            return;
1661        }
1662        newAllowedUsers.insert(static_cast<userid_t>(newUserId[i]));
1663    }
1664
1665
1666    if (newAllowedUsers == mAllowedUsers) {
1667        ALOGW("%s: Received notification of user switch with no updated user IDs.", __FUNCTION__);
1668        return;
1669    }
1670
1671    logUserSwitch(mAllowedUsers, newAllowedUsers);
1672
1673    mAllowedUsers = std::move(newAllowedUsers);
1674
1675    // Current user has switched, evict all current clients.
1676    std::vector<sp<BasicClient>> evicted;
1677    for (auto& i : mActiveClientManager.getAll()) {
1678        auto clientSp = i->getValue();
1679
1680        if (clientSp.get() == nullptr) {
1681            ALOGE("%s: Dead client still in mActiveClientManager.", __FUNCTION__);
1682            continue;
1683        }
1684
1685        // Don't evict clients that are still allowed.
1686        uid_t clientUid = clientSp->getClientUid();
1687        userid_t clientUserId = multiuser_get_user_id(clientUid);
1688        if (mAllowedUsers.find(clientUserId) != mAllowedUsers.end()) {
1689            continue;
1690        }
1691
1692        evicted.push_back(clientSp);
1693
1694        String8 curTime = getFormattedCurrentTime();
1695
1696        ALOGE("Evicting conflicting client for camera ID %s due to user change",
1697                i->getKey().string());
1698
1699        // Log the clients evicted
1700        logEvent(String8::format("EVICT device %s client held by package %s (PID %"
1701                PRId32 ", priority %" PRId32 ")\n   - Evicted due to user switch.",
1702                i->getKey().string(), String8{clientSp->getPackageName()}.string(),
1703                i->getOwnerId(), i->getPriority()));
1704
1705    }
1706
1707    // Do not hold mServiceLock while disconnecting clients, but retain the condition
1708    // blocking other clients from connecting in mServiceLockWrapper if held.
1709    mServiceLock.unlock();
1710
1711    // Clear caller identity temporarily so client disconnect PID checks work correctly
1712    int64_t token = IPCThreadState::self()->clearCallingIdentity();
1713
1714    for (auto& i : evicted) {
1715        i->disconnect();
1716    }
1717
1718    IPCThreadState::self()->restoreCallingIdentity(token);
1719
1720    // Reacquire mServiceLock
1721    mServiceLock.lock();
1722}
1723
1724void CameraService::logEvent(const char* event) {
1725    String8 curTime = getFormattedCurrentTime();
1726    Mutex::Autolock l(mLogLock);
1727    mEventLog.add(String8::format("%s : %s", curTime.string(), event));
1728}
1729
1730void CameraService::logDisconnected(const char* cameraId, int clientPid,
1731        const char* clientPackage) {
1732    // Log the clients evicted
1733    logEvent(String8::format("DISCONNECT device %s client for package %s (PID %d)", cameraId,
1734            clientPackage, clientPid));
1735}
1736
1737void CameraService::logConnected(const char* cameraId, int clientPid,
1738        const char* clientPackage) {
1739    // Log the clients evicted
1740    logEvent(String8::format("CONNECT device %s client for package %s (PID %d)", cameraId,
1741            clientPackage, clientPid));
1742}
1743
1744void CameraService::logRejected(const char* cameraId, int clientPid,
1745        const char* clientPackage, const char* reason) {
1746    // Log the client rejected
1747    logEvent(String8::format("REJECT device %s client for package %s (PID %d), reason: (%s)",
1748            cameraId, clientPackage, clientPid, reason));
1749}
1750
1751void CameraService::logUserSwitch(const std::set<userid_t>& oldUserIds,
1752        const std::set<userid_t>& newUserIds) {
1753    String8 newUsers = toString(newUserIds);
1754    String8 oldUsers = toString(oldUserIds);
1755    // Log the new and old users
1756    logEvent(String8::format("USER_SWITCH previous allowed users: %s , current allowed users: %s",
1757            oldUsers.string(), newUsers.string()));
1758}
1759
1760void CameraService::logDeviceRemoved(const char* cameraId, const char* reason) {
1761    // Log the device removal
1762    logEvent(String8::format("REMOVE device %s, reason: (%s)", cameraId, reason));
1763}
1764
1765void CameraService::logDeviceAdded(const char* cameraId, const char* reason) {
1766    // Log the device removal
1767    logEvent(String8::format("ADD device %s, reason: (%s)", cameraId, reason));
1768}
1769
1770void CameraService::logClientDied(int clientPid, const char* reason) {
1771    // Log the device removal
1772    logEvent(String8::format("DIED client(s) with PID %d, reason: (%s)", clientPid, reason));
1773}
1774
1775void CameraService::logServiceError(const char* msg, int errorCode) {
1776    String8 curTime = getFormattedCurrentTime();
1777    logEvent(String8::format("SERVICE ERROR: %s : %d (%s)", msg, errorCode, strerror(-errorCode)));
1778}
1779
1780status_t CameraService::onTransact(uint32_t code, const Parcel& data, Parcel* reply,
1781        uint32_t flags) {
1782
1783    const int pid = getCallingPid();
1784    const int selfPid = getpid();
1785
1786    // Permission checks
1787    switch (code) {
1788        case BnCameraService::CONNECT:
1789        case BnCameraService::CONNECT_DEVICE:
1790        case BnCameraService::CONNECT_LEGACY: {
1791            if (pid != selfPid) {
1792                // we're called from a different process, do the real check
1793                if (!checkCallingPermission(
1794                        String16("android.permission.CAMERA"))) {
1795                    const int uid = getCallingUid();
1796                    ALOGE("Permission Denial: "
1797                         "can't use the camera pid=%d, uid=%d", pid, uid);
1798                    return PERMISSION_DENIED;
1799                }
1800            }
1801            break;
1802        }
1803        case BnCameraService::NOTIFY_SYSTEM_EVENT: {
1804            if (pid != selfPid) {
1805                // Ensure we're being called by system_server, or similar process with
1806                // permissions to notify the camera service about system events
1807                if (!checkCallingPermission(
1808                        String16("android.permission.CAMERA_SEND_SYSTEM_EVENTS"))) {
1809                    const int uid = getCallingUid();
1810                    ALOGE("Permission Denial: cannot send updates to camera service about system"
1811                            " events from pid=%d, uid=%d", pid, uid);
1812                    return PERMISSION_DENIED;
1813                }
1814            }
1815            break;
1816        }
1817    }
1818
1819    return BnCameraService::onTransact(code, data, reply, flags);
1820}
1821
1822// We share the media players for shutter and recording sound for all clients.
1823// A reference count is kept to determine when we will actually release the
1824// media players.
1825
1826MediaPlayer* CameraService::newMediaPlayer(const char *file) {
1827    MediaPlayer* mp = new MediaPlayer();
1828    if (mp->setDataSource(NULL /* httpService */, file, NULL) == NO_ERROR) {
1829        mp->setAudioStreamType(AUDIO_STREAM_ENFORCED_AUDIBLE);
1830        mp->prepare();
1831    } else {
1832        ALOGE("Failed to load CameraService sounds: %s", file);
1833        return NULL;
1834    }
1835    return mp;
1836}
1837
1838void CameraService::loadSound() {
1839    ATRACE_CALL();
1840
1841    Mutex::Autolock lock(mSoundLock);
1842    LOG1("CameraService::loadSound ref=%d", mSoundRef);
1843    if (mSoundRef++) return;
1844
1845    mSoundPlayer[SOUND_SHUTTER] = newMediaPlayer("/system/media/audio/ui/camera_click.ogg");
1846    mSoundPlayer[SOUND_RECORDING_START] = newMediaPlayer("/system/media/audio/ui/VideoRecord.ogg");
1847    mSoundPlayer[SOUND_RECORDING_STOP] = newMediaPlayer("/system/media/audio/ui/VideoStop.ogg");
1848}
1849
1850void CameraService::releaseSound() {
1851    Mutex::Autolock lock(mSoundLock);
1852    LOG1("CameraService::releaseSound ref=%d", mSoundRef);
1853    if (--mSoundRef) return;
1854
1855    for (int i = 0; i < NUM_SOUNDS; i++) {
1856        if (mSoundPlayer[i] != 0) {
1857            mSoundPlayer[i]->disconnect();
1858            mSoundPlayer[i].clear();
1859        }
1860    }
1861}
1862
1863void CameraService::playSound(sound_kind kind) {
1864    ATRACE_CALL();
1865
1866    LOG1("playSound(%d)", kind);
1867    Mutex::Autolock lock(mSoundLock);
1868    sp<MediaPlayer> player = mSoundPlayer[kind];
1869    if (player != 0) {
1870        player->seekTo(0);
1871        player->start();
1872    }
1873}
1874
1875// ----------------------------------------------------------------------------
1876
1877CameraService::Client::Client(const sp<CameraService>& cameraService,
1878        const sp<ICameraClient>& cameraClient,
1879        const String16& clientPackageName,
1880        int cameraId, int cameraFacing,
1881        int clientPid, uid_t clientUid,
1882        int servicePid) :
1883        CameraService::BasicClient(cameraService,
1884                IInterface::asBinder(cameraClient),
1885                clientPackageName,
1886                cameraId, cameraFacing,
1887                clientPid, clientUid,
1888                servicePid)
1889{
1890    int callingPid = getCallingPid();
1891    LOG1("Client::Client E (pid %d, id %d)", callingPid, cameraId);
1892
1893    mRemoteCallback = cameraClient;
1894
1895    cameraService->loadSound();
1896
1897    LOG1("Client::Client X (pid %d, id %d)", callingPid, cameraId);
1898}
1899
1900// tear down the client
1901CameraService::Client::~Client() {
1902    ALOGV("~Client");
1903    mDestructionStarted = true;
1904
1905    mCameraService->releaseSound();
1906    // unconditionally disconnect. function is idempotent
1907    Client::disconnect();
1908}
1909
1910CameraService::BasicClient::BasicClient(const sp<CameraService>& cameraService,
1911        const sp<IBinder>& remoteCallback,
1912        const String16& clientPackageName,
1913        int cameraId, int cameraFacing,
1914        int clientPid, uid_t clientUid,
1915        int servicePid):
1916        mClientPackageName(clientPackageName), mDisconnected(false)
1917{
1918    mCameraService = cameraService;
1919    mRemoteBinder = remoteCallback;
1920    mCameraId = cameraId;
1921    mCameraFacing = cameraFacing;
1922    mClientPid = clientPid;
1923    mClientUid = clientUid;
1924    mServicePid = servicePid;
1925    mOpsActive = false;
1926    mDestructionStarted = false;
1927
1928    // In some cases the calling code has no access to the package it runs under.
1929    // For example, NDK camera API.
1930    // In this case we will get the packages for the calling UID and pick the first one
1931    // for attributing the app op. This will work correctly for runtime permissions
1932    // as for legacy apps we will toggle the app op for all packages in the UID.
1933    // The caveat is that the operation may be attributed to the wrong package and
1934    // stats based on app ops may be slightly off.
1935    if (mClientPackageName.size() <= 0) {
1936        sp<IServiceManager> sm = defaultServiceManager();
1937        sp<IBinder> binder = sm->getService(String16(kPermissionServiceName));
1938        if (binder == 0) {
1939            ALOGE("Cannot get permission service");
1940            // Leave mClientPackageName unchanged (empty) and the further interaction
1941            // with camera will fail in BasicClient::startCameraOps
1942            return;
1943        }
1944
1945        sp<IPermissionController> permCtrl = interface_cast<IPermissionController>(binder);
1946        Vector<String16> packages;
1947
1948        permCtrl->getPackagesForUid(mClientUid, packages);
1949
1950        if (packages.isEmpty()) {
1951            ALOGE("No packages for calling UID");
1952            // Leave mClientPackageName unchanged (empty) and the further interaction
1953            // with camera will fail in BasicClient::startCameraOps
1954            return;
1955        }
1956        mClientPackageName = packages[0];
1957    }
1958}
1959
1960CameraService::BasicClient::~BasicClient() {
1961    ALOGV("~BasicClient");
1962    mDestructionStarted = true;
1963}
1964
1965void CameraService::BasicClient::disconnect() {
1966    if (mDisconnected) {
1967        return;
1968    }
1969    mDisconnected = true;
1970
1971    mCameraService->removeByClient(this);
1972    mCameraService->logDisconnected(String8::format("%d", mCameraId), mClientPid,
1973            String8(mClientPackageName));
1974
1975    sp<IBinder> remote = getRemote();
1976    if (remote != nullptr) {
1977        remote->unlinkToDeath(mCameraService);
1978    }
1979
1980    finishCameraOps();
1981    ALOGI("%s: Disconnected client for camera %d for PID %d", __FUNCTION__, mCameraId, mClientPid);
1982
1983    // client shouldn't be able to call into us anymore
1984    mClientPid = 0;
1985}
1986
1987status_t CameraService::BasicClient::dump(int, const Vector<String16>&) {
1988    // No dumping of clients directly over Binder,
1989    // must go through CameraService::dump
1990    android_errorWriteWithInfoLog(SN_EVENT_LOG_ID, "26265403",
1991            IPCThreadState::self()->getCallingUid(), NULL, 0);
1992    return OK;
1993}
1994
1995String16 CameraService::BasicClient::getPackageName() const {
1996    return mClientPackageName;
1997}
1998
1999
2000int CameraService::BasicClient::getClientPid() const {
2001    return mClientPid;
2002}
2003
2004uid_t CameraService::BasicClient::getClientUid() const {
2005    return mClientUid;
2006}
2007
2008bool CameraService::BasicClient::canCastToApiClient(apiLevel level) const {
2009    // Defaults to API2.
2010    return level == API_2;
2011}
2012
2013status_t CameraService::BasicClient::startCameraOps() {
2014    ATRACE_CALL();
2015
2016    int32_t res;
2017    // Notify app ops that the camera is not available
2018    mOpsCallback = new OpsCallback(this);
2019
2020    {
2021        ALOGV("%s: Start camera ops, package name = %s, client UID = %d",
2022              __FUNCTION__, String8(mClientPackageName).string(), mClientUid);
2023    }
2024
2025    mAppOpsManager.startWatchingMode(AppOpsManager::OP_CAMERA,
2026            mClientPackageName, mOpsCallback);
2027    res = mAppOpsManager.startOp(AppOpsManager::OP_CAMERA,
2028            mClientUid, mClientPackageName);
2029
2030    if (res == AppOpsManager::MODE_ERRORED) {
2031        ALOGI("Camera %d: Access for \"%s\" has been revoked",
2032                mCameraId, String8(mClientPackageName).string());
2033        return PERMISSION_DENIED;
2034    }
2035
2036    if (res == AppOpsManager::MODE_IGNORED) {
2037        ALOGI("Camera %d: Access for \"%s\" has been restricted",
2038                mCameraId, String8(mClientPackageName).string());
2039        // Return the same error as for device policy manager rejection
2040        return -EACCES;
2041    }
2042
2043    mOpsActive = true;
2044
2045    // Transition device availability listeners from PRESENT -> NOT_AVAILABLE
2046    mCameraService->updateStatus(ICameraServiceListener::STATUS_NOT_AVAILABLE,
2047            String8::format("%d", mCameraId));
2048
2049    // Transition device state to OPEN
2050    mCameraService->updateProxyDeviceState(ICameraServiceProxy::CAMERA_STATE_OPEN,
2051            String8::format("%d", mCameraId));
2052
2053    return OK;
2054}
2055
2056status_t CameraService::BasicClient::finishCameraOps() {
2057    ATRACE_CALL();
2058
2059    // Check if startCameraOps succeeded, and if so, finish the camera op
2060    if (mOpsActive) {
2061        // Notify app ops that the camera is available again
2062        mAppOpsManager.finishOp(AppOpsManager::OP_CAMERA, mClientUid,
2063                mClientPackageName);
2064        mOpsActive = false;
2065
2066        auto rejected = {ICameraServiceListener::STATUS_NOT_PRESENT,
2067                ICameraServiceListener::STATUS_ENUMERATING};
2068
2069        // Transition to PRESENT if the camera is not in either of the rejected states
2070        mCameraService->updateStatus(ICameraServiceListener::STATUS_PRESENT,
2071                String8::format("%d", mCameraId), rejected);
2072
2073        // Transition device state to CLOSED
2074        mCameraService->updateProxyDeviceState(ICameraServiceProxy::CAMERA_STATE_CLOSED,
2075                String8::format("%d", mCameraId));
2076
2077        // Notify flashlight that a camera device is closed.
2078        mCameraService->mFlashlight->deviceClosed(
2079                String8::format("%d", mCameraId));
2080    }
2081    // Always stop watching, even if no camera op is active
2082    if (mOpsCallback != NULL) {
2083        mAppOpsManager.stopWatchingMode(mOpsCallback);
2084    }
2085    mOpsCallback.clear();
2086
2087    return OK;
2088}
2089
2090void CameraService::BasicClient::opChanged(int32_t op, const String16& packageName) {
2091    ATRACE_CALL();
2092
2093    String8 name(packageName);
2094    String8 myName(mClientPackageName);
2095
2096    if (op != AppOpsManager::OP_CAMERA) {
2097        ALOGW("Unexpected app ops notification received: %d", op);
2098        return;
2099    }
2100
2101    int32_t res;
2102    res = mAppOpsManager.checkOp(AppOpsManager::OP_CAMERA,
2103            mClientUid, mClientPackageName);
2104    ALOGV("checkOp returns: %d, %s ", res,
2105            res == AppOpsManager::MODE_ALLOWED ? "ALLOWED" :
2106            res == AppOpsManager::MODE_IGNORED ? "IGNORED" :
2107            res == AppOpsManager::MODE_ERRORED ? "ERRORED" :
2108            "UNKNOWN");
2109
2110    if (res != AppOpsManager::MODE_ALLOWED) {
2111        ALOGI("Camera %d: Access for \"%s\" revoked", mCameraId,
2112                myName.string());
2113        // Reset the client PID to allow server-initiated disconnect,
2114        // and to prevent further calls by client.
2115        mClientPid = getCallingPid();
2116        CaptureResultExtras resultExtras; // a dummy result (invalid)
2117        notifyError(ICameraDeviceCallbacks::ERROR_CAMERA_SERVICE, resultExtras);
2118        disconnect();
2119    }
2120}
2121
2122// ----------------------------------------------------------------------------
2123
2124// Provide client strong pointer for callbacks.
2125sp<CameraService::Client> CameraService::Client::getClientFromCookie(void* user) {
2126    String8 cameraId = String8::format("%d", (int)(intptr_t) user);
2127    auto clientDescriptor = gCameraService->mActiveClientManager.get(cameraId);
2128    if (clientDescriptor != nullptr) {
2129        return sp<Client>{
2130                static_cast<Client*>(clientDescriptor->getValue().get())};
2131    }
2132    return sp<Client>{nullptr};
2133}
2134
2135void CameraService::Client::notifyError(ICameraDeviceCallbacks::CameraErrorCode errorCode,
2136        const CaptureResultExtras& resultExtras) {
2137    (void) errorCode;
2138    (void) resultExtras;
2139    if (mRemoteCallback != NULL) {
2140        mRemoteCallback->notifyCallback(CAMERA_MSG_ERROR, CAMERA_ERROR_RELEASED, 0);
2141    } else {
2142        ALOGE("mRemoteCallback is NULL!!");
2143    }
2144}
2145
2146// NOTE: function is idempotent
2147void CameraService::Client::disconnect() {
2148    ALOGV("Client::disconnect");
2149    BasicClient::disconnect();
2150}
2151
2152bool CameraService::Client::canCastToApiClient(apiLevel level) const {
2153    return level == API_1;
2154}
2155
2156CameraService::Client::OpsCallback::OpsCallback(wp<BasicClient> client):
2157        mClient(client) {
2158}
2159
2160void CameraService::Client::OpsCallback::opChanged(int32_t op,
2161        const String16& packageName) {
2162    sp<BasicClient> client = mClient.promote();
2163    if (client != NULL) {
2164        client->opChanged(op, packageName);
2165    }
2166}
2167
2168// ----------------------------------------------------------------------------
2169//                  CameraState
2170// ----------------------------------------------------------------------------
2171
2172CameraService::CameraState::CameraState(const String8& id, int cost,
2173        const std::set<String8>& conflicting) : mId(id),
2174        mStatus(ICameraServiceListener::STATUS_PRESENT), mCost(cost), mConflicting(conflicting) {}
2175
2176CameraService::CameraState::~CameraState() {}
2177
2178ICameraServiceListener::Status CameraService::CameraState::getStatus() const {
2179    Mutex::Autolock lock(mStatusLock);
2180    return mStatus;
2181}
2182
2183CameraParameters CameraService::CameraState::getShimParams() const {
2184    return mShimParams;
2185}
2186
2187void CameraService::CameraState::setShimParams(const CameraParameters& params) {
2188    mShimParams = params;
2189}
2190
2191int CameraService::CameraState::getCost() const {
2192    return mCost;
2193}
2194
2195std::set<String8> CameraService::CameraState::getConflicting() const {
2196    return mConflicting;
2197}
2198
2199String8 CameraService::CameraState::getId() const {
2200    return mId;
2201}
2202
2203// ----------------------------------------------------------------------------
2204//                  ClientEventListener
2205// ----------------------------------------------------------------------------
2206
2207void CameraService::ClientEventListener::onClientAdded(
2208        const resource_policy::ClientDescriptor<String8,
2209        sp<CameraService::BasicClient>>& descriptor) {
2210    auto basicClient = descriptor.getValue();
2211    if (basicClient.get() != nullptr) {
2212        BatteryNotifier& notifier(BatteryNotifier::getInstance());
2213        notifier.noteStartCamera(descriptor.getKey(),
2214                static_cast<int>(basicClient->getClientUid()));
2215    }
2216}
2217
2218void CameraService::ClientEventListener::onClientRemoved(
2219        const resource_policy::ClientDescriptor<String8,
2220        sp<CameraService::BasicClient>>& descriptor) {
2221    auto basicClient = descriptor.getValue();
2222    if (basicClient.get() != nullptr) {
2223        BatteryNotifier& notifier(BatteryNotifier::getInstance());
2224        notifier.noteStopCamera(descriptor.getKey(),
2225                static_cast<int>(basicClient->getClientUid()));
2226    }
2227}
2228
2229
2230// ----------------------------------------------------------------------------
2231//                  CameraClientManager
2232// ----------------------------------------------------------------------------
2233
2234CameraService::CameraClientManager::CameraClientManager() {
2235    setListener(std::make_shared<ClientEventListener>());
2236}
2237
2238CameraService::CameraClientManager::~CameraClientManager() {}
2239
2240sp<CameraService::BasicClient> CameraService::CameraClientManager::getCameraClient(
2241        const String8& id) const {
2242    auto descriptor = get(id);
2243    if (descriptor == nullptr) {
2244        return sp<BasicClient>{nullptr};
2245    }
2246    return descriptor->getValue();
2247}
2248
2249String8 CameraService::CameraClientManager::toString() const {
2250    auto all = getAll();
2251    String8 ret("[");
2252    bool hasAny = false;
2253    for (auto& i : all) {
2254        hasAny = true;
2255        String8 key = i->getKey();
2256        int32_t cost = i->getCost();
2257        int32_t pid = i->getOwnerId();
2258        int32_t priority = i->getPriority();
2259        auto conflicting = i->getConflicting();
2260        auto clientSp = i->getValue();
2261        String8 packageName;
2262        userid_t clientUserId = 0;
2263        if (clientSp.get() != nullptr) {
2264            packageName = String8{clientSp->getPackageName()};
2265            uid_t clientUid = clientSp->getClientUid();
2266            clientUserId = multiuser_get_user_id(clientUid);
2267        }
2268        ret.appendFormat("\n(Camera ID: %s, Cost: %" PRId32 ", PID: %" PRId32 ", Priority: %"
2269                PRId32 ", ", key.string(), cost, pid, priority);
2270
2271        if (clientSp.get() != nullptr) {
2272            ret.appendFormat("User Id: %d, ", clientUserId);
2273        }
2274        if (packageName.size() != 0) {
2275            ret.appendFormat("Client Package Name: %s", packageName.string());
2276        }
2277
2278        ret.append(", Conflicting Client Devices: {");
2279        for (auto& j : conflicting) {
2280            ret.appendFormat("%s, ", j.string());
2281        }
2282        ret.append("})");
2283    }
2284    if (hasAny) ret.append("\n");
2285    ret.append("]\n");
2286    return ret;
2287}
2288
2289CameraService::DescriptorPtr CameraService::CameraClientManager::makeClientDescriptor(
2290        const String8& key, const sp<BasicClient>& value, int32_t cost,
2291        const std::set<String8>& conflictingKeys, int32_t priority, int32_t ownerId) {
2292
2293    return std::make_shared<resource_policy::ClientDescriptor<String8, sp<BasicClient>>>(
2294            key, value, cost, conflictingKeys, priority, ownerId);
2295}
2296
2297CameraService::DescriptorPtr CameraService::CameraClientManager::makeClientDescriptor(
2298        const sp<BasicClient>& value, const CameraService::DescriptorPtr& partial) {
2299    return makeClientDescriptor(partial->getKey(), value, partial->getCost(),
2300            partial->getConflicting(), partial->getPriority(), partial->getOwnerId());
2301}
2302
2303// ----------------------------------------------------------------------------
2304
2305static const int kDumpLockRetries = 50;
2306static const int kDumpLockSleep = 60000;
2307
2308static bool tryLock(Mutex& mutex)
2309{
2310    bool locked = false;
2311    for (int i = 0; i < kDumpLockRetries; ++i) {
2312        if (mutex.tryLock() == NO_ERROR) {
2313            locked = true;
2314            break;
2315        }
2316        usleep(kDumpLockSleep);
2317    }
2318    return locked;
2319}
2320
2321status_t CameraService::dump(int fd, const Vector<String16>& args) {
2322    ATRACE_CALL();
2323
2324    String8 result("Dump of the Camera Service:\n");
2325    if (checkCallingPermission(String16("android.permission.DUMP")) == false) {
2326        result = result.format("Permission Denial: "
2327                "can't dump CameraService from pid=%d, uid=%d\n",
2328                getCallingPid(),
2329                getCallingUid());
2330        write(fd, result.string(), result.size());
2331    } else {
2332        bool locked = tryLock(mServiceLock);
2333        // failed to lock - CameraService is probably deadlocked
2334        if (!locked) {
2335            result.append("CameraService may be deadlocked\n");
2336            write(fd, result.string(), result.size());
2337        }
2338
2339        bool hasClient = false;
2340        if (!mModule) {
2341            result = String8::format("No camera module available!\n");
2342            write(fd, result.string(), result.size());
2343
2344            // Dump event log for error information
2345            dumpEventLog(fd);
2346
2347            if (locked) mServiceLock.unlock();
2348            return NO_ERROR;
2349        }
2350
2351        result = String8::format("Camera module HAL API version: 0x%x\n", mModule->getHalApiVersion());
2352        result.appendFormat("Camera module API version: 0x%x\n", mModule->getModuleApiVersion());
2353        result.appendFormat("Camera module name: %s\n", mModule->getModuleName());
2354        result.appendFormat("Camera module author: %s\n", mModule->getModuleAuthor());
2355        result.appendFormat("Number of camera devices: %d\n", mNumberOfCameras);
2356        result.appendFormat("Number of normal camera devices: %d\n", mNumberOfNormalCameras);
2357        String8 activeClientString = mActiveClientManager.toString();
2358        result.appendFormat("Active Camera Clients:\n%s", activeClientString.string());
2359        result.appendFormat("Allowed users:\n%s\n", toString(mAllowedUsers).string());
2360
2361        sp<VendorTagDescriptor> desc = VendorTagDescriptor::getGlobalVendorTagDescriptor();
2362        if (desc == NULL) {
2363            result.appendFormat("Vendor tags left unimplemented.\n");
2364        } else {
2365            result.appendFormat("Vendor tag definitions:\n");
2366        }
2367
2368        write(fd, result.string(), result.size());
2369
2370        if (desc != NULL) {
2371            desc->dump(fd, /*verbosity*/2, /*indentation*/4);
2372        }
2373
2374        dumpEventLog(fd);
2375
2376        bool stateLocked = tryLock(mCameraStatesLock);
2377        if (!stateLocked) {
2378            result = String8::format("CameraStates in use, may be deadlocked\n");
2379            write(fd, result.string(), result.size());
2380        }
2381
2382        for (auto& state : mCameraStates) {
2383            String8 cameraId = state.first;
2384            result = String8::format("Camera %s information:\n", cameraId.string());
2385            camera_info info;
2386
2387            // TODO: Change getCameraInfo + HAL to use String cameraIds
2388            status_t rc = mModule->getCameraInfo(cameraIdToInt(cameraId), &info);
2389            if (rc != OK) {
2390                result.appendFormat("  Error reading static information!\n");
2391                write(fd, result.string(), result.size());
2392            } else {
2393                result.appendFormat("  Facing: %s\n",
2394                        info.facing == CAMERA_FACING_BACK ? "BACK" : "FRONT");
2395                result.appendFormat("  Orientation: %d\n", info.orientation);
2396                int deviceVersion;
2397                if (mModule->getModuleApiVersion() < CAMERA_MODULE_API_VERSION_2_0) {
2398                    deviceVersion = CAMERA_DEVICE_API_VERSION_1_0;
2399                } else {
2400                    deviceVersion = info.device_version;
2401                }
2402
2403                auto conflicting = state.second->getConflicting();
2404                result.appendFormat("  Resource Cost: %d\n", state.second->getCost());
2405                result.appendFormat("  Conflicting Devices:");
2406                for (auto& id : conflicting) {
2407                    result.appendFormat(" %s", id.string());
2408                }
2409                if (conflicting.size() == 0) {
2410                    result.appendFormat(" NONE");
2411                }
2412                result.appendFormat("\n");
2413
2414                result.appendFormat("  Device version: %#x\n", deviceVersion);
2415                if (deviceVersion >= CAMERA_DEVICE_API_VERSION_3_0) {
2416                    result.appendFormat("  Device static metadata:\n");
2417                    write(fd, result.string(), result.size());
2418                    dump_indented_camera_metadata(info.static_camera_characteristics,
2419                            fd, /*verbosity*/2, /*indentation*/4);
2420                } else {
2421                    write(fd, result.string(), result.size());
2422                }
2423
2424                CameraParameters p = state.second->getShimParams();
2425                if (!p.isEmpty()) {
2426                    result = String8::format("  Camera1 API shim is using parameters:\n        ");
2427                    write(fd, result.string(), result.size());
2428                    p.dump(fd, args);
2429                }
2430            }
2431
2432            auto clientDescriptor = mActiveClientManager.get(cameraId);
2433            if (clientDescriptor == nullptr) {
2434                result = String8::format("  Device %s is closed, no client instance\n",
2435                        cameraId.string());
2436                write(fd, result.string(), result.size());
2437                continue;
2438            }
2439            hasClient = true;
2440            result = String8::format("  Device %s is open. Client instance dump:\n\n",
2441                    cameraId.string());
2442            result.appendFormat("Client priority level: %d\n", clientDescriptor->getPriority());
2443            result.appendFormat("Client PID: %d\n", clientDescriptor->getOwnerId());
2444
2445            auto client = clientDescriptor->getValue();
2446            result.appendFormat("Client package: %s\n",
2447                    String8(client->getPackageName()).string());
2448            write(fd, result.string(), result.size());
2449
2450            client->dumpClient(fd, args);
2451        }
2452
2453        if (stateLocked) mCameraStatesLock.unlock();
2454
2455        if (!hasClient) {
2456            result = String8::format("\nNo active camera clients yet.\n");
2457            write(fd, result.string(), result.size());
2458        }
2459
2460        if (locked) mServiceLock.unlock();
2461
2462        // Dump camera traces if there were any
2463        write(fd, "\n", 1);
2464        camera3::CameraTraces::dump(fd, args);
2465
2466        // change logging level
2467        int n = args.size();
2468        for (int i = 0; i + 1 < n; i++) {
2469            String16 verboseOption("-v");
2470            if (args[i] == verboseOption) {
2471                String8 levelStr(args[i+1]);
2472                int level = atoi(levelStr.string());
2473                result = String8::format("\nSetting log level to %d.\n", level);
2474                setLogLevel(level);
2475                write(fd, result.string(), result.size());
2476            }
2477        }
2478    }
2479    return NO_ERROR;
2480}
2481
2482void CameraService::dumpEventLog(int fd) {
2483    String8 result = String8("\nPrior client events (most recent at top):\n");
2484
2485    Mutex::Autolock l(mLogLock);
2486    for (const auto& msg : mEventLog) {
2487        result.appendFormat("  %s\n", msg.string());
2488    }
2489
2490    if (mEventLog.size() == DEFAULT_EVENT_LOG_LENGTH) {
2491        result.append("  ...\n");
2492    } else if (mEventLog.size() == 0) {
2493        result.append("  [no events yet]\n");
2494    }
2495    result.append("\n");
2496
2497    write(fd, result.string(), result.size());
2498}
2499
2500void CameraService::handleTorchClientBinderDied(const wp<IBinder> &who) {
2501    Mutex::Autolock al(mTorchClientMapMutex);
2502    for (size_t i = 0; i < mTorchClientMap.size(); i++) {
2503        if (mTorchClientMap[i] == who) {
2504            // turn off the torch mode that was turned on by dead client
2505            String8 cameraId = mTorchClientMap.keyAt(i);
2506            status_t res = mFlashlight->setTorchMode(cameraId, false);
2507            if (res) {
2508                ALOGE("%s: torch client died but couldn't turn off torch: "
2509                    "%s (%d)", __FUNCTION__, strerror(-res), res);
2510                return;
2511            }
2512            mTorchClientMap.removeItemsAt(i);
2513            break;
2514        }
2515    }
2516}
2517
2518/*virtual*/void CameraService::binderDied(const wp<IBinder> &who) {
2519
2520    /**
2521      * While tempting to promote the wp<IBinder> into a sp, it's actually not supported by the
2522      * binder driver
2523      */
2524
2525    logClientDied(getCallingPid(), String8("Binder died unexpectedly"));
2526
2527    // check torch client
2528    handleTorchClientBinderDied(who);
2529
2530    // check camera device client
2531    if(!evictClientIdByRemote(who)) {
2532        ALOGV("%s: Java client's binder death already cleaned up (normal case)", __FUNCTION__);
2533        return;
2534    }
2535
2536    ALOGE("%s: Java client's binder died, removing it from the list of active clients",
2537            __FUNCTION__);
2538}
2539
2540void CameraService::updateStatus(ICameraServiceListener::Status status, const String8& cameraId) {
2541    updateStatus(status, cameraId, {});
2542}
2543
2544void CameraService::updateStatus(ICameraServiceListener::Status status, const String8& cameraId,
2545        std::initializer_list<ICameraServiceListener::Status> rejectSourceStates) {
2546    // Do not lock mServiceLock here or can get into a deadlock from
2547    // connect() -> disconnect -> updateStatus
2548
2549    auto state = getCameraState(cameraId);
2550
2551    if (state == nullptr) {
2552        ALOGW("%s: Could not update the status for %s, no such device exists", __FUNCTION__,
2553                cameraId.string());
2554        return;
2555    }
2556
2557    // Update the status for this camera state, then send the onStatusChangedCallbacks to each
2558    // of the listeners with both the mStatusStatus and mStatusListenerLock held
2559    state->updateStatus(status, cameraId, rejectSourceStates, [this]
2560            (const String8& cameraId, ICameraServiceListener::Status status) {
2561
2562            if (status != ICameraServiceListener::STATUS_ENUMERATING) {
2563                // Update torch status if it has a flash unit.
2564                Mutex::Autolock al(mTorchStatusMutex);
2565                ICameraServiceListener::TorchStatus torchStatus;
2566                if (getTorchStatusLocked(cameraId, &torchStatus) !=
2567                        NAME_NOT_FOUND) {
2568                    ICameraServiceListener::TorchStatus newTorchStatus =
2569                            status == ICameraServiceListener::STATUS_PRESENT ?
2570                            ICameraServiceListener::TORCH_STATUS_AVAILABLE_OFF :
2571                            ICameraServiceListener::TORCH_STATUS_NOT_AVAILABLE;
2572                    if (torchStatus != newTorchStatus) {
2573                        onTorchStatusChangedLocked(cameraId, newTorchStatus);
2574                    }
2575                }
2576            }
2577
2578            Mutex::Autolock lock(mStatusListenerLock);
2579
2580            for (auto& listener : mListenerList) {
2581                // TODO: Refactor status listeners to use strings for Camera IDs and remove this.
2582                int id = cameraIdToInt(cameraId);
2583                if (id != -1) listener->onStatusChanged(status, id);
2584            }
2585        });
2586}
2587
2588void CameraService::updateProxyDeviceState(ICameraServiceProxy::CameraState newState,
2589        const String8& cameraId) {
2590    sp<ICameraServiceProxy> proxyBinder = getCameraServiceProxy();
2591    if (proxyBinder == nullptr) return;
2592    String16 id(cameraId);
2593    proxyBinder->notifyCameraState(id, newState);
2594}
2595
2596status_t CameraService::getTorchStatusLocked(
2597        const String8& cameraId,
2598        ICameraServiceListener::TorchStatus *status) const {
2599    if (!status) {
2600        return BAD_VALUE;
2601    }
2602    ssize_t index = mTorchStatusMap.indexOfKey(cameraId);
2603    if (index == NAME_NOT_FOUND) {
2604        // invalid camera ID or the camera doesn't have a flash unit
2605        return NAME_NOT_FOUND;
2606    }
2607
2608    *status = mTorchStatusMap.valueAt(index);
2609    return OK;
2610}
2611
2612status_t CameraService::setTorchStatusLocked(const String8& cameraId,
2613        ICameraServiceListener::TorchStatus status) {
2614    ssize_t index = mTorchStatusMap.indexOfKey(cameraId);
2615    if (index == NAME_NOT_FOUND) {
2616        return BAD_VALUE;
2617    }
2618    ICameraServiceListener::TorchStatus& item =
2619            mTorchStatusMap.editValueAt(index);
2620    item = status;
2621
2622    return OK;
2623}
2624
2625}; // namespace android
2626