Home
last modified time | relevance | path

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

123

/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/hiappevent/test/unittest/common/native/
Dhiappevent_inner_api_test.cpp51 std::shared_ptr<AppEventProcessor> processor, int64_t& processorSeq) in CheckRegisterObserver() argument
53 ASSERT_EQ(AppEventProcessorMgr::RegisterProcessor(observer, processor), 0); in CheckRegisterObserver()
60 std::shared_ptr<AppEventProcessor> processor, in CheckRegisterObserverWithConfig() argument
64 ASSERT_EQ(AppEventProcessorMgr::RegisterProcessor(observer, processor), 0); in CheckRegisterObserverWithConfig()
273 auto processor = std::make_shared<AppEventProcessorTest>(); variable
275 CheckRegisterObserver(TEST_PROCESSOR_NAME, processor, processorSeq);
297 auto processor = std::make_shared<AppEventProcessorTest>(); variable
298 auto ret = AppEventProcessorMgr::RegisterProcessor(TEST_PROCESSOR_NAME, processor);
300 ret = AppEventProcessorMgr::RegisterProcessor(TEST_PROCESSOR_NAME, processor);
321 auto processor = std::make_shared<AppEventProcessorTest>(); variable
[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.cpp110 PkgStream::ExtractFileProcessor processor = in ExtractBinFile() local
114 ret = pkgManager->CreatePkgStream(processStream, upgradeFileName, processor, stream); in ExtractBinFile()
254 std::unique_ptr<ComponentProcessor> processor = in ComponentProcess() local
262 processor.reset(); in ComponentProcess()
263 processor = std::make_unique<SkipImgProcessor>(name, fileSize); in ComponentProcess()
267 if (processor == nullptr && fileInfo.resType == UPGRADE_FILE_COMP_OTHER_TPYE) { in ComponentProcess()
269 processor.reset(); in ComponentProcess()
270 processor = std::make_unique<SkipImgProcessor>(name, fileSize); in ComponentProcess()
273 if (processor == nullptr) { in ComponentProcess()
277processor->SetPkgFileInfo(stream->GetReadOffset(), stream->GetFileLength(), fullUpdateProportion_); in ComponentProcess()
[all …]
/base/hiviewdfx/hiappevent/test/processor/
Dtest_init.cpp31 auto processor = std::make_shared<TestProcessor>(); in XInit() local
32 int ret = AppEventProcessorMgr::RegisterProcessor("test_processor", processor); in XInit()
/base/hiviewdfx/hiappevent/test/unittest/common/napi/
Dnapi_hiappevent_processor.test.js73 function validProcessorTest(processor, done) { argument
74 let processorId = hiAppEvent.addProcessor(processor);
83 function invalidProcessorTest(processor, expectErr) { argument
86 processorId = hiAppEvent.addProcessor(processor);
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/observer/include/
Dapp_event_processor_proxy.h28 AppEventProcessorProxy(const std::string& name, std::shared_ptr<AppEventProcessor> processor) in AppEventProcessorProxy() argument
29 … : AppEventObserver(name), processor_(processor), userIdVersion_(-1), userPropertyVersion_(-1) {} in AppEventProcessorProxy()
/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.h38 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa…
/base/hiviewdfx/hiappevent/interfaces/native/inner_api/src/
Dapp_event_processor_mgr.cpp42 …cessorMgr::RegisterProcessor(const std::string& name, std::shared_ptr<AppEventProcessor> processor) in RegisterProcessor() argument
44 return ModuleLoader::GetInstance().RegisterProcessor(name, processor); in RegisterProcessor()
/base/security/device_security_level/baselib/msglib/src/standard/
Dmessenger_device_status_manager.cpp159 auto processor = DeviceStatusControlBlock::GetInstance().GetStateReceiver(); in ProcessDeviceStatusReceiver() local
160 if (processor == nullptr) { in ProcessDeviceStatusReceiver()
164 processor(&queueData->srcIdentity, queueData->status, queueData->devType); in ProcessDeviceStatusReceiver()
338 void MessengerForEachDeviceProcess(const DeviceProcessor processor, void *para) in MessengerForEachDeviceProcess() argument
340 if (processor == nullptr) { in MessengerForEachDeviceProcess()
357 processor(&curr, device.deviceTypeId, para); in MessengerForEachDeviceProcess()
Dmessenger_impl.c123 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa… in ForEachDeviceProcessImpl() argument
130 return MessengerForEachDeviceProcess(processor, para); in ForEachDeviceProcessImpl()
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/load/
Dmodule_loader.cpp101 …uleLoader::RegisterProcessor(const std::string& name, std::shared_ptr<AppEventProcessor> processor) in RegisterProcessor() argument
103 if (name.empty() || processor == nullptr) { in RegisterProcessor()
111 processors_[name] = processor; in RegisterProcessor()
/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));
/base/security/device_security_level/baselib/msglib/src/lite/
Dmessenger_impl.c126 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa… in ForEachDeviceProcessImpl() argument
133 return MessengerForEachDeviceProcess(processor, para); in ForEachDeviceProcessImpl()
/base/startup/init/interfaces/innerkits/syspara/
Dparam_comm.c121 INIT_LOCAL_API PropertyValueProcessor SetPropertyGetProcessor(PropertyValueProcessor processor) in SetPropertyGetProcessor() argument
124 g_propertyGetProcessor = processor; in SetPropertyGetProcessor()
Dparam_comm.h36 INIT_LOCAL_API PropertyValueProcessor SetPropertyGetProcessor(PropertyValueProcessor processor);
/base/hiviewdfx/hiappevent/interfaces/native/inner_api/include/
Dapp_event_processor_mgr.h30 …tatic int RegisterProcessor(const std::string& name, std::shared_ptr<AppEventProcessor> processor);
/base/hiviewdfx/hiappevent/frameworks/native/libhiappevent/load/include/
Dmodule_loader.h34 int RegisterProcessor(const std::string& name, std::shared_ptr<AppEventProcessor> 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/services/script/threadpool/
Dthread_pool.h26 std::function<void(int)> processor; member

123