Home
last modified time | relevance | path

Searched refs:processor (Results 1 – 25 of 35) sorted by relevance

12

/base/useriam/face_auth/services/src/
Dsa_command_manager.cpp32 std::shared_ptr<ISaCommandProcessor> processor) in RegisterSaCommandProcessor() argument
34 IF_FALSE_LOGE_AND_RETURN(processor != nullptr); in RegisterSaCommandProcessor()
38 processors_.insert(processor); in RegisterSaCommandProcessor()
45 commandId2Processors_[commandId].insert(processor); in RegisterSaCommandProcessor()
50 std::shared_ptr<ISaCommandProcessor> processor) in UnregisterSaCommandProcessor() argument
52 IF_FALSE_LOGE_AND_RETURN(processor != nullptr); in UnregisterSaCommandProcessor()
56 processors_.erase(processor); in UnregisterSaCommandProcessor()
63 commandId2Processors_[commandId].erase(processor); in UnregisterSaCommandProcessor()
75 for (const auto &processor : commandId2Processors_[command.id]) { in ProcessSaCommands() local
76 IF_FALSE_LOGE_AND_RETURN_VAL(processor != nullptr, UserAuth::GENERAL_ERROR); in ProcessSaCommands()
[all …]
/base/useriam/fingerprint_auth/services/src/
Dsa_command_manager.cpp32 std::shared_ptr<ISaCommandProcessor> processor) in RegisterSaCommandProcessor() argument
34 IF_FALSE_LOGE_AND_RETURN(processor != nullptr); in RegisterSaCommandProcessor()
38 processors_.insert(processor); in RegisterSaCommandProcessor()
45 commandId2Processors_[commandId].insert(processor); in RegisterSaCommandProcessor()
50 std::shared_ptr<ISaCommandProcessor> processor) in UnregisterSaCommandProcessor() argument
52 IF_FALSE_LOGE_AND_RETURN(processor != nullptr); in UnregisterSaCommandProcessor()
56 processors_.erase(processor); in UnregisterSaCommandProcessor()
63 commandId2Processors_[commandId].erase(processor); in UnregisterSaCommandProcessor()
76 for (const auto &processor : commandId2Processors_[command.id]) { in ProcessSaCommands() local
77 IF_FALSE_LOGE_AND_RETURN_VAL(processor != nullptr, UserAuth::GENERAL_ERROR); in ProcessSaCommands()
[all …]
/base/hiviewdfx/hiview/base/include/
Daudit_log_parser.h29 std::string processor = ""; member
41 …urn "SerialId:" + std::to_string(eventSerialId) + " Sender:" + sender + " Processor:" + processor + in ToString()
65 for (auto &processor : processChain) { in ToString()
67 ret.append(processor.processor); in ToString()
69 ret.append(std::to_string(processor.inTime)); in ToString()
71 ret.append(std::to_string(processor.outTime)); in ToString()
73 ret.append(processor.threadNameOrTid); in ToString()
/base/update/updater/services/flow_update/update_bin/
Dbin_process.cpp102 PkgStream::ExtractFileProcessor processor = in ExtractBinFile() local
106 ret = pkgManager->CreatePkgStream(processStream, upgradeFileName, processor, stream); in ExtractBinFile()
245 std::unique_ptr<ComponentProcessor> processor = in ComponentProcess() local
253 processor.reset(); in ComponentProcess()
254 processor = std::make_unique<SkipImgProcessor>(name, fileSize); in ComponentProcess()
258 if (processor == nullptr) { in ComponentProcess()
262 processor->SetPkgFileSize(stream->GetReadOffset(), stream->GetFileLength()); in ComponentProcess()
265 if (processor->PreProcess(env) != USCRIPT_SUCCESS) { in ComponentProcess()
270 if (processor->DoProcess(env) != USCRIPT_SUCCESS) { in ComponentProcess()
275 if (processor->PostProcess(env) != USCRIPT_SUCCESS) { in ComponentProcess()
Dcomponent_processor.cpp191 PkgStream::ExtractFileProcessor processor = in DoProcess() local
197 …int ret = env.GetPkgManager()->CreatePkgStream(outStream, partitionName, processor, writer_.get()); in DoProcess()
323 PkgStream::ExtractFileProcessor processor = in DoProcess() local
329 …int ret = env.GetPkgManager()->CreatePkgStream(outStream, partitionName, processor, writer_.get()); in DoProcess()
/base/update/updater/services/script/threadpool/
Dthreadpool.cpp69 taskQueue_[k].task.processor(threadIndex); in ThreadRun()
110 task.processor(i); in AddNewTask()
120 newTask.processor = [workSize, &task, this](int tId) { in AddNewTask()
122 task.processor(v); in AddNewTask()
157 taskQueue_[index].task.processor(0); in RunTask()
Dthread_pool.h26 std::function<void(int)> processor; member
/base/useriam/face_auth/services/inc/
Dsa_command_manager.h39 std::shared_ptr<ISaCommandProcessor> processor);
41 std::shared_ptr<ISaCommandProcessor> processor);
/base/useriam/fingerprint_auth/services/inc/
Dsa_command_manager.h39 std::shared_ptr<ISaCommandProcessor> processor);
41 std::shared_ptr<ISaCommandProcessor> processor);
/base/security/device_security_level/baselib/msglib/src/common/
Dmessenger.c50 void ForEachDeviceProcess(const Messenger *messenger, const DeviceProcessor processor, void *para) in ForEachDeviceProcess() argument
52 ForEachDeviceProcessImpl(messenger, processor, para); in ForEachDeviceProcess()
Dmessenger_device_status_manager.h42 void MessengerForEachDeviceProcess(const DeviceProcessor processor, void *para);
Dmessenger_impl.c126 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa… in ForEachDeviceProcessImpl() argument
133 return MessengerForEachDeviceProcess(processor, para); in ForEachDeviceProcessImpl()
Dmessenger_impl.h38 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa…
/base/security/device_security_level/test/dslm_unit_test/
Ddslm_msg_interface_mock.h43 …virtual void ForEachDeviceProcess(const Messenger *messenger, const DeviceProcessor processor, voi…
56 …rEachDeviceProcess, void(const Messenger *messenger, const DeviceProcessor processor, void *para));
Ddslm_msg_interface_mock.cpp124 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa… in ForEachDeviceProcessImpl() argument
/base/security/device_security_level/baselib/msglib/src/standard/
Dmessenger_device_status_manager.cpp156 auto processor = DeviceStatusControlBlock::GetInstance().GetStateReceiver(); in ProcessDeviceStatusReceiver() local
157 if (processor == nullptr) { in ProcessDeviceStatusReceiver()
161 processor(&queueData->srcIdentity, queueData->status, queueData->devType); in ProcessDeviceStatusReceiver()
335 void MessengerForEachDeviceProcess(const DeviceProcessor processor, void *para) in MessengerForEachDeviceProcess() argument
337 if (processor == nullptr) { in MessengerForEachDeviceProcess()
354 processor(&curr, device.deviceTypeId, para); in MessengerForEachDeviceProcess()
/base/startup/init/interfaces/innerkits/syspara/
Dparam_comm.c114 INIT_LOCAL_API PropertyValueProcessor SetPropertyGetProcessor(PropertyValueProcessor processor) in SetPropertyGetProcessor() argument
117 g_propertyGetProcessor = processor; in SetPropertyGetProcessor()
Dparam_comm.h36 INIT_LOCAL_API PropertyValueProcessor SetPropertyGetProcessor(PropertyValueProcessor processor);
/base/hiviewdfx/hiview/base/
Daudit_log_parser.cpp50 info.processor = eventElements[LOG_ELEMENT_PIPE_EVENT_PROCESSOR_POS]; in CreateEventInfo()
124 if (event.processor.find(name) != std::string::npos) { in GetPluginSummary()
131 if (chainEvent.processor.find(name) != std::string::npos) { in GetPluginSummary()
185 info.processor = eventElements[LOG_ELEMENT_NORMAL_EVENT_PROCESSOR_POS]; in ParseNormalEnqueueEvent()
/base/update/updater/test/unittest/script/
Dthreadpool_unittest.cpp60 task.processor = [&](int iter) { in TestThreadPoolCreate()
/base/startup/init/services/param/manager/
Dparam_server.c43 int (*processor)(const char *name, const char *value); member
157 ret = CMDLINES[i].processor(fullName, nv->value); in CmdlineIterator()
158 if ((ret == 0) && (SnDealFun == CMDLINES[i].processor)) { in CmdlineIterator()
/base/security/device_security_level/baselib/msglib/src/lite/
Dmessenger_device_status_manager.c336 void MessengerForEachDeviceProcess(const DeviceProcessor processor, void *para) in MessengerForEachDeviceProcess() argument
338 if (processor == NULL) { in MessengerForEachDeviceProcess()
357 processor(&devId, node->deviceTypeId, para); in MessengerForEachDeviceProcess()
/base/security/device_security_level/baselib/msglib/include/
Dmessenger.h88 void ForEachDeviceProcess(const Messenger *messenger, const DeviceProcessor processor, void *para);
/base/update/updater/services/package/pkg_manager/
Dpkg_stream.h169 ExtractFileProcessor processor, const void *context) in ProcessorStream() argument
170 : PkgStreamImpl(pkgManager, fileName), processor_(processor), context_(context) {} in ProcessorStream()
/base/telephony/call_manager/services/audio/src/
Daudio_control_manager.cpp529 auto processor = DelayedSingleton<CallStateProcessor>::GetInstance(); in ShouldPlayRingtone() local
530 int32_t alertingCallNum = processor->GetCallNumber(TelCallState::CALL_STATUS_ALERTING); in ShouldPlayRingtone()
531 int32_t incomingCallNum = processor->GetCallNumber(TelCallState::CALL_STATUS_INCOMING); in ShouldPlayRingtone()

12