| /base/hiviewdfx/hiview/base/include/ |
| D | audit_log_parser.h | 29 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/script/threadpool/ |
| D | threadpool.cpp | 66 taskQueue_[k].task.processor(threadIndex); in ThreadRun()
107 task.processor(i); in AddNewTask()
117 newTask.processor = [workSize, &task, this](int tId) { in AddNewTask()
119 task.processor(v); in AddNewTask()
154 taskQueue_[index].task.processor(0); in RunTask()
|
| D | thread_pool.h | 26 std::function<void(int)> processor; member
|
| /base/security/device_security_level/baselib/msglib/src/ |
| D | messenger.c | 50 void ForEachDeviceProcess(const Messenger *messenger, const DeviceProcessor processor, void *para) in ForEachDeviceProcess() argument
52 ForEachDeviceProcessImpl(messenger, processor, para); in ForEachDeviceProcess()
|
| D | messenger_impl.h | 40 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa…
|
| /base/security/device_security_level/test/dslm_unit_test/ |
| D | dslm_msg_interface_mock.h | 43 …virtual void ForEachDeviceProcess(const Messenger *messenger, const DeviceProcessor processor, voi…
56 …rEachDeviceProcess, void(const Messenger *messenger, const DeviceProcessor processor, void *para));
|
| D | dslm_msg_interface_mock.cpp | 124 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa… in ForEachDeviceProcessImpl() argument
|
| /base/security/device_security_level/baselib/msglib/src/standard/ |
| D | messenger_device_status_manager.cpp | 156 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()
|
| D | messenger_device_status_manager.h | 42 void MessengerForEachDeviceProcess(const DeviceProcessor processor, void *para);
|
| D | messenger_impl.c | 126 void ForEachDeviceProcessImpl(const Messenger *messenger, const DeviceProcessor processor, void *pa… in ForEachDeviceProcessImpl() argument
133 return MessengerForEachDeviceProcess(processor, para); in ForEachDeviceProcessImpl()
|
| /base/hiviewdfx/hiview/base/ |
| D | audit_log_parser.cpp | 50 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/ |
| D | threadpool_unittest.cpp | 57 task.processor = [&](int iter) { in TestThreadPoolCreate()
|
| D | script_unittest.h | 77 PkgStream::ExtractFileProcessor processor, const void *context) override in CreatePkgStream() argument
|
| /base/security/device_security_level/baselib/msglib/src/lite/ |
| D | messenger_device_status_manager.c | 336 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/update/updater/services/package/pkg_manager/ |
| D | pkg_manager_impl.h | 55 PkgStream::ExtractFileProcessor processor, const void *context) override;
117 PkgStream::ExtractFileProcessor processor, const void *context);
|
| D | pkg_stream.h | 160 ExtractFileProcessor processor, const void *context) in ProcessorStream() argument
161 : PkgStreamImpl(pkgManager, fileName), processor_(processor), context_(context) {} in ProcessorStream()
|
| D | pkg_managerImpl.cpp | 488 PkgStream::ExtractFileProcessor processor, const void *context) in CreatePkgStream() argument
491 int32_t ret = CreatePkgStream(pkgStream, fileName, processor, context); in CreatePkgStream()
561 PkgStream::ExtractFileProcessor processor, const void *context) in CreatePkgStream() argument
563 stream = new ProcessorStream(this, fileName, processor, context); in CreatePkgStream()
|
| /base/security/device_security_level/baselib/msglib/include/ |
| D | messenger.h | 88 void ForEachDeviceProcess(const Messenger *messenger, const DeviceProcessor processor, void *para);
|
| /base/telephony/call_manager/services/audio/src/ |
| D | audio_control_manager.cpp | 485 auto processor = DelayedSingleton<CallStateProcessor>::GetInstance(); in ShouldPlayRingtone() local
486 int32_t alertingCallNum = processor->GetCallNumber(TelCallState::CALL_STATUS_ALERTING); in ShouldPlayRingtone()
487 int32_t incomingCallNum = processor->GetCallNumber(TelCallState::CALL_STATUS_INCOMING); in ShouldPlayRingtone()
|
| /base/startup/init/services/param/include/ |
| D | param_utils.h | 47 int (*processor)(const char *name, const char *value, int); member
|
| /base/update/updater/services/script/script_manager/ |
| D | script_managerImpl.cpp | 155 task.processor = [&](int iter) { in ExecuteScript()
|
| /base/update/updater/services/include/package/ |
| D | pkg_manager.h | 323 PkgStream::ExtractFileProcessor processor, const void *context) = 0;
|
| /base/startup/init/services/param/manager/ |
| D | param_server.c | 145 cmdLines[i].processor(cmdLines[i].name, value, ret); in LoadParamFromCmdLine()
|
| /base/startup/init/services/param/watcher/proxy/ |
| D | watcher_manager.h | 212 void TraversalNodeSafe(ParamWatcherProcessor processor);
|
| D | watcher_manager.cpp | 675 void ParamWatcherList::TraversalNodeSafe(ParamWatcherProcessor processor) in TraversalNodeSafe() argument
683 processor(this, node, index); in TraversalNodeSafe()
|