| /drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/dispatcher/ |
| D | stream_pipeline_dispatcher.cpp | 36 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 CAMERA_LOGI("seq node name:%{public}s\n", it->GetName().c_str()); in Update()
[all …]
|
| /drivers/hdf_core/framework/utils/src/ |
| D | osal_msg_queue.c | 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()
68 HdfSListIteratorRemove(&it); in HdfMessageQueueNext()
[all …]
|
| /drivers/peripheral/camera/vdi_base/common/buffer_manager/src/ |
| D | buffer_pool.cpp | 123 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 …]
|
| D | buffer_loop_tracking.cpp | 45 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/camera/vdi_base/v4l2/src/offline_stream_operator/ |
| D | offline_stream_operator_vdi_impl.cpp | 58 for (auto it : streamIds) { in ReleaseStreams() local
59 RetCode ret = offlineStreamMap_[it]->Release(); in ReleaseStreams()
61 CAMERA_LOGE("release stream %{public}d failed", it); in ReleaseStreams()
66 offlineStreamMap_.erase(it); in ReleaseStreams()
81 for (auto it = offlineStreamMap_.begin(); it != offlineStreamMap_.end(); it++) { in Release() local
82 it->second->Release(); in Release()
107 for (auto it = offlineStreamMap_.begin(); it != offlineStreamMap_.end(); it++) { in FindStreamByCaptureId() local
108 if (it->second->CheckCaptureIdExist(captureId)) { in FindStreamByCaptureId()
109 stream = it->second; in FindStreamByCaptureId()
|
| /drivers/peripheral/camera/vdi_base/common/pipeline_core/host_stream/src/ |
| D | host_stream_mgr_impl.cpp | 35 …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/ |
| D | algo_plugin_manager.cpp | 41 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()
|
| D | offline_pipeline.cpp | 106 auto it = std::find_if(bufferCache_.begin(), bufferCache_.end(), in CancelCapture() local
115 if (it == bufferCache_.end()) { in CancelCapture()
119 cache = *it; in CancelCapture()
120 bufferCache_.erase(it); in CancelCapture()
122 for (auto it : cache) { in CancelCapture() local
123 it->SetBufferStatus(CAMERA_BUFFER_STATUS_DROP); in CancelCapture()
143 for (auto it : cache) { in FlushOfflineStream() local
144 it->SetBufferStatus(CAMERA_BUFFER_STATUS_DROP); in FlushOfflineStream()
194 for (auto it : buffers) { in DeliverCacheCheck() local
195 if (it == nullptr) { in DeliverCacheCheck()
[all …]
|
| 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() 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/ |
| D | capture_message.cpp | 76 auto it = messageBox_.find(message->GetMessageType()); in SendMessage() local
77 if (it == messageBox_.end()) { in SendMessage()
85 for (auto& mit : it->second) { in SendMessage()
106 it->second.emplace_back(mg); in SendMessage()
160 for (auto it = lit.second.begin(); it != lit.second.end();) { in HandleMessage() local
161 if (it->empty()) { in HandleMessage()
162 it = lit.second.erase(it); in HandleMessage()
165 it++; in HandleMessage()
170 for (auto it = messages.begin(); it != messages.end();) { in HandleMessage() local
171 messageOperator_(*it); in HandleMessage()
[all …]
|
| D | stream_operator_vdi_impl.cpp | 82 for (auto &it : streamMap_) { in GetStreamSupportType() local
83 currentIDSet.emplace(it.first); in GetStreamSupportType()
141 for (auto it : infos) { in IsStreamsSupported() local
142 CHECK_IF_NOT_EQUAL_RETURN_VALUE(CheckStreamInfo(it), true, INVALID_ARGUMENT); in IsStreamsSupported()
143 inputIDSet.emplace(it.streamId_); in IsStreamsSupported()
144 checkStreamIdVec.push_back(it.streamId_); in IsStreamsSupported()
193 for (auto &it : infos) { in CheckStreamsSupported() local
195 config.type = it.intent_; in CheckStreamsSupported()
196 config.width = it.width_; in CheckStreamsSupported()
197 config.height = it.height_; in CheckStreamsSupported()
[all …]
|
| /drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/ |
| D | stream_pipeline_core.cpp | 63 for (const auto& it : streamIds) { in DestroyPipeline() local
64 re = dispatcher_->Destroy(it) | re; in DestroyPipeline()
65 re = builder_->Destroy(it) | re; in DestroyPipeline()
66 re = strategy_->Destroy(it) | re; in DestroyPipeline()
75 for (const auto& it : streamIds) { in Prepare() local
76 re = dispatcher_->Prepare(it) | re; in Prepare()
85 for (const auto& it : streamIds) { in Start() local
86 re = dispatcher_->Start(it) | re; in Start()
103 for (const auto& it : streamIds) { in Stop() local
104 CAMERA_LOGV("stop stream %{public}d begin", it); in Stop()
[all …]
|
| /drivers/peripheral/power/test/unittest/mock/ |
| 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/strategy/ |
| D | stream_pipeline_strategy.cpp | 46 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()
188 for (const auto& it : n.portSpecSet_) { in PrintConnection() local
189 if (it.direction_ == 1) { in PrintConnection()
192 … n.name_.c_str(), it.info_.name_.c_str(), it.format_.w_, it.format_.h_, it.format_.format_, in PrintConnection()
193 it.format_.usage_, it.format_.bufferPoolId_, in PrintConnection()
194 it.info_.peerPortNodeName_.c_str(), it.info_.peerPortName_.c_str()); in PrintConnection()
197 [it](const NodeSpec& n) { in PrintConnection()
198 return n.name_ == it.info_.peerPortNodeName_; in PrintConnection()
[all …]
|
| /drivers/peripheral/camera/hal_c/hdi_cif/src/ |
| D | stream_operator_callback_wrapper.cpp | 49 …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/external_device_manager/test/unittest/device_manager_js_test/ |
| D | DeviceManagerJsTest.js | 17 import {describe, beforeAll, beforeEach, afterEach, afterAll, it, expect} from 'deccjsunit/index'
54 it("DeviceManager_queryDevices_001", 0, function () {
69 it("DeviceManager_queryDevices_002", 0, function () {
84 it("DeviceManager_bindDevices_003", 0, async function (done) {
107 it("DeviceManager_bindDevices_004", 0, async function (done) {
130 it("DeviceManager_bindDevices_005", 0, async function (done) {
147 it("DeviceManager_bindDevices_006", 0, async function (done) {
164 it("DeviceManager_bindDevices_007", 0, async function (done) {
181 it("DeviceManager_bindDevices_008", 0, async function (done) {
207 it("DeviceManager_bindDevices_009", 0, async function (done) {
[all …]
|
| /drivers/peripheral/camera/vdi_base/common/pipeline_core/pipeline_impl/src/builder/ |
| D | stream_pipeline_builder.cpp | 31 for (auto& it : pipelineSpec->nodeSpecSet_) { in Build() local
32 if (it.status_ == "new") { in Build()
34 size_t pos = it.name_.find_first_of('#'); in Build()
35 nodeName = it.name_.substr(0, pos); in Build()
36 … std::shared_ptr<INode> newNode = NodeFactory::Instance().CreateShared(nodeName, it.name_, in Build()
37 … it.type_, cameraId); in Build()
42 … std::optional<int32_t> typeId = GetTypeId(it.type_, G_STREAM_TABLE_PTR, G_STREAM_TABLE_SIZE); in Build()
44 newNode->SetCallBack(hostStreamMgr_->GetBufferCb(it.streamId_)); in Build()
47 it.status_ = "remain"; in Build()
48 for (const auto& portSpec : it.portSpecSet_) { in Build()
|
| /drivers/peripheral/camera/vdi_base/common/metadata_manager/src/ |
| D | metadata_config.cpp | 50 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/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/node_base/ |
| 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()… 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()
239 (*it)->DeliverBuffer(buffer); in DeliverBuffer()
[all …]
|
| /drivers/peripheral/camera/vdi_base/usb_camera/pipeline_core/src/node/ |
| D | fork_node.cpp | 113 for (auto& it : outPutPorts_) { in DeliverBuffer() local
114 if (it->format_.streamId_ != streamId_) { in DeliverBuffer()
117 CAMERA_LOGI("deliver fork buffer for streamid = %{public}d", it->format_.streamId_); in DeliverBuffer()
131 it->DeliverBuffer(forkBuffer); in DeliverBuffer()
137 for (auto& it : outPutPorts_) { in DeliverBuffer() local
138 if (it->format_.streamId_ == buffer->GetStreamId()) { in DeliverBuffer()
139 it->DeliverBuffer(buffer); in DeliverBuffer()
140 CAMERA_LOGI("fork node deliver buffer streamid = %{public}d", it->format_.streamId_); in DeliverBuffer()
184 for (auto& it : outPutPorts_) { in DrainForkBufferPool() local
185 if (it->format_.streamId_ == streamId_) { in DrainForkBufferPool()
[all …]
|
| /drivers/peripheral/camera/test/fuzztest/common/src/ |
| D | common.cpp | 95 for (auto it : streamId) { in OnCaptureStarted() local
96 CAMERA_LOGE("captureId: %{public}d, streamId: %{public}d", captureId, it); in OnCaptureStarted()
104 for (auto it : infos) { in OnCaptureEnded() local
105 …CAMERA_LOGE("captureId: %{public}d, streamId: %{public}d, count: %{public}d", captureId, it.stream… in OnCaptureEnded()
106 it.frameCount_); in OnCaptureEnded()
114 for (auto it : infos) { in OnCaptureError() local
115 …CAMERA_LOGE("captureId: %{public}d, streamId: %{public}d, error: %{public}d", captureId, it.stream… in OnCaptureError()
116 it.error_); in OnCaptureError()
125 for (auto it : streamIds) { in OnFrameShutter() local
126 CAMERA_LOGE("captureId: %{public}d, streamId: %{public}d", captureId, it); in OnFrameShutter()
|
| /drivers/hdf_core/adapter/uhdf2/hdi/src/ |
| D | object_collector.cpp | 77 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/usb/ddk_service/src/ |
| D | usb_ddk_hash.cpp | 61 for (auto it = g_hashMap.begin(); it != g_hashMap.end();) { in UsbDdkGetRecordByVal() local
62 if (it->second.busNum == info.busNum && it->second.devNum == info.devNum) { in UsbDdkGetRecordByVal()
63 return it->first; in UsbDdkGetRecordByVal()
|
| /drivers/peripheral/camera/vdi_base/common/pipeline_core/nodes/src/fork_node/ |
| D | fork_node.cpp | 138 for (auto& it : outPutPorts_) { in DeliverBuffer() local
139 if (it->format_.streamId_ == buffer->GetStreamId()) { in DeliverBuffer()
140 it->DeliverBuffer(buffer); in DeliverBuffer()
141 CAMERA_LOGI("fork node deliver buffer streamid = %{public}d", it->format_.streamId_); in DeliverBuffer()
189 for (auto& it : outPutPorts_) { in DeliverBufferToNextNode() local
190 if (it->format_.streamId_ != streamId_) { in DeliverBufferToNextNode()
204 it->DeliverBuffer(forkBuffer); in DeliverBufferToNextNode()
225 for (auto& it : outPutPorts_) { in DrainForkBufferPool() local
226 if (it->format_.streamId_ == streamId_) { in DrainForkBufferPool()
227 it->DeliverBuffer(buffer); in DrainForkBufferPool()
|
| /drivers/peripheral/sensor/hdi_service/ |
| D | sensor_if_service.cpp | 107 for (const auto &it : sensorInfoVdi) { in GetAllSensorInfo() local
109 sensorInfo.sensorName = it.sensorName; in GetAllSensorInfo()
110 sensorInfo.vendorName = it.vendorName; in GetAllSensorInfo()
111 sensorInfo.firmwareVersion = it.firmwareVersion; in GetAllSensorInfo()
112 sensorInfo.hardwareVersion = it.hardwareVersion; in GetAllSensorInfo()
113 sensorInfo.sensorTypeId = it.sensorTypeId; in GetAllSensorInfo()
114 sensorInfo.sensorId = it.sensorId; in GetAllSensorInfo()
115 sensorInfo.maxRange = it.maxRange; in GetAllSensorInfo()
116 sensorInfo.accuracy = it.accuracy; in GetAllSensorInfo()
117 sensorInfo.power = it.power; in GetAllSensorInfo()
[all …]
|