1 /*
2  * Copyright (c) 2022-2024 Huawei Device Co., Ltd.
3  * Licensed under the Apache License, Version 2.0 (the "License");
4  * you may not use this file except in compliance with the License.
5  * You may obtain a copy of the License at
6  *
7  *     http://www.apache.org/licenses/LICENSE-2.0
8  *
9  * Unless required by applicable law or agreed to in writing, software
10  * distributed under the License is distributed on an "AS IS" BASIS,
11  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12  * See the License for the specific language governing permissions and
13  * limitations under the License.
14  */
15 
16 #include <hdf_base.h>
17 #include <hdf_device_desc.h>
18 #include <hdf_log.h>
19 #include <hdf_sbuf_ipc.h>
20 
21 #include "dcamera_host.h"
22 #include "v1_3/camera_host_stub.h"
23 
24 #include <shared_mutex>
25 using namespace OHOS::HDI::Camera::V1_3;
26 
27 namespace {
28     std::shared_mutex mutex_;
29 }
30 
31 struct HdfCameraHostHost {
32     struct IDeviceIoService ioService;
33     OHOS::sptr<OHOS::IRemoteObject> stub;
34 };
35 
CameraHostDriverDispatch(struct HdfDeviceIoClient * client,int cmdId,struct HdfSBuf * data,struct HdfSBuf * reply)36 static int32_t CameraHostDriverDispatch(struct HdfDeviceIoClient *client, int cmdId, struct HdfSBuf *data,
37     struct HdfSBuf *reply)
38 {
39     OHOS::MessageParcel *dataParcel = nullptr;
40     OHOS::MessageParcel *replyParcel = nullptr;
41     OHOS::MessageOption option;
42 
43     if (SbufToParcel(data, &dataParcel) != HDF_SUCCESS) {
44         HDF_LOGE("%{public}s:invalid data sbuf object to dispatch", __func__);
45         return HDF_ERR_INVALID_PARAM;
46     }
47     if (SbufToParcel(reply, &replyParcel) != HDF_SUCCESS) {
48         HDF_LOGE("%{public}s:invalid reply sbuf object to dispatch", __func__);
49         return HDF_ERR_INVALID_PARAM;
50     }
51 
52     std::shared_lock lock(mutex_);
53     if (client == nullptr || client->device == nullptr || client->device->service == nullptr) {
54         HDF_LOGE("%{public}s: client or client.device or service is nullptr", __func__);
55         return HDF_FAILURE;
56     }
57     auto *hdfCameraHostHost = CONTAINER_OF(client->device->service, struct HdfCameraHostHost, ioService);
58     if (hdfCameraHostHost == NULL || hdfCameraHostHost->stub == NULL) {
59         HDF_LOGE("%{public}s:invalid hdfCameraHostHost", __func__);
60         return HDF_ERR_INVALID_PARAM;
61     }
62     return hdfCameraHostHost->stub->SendRequest(cmdId, *dataParcel, *replyParcel, option);
63 }
64 
HdfCameraHostDriverInit(struct HdfDeviceObject * deviceObject)65 static int HdfCameraHostDriverInit(struct HdfDeviceObject *deviceObject)
66 {
67     HDF_LOGI("HdfCameraHostDriverInit enter");
68     if (deviceObject == nullptr) {
69         HDF_LOGE("HdfCameraHostDriverInit:: HdfDeviceObject is NULL !");
70         return HDF_FAILURE;
71     }
72 
73     if (!HdfDeviceSetClass(deviceObject, DEVICE_CLASS_CAMERA)) {
74         HDF_LOGE("HdfCameraHostDriverInit set camera class failed");
75         return HDF_FAILURE;
76     }
77     return HDF_SUCCESS;
78 }
79 
HdfCameraHostDriverBind(struct HdfDeviceObject * deviceObject)80 static int HdfCameraHostDriverBind(struct HdfDeviceObject *deviceObject)
81 {
82     HDF_LOGI("HdfCameraHostDriverBind enter");
83 
84     auto *hdfCameraHostHost = new (std::nothrow) HdfCameraHostHost;
85     if (hdfCameraHostHost == nullptr) {
86         HDF_LOGE("%{public}s: failed to create create HdfCameraHostHost object", __func__);
87         return HDF_FAILURE;
88     }
89 
90     hdfCameraHostHost->ioService.Dispatch = CameraHostDriverDispatch;
91     hdfCameraHostHost->ioService.Open = NULL;
92     hdfCameraHostHost->ioService.Release = NULL;
93 
94     auto serviceImpl = OHOS::DistributedHardware::DCameraHost::GetInstance();
95     if (serviceImpl == nullptr) {
96         HDF_LOGE("%{public}s: failed to get of implement service", __func__);
97         delete hdfCameraHostHost;
98         return HDF_FAILURE;
99     }
100 
101     hdfCameraHostHost->stub = OHOS::HDI::ObjectCollector::GetInstance().GetOrNewObject(serviceImpl,
102         HDI::Camera::V1_3::ICameraHost::GetDescriptor());
103     if (hdfCameraHostHost->stub == nullptr) {
104         HDF_LOGE("%{public}s: failed to get stub object", __func__);
105         delete hdfCameraHostHost;
106         return HDF_FAILURE;
107     }
108 
109     deviceObject->service = &hdfCameraHostHost->ioService;
110     return HDF_SUCCESS;
111 }
112 
HdfCameraHostDriverRelease(struct HdfDeviceObject * deviceObject)113 static void HdfCameraHostDriverRelease(struct HdfDeviceObject *deviceObject)
114 {
115     HDF_LOGI("HdfCameraHostDriverRelease enter");
116     if (deviceObject == nullptr || deviceObject->service == nullptr) {
117         HDF_LOGE("HdfCameraHostDriverRelease not initted");
118         return;
119     }
120 
121     std::unique_lock lock(mutex_);
122     auto *hdfCameraHostHost = CONTAINER_OF(deviceObject->service, struct HdfCameraHostHost, ioService);
123     if (hdfCameraHostHost != nullptr) {
124         hdfCameraHostHost->stub = nullptr;
125     }
126     delete hdfCameraHostHost;
127     hdfCameraHostHost = nullptr;
128     if (deviceObject != nullptr) {
129         deviceObject->service = nullptr;
130     }
131 }
132 
133 static struct HdfDriverEntry g_camerahostDriverEntry = {
134     .moduleVersion = 1,
135     .moduleName = "distributed_camera_service",
136     .Bind = HdfCameraHostDriverBind,
137     .Init = HdfCameraHostDriverInit,
138     .Release = HdfCameraHostDriverRelease,
139 };
140 
141 #ifdef __cplusplus
142 extern "C" {
143 #endif /* __cplusplus */
144 
145 HDF_INIT(g_camerahostDriverEntry);
146 
147 #ifdef __cplusplus
148 }
149 #endif /* __cplusplus */
150