Home
last modified time | relevance | path

Searched refs:it (Results 1 – 25 of 327) sorted by relevance

12345678910>>...14

/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/dispatcher/
Dstream_pipeline_dispatcher.cpp36 for (const auto& it : node->GetInPorts()) { in GenerateNodeSeq() local
37 GenerateNodeSeq(nodeVec, it->Peer()->GetNode()); in GenerateNodeSeq()
44 for (auto it = p->nodes_.rbegin(); it < p->nodes_.rend(); it++) { in Update() local
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() local
52 auto inPorts = it->GetInPorts(); in Update()
55 GenerateNodeSeq(seqNode[inPorts[0]->GetStreamId()], it); in Update()
67 for (auto it : vv) { in Update() local
68 it->wide_ = p->maxWidth_; in Update()
[all …]
/drivers/hdf_core/framework/utils/src/
Dosal_msg_queue.c38 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()
68 HdfSListIteratorRemove(&it); in HdfMessageQueueNext()
[all …]
/drivers/peripheral/camera/vdi_base/common/buffer_manager/src/
Dbuffer_pool.cpp123 for (auto it : idleList_) { in DestroyBuffer() local
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() local
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->GetIndex()); in DestroyBuffer()
[all …]
Dbuffer_loop_tracking.cpp45 auto it = std::find_if(trackingBufferList_.begin(), trackingBufferList_.end(), in FindTrackingBuffer() local
49 if (it == trackingBufferList_.end()) { in FindTrackingBuffer()
52 return *it; in FindTrackingBuffer()
69 auto it = std::find_if(trackingBufferList_.begin(), trackingBufferList_.end(), in DetachTrackingBuffer() local
73 if (it != trackingBufferList_.end()) { in DetachTrackingBuffer()
74 trackingBufferList_.erase(it); in DetachTrackingBuffer()
108 auto it = std::find_if(trackingNodeList_.begin(), trackingNodeList_.end(), in FindTrackingNode() local
110 if (it != trackingNodeList_.end()) { in FindTrackingNode()
111 return *it; in FindTrackingNode()
140 auto it = std::find(trackingNodeList_.begin(), trackingNodeList_.end(), node); in DetachTrackingNode() local
[all …]
/drivers/peripheral/sensor/hdi_service/
Dsensor_clients_manager.cpp118 auto it = clients_[groupId].find(serviceId); in ReportDataCbRegister() local
119 it -> second.SetReportDataCb(callbackObj); in ReportDataCbRegister()
133 auto it = clients_[groupId].find(serviceId); in ReportDataCbUnRegister() local
134 clients_[groupId].erase(it); in ReportDataCbUnRegister()
142 auto it = sensorConfig_.find(sensorId); in UpdateSensorConfig() local
143 if (it != sensorConfig_.end()) { in UpdateSensorConfig()
144 … it->second.samplingInterval = samplingInterval <= it->second.samplingInterval ? samplingInterval in UpdateSensorConfig()
145 : it->second.samplingInterval; in UpdateSensorConfig()
146 it->second.reportInterval = reportInterval <= it->second.reportInterval ? reportInterval in UpdateSensorConfig()
147 : it->second.reportInterval; in UpdateSensorConfig()
[all …]
/drivers/peripheral/camera/vdi_base/v4l2/src/offline_stream_operator/
Doffline_stream_operator_vdi_impl.cpp58 for (auto it : streamIds) { in ReleaseStreams() local
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() local
83 it->second->Release(); in Release()
108 for (auto it = offlineStreamMap_.begin(); it != offlineStreamMap_.end(); it++) { in FindStreamByCaptureId() local
109 if (it->second->CheckCaptureIdExist(captureId)) { in FindStreamByCaptureId()
110 stream = it->second; in FindStreamByCaptureId()
/drivers/peripheral/camera/vdi_base/common/pipeline_core/host_stream/src/
Dhost_stream_mgr_impl.cpp35 …auto it = std::find_if(streams_.begin(), streams_.end(), [info](const std::unique_ptr<HostStream>&… 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<HostStre… in DestroyHostStream() local
61 if (it != streams_.end()) { in DestroyHostStream()
62 streams_.erase(it); in DestroyHostStream()
82 [](auto &it) { return it->GetStreamId(); }); in GetStreamIds() argument
87 auto it = std::find_if(streams_.begin(), streams_.end(), in GetStreamInfo() local
89 if (it != streams_.end()) { in GetStreamInfo()
90 return (*it)->GetStreamInfo(); in GetStreamInfo()
97 …auto it = std::find_if(streams_.begin(), streams_.end(), [streamId](const std::unique_ptr<HostStre… in GetBufferCb() local
[all …]
/drivers/peripheral/camera/vdi_base/common/pipeline_core/ipp/src/
Dalgo_plugin_manager.cpp41 for (auto it : algoPluginList_) { in LoadPlugin() local
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() local
54 if (it->GetMode() == mode) { in GetAlgoPlugin()
55 plugin = it; in GetAlgoPlugin()
65 for (auto it : algoPluginList_) { in UnloadPlugin() local
66 it->UnloadLib(); in UnloadPlugin()
Doffline_pipeline.cpp108 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() local
125 it->SetBufferStatus(CAMERA_BUFFER_STATUS_DROP); in CancelCapture()
145 for (auto it : cache) { in FlushOfflineStream() local
146 it->SetBufferStatus(CAMERA_BUFFER_STATUS_DROP); in FlushOfflineStream()
196 for (auto it : buffers) { in DeliverCacheCheck() local
197 if (it == nullptr) { in DeliverCacheCheck()
[all …]
Doffline_pipeline_manager.cpp76 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() local
94 it.second->FlushOfflineStream(); in DestoryOfflinePipelines()
116 for (const auto& it : offlinePipelineList_) { in FindOfflinePipeline() local
117 if (it.first == id) { in FindOfflinePipeline()
118 op = it.second; in FindOfflinePipeline()
/drivers/peripheral/camera/vdi_base/v4l2/src/stream_operator/
Dstream_operator_vdi_impl.cpp85 for (auto &it : streamMap_) { in GetStreamSupportType() local
86 currentIDSet.emplace(it.first); in GetStreamSupportType()
144 for (auto it : infos) { in IsStreamsSupported() local
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() local
198 config.type = it.intent_; in CheckStreamsSupported()
199 config.width = it.width_; in CheckStreamsSupported()
200 config.height = it.height_; in CheckStreamsSupported()
[all …]
Dcapture_message.cpp80 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() local
174 if (it->empty()) { in HandleMessage()
175 it = lit.second.erase(it); in HandleMessage()
178 it++; in HandleMessage()
183 for (auto it = messages.begin(); it != messages.end();) { in HandleMessage() local
184 messageOperator_(*it); in HandleMessage()
[all …]
/drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/
Dstream_pipeline_core.cpp68 for (const auto& it : streamIds) { in DestroyPipeline() local
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() local
81 re = dispatcher_->Prepare(it) | re; in Prepare()
90 for (const auto& it : streamIds) { in Start() local
91 re = dispatcher_->Start(it) | re; in Start()
108 for (const auto& it : streamIds) { in Stop() local
109 CAMERA_LOGV("stop stream %{public}d begin", it); in Stop()
[all …]
/drivers/peripheral/power/test/unittest/mock/
Dmock_wakelock_name.cpp28 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/strategy/
Dstream_pipeline_strategy.cpp46 for (const auto& it : streamTypeSet) { in ConstructKeyStrIndex() local
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() local
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.format_.usage_, it.format_.bufferPoolId_, in PrintConnection()
205 it.info_.peerPortNodeName_.c_str(), it.info_.peerPortName_.c_str()); in PrintConnection()
208 [it](const NodeSpec& n) { in PrintConnection()
209 return n.name_ == it.info_.peerPortNodeName_; in PrintConnection()
[all …]
/drivers/peripheral/camera/hal_c/hdi_cif/src/
Dstream_operator_callback_wrapper.cpp49 …std::shared_ptr<OHOS::Camera::CaptureEndedInfo> it = std::make_shared<OHOS::Camera::CaptureEndedIn… in StreamCBOnCaptureEnded() local
50 if (it == nullptr) { 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::CaptureErrorIn… in StreamCBOnCaptureError() local
73 if (it == nullptr) { in StreamCBOnCaptureError()
77 it->streamId_ = info[i].streamId; in StreamCBOnCaptureError()
78 it->error_ = static_cast<OHOS::Camera::StreamError>(info[i].error); in StreamCBOnCaptureError()
79 errors.push_back(it); in StreamCBOnCaptureError()
/drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/node_base/
Dnode_base.cpp123 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()… in GetNumberOfInPorts() argument
181 …int32_t re = std::count_if(portVec_.begin(), portVec_.end(), [](auto &it) { return it->Direction()… in GetNumberOfOutPorts() argument
190 [](auto &it) { return it->Direction() == 0; }); in GetInPorts() argument
200 [](auto &it) { return it->Direction() == 1; }); in GetOutPorts() argument
236 auto it = std::find_if(outPorts.begin(), outPorts.end(), in DeliverBuffer() local
238 if (it != outPorts.end()) { in DeliverBuffer()
241 …GetName().c_str(), (*it)->Peer()->GetNode()->GetName().c_str(), buffer->GetStreamId(), buffer->Get… in DeliverBuffer()
[all …]
/drivers/peripheral/camera/vdi_base/common/metadata_manager/src/
Dmetadata_config.cpp50 for (auto it = updateKeys.cbegin(); it != updateKeys.cend(); it++) { in UpdateSettingsConfig() local
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/external_device_manager/test/unittest/permission_js_test/
DPermissionJsTest.js18 import { describe, beforeAll, beforeEach, afterEach, afterAll, it, expect } from 'deccjsunit/index'
72 it("Permission_queryDevices_001", 0, done => {
92 it("Permission_bindDevice_001", 0, done => {
112 it("Permission_bindDevice_002", 0, async done => {
132 it("Permission_bindDeviceDriver_001", 0, done => {
152 it("Permission_bindDeviceDriver_002", 0, async done => {
172 it("Permission_unbindDevice_001", 0, done => {
192 it("Permission_unbindDevice_002", 0, async done => {
212 it("Permission_queryDeviceInfo_001", 0, done => {
232 it("Permission_queryDriverInfo_001", 0, done => {
/drivers/peripheral/usb/ddk_service/src/
Dusb_ddk_hash.cpp62 for (auto it = g_hashMap.begin(); it != g_hashMap.end(); it++) { in UsbDdkGetRecordByVal() local
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/builder/
Dstream_pipeline_builder.cpp44 for (auto& it : pipelineSpec->nodeSpecSet_) { in Build() local
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.portSpecSet_) { in Build()
/drivers/external_device_manager/test/unittest/device_manager_js_test/
DDeviceManagerJsTest.js17 import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index'
55 it("DeviceManager_queryDevices_001", 0, function () {
75 it("DeviceManager_queryDevices_002", 0, function () {
90 it("DeviceManager_bindDevices_003", 0, async function (done) {
113 it("DeviceManager_bindDevices_004", 0, async function (done) {
136 it("DeviceManager_bindDeviceDriver_005", 0, async function (done) {
159 it("DeviceManager_bindDevices_006", 0, async function (done) {
176 it("DeviceManager_bindDevices_007", 0, async function (done) {
193 it("DeviceManager_bindDevices_008", 0, async function (done) {
210 it("DeviceManager_bindDevices_009", 0, async function (done) {
[all …]
/drivers/hdf_core/adapter/uhdf2/hdi/src/
Dobject_collector.cpp77 auto it = interfaceObjectCollector_.find(interface.GetRefPtr()); in GetOrNewObject()
78 if (it != interfaceObjectCollector_.end()) { in GetOrNewObject()
79 if (it->second->GetSptrRefCount() == 0) { in GetOrNewObject()
87 return it->second; in GetOrNewObject()
98 auto it = interfaceObjectCollector_.find(interface.GetRefPtr()); in RemoveObject() local
99 if (it == interfaceObjectCollector_.end()) { in RemoveObject()
102 interfaceObjectCollector_.erase(it); in RemoveObject()
/drivers/peripheral/clearplay/hdi_service/src/
Dmedia_key_system_service.cpp90 for (auto it = time.begin(); it != time.end(); ++it) { in GetDecryptTimeAsString() local
91 if (it != time.begin()) { in GetDecryptTimeAsString()
94 decryptTimes.append(std::to_string(*it)); in GetDecryptTimeAsString()
224 for (auto it = mediaKeySessionMap_.begin(); it != mediaKeySessionMap_.end(); ++it) { in GetOfflineMediaKeyStatus() local
225 if (it->second == false) { in GetOfflineMediaKeyStatus()
228 licenseStatus = it->first->session_->keyIdStatusMap[licenseId]; in GetOfflineMediaKeyStatus()
246 auto it = offlineKeyIdAndKeyValueBase64_.find(keyIdBase64); in ClearOfflineMediaKeys() local
247 if (it != offlineKeyIdAndKeyValueBase64_.end()) { in ClearOfflineMediaKeys()
248 offlineKeyIdAndKeyValueBase64_.erase(it); in ClearOfflineMediaKeys()
254 for (auto it = mediaKeySessionMap_.begin(); it != mediaKeySessionMap_.end(); ++it) { in ClearOfflineMediaKeys() local
[all …]
/drivers/peripheral/clearplay/hdi_service/common/
Dbase64_utils.cpp103 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()

12345678910>>...14