| /base/hiviewdfx/hiview/framework/native/unified_collection/decorator/ |
| D | memory_decorator.cpp | 27 auto task = [this, &pid] { return memoryCollector_->CollectProcessMemory(pid); }; in CollectProcessMemory() local
33 auto task = [this] { return memoryCollector_->CollectSysMemory(); }; in CollectSysMemory() local
39 auto task = [this] { return memoryCollector_->CollectRawMemInfo(); }; in CollectRawMemInfo() local
45 auto task = [this] { return memoryCollector_->ExportMemView(); }; in ExportMemView() local
51 auto task = [this] { return memoryCollector_->CollectAllProcessMemory(); }; in CollectAllProcessMemory() local
56 auto task = [this] { return memoryCollector_->ExportAllProcessMemory(); }; in ExportAllProcessMemory() local
62 auto task = [this] { return memoryCollector_->CollectRawSlabInfo(); }; in CollectRawSlabInfo() local
68 auto task = [this] { return memoryCollector_->CollectRawPageTypeInfo(); }; in CollectRawPageTypeInfo() local
74 auto task = [this] { return memoryCollector_->CollectRawDMA(); }; in CollectRawDMA() local
80 auto task = [this] { return memoryCollector_->CollectAllAIProcess(); }; in CollectAllAIProcess() local
[all …]
|
| D | io_decorator.cpp | 27 auto task = [this, &pid] { return ioCollector_->CollectProcessIo(pid); }; in CollectProcessIo() local
33 auto task = [this] { return ioCollector_->CollectRawDiskStats(); }; in CollectRawDiskStats() local
40 …auto task = [this, &filter, &isUpdate] { return ioCollector_->CollectDiskStats(filter, isUpdate); … in CollectDiskStats() local
46 auto task = [this, &filter] { return ioCollector_->ExportDiskStats(filter); }; in ExportDiskStats() local
52 auto task = [this] { return ioCollector_->CollectEMMCInfo(); }; in CollectEMMCInfo() local
58 auto task = [this] { return ioCollector_->ExportEMMCInfo(); }; in ExportEMMCInfo() local
64 auto task = [this, &isUpdate] { return ioCollector_->CollectAllProcIoStats(isUpdate); }; in CollectAllProcIoStats() local
70 auto task = [this] { return ioCollector_->ExportAllProcIoStats(); }; in ExportAllProcIoStats() local
76 auto task = [this] { return ioCollector_->CollectSysIoStats(); }; in CollectSysIoStats() local
82 auto task = [this] { return ioCollector_->ExportSysIoStats(); }; in ExportSysIoStats() local
|
| D | mem_profiler_decorator.cpp | 27 auto task = [this] { return memProfilerCollector_->Prepare(); }; in Prepare() local
33 auto task = [this, &memoryProfilerConfig] { in Start() local
42 auto task = [this, &pid] { return memProfilerCollector_->Stop(pid); }; in Stop() local
49 auto task = [this, &processName] { return memProfilerCollector_->Stop(processName); }; in Stop() local
56 auto task = [this, &fd, &memoryProfilerConfig] { in Start() local
65 …auto task = [this, &fd, &pid, &type] { return memProfilerCollector_->StartPrintNmd(fd, pid, type);… in StartPrintNmd() local
71 auto task = [this, &fd, &startup, &memoryProfilerConfig] { in Start() local
80 auto task = [this, &fd, &pid, &duration, &config] { in Start() local
89 …auto task = [this, &pid, &memStats] { return memProfilerCollector_->StartPrintSimplifiedNmd(pid, m… in StartPrintSimplifiedNmd() local
|
| D | cpu_decorator.cpp | 32 auto task = [this] { return cpuCollector_->CollectSysCpuLoad(); }; in CollectSysCpuLoad() local
42 auto task = [this, &isNeedUpdate] { return cpuCollector_->CollectSysCpuUsage(isNeedUpdate); }; in CollectSysCpuUsage() local
52 auto task = [this] { return cpuCollector_->GetSysCpuUsage(); }; in GetSysCpuUsage() local
62 …auto task = [this, &pid, &isNeedUpdate] { return cpuCollector_->CollectProcessCpuStatInfo(pid, isN… in CollectProcessCpuStatInfo() local
72 auto task = [this] { return cpuCollector_->CollectCpuFrequency(); }; in CollectCpuFrequency() local
82 …auto task = [this, &isNeedUpdate] { return cpuCollector_->CollectProcessCpuStatInfos(isNeedUpdate)… in CollectProcessCpuStatInfos() local
97 …auto task = [this, &isNeedUpdate] { return threadCpuCollector_->CollectThreadStatInfos(isNeedUpdat… in CollectThreadStatInfos() local
|
| /base/security/device_auth/test/unittest/deviceauth/source/ |
| D | iso_auth_task_test.cpp | 72 TaskBase *task = CreateIsoAuthTask(nullptr, nullptr, nullptr); variable
225 TaskBase *task = CreateIsoAuthServerTask(inJson, outJson, &info); in CreateServerTask() local
239 TaskBase *task = CreateIsoAuthServerTask(nullptr, outJson, &info); variable
263 TaskBase *task = CreateServerTask(); variable
288 TaskBase *task = CreateServerTask(); variable
315 TaskBase *task = CreateServerTask(); variable
339 TaskBase *task = CreateServerTask(); variable
364 TaskBase *task = CreateServerTask(); variable
390 TaskBase *task = CreateServerTask(); variable
414 TaskBase *task = CreateServerTask(); variable
[all …]
|
| /base/inputmethod/imf/test/unittest/cpp_test/src/ |
| D | task_manager_test.cpp | 64 std::shared_ptr<Task> task { nullptr }; variable
78 std::shared_ptr<Task> task = std::make_shared<TaskAmsInit>(); variable
193 auto task = std::make_shared<TaskAmsInit>(); variable
219 std::shared_ptr<Task> task { nullptr }; variable
243 std::shared_ptr<Task> task = std::make_shared<TaskAmsInit>(); variable
280 auto task = std::make_shared<TaskAmsInit>(); variable
305 auto task = std::make_shared<TaskAmsInit>(); variable
322 auto task = std::make_shared<TaskAmsInit>(); variable
|
| /base/update/updateservice/services/firmware/upgrade/flow/src/ |
| D | firmware_manager.cpp | 136 FirmwareTask task; in IsIdle() local
157 FirmwareTask task; in DoCancel() local
216 FirmwareTask task; in CanInstall() local
263 FirmwareTask task; in DoAutoDownloadSwitchChanged() local
283 FirmwareTask task; in DoClearError() local
316 FirmwareTask task; in HandleBootComplete() local
347 FirmwareTask task; in HandleNetChanged() local
372 void FirmwareManager::HandleBootUpdateOnStatusProcess(const FirmwareTask &task) in HandleBootUpdateOnStatusProcess()
391 void FirmwareManager::HandleBootUpdateSuccess(const FirmwareTask &task) in HandleBootUpdateSuccess()
418 void FirmwareManager::HandleBootUpdateFail(const FirmwareTask &task, in HandleBootUpdateFail()
[all …]
|
| /base/security/device_auth/test/fuzztest/authenticators/account_related/auth/isoauthtask_fuzzer/ |
| D | isoauthtask_fuzzer.cpp | 70 TaskBase *task = CreateIsoAuthServerTask(inJson, outJson, &info); in CreateServerTask() local
95 TaskBase *task = CreateIsoAuthClientTask(inJson, outJson, &info); in CreateClientTask() local
106 TaskBase *task = CreateIsoAuthTask(nullptr, nullptr, nullptr); in IsoAuthTaskTest01() local
201 TaskBase *task = CreateIsoAuthServerTask(nullptr, outJson, &info); in IsoAuthTaskTest05() local
216 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest06() local
232 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest07() local
252 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest08() local
268 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest09() local
287 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest10() local
307 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest11() local
[all …]
|
| /base/inputmethod/imf/frameworks/native/inputmethod_ability/src/ |
| D | input_method_core_service_impl.cpp | 40 auto task = std::make_shared<TaskImsaInitInputCtrlChannel>(inputControlChannel->AsObject()); in InitInputControlChannel() local
47 auto task = std::make_shared<TaskImsaShowKeyboard>(requestKeyboardReason); in ShowKeyboard() local
54 auto task = std::make_shared<TaskImsaHideKeyboard>(); in HideKeyboard() local
61 auto task = std::make_shared<TaskImsaStopInputService>(isTerminateIme); in StopInputService() local
76 auto task = std::make_shared<TaskImsaStartInput>(clientInfo, isBindFromClient); in StartInput() local
83 auto task = std::make_shared<TaskImsaOnSetSubProperty>(property); in SetSubtype() local
101 auto task = std::make_shared<TaskImsaStopInput>(channel, sessionId); in StopInput() local
119 auto task = std::make_shared<TaskImsaOnClientInactive>(channel); in OnClientInactive() local
|
| D | input_method_agent_service_impl.cpp | 47 auto task = std::make_shared<TaskImsaOnCursorUpdate>(positionX, positionY, height); in OnCursorUpdate() local
56 …auto task = std::make_shared<TaskImsaOnSelectionChange>(u16text, oldBegin, oldEnd, newBegin, newEn… in OnSelectionChange() local
70 auto task = std::make_shared<TaskImsaSendPrivateCommand>(privateCommand); in SendPrivateCommand() local
78 auto task = std::make_shared<TaskImsaAttributeChange>(attribute); in OnAttributeChange() local
97 auto task = std::make_shared<TaskImsaDiscardTypingText>(); in DiscardTypingText() local
104 auto task = std::make_shared<TaskImsaOnFunctionKey>(funcKey); in OnFunctionKey() local
|
| /base/startup/init/services/loopevent/task/ |
| D | le_task.c | 22 int CheckTaskFlags(const BaseTask *task, uint32_t flags) in CheckTaskFlags()
30 int GetSocketFd(const TaskHandle task) in GetSocketFd()
41 BaseTask *task = (BaseTask *)calloc(1, size + info->userDataSize); in CreateTask() local
56 void CloseTask(const LoopHandle loopHandle, BaseTask *task) in CloseTask()
86 int IsBufferEmpty(StreamTask *task) in IsBufferEmpty()
94 LE_Buffer *GetFirstBuffer(StreamTask *task) in GetFirstBuffer()
106 void AddBuffer(StreamTask *task, LE_Buffer *buffer) in AddBuffer()
113 LE_Buffer *GetNextBuffer(StreamTask *task, const LE_Buffer *next) in GetNextBuffer()
130 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer) in FreeBuffer()
198 BaseTask *task = (BaseTask *)taskHandle; in LE_CloseTask() local
|
| /base/request/request/services/tests/ut/task/ |
| D | ut_download.rs | 47 let task = Arc::new(RequestTask::new( in build_task() localVariable
86 let task = build_task(config); in ut_download_basic() localVariable
119 let task = build_task(config); in ut_download_resume() localVariable
154 let task = build_task(config); in ut_download_not_support_range() localVariable
187 let task = build_task(config); in ut_download_resume_not_support_range() localVariable
234 let task = build_task(config); in ut_download_not_support_range_resume() localVariable
267 let task = build_task(config); in ut_download_range_0() localVariable
299 let task = build_task(config); in ut_download_range_1() localVariable
331 let task = build_task(config); in ut_download_range_resume_0() localVariable
363 let task = build_task(config); in ut_download_range_resume_1() localVariable
[all …]
|
| /base/notification/eventhandler/test/systemtest/ems_event_runner_system_test/ |
| D | ems_event_runner_system_test.cpp | 238 auto task = []() { ; }; in __anon4cd4f5e10302() variable
257 auto task = []() { ; }; in __anon4cd4f5e10402() variable
275 auto task = []() { ; }; in __anon4cd4f5e10502() variable
293 auto task = []() { ; }; in __anon4cd4f5e10602() variable
311 auto task = []() { ; }; in __anon4cd4f5e10702() variable
329 auto task = []() { ; }; in __anon4cd4f5e10802() variable
348 auto task = []() { ; }; in __anon4cd4f5e10902() variable
366 auto task = []() { ; }; in __anon4cd4f5e10a02() variable
384 auto task = []() { ; }; in __anon4cd4f5e10b02() variable
402 auto task = []() { ; }; in __anon4cd4f5e10c02() variable
[all …]
|
| /base/request/request/frameworks/cj/ffi/src/ |
| D | cj_request_event.cpp | 65 ExceptionErrorCode CJRequestEvent::Exec(std::string execType, const CJRequestTask *task) in Exec()
75 ExceptionErrorCode CJRequestEvent::StartExec(const CJRequestTask *task) in StartExec()
98 ExceptionErrorCode CJRequestEvent::StopExec(const CJRequestTask *task) in StopExec()
103 ExceptionErrorCode CJRequestEvent::PauseExec(const CJRequestTask *task) in PauseExec()
108 ExceptionErrorCode CJRequestEvent::ResumeExec(const CJRequestTask *task) in ResumeExec()
|
| /base/hiviewdfx/hitrace/frameworks/trace_dump_executor/ |
| D | trace_dump_pipe.cpp | 135 bool HitraceDumpPipe::WriteToPipe(const int fd, const TraceDumpTask& task, const char* operation) in WriteToPipe()
146 bool HitraceDumpPipe::ReadFromPipe(const int fd, TraceDumpTask& task, const int timeoutMs, const ch… in ReadFromPipe()
181 bool HitraceDumpPipe::SubmitTraceDumpTask(const TraceDumpTask& task) in SubmitTraceDumpTask()
190 bool HitraceDumpPipe::ReadSyncDumpRet(const int timeout, TraceDumpTask& task) in ReadSyncDumpRet()
199 bool HitraceDumpPipe::ReadAsyncDumpRet(const int timeout, TraceDumpTask& task) in ReadAsyncDumpRet()
208 bool HitraceDumpPipe::ReadTraceTask(const int timeoutMs, TraceDumpTask& task) in ReadTraceTask()
217 bool HitraceDumpPipe::WriteSyncReturn(const TraceDumpTask& task) in WriteSyncReturn()
226 bool HitraceDumpPipe::WriteAsyncReturn(const TraceDumpTask& task) in WriteAsyncReturn()
|
| /base/security/device_auth/services/legacy/authenticators/src/account_related/auth/pake_v2_auth_task/ |
| D | pake_v2_auth_server_task.c | 42 static void DestroyAuthServerAuthTask(TaskBase *task) in DestroyAuthServerAuthTask()
53 static int32_t DealAsyStepOneData(PakeV2AuthServerTask *task) in DealAsyStepOneData()
115 static int32_t AsyAuthServerStepOne(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in AsyAuthServerStepOne()
155 static int32_t DealAsyStepTwoData(PakeV2AuthServerTask *task) in DealAsyStepTwoData()
164 static int32_t SendFinalToOut(PakeV2AuthServerTask *task, CJson *out) in SendFinalToOut()
213 static int32_t AsyAuthServerStepTwo(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in AsyAuthServerStepTwo()
235 static int32_t ProcessServerTask(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in ProcessServerTask()
|
| /base/update/updateservice/services/firmware/upgrade/mode/src/ |
| D | firmware_download_mode.cpp | 97 FirmwareTask task; in GetStepAfterDownload() local
132 void FirmwareDownloadMode::DownloadPauseProcess(const FirmwareTask &task, const ErrorMessage &error… in DownloadPauseProcess()
139 void FirmwareDownloadMode::DownloadFailProcess(const FirmwareTask &task, const ErrorMessage &errorM… in DownloadFailProcess()
147 void FirmwareDownloadMode::DownloadCancelProcess(const FirmwareTask &task, const ErrorMessage &erro… in DownloadCancelProcess()
164 void FirmwareDownloadMode::DownloadSucessProcess(const FirmwareTask &task, const ErrorMessage &erro… in DownloadSucessProcess()
|
| D | firmware_download_mode_empty.cpp | 40 void FirmwareDownloadMode::DownloadPauseProcess(const FirmwareTask &task, const ErrorMessage &error… in DownloadPauseProcess()
45 void FirmwareDownloadMode::DownloadFailProcess(const FirmwareTask &task, const ErrorMessage &errorM… in DownloadFailProcess()
50 void FirmwareDownloadMode::DownloadCancelProcess(const FirmwareTask &task, const ErrorMessage &erro… in DownloadCancelProcess()
55 void FirmwareDownloadMode::DownloadSucessProcess(const FirmwareTask &task, const ErrorMessage &erro… in DownloadSucessProcess()
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 28 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_()
45 BaseTask *task = (BaseTask *)signalHandle; in HandleSignalTaskClose_() local
65 static void DumpSignalTaskInfo_(const TaskHandle task) in DumpSignalTaskInfo_()
86 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); in LE_CreateSignalTask() local
102 SignalTask *task = (SignalTask *)signalHandle; in LE_AddSignal() local
124 SignalTask *task = (SignalTask *)signalHandle; in LE_RemoveSignal() local
|
| /base/security/device_auth/services/legacy/authenticators/src/account_unrelated/iso_task/ |
| D | iso_client_task.c | 23 static int GetIsoClientTaskType(const struct SubTaskBaseT *task) in GetIsoClientTaskType()
33 static void DestroyIsoClientTask(struct SubTaskBaseT *task) in DestroyIsoClientTask()
79 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process()
99 IsoClientTask *task = (IsoClientTask *)HcMalloc(sizeof(IsoClientTask), 0); in CreateIsoClientTask() local
|
| D | iso_server_task.c | 23 static int GetIsoServerTaskType(const struct SubTaskBaseT *task) in GetIsoServerTaskType()
33 static void DestroyIsoServerTask(struct SubTaskBaseT *task) in DestroyIsoServerTask()
92 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process()
113 IsoServerTask *task = (IsoServerTask *)HcMalloc(sizeof(IsoServerTask), 0); in CreateIsoServerTask() local
|
| /base/powermgr/power_manager/utils/ffrt/src/ |
| D | ffrt_utils.cpp | 21 void FFRTUtils::SubmitTask(const FFRTTask& task) in SubmitTask()
26 void FFRTUtils::SubmitTaskSync(const FFRTTask& task) in SubmitTaskSync()
37 for (auto task : tasks) { in SubmitQueueTasks() local
42 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue) in SubmitDelayTask()
50 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, std::shared_ptr<FFRTQueue> … in SubmitDelayTask()
58 bool FFRTUtils::SubmitTimeoutTask(const FFRTTask& task, uint32_t timeoutMs) in SubmitTimeoutTask()
123 void FFRTTimer::SetTimer(uint32_t timerId, FFRTTask& task, uint32_t delayMs) in SetTimer()
|
| /base/security/device_auth/services/legacy/authenticators/src/account_unrelated/pake_task/pake_v1_task/pake_v1_protocol_task/ |
| D | pake_v1_client_protocol_task.c | 37 static void DestroyPakeV1ProtocolClientTask(struct AsyBaseCurTaskT *task) in DestroyPakeV1ProtocolClientTask()
42 static int PakeRequest(AsyBaseCurTask *task, PakeParams *params, CJson *out, int *status) in PakeRequest()
147 static int PakeClientConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeClientConfirm()
191 static int PakeClientVerifyConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *… in PakeClientVerifyConfirm()
222 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
260 …PakeV1ProtocolClientTask *task = (PakeV1ProtocolClientTask *)HcMalloc(sizeof(PakeV1ProtocolClientT… in CreatePakeV1ProtocolClientTask() local
|
| /base/customization/enterprise_device_management/framework/extension/src/ |
| D | js_enterprise_admin_extension.cpp | 115 auto task = [this]() { in OnStart() local
151 auto task = [this]() { in OnAdminEnabled() local
160 auto task = [this]() { in OnAdminDisabled() local
169 auto task = [bundleName, accountId, this]() { in OnBundleAdded() local
181 auto task = [bundleName, accountId, this]() { in OnBundleRemoved() local
193 auto task = [bundleName, this]() { in OnAppStart() local
204 auto task = [bundleName, this]() { in OnAppStop() local
215 auto task = [updateInfo, this]() { in OnSystemUpdate() local
226 auto task = [accountId, this]() { in OnAccountAdded() local
237 auto task = [accountId, this]() { in OnAccountSwitched() local
[all …]
|
| /base/startup/init/services/loopevent/loop/ |
| D | le_loop.c | 29 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskKeyCompare() local
36 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskGetNodeHasCode() local
48 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskNodeFree() local
94 BaseTask *task = GetTaskByFd((EventLoop *)loop, fd); in ProcessEvent() local
103 LE_STATUS AddTask(EventLoop *loop, BaseTask *task) in AddTask()
118 BaseTask *task = NULL; in GetTaskByFd() local
129 void DelTask(EventLoop *loop, BaseTask *task) in DelTask()
|