| /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 *)malloc(size + info->userDataSize); in CreateTask() local
56 void CloseTask(const LoopHandle loopHandle, BaseTask *task) in CloseTask()
87 int IsBufferEmpty(StreamTask *task) in IsBufferEmpty()
95 LE_Buffer *GetFirstBuffer(StreamTask *task) in GetFirstBuffer()
107 void AddBuffer(StreamTask *task, LE_Buffer *buffer) in AddBuffer()
114 LE_Buffer *GetNextBuffer(StreamTask *task, const LE_Buffer *next) in GetNextBuffer()
131 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer) in FreeBuffer()
193 BaseTask *task = (BaseTask *)taskHandle; in LE_CloseTask() local
|
| /base/security/device_auth/services/ |
| D | device_auth.c | 35 static void DestroyGroupAuthTask(HcTaskBase *task) in DestroyGroupAuthTask()
41 static bool InitAuthDeviceTask(int32_t osAccountId, AuthDeviceTask *task, int64_t authReqId, CJson … in InitAuthDeviceTask()
64 static bool InitProcessDataTask(AuthDeviceTask *task, int64_t authReqId, in InitProcessDataTask()
101 AuthDeviceTask *task = (AuthDeviceTask *)HcMalloc(sizeof(AuthDeviceTask), 0); in AuthDevice() local
135 AuthDeviceTask *task = (AuthDeviceTask *)HcMalloc(sizeof(AuthDeviceTask), 0); in ProcessData() local
156 static void DoCancelAuthRequest(HcTaskBase *task) in DoCancelAuthRequest()
166 static void DestroyAuthCancelTask(HcTaskBase *task) in DestroyAuthCancelTask()
193 AuthCancelTask *task = (AuthCancelTask *)HcMalloc(sizeof(AuthCancelTask), 0); in CancelAuthRequest() local
|
| /base/security/device_auth/services/authenticators/src/account_unrelated/iso_task/ |
| D | iso_client_task.c | 24 static int GetIsoClientTaskType(const struct SubTaskBaseT *task) in GetIsoClientTaskType()
34 static void DestroyIsoClientTask(struct SubTaskBaseT *task) in DestroyIsoClientTask()
93 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process()
113 IsoClientTask *task = (IsoClientTask *)HcMalloc(sizeof(IsoClientTask), 0); in CreateIsoClientTask() local
|
| D | iso_server_task.c | 24 static int GetIsoServerTaskType(const struct SubTaskBaseT *task) in GetIsoServerTaskType()
34 static void DestroyIsoServerTask(struct SubTaskBaseT *task) in DestroyIsoServerTask()
100 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process()
121 IsoServerTask *task = (IsoServerTask *)HcMalloc(sizeof(IsoServerTask), 0); in CreateIsoServerTask() local
|
| /base/notification/eventhandler/test/systemtest/ems_event_runner_system_test/ |
| D | ems_event_runner_system_test.cpp | 238 auto task = []() { ; }; in __anon2a210be00302() variable
257 auto task = []() { ; }; in __anon2a210be00402() variable
275 auto task = []() { ; }; in __anon2a210be00502() variable
293 auto task = []() { ; }; in __anon2a210be00602() variable
311 auto task = []() { ; }; in __anon2a210be00702() variable
329 auto task = []() { ; }; in __anon2a210be00802() variable
348 auto task = []() { ; }; in __anon2a210be00902() variable
366 auto task = []() { ; }; in __anon2a210be00a02() variable
384 auto task = []() { ; }; in __anon2a210be00b02() variable
402 auto task = []() { ; }; in __anon2a210be00c02() variable
[all …]
|
| /base/startup/init/services/loopevent/signal/ |
| D | le_signal.c | 27 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_()
44 BaseTask *task = (BaseTask *)signalHandle; in HandleSignalTaskClose_() local
58 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); in LE_CreateSignalTask() local
73 SignalTask *task = (SignalTask *)signalHandle; in LE_AddSignal() local
95 SignalTask *task = (SignalTask *)signalHandle; in LE_RemoveSignal() local
|
| /base/hiviewdfx/hicollie/frameworks/native/ |
| D | watchdog_inner.cpp | 67 void WatchdogInner::RunOneShotTask(const std::string& name, Task&& task, uint64_t delay) in RunOneShotTask()
82 void WatchdogInner::RunPeriodicalTask(const std::string& name, Task&& task, uint64_t interval, uint… in RunPeriodicalTask()
117 bool WatchdogInner::InsertWatchdogTaskLocked(const std::string& name, WatchdogTask&& task) in InsertWatchdogTaskLocked()
153 uint64_t WatchdogInner::FetchNextTask(uint64_t now, WatchdogTask& task) in FetchNextTask()
177 void WatchdogInner::ReInsertTaskIfNeed(WatchdogTask& task) in ReInsertTaskIfNeed()
194 WatchdogTask task; in Start() 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
88 BaseTask *task = GetTaskByFd((EventLoop *)loop, fd); in ProcessEvent() local
100 LE_STATUS AddTask(EventLoop *loop, BaseTask *task) in AddTask()
110 BaseTask *task = NULL; in GetTaskByFd() local
121 void DelTask(EventLoop *loop, BaseTask *task) in DelTask()
|
| /base/security/device_auth/services/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, const CJson *in) 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/security/device_auth/services/group_manager/src/ |
| D | group_manager_common.c | 23 static int32_t InitGroupManagerTask(GroupManagerTask *task, GMTaskParams *taskParams, TaskFunc func) in InitGroupManagerTask()
47 int32_t BindCallbackToTask(GroupManagerTask *task, const CJson *jsonParams) in BindCallbackToTask()
62 void DestroyGroupManagerTask(HcTaskBase *task) in DestroyGroupManagerTask()
82 GroupManagerTask *task = (GroupManagerTask *)HcMalloc(sizeof(GroupManagerTask), 0); in InitAndPushGMTask() local
|
| /base/security/device_auth/services/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()
138 static int PakeClientConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeClientConfirm()
182 static int PakeClientVerifyConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *… in PakeClientVerifyConfirm()
213 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
251 …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()
76 static int PakeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, int … in PakeResponse()
126 static int PakeServerConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeServerConfirm()
181 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
215 …PakeV1ProtocolServerTask *task = (PakeV1ProtocolServerTask *)HcMalloc(sizeof(PakeV1ProtocolServerT… in CreatePakeV1ProtocolServerTask() local
|
| /base/security/device_auth/services/authenticators/src/account_unrelated/pake_task/standard_exchange_task/ |
| D | standard_client_unbind_exchange_task.c | 33 static int ExchangeRequest(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, i… in ExchangeRequest()
82 static int ExchangeConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *status) in ExchangeConfirm()
117 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
151 static void DestroyStandardUnbindExchangeClientTask(struct AsyBaseCurTaskT *task) in DestroyStandardUnbindExchangeClientTask()
164 StandardUnbindExchangeClientTask *task = in CreateStandardUnbindExchangeClientTask() local
|
| 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_unbind_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()
119 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
158 static void DestroyStandardUnbindExchangeServerTask(struct AsyBaseCurTaskT *task) in DestroyStandardUnbindExchangeServerTask()
171 StandardUnbindExchangeServerTask *task = in CreateStandardUnbindExchangeServerTask() 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
|
| /base/security/device_auth/services/authenticators/src/account_unrelated/pake_task/pake_v1_task/ |
| D | pake_v1_client_task.c | 26 static int GetPakeV1ClientTaskType(const struct SubTaskBaseT *task) in GetPakeV1ClientTaskType()
36 static void DestroyPakeV1ClientTask(struct SubTaskBaseT *task) in DestroyPakeV1ClientTask()
121 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int *status) in Process()
144 PakeV1ClientTask *task = (PakeV1ClientTask *)HcMalloc(sizeof(PakeV1ClientTask), 0); in CreatePakeV1ClientTask() local
|
| D | pake_v1_server_task.c | 26 static int GetPakeV1ServerTaskType(const struct SubTaskBaseT *task) in GetPakeV1ServerTaskType()
36 static void DestroyPakeV1ServerTask(struct SubTaskBaseT *task) in DestroyPakeV1ServerTask()
121 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int *status) in Process()
144 PakeV1ServerTask *task = (PakeV1ServerTask *)HcMalloc(sizeof(PakeV1ServerTask), 0); in CreatePakeV1ServerTask() local
|
| /base/security/device_auth/services/authenticators/src/account_unrelated/iso_task/iso_protocol_task/ |
| D | iso_client_protocol_task.c | 36 static void DestroyProtocolClientTask(struct SymBaseCurTaskT *task) in DestroyProtocolClientTask()
80 static int IsoClientStart(SymBaseCurTask *task, IsoParams *params, CJson *out, int32_t *status) in IsoClientStart()
152 static int CalculateTokenClient(SymBaseCurTask *task, IsoParams *params, const CJson *in, CJson *ou… in CalculateTokenClient()
202 static int GenerateSessionKey(SymBaseCurTask *task, IsoParams *params, const CJson *in, int32_t *st… in GenerateSessionKey()
241 static int Process(struct SymBaseCurTaskT *task, IsoParams *params, const CJson *in, CJson *out, in… in Process()
279 … IsoProtocolClientTask *task = (IsoProtocolClientTask *)HcMalloc(sizeof(IsoProtocolClientTask), 0); in CreateProtocolClientTask() local
|
| D | iso_server_protocol_task.c | 37 static void DestroyProtocolServerTask(struct SymBaseCurTaskT *task) in DestroyProtocolServerTask()
75 static int IsoServerStart(SymBaseCurTask *task, IsoParams *params, const CJson *in, CJson *out, int… in IsoServerStart()
154 static int CalTokenAndGenSessionKey(SymBaseCurTask *task, IsoParams *params, const CJson *in, CJson… in CalTokenAndGenSessionKey()
211 static int Process(struct SymBaseCurTaskT *task, IsoParams *params, const CJson *in, CJson *out, in… in Process()
244 … IsoProtocolServerTask *task = (IsoProtocolServerTask *)HcMalloc(sizeof(IsoProtocolServerTask), 0); in CreateProtocolServerTask() local
|
| /base/startup/init/services/loopevent/timer/ |
| D | le_timer.c | 41 static LE_STATUS HandleTimerEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleTimerEvent_()
68 BaseTask *task = (BaseTask *)taskHandle; in HandleTimerClose_() local
85 TimerTask *task = (TimerTask *)CreateTask(loopHandle, fd, &baseInfo, sizeof(TimerTask)); in LE_CreateTimer() local
101 TimerTask *task = (TimerTask *)timer; in LE_StartTimer() local
|
| /base/security/device_auth/services/authenticators/src/account_related/auth/iso_auth_task/ |
| D | iso_auth_client_task.c | 133 static int32_t IsoAuthClientBegin(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in IsoAuthClientBegin()
236 static int32_t IsoAuthClientGetToken(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in IsoAuthClientGetToken()
283 static int32_t IsoAuthClientGetSessionKey(TaskBase *task, const CJson *in, CJson *out, int32_t *sta… in IsoAuthClientGetSessionKey()
321 static int32_t ProcessClientTask(TaskBase *task, const CJson *in, CJson *out, int32_t *status) in ProcessClientTask()
353 static void DestroyAuthClientAuthTask(TaskBase *task) in DestroyAuthClientAuthTask()
369 IsoAuthClientTask *task = (IsoAuthClientTask *)HcMalloc(sizeof(IsoAuthClientTask), 0); in CreateIsoAuthClientTask() local
|
| /base/update/updater/services/script/threadpool/ |
| D | threadpool.cpp | 84 for (auto& task : taskQueue_) { in ~ThreadPool() local
91 void ThreadPool::AddTask(Task &&task) in AddTask()
98 void ThreadPool::AddNewTask(Task &&task) in AddNewTask()
144 void ThreadPool::RunTask(Task &&task, int32_t index) in RunTask()
|
| /base/security/device_auth/services/authenticators/src/account_related/ |
| D | account_task_main.c | 94 static void DestroyTaskT(AccountTask *task) in DestroyTaskT()
133 static int32_t ProcessTaskT(AccountTask *task, const CJson *in, CJson *out, int32_t *status) in ProcessTaskT()
148 static int32_t NegotiateAndCreateSubTask(AccountTask *task, const CJson *in, CJson *out) in NegotiateAndCreateSubTask()
195 AccountTask *task = (AccountTask *)HcMalloc(sizeof(AccountTask), 0); in CreateAccountTaskT() local
|