/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/dispatcher/ |
H A D | stream_pipeline_dispatcher.cpp | 36 for (const auto& it : node->GetInPorts()) { in GenerateNodeSeq() 37 GenerateNodeSeq(nodeVec, it->Peer()->GetNode()); in GenerateNodeSeq() 44 for (auto it = p->nodes_.rbegin(); it < p->nodes_.rend(); it++) { in Update() 45 if ((*it)->GetNumberOfInPorts() == 1 && (*it)->GetNumberOfOutPorts() == 0) { in Update() 46 sink.push_back(*it); in Update() 51 for (const auto& it : sink) { in Update() 52 auto inPorts = it in Update() 94 auto it = std::find_if(branch.begin(), branch.end(), [streamId](const std::shared_ptr<INode> node) { CutUselessBranch() local 222 auto it = seqNode_.find(streamId); Destroy() local [all...] |
/drivers/hdf_core/framework/utils/src/ |
H A D | osal_msg_queue.c | 4 * HDF is dual licensed: you can use it either under the terms of 38 struct HdfSListIterator it; in HdfMessageQueueEnqueue() local 42 HdfSListIteratorInit(&it, &queue->list); in HdfMessageQueueEnqueue() 43 while (HdfSListIteratorHasNext(&it)) { in HdfMessageQueueEnqueue() 44 struct HdfMessage *next = (struct HdfMessage *)HdfSListIteratorNext(&it); in HdfMessageQueueEnqueue() 46 HdfSListIteratorInsert(&it, &message->entry); in HdfMessageQueueEnqueue() 59 struct HdfSListIterator it; in HdfMessageQueueNext() local 64 HdfSListIteratorInit(&it, &queue->list); in HdfMessageQueueNext() 65 while (HdfSListIteratorHasNext(&it)) { in HdfMessageQueueNext() 66 message = (struct HdfMessage *)HdfSListIteratorNext(&it); in HdfMessageQueueNext() 81 struct HdfSListIterator it; HdfMessageQueueFlush() local [all...] |
/drivers/peripheral/camera/vdi_base/common/buffer_manager/src/ |
H A D | buffer_pool.cpp | 123 for (auto it : idleList_) { in DestroyBuffer() 124 RetCode ret = bufferAllocator_->UnmapBuffer(it); in DestroyBuffer() 126 CAMERA_LOGE("unmap (%{public}d) buffer failed", it->GetIndex()); in DestroyBuffer() 128 ret = bufferAllocator_->FreeBuffer(it); in DestroyBuffer() 130 CAMERA_LOGE("free (%{public}d) buffer failed", it->GetIndex()); in DestroyBuffer() 138 for (auto it : busyList_) { in DestroyBuffer() 139 RetCode ret = bufferAllocator_->UnmapBuffer(it); in DestroyBuffer() 141 CAMERA_LOGE("unmap (%{public}d) buffer failed", it->GetIndex()); in DestroyBuffer() 143 ret = bufferAllocator_->FreeBuffer(it); in DestroyBuffer() 145 CAMERA_LOGE("free (%{public}d) buffer failed", it in DestroyBuffer() 169 auto it = idleList_.begin(); AcquireBuffer() local 182 auto it = idleList_.begin(); AcquireBuffer() local 199 auto it = idleList_.begin(); AcquireBuffer() local 215 auto it = std::find(busyList_.begin(), busyList_.end(), buffer); ReturnBuffer() local [all...] |
/drivers/peripheral/sensor/hdi_service/ |
H A D | sensor_clients_manager.cpp | 122 auto it = clients_[groupId].find(serviceId);
in ReportDataCbRegister() local 123 it -> second.SetReportDataCb(callbackObj);
in ReportDataCbRegister() 138 auto it = clients_[groupId].find(serviceId);
in ReportDataCbUnRegister() local 139 clients_[groupId].erase(it);
in ReportDataCbUnRegister() 148 auto it = sensorConfig_.find(sensorId);
in UpdateSensorConfig() local 149 if (it != sensorConfig_.end()) {
in UpdateSensorConfig() 150 it->second.samplingInterval = samplingInterval <= it->second.samplingInterval ? samplingInterval
in UpdateSensorConfig() 151 : it->second.samplingInterval;
in UpdateSensorConfig() 152 it in UpdateSensorConfig() 164 auto it = sdcSensorConfig_.find(sensorId); UpdateSdcSensorConfig() local 212 auto it = sensorConfig_.find(sensorId); SetSensorBestConfig() local 230 auto it = sdcSensorConfig_.find(sensorId); SetSdcSensorBestConfig() local 249 auto it = sensorConfig_.find(sensorId); GetSensorBestConfig() local 269 auto it = sdcSensorConfig_.find(sensorId); EraseSdcSensorBestConfig() local 291 auto it = sensorUsed_.find(sensorId); IsNeedOpenSensor() local 307 auto it = sensorUsed_.find(sensorId); IsNeedCloseSensor() local 329 auto it = sdcSensorConfig_.find(sensorId); IsExistSdcSensorEnable() local 376 auto it = clients_.find(groupId); GetClients() local 488 auto it = sensorReportCountMap[sensorId].find(serviceId); ReportEachClient() local [all...] |
/drivers/peripheral/camera/vdi_base/common/pipeline_core/ipp/src/ |
H A D | algo_plugin_manager.cpp | 41 for (auto it : algoPluginList_) { in LoadPlugin() 42 if (it->LoadLib() != RC_OK) { in LoadPlugin() 43 CAMERA_LOGE("load algorithm lib: %{public}s failed", it->GetName().c_str()); in LoadPlugin() 53 for (auto& it : algoPluginList_) { in GetAlgoPlugin() 54 if (it->GetMode() == mode) { in GetAlgoPlugin() 55 plugin = it; in GetAlgoPlugin() 65 for (auto it : algoPluginList_) { in UnloadPlugin() 66 it->UnloadLib(); in UnloadPlugin()
|
H A D | offline_pipeline.cpp | 108 auto it = std::find_if(bufferCache_.begin(), bufferCache_.end(), in CancelCapture() local 117 if (it == bufferCache_.end()) { in CancelCapture() 121 cache = *it; in CancelCapture() 122 bufferCache_.erase(it); in CancelCapture() 124 for (auto it : cache) { in CancelCapture() 125 it->SetBufferStatus(CAMERA_BUFFER_STATUS_DROP); in CancelCapture() 145 for (auto it : cache) { in FlushOfflineStream() 146 it->SetBufferStatus(CAMERA_BUFFER_STATUS_DROP); in FlushOfflineStream() 196 for (auto it : buffers) { in DeliverCacheCheck() 197 if (it in DeliverCacheCheck() [all...] |
H A D | offline_pipeline_manager.cpp | 76 auto it = std::find_if(offlinePipelineList_.begin(), offlinePipelineList_.end(), in DestoryOfflinePipeline() local 80 offlinePipelineList_.erase(it); in DestoryOfflinePipeline() 93 for (auto it : offlinePipelineList_) { in DestoryOfflinePipelines() 94 it.second->FlushOfflineStream(); in DestoryOfflinePipelines() 116 for (const auto& it : offlinePipelineList_) { in FindOfflinePipeline() 117 if (it.first == id) { in FindOfflinePipeline() 118 op = it.second; in FindOfflinePipeline()
|
/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/ |
H A D | capture_message.cpp | 80 auto it = messageBox_.find(message->GetMessageType()); in SendMessage() local 81 if (it == messageBox_.end()) { in SendMessage() 89 for (auto& mit : it->second) { in SendMessage() 110 it->second.emplace_back(mg); in SendMessage() 173 for (auto it = lit.second.begin(); it != lit.second.end();) { in HandleMessage() 174 if (it->empty()) { in HandleMessage() 175 it = lit.second.erase(it); in HandleMessage() 178 it in HandleMessage() [all...] |
H A D | stream_operator_vdi_impl.cpp | 85 for (auto &it : streamMap_) { in GetStreamSupportType() 86 currentIDSet.emplace(it.first); in GetStreamSupportType() 144 for (auto it : infos) { in IsStreamsSupported() 145 CHECK_IF_NOT_EQUAL_RETURN_VALUE(CheckStreamInfo(it), true, INVALID_ARGUMENT); in IsStreamsSupported() 146 inputIDSet.emplace(it.streamId_); in IsStreamsSupported() 147 checkStreamIdVec.push_back(it.streamId_); in IsStreamsSupported() 196 for (auto &it : infos) { in CheckStreamsSupported() 198 config.type = it.intent_; in CheckStreamsSupported() 199 config.width = it.width_; in CheckStreamsSupported() 200 config.height = it in CheckStreamsSupported() 281 auto it = streamMap_.find(id); ReleaseStreams() local [all...] |
/drivers/peripheral/camera/vdi_base/common/pipeline_core/host_stream/src/ |
H A D | host_stream_mgr_impl.cpp | 35 auto it = std::find_if(streams_.begin(), streams_.end(), [info](const std::unique_ptr<HostStream>& s) { in CreateHostStream() local 38 if (it != streams_.end()) { in CreateHostStream() 58 auto it = std::find_if(streams_.begin(), streams_.end(), [streamId](const std::unique_ptr<HostStream>& s) { in DestroyHostStream() local 61 if (it != streams_.end()) { in DestroyHostStream() 62 streams_.erase(it); in DestroyHostStream() 82 [](auto &it) { return it->GetStreamId(); }); in GetStreamIds() 87 auto it = std::find_if(streams_.begin(), streams_.end(), in GetStreamInfo() local 89 if (it != streams_.end()) { in GetStreamInfo() 90 return (*it) in GetStreamInfo() 97 auto it = std::find_if(streams_.begin(), streams_.end(), [streamId](const std::unique_ptr<HostStream>& s) { GetBufferCb() local [all...] |
/drivers/peripheral/camera/vdi_base/v4l2/src/offline_stream_operator/ |
H A D | offline_stream_operator_vdi_impl.cpp | 58 for (auto it : streamIds) { in ReleaseStreams() 59 if (offlineStreamMap_.find(it) != offlineStreamMap_.end()) { in ReleaseStreams() 60 RetCode ret = offlineStreamMap_[it]->Release(); in ReleaseStreams() 62 CAMERA_LOGE("release stream %{public}d failed", it); in ReleaseStreams() 66 offlineStreamMap_.erase(it); in ReleaseStreams() 82 for (auto it = offlineStreamMap_.begin(); it != offlineStreamMap_.end(); it++) { in Release() 83 it->second->Release(); in Release() 108 for (auto it in FindStreamByCaptureId() [all...] |
H A D | offline_stream.cpp | 48 for (auto it : context_->restRequests) { in Init() 49 it->DisableSync(); in Init() 80 for (auto it : context_->restRequests) { in Release() 81 CancelCapture(it->GetCaptureId()); in Release() 130 auto it = std::find_if( in ReturnBuffer() local 133 if (it == context_->restRequests.end()) { in ReturnBuffer() 138 request = *it; in ReturnBuffer() 139 context_->restRequests.erase(it); in ReturnBuffer() 174 auto it = in CheckCaptureIdExist() local 177 if (it ! in CheckCaptureIdExist() [all...] |
/drivers/peripheral/power/test/unittest/mock/ |
H A D | mock_wakelock_name.cpp | 28 auto it = std::find(wakeLockName.begin(), wakeLockName.end(), name); in FindWakeLockName() local 29 if (it != wakeLockName.end()) { in FindWakeLockName() 37 auto it = std::find(wakeLockName.begin(), wakeLockName.end(), name); in WriteWakeLockName() local 38 if (it == wakeLockName.end()) { in WriteWakeLockName() 45 auto it = std::find(wakeLockName.begin(), wakeLockName.end(), name); in WriteWakeUnlockName() local 46 if (it != wakeLockName.end()) { in WriteWakeUnlockName() 47 wakeLockName.erase(it); in WriteWakeUnlockName()
|
/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/ |
H A D | stream_pipeline_core.cpp | 68 for (const auto& it : streamIds) { in DestroyPipeline() 69 re = dispatcher_->Destroy(it) | re; in DestroyPipeline() 70 re = builder_->Destroy(it) | re; in DestroyPipeline() 71 re = strategy_->Destroy(it) | re; in DestroyPipeline() 80 for (const auto& it : streamIds) { in Prepare() 81 re = dispatcher_->Prepare(it) | re; in Prepare() 90 for (const auto& it : streamIds) { in Start() 91 re = dispatcher_->Start(it) | re; in Start() 108 for (const auto& it : streamIds) { in Stop() 109 CAMERA_LOGV("stop stream %{public}d begin", it); in Stop() [all...] |
/drivers/peripheral/camera/vdi_base/common/metadata_manager/src/ |
H A D | metadata_config.cpp | 50 for (auto it = updateKeys.cbegin(); it != updateKeys.cend(); it++) {
in UpdateSettingsConfig() 52 int ret = FindCameraMetadataItem(data, *it, &entry);
in UpdateSettingsConfig() 54 CAMERA_LOGE("get [%{public}d] error", *it);
in UpdateSettingsConfig() 58 result = metadata_[streamId]->addEntry(*it, static_cast<void *>(entry.data.u8), entry.count);
in UpdateSettingsConfig() 60 result = metadata_[streamId]->updateEntry(*it, static_cast<void *>(entry.data.u8), entry.count);
in UpdateSettingsConfig() 63 CAMERA_LOGE("add key: [%{public}d] failed", *it);
in UpdateSettingsConfig()
|
/drivers/peripheral/camera/hal_c/hdi_cif/src/ |
H A D | stream_operator_callback_wrapper.cpp | 49 std::shared_ptr<OHOS::Camera::CaptureEndedInfo> it = std::make_shared<OHOS::Camera::CaptureEndedInfo>(); in StreamCBOnCaptureEnded() local 50 if (it == nullptr) { in StreamCBOnCaptureEnded() 51 CAMERA_LOGE("it is nullptr captureId: %{public}d streamId: %{public}d", captureId, info[i].streamId); in StreamCBOnCaptureEnded() 54 it->streamId_ = info[i].streamId; in StreamCBOnCaptureEnded() 55 it->frameCount_ = info[i].frameCount; in StreamCBOnCaptureEnded() 56 ends.push_back(it); in StreamCBOnCaptureEnded() 72 std::shared_ptr<OHOS::Camera::CaptureErrorInfo> it = std::make_shared<OHOS::Camera::CaptureErrorInfo>(); in StreamCBOnCaptureError() local 73 if (it == nullptr) { in StreamCBOnCaptureError() 74 CAMERA_LOGE("it is nullptr captureId: %{public}d streamId: %{public}d", captureId, info[i].streamId); in StreamCBOnCaptureError() 77 it in StreamCBOnCaptureError() [all...] |
/drivers/peripheral/usb/ddk_service/src/ |
H A D | usb_ddk_hash.cpp | 62 for (auto it = g_hashMap.begin(); it != g_hashMap.end(); it++) { in UsbDdkGetRecordByVal() 63 if (it->second.busNum == info.busNum && it->second.devNum == info.devNum) { in UsbDdkGetRecordByVal() 64 hashVal = it->first; in UsbDdkGetRecordByVal()
|
/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/strategy/ |
H A D | stream_pipeline_strategy.cpp | 46 for (const auto& it : streamTypeSet) { in ConstructKeyStrIndex() 47 std::string streamStr = CheckIdExsit(it, G_STREAM_TABLE_PTR, G_STREAM_TABLE_SIZE); in ConstructKeyStrIndex() 49 CAMERA_LOGI("stream type:%{public}d not support!\n", it); in ConstructKeyStrIndex() 199 for (const auto& it : n.portSpecSet_) { in PrintConnection() 200 if (it.direction_ == 1) { in PrintConnection() 203 n.name_.c_str(), it.info_.name_.c_str(), it.format_.w_, it.format_.h_, it.format_.format_, in PrintConnection() 204 it in PrintConnection() [all...] |
/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/node_base/ |
H A D | node_base.cpp | 123 auto it = std::find_if(portVec_.begin(), portVec_.end(), in GetPort() local 125 if (it != portVec_.end()) { in GetPort() 126 return *it; in GetPort() 174 int32_t re = std::count_if(portVec_.begin(), portVec_.end(), [](auto &it) { return it->Direction() == 0; }); in GetNumberOfInPorts() 181 int32_t re = std::count_if(portVec_.begin(), portVec_.end(), [](auto &it) { return it->Direction() == 1; }); in GetNumberOfOutPorts() 190 [](auto &it) { return it->Direction() == 0; }); in GetInPorts() 200 [](auto &it) { retur in GetOutPorts() 236 auto it = std::find_if(outPorts.begin(), outPorts.end(), DeliverBuffer() local 252 auto it = std::find_if(outPorts.begin(), outPorts.end(), DeliverBuffers() local [all...] |
/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/builder/ |
H A D | stream_pipeline_builder.cpp | 44 for (auto& it : pipelineSpec->nodeSpecSet_) { in Build() 45 if (it.status_ == "new") { in Build() 47 size_t pos = it.name_.find_first_of('#'); in Build() 48 nodeName = it.name_.substr(0, pos); in Build() 49 std::shared_ptr<INode> newNode = NodeFactory::Instance().CreateShared(nodeName, it.name_, in Build() 50 it.type_, cameraId); in Build() 55 std::optional<int32_t> typeId = GetTypeId(it.type_, G_STREAM_TABLE_PTR, G_STREAM_TABLE_SIZE); in Build() 57 newNode->SetCallBack(hostStreamMgr_->GetBufferCb(it.streamId_)); in Build() 60 it.status_ = "remain"; in Build() 61 for (const auto& portSpec : it in Build() [all...] |
/drivers/peripheral/clearplay/hdi_service/common/ |
H A D | base64_utils.cpp | 103 auto it = source.begin(); in Encode() local 109 while (it != source.end()) { in Encode() 110 charArrayThree[index] = *it; in Encode() 112 ++it; in Encode() 148 auto it = encoded.begin(); in Decode() local 154 while (it != encoded.end() && IsBase64Char(*it)) { in Decode() 155 charArrayFour[index] = *it; in Decode() 157 ++it; in Decode()
|
/drivers/hdf_core/adapter/uhdf2/hdi/src/ |
H A D | object_collector.cpp | 78 auto it = interfaceObjectCollector_.find(interface.GetRefPtr()); in GetOrNewObject() local 79 if (it != interfaceObjectCollector_.end()) { in GetOrNewObject() 80 if (it->second->GetSptrRefCount() == 0) { in GetOrNewObject() 86 return it->second.GetRefPtr(); in GetOrNewObject() 96 auto it = interfaceObjectCollector_.find(interface.GetRefPtr()); in RemoveObject() local 97 if (it == interfaceObjectCollector_.end()) { in RemoveObject() 100 interfaceObjectCollector_.erase(it); in RemoveObject()
|
/drivers/peripheral/clearplay/hdi_service/src/ |
H A D | media_key_system_service.cpp | 90 for (auto it = time.begin(); it != time.end(); ++it) { in GetDecryptTimeAsString() 91 if (it != time.begin()) { in GetDecryptTimeAsString() 94 decryptTimes.append(std::to_string(*it)); in GetDecryptTimeAsString() 223 for (auto it = mediaKeySessionMap_.begin(); it != mediaKeySessionMap_.end(); ++it) { in GetOfflineMediaKeyStatus() 224 if (it->second == false) { in GetOfflineMediaKeyStatus() 227 licenseStatus = it in GetOfflineMediaKeyStatus() 245 auto it = offlineKeyIdAndKeyValueBase64_.find(keyIdBase64); ClearOfflineMediaKeys() local 307 auto it = mediaKeySessionMap_.find(mediaKeySession); CloseKeySessionService() local [all...] |
/drivers/peripheral/battery/interfaces/hdi_service/test/systemtest/src/ |
H A D | battery_sys_test.cpp | 83 for (auto it = chargeSceneConfigMap.begin(); it != chargeSceneConfigMap.end(); it++) {
in HWTEST_F() 84 ASSERT_TRUE(!(it->first).empty());
in HWTEST_F() 86 auto chargeSceneConfig = it->second;
in HWTEST_F()
|
/drivers/peripheral/camera/test/ut/v4l2/ |
H A D | camera_ability_test.cpp | 78 for (auto it = afAvailable.begin(); it != afAvailable.end(); it++) { in GetAfAvailable() 79 CAMERA_LOGI("afAvailable = %{public}d", static_cast<int>(*it)); in GetAfAvailable() 101 for (auto it = zoomRatioRange.begin(); it != zoomRatioRange.end(); it++) { in GetZoomRatioRange() 102 CAMERA_LOGI("zoomRatioRange = %{public}f", *it); in GetZoomRatioRange()
|