| /base/hiviewdfx/hiview/framework/native/unified_collection/decorator/ |
| D | memory_decorator.cpp | 26 auto task = [this, &pid] { return memoryCollector_->CollectProcessMemory(pid); }; in CollectProcessMemory() local
32 auto task = [this] { return memoryCollector_->CollectSysMemory(); }; in CollectSysMemory() local
38 auto task = [this] { return memoryCollector_->CollectRawMemInfo(); }; in CollectRawMemInfo() local
44 auto task = [this] { return memoryCollector_->ExportMemView(); }; in ExportMemView() local
50 auto task = [this] { return memoryCollector_->CollectAllProcessMemory(); }; in CollectAllProcessMemory() local
55 auto task = [this] { return memoryCollector_->ExportAllProcessMemory(); }; in ExportAllProcessMemory() local
61 auto task = [this] { return memoryCollector_->CollectRawSlabInfo(); }; in CollectRawSlabInfo() local
67 auto task = [this] { return memoryCollector_->CollectRawPageTypeInfo(); }; in CollectRawPageTypeInfo() local
73 auto task = [this] { return memoryCollector_->CollectRawDMA(); }; in CollectRawDMA() local
79 auto task = [this] { return memoryCollector_->CollectAllAIProcess(); }; in CollectAllAIProcess() local
[all …]
|
| D | io_decorator.cpp | 26 auto task = [this, &pid] { return ioCollector_->CollectProcessIo(pid); }; in CollectProcessIo() local
32 auto task = [this] { return ioCollector_->CollectRawDiskStats(); }; in CollectRawDiskStats() local
39 …auto task = [this, &filter, &isUpdate] { return ioCollector_->CollectDiskStats(filter, isUpdate); … in CollectDiskStats() local
45 auto task = [this, &filter] { return ioCollector_->ExportDiskStats(filter); }; in ExportDiskStats() local
51 auto task = [this] { return ioCollector_->CollectEMMCInfo(); }; in CollectEMMCInfo() local
57 auto task = [this] { return ioCollector_->ExportEMMCInfo(); }; in ExportEMMCInfo() local
63 auto task = [this, &isUpdate] { return ioCollector_->CollectAllProcIoStats(isUpdate); }; in CollectAllProcIoStats() local
69 auto task = [this] { return ioCollector_->ExportAllProcIoStats(); }; in ExportAllProcIoStats() local
75 auto task = [this] { return ioCollector_->CollectSysIoStats(); }; in CollectSysIoStats() local
81 auto task = [this] { return ioCollector_->ExportSysIoStats(); }; in ExportSysIoStats() local
|
| D | cpu_decorator.cpp | 31 auto task = [this] { return cpuCollector_->CollectSysCpuLoad(); }; in CollectSysCpuLoad() local
41 auto task = [this, &isNeedUpdate] { return cpuCollector_->CollectSysCpuUsage(isNeedUpdate); }; in CollectSysCpuUsage() local
51 auto task = [this] { return cpuCollector_->GetSysCpuUsage(); }; in GetSysCpuUsage() local
61 …auto task = [this, &pid, &isNeedUpdate] { return cpuCollector_->CollectProcessCpuStatInfo(pid, isN… in CollectProcessCpuStatInfo() local
71 auto task = [this] { return cpuCollector_->CollectCpuFrequency(); }; in CollectCpuFrequency() local
81 …auto task = [this, &isNeedUpdate] { return cpuCollector_->CollectProcessCpuStatInfos(isNeedUpdate)… in CollectProcessCpuStatInfos() local
96 …auto task = [this, &isNeedUpdate] { return threadCpuCollector_->CollectThreadStatInfos(isNeedUpdat… in CollectThreadStatInfos() local
|
| D | mem_profiler_decorator.cpp | 26 auto task = [this] { return memProfilerCollector_->Prepare(); }; in Prepare() local
32 auto task = [this, &type, &pid, &duration, &sampleInterval] { in Start() local
41 auto task = [this, &pid] { return memProfilerCollector_->Stop(pid); }; in Stop() local
48 auto task = [this, &processName] { return memProfilerCollector_->Stop(processName); }; in Stop() local
55 auto task = [this, &fd, &type, &pid, &duration, &sampleInterval] { in Start() local
64 …auto task = [this, &fd, &pid, &type] { return memProfilerCollector_->StartPrintNmd(fd, pid, type);… in StartPrintNmd() local
71 auto task = [this, &fd, &type, &processName, &duration, &sampleInterval, &startup] { in Start() local
|
| D | perf_decorator.cpp | 26 auto task = [this, &logDir] { return perfCollector_->StartPerf(logDir); }; in StartPerf() local
97 auto task = [this, &logDir] { return perfCollector_->Prepare(logDir); }; in Prepare() local
103 auto task = [this] { return perfCollector_->StartRun(); }; in StartRun() local
109 auto task = [this] { return perfCollector_->Pause(); }; in Pause() local
115 auto task = [this] { return perfCollector_->Resume(); }; in Resume() local
121 auto task = [this] { return perfCollector_->Stop(); }; in Stop() 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/update/updateservice/services/firmware/upgrade/flow/src/ |
| D | firmware_manager.cpp | 135 FirmwareTask task; in IsIdle() local
156 FirmwareTask task; in DoCancelDownload() local
215 FirmwareTask task; in CanInstall() local
248 FirmwareTask task; in DoAutoDownloadSwitchChanged() local
268 FirmwareTask task; in DoClearError() local
301 FirmwareTask task; in HandleBootComplete() local
326 FirmwareTask task; in HandleNetChanged() local
351 void FirmwareManager::HandleBootUpdateOnStatusProcess(const FirmwareTask &task) in HandleBootUpdateOnStatusProcess()
370 void FirmwareManager::HandleBootUpdateSuccess(const FirmwareTask &task, in HandleBootUpdateSuccess()
398 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 | 68 TaskBase *task = CreateIsoAuthServerTask(inJson, outJson, &info); in CreateServerTask() local
92 TaskBase *task = CreateIsoAuthClientTask(inJson, outJson, &info); in CreateClientTask() local
103 TaskBase *task = CreateIsoAuthTask(nullptr, nullptr, nullptr); in IsoAuthTaskTest01() local
198 TaskBase *task = CreateIsoAuthServerTask(nullptr, outJson, &info); in IsoAuthTaskTest05() local
213 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest06() local
229 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest07() local
249 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest08() local
265 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest09() local
284 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest10() local
304 TaskBase *task = CreateServerTask(); in IsoAuthTaskTest11() local
[all …]
|
| /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/frameworks/cj/ffi/src/ |
| D | cj_request_event.cpp | 68 ExceptionErrorCode CJRequestEvent::Exec(std::string execType, const CJTask *task) in Exec()
78 ExceptionErrorCode CJRequestEvent::StartExec(const CJTask *task) in StartExec()
101 ExceptionErrorCode CJRequestEvent::StopExec(const CJTask *task) in StopExec()
106 ExceptionErrorCode CJRequestEvent::PauseExec(const CJTask *task) in PauseExec()
111 ExceptionErrorCode CJRequestEvent::ResumeExec(const CJTask *task) in ResumeExec()
|
| /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()
122 void FFRTTimer::SetTimer(uint32_t timerId, FFRTTask& task) in SetTimer()
132 void FFRTTimer::SetTimer(uint32_t timerId, FFRTTask& task, uint32_t delayMs) in SetTimer()
|
| /base/notification/eventhandler/test/systemtest/ems_event_runner_system_test/ |
| D | ems_event_runner_system_test.cpp | 238 auto task = []() { ; }; in __anon99d984600302() variable
257 auto task = []() { ; }; in __anon99d984600402() variable
275 auto task = []() { ; }; in __anon99d984600502() variable
293 auto task = []() { ; }; in __anon99d984600602() variable
311 auto task = []() { ; }; in __anon99d984600702() variable
329 auto task = []() { ; }; in __anon99d984600802() variable
348 auto task = []() { ; }; in __anon99d984600902() variable
366 auto task = []() { ; }; in __anon99d984600a02() variable
384 auto task = []() { ; }; in __anon99d984600b02() variable
402 auto task = []() { ; }; in __anon99d984600c02() variable
[all …]
|
| /base/update/updateservice/services/firmware/upgrade/mode/src/ |
| D | firmware_download_mode.cpp | 96 FirmwareTask task; in GetStepAfterDownload() local
131 void FirmwareDownloadMode::DownloadPauseProcess(const FirmwareTask &task, const ErrorMessage &error… in DownloadPauseProcess()
138 void FirmwareDownloadMode::DownloadFailProcess(const FirmwareTask &task, const ErrorMessage &errorM… in DownloadFailProcess()
146 void FirmwareDownloadMode::DownloadCancelProcess(const FirmwareTask &task, const ErrorMessage &erro… in DownloadCancelProcess()
163 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/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/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()
|
| D | pake_v2_auth_client_task.c | 40 static int32_t AsyAuthClientStepOne(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in AsyAuthClientStepOne()
83 static int32_t DealAsyStepTwoData(PakeV2AuthClientTask *task) in DealAsyStepTwoData()
134 static int32_t AsyAuthClientStepTwo(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in AsyAuthClientStepTwo()
186 static int32_t SendFinalToOut(PakeV2AuthClientTask *task, CJson *out) in SendFinalToOut()
211 static int32_t AsyAuthClientStepThree(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in AsyAuthClientStepThree()
230 static int32_t ProcessClientTask(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in ProcessClientTask()
268 static void DestroyAuthClientAuthTask(TaskBase *task) in DestroyAuthClientAuthTask()
|
| /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/hiviewdfx/hiview/plugins/performance/executor/ |
| D | ThrTaskContainer.cpp | 34 void ThrTaskContainer::PostTask(ITask* task) in PostTask()
52 for (auto& task: tasks) { in IsTaskOverLimit() local
69 ITask* task = tasks.front(); in Entry() local
|
| /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()
146 static int PakeClientConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeClientConfirm()
190 static int PakeClientVerifyConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *… in PakeClientVerifyConfirm()
221 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
259 …PakeV1ProtocolClientTask *task = (PakeV1ProtocolClientTask *)HcMalloc(sizeof(PakeV1ProtocolClientT… in CreatePakeV1ProtocolClientTask() local
|
| D | pake_v1_server_protocol_task.c | 36 static void DestroyPakeV1ProtocolServerTask(struct AsyBaseCurTaskT *task) in DestroyPakeV1ProtocolServerTask()
80 static int PakeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, int … in PakeResponse()
134 static int PakeServerConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeServerConfirm()
189 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
223 …PakeV1ProtocolServerTask *task = (PakeV1ProtocolServerTask *)HcMalloc(sizeof(PakeV1ProtocolServerT… in CreatePakeV1ProtocolServerTask() local
|
| /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()
|
| /base/security/device_auth/services/legacy/authenticators/src/account_unrelated/pake_task/standard_exchange_task/ |
| D | standard_client_bind_exchange_task.c | 33 static int ExchangeRequest(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, i… in ExchangeRequest()
79 static int ExchangeConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *status) in ExchangeConfirm()
114 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
148 static void DestroyStandardBindExchangeClientTask(struct AsyBaseCurTaskT *task) in DestroyStandardBindExchangeClientTask()
161 StandardBindExchangeClientTask *task = in CreateStandardBindExchangeClientTask() local
|
| D | standard_server_bind_exchange_task.c | 33 static int ExchangeStart(AsyBaseCurTask *task, PakeParams *params, CJson *out, int *status) in ExchangeStart()
65 static int ExchangeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, … in ExchangeResponse()
126 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
160 static void DestroyStandardBindExchangeServerTask(struct AsyBaseCurTaskT *task) in DestroyStandardBindExchangeServerTask()
173 StandardBindExchangeServerTask *task = in CreateStandardBindExchangeServerTask() local
|