| /base/startup/init_lite/services/loopevent/task/ |
| D | le_task.c | 25 int CheckTaskFlags(const BaseTask *task, uint32_t flags) in CheckTaskFlags()
33 int GetSocketFd(const TaskHandle task) in GetSocketFd()
44 BaseTask *task = (BaseTask *)malloc(size + info->userDataSize); in CreateTask() local
59 void CloseTask(const LoopHandle loopHandle, BaseTask *task) in CloseTask()
91 int IsBufferEmpty(StreamTask *task) in IsBufferEmpty()
99 LE_Buffer *GetFirstBuffer(StreamTask *task) in GetFirstBuffer()
111 void AddBuffer(StreamTask *task, LE_Buffer *buffer) in AddBuffer()
118 LE_Buffer *GetNextBuffer(StreamTask *task, const LE_Buffer *next) in GetNextBuffer()
135 void FreeBuffer(const LoopHandle loop, StreamTask *task, LE_Buffer *buffer) in FreeBuffer()
193 BaseTask *task = (BaseTask *)taskHandle; in LE_CloseTask() local
|
| /base/security/deviceauth/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/startup/init_lite/services/loopevent/signal/ |
| D | le_signal.c | 29 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_()
46 BaseTask *task = (BaseTask *)signalHandle; in HandleSignalTaskClose_() local
60 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); in LE_CreateSignalTask() local
75 SignalTask *task = (SignalTask *)signalHandle; in LE_AddSignal() local
97 SignalTask *task = (SignalTask *)signalHandle; in LE_RemoveSignal() local
|
| /base/startup/init_lite/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
98 LE_STATUS AddTask(EventLoop *loop, BaseTask *task) in AddTask()
108 BaseTask *task = NULL; in GetTaskByFd() local
119 void DelTask(EventLoop *loop, BaseTask *task) in DelTask()
|
| /base/security/deviceauth/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()
114 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
148 static void DestroyStandardUnbindExchangeClientTask(struct AsyBaseCurTaskT *task) in DestroyStandardUnbindExchangeClientTask()
161 StandardUnbindExchangeClientTask *task = in CreateStandardUnbindExchangeClientTask() local
|
| D | standard_server_unbind_exchange_task.c | 33 static int ExchangeStart(AsyBaseCurTask *task, PakeParams *params, CJson *out, int *status) in ExchangeStart()
62 static int ExchangeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, … in ExchangeResponse()
116 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
155 static void DestroyStandardUnbindExchangeServerTask(struct AsyBaseCurTaskT *task) in DestroyStandardUnbindExchangeServerTask()
168 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()
62 static int ExchangeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, … in ExchangeResponse()
123 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
157 static void DestroyStandardBindExchangeServerTask(struct AsyBaseCurTaskT *task) in DestroyStandardBindExchangeServerTask()
170 StandardBindExchangeServerTask *task = in CreateStandardBindExchangeServerTask() 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()
111 static int Process(struct AsyBaseCurTaskT *task, PakeParams *params, const CJson *in, CJson *out, i… in Process()
145 static void DestroyStandardBindExchangeClientTask(struct AsyBaseCurTaskT *task) in DestroyStandardBindExchangeClientTask()
158 StandardBindExchangeClientTask *task = in CreateStandardBindExchangeClientTask() local
|
| /base/security/deviceauth/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/deviceauth/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/deviceauth/services/ |
| D | device_auth.c | 36 static void DestroyGroupAuthTask(HcTaskBase *task) in DestroyGroupAuthTask()
42 static bool InitAuthDeviceTask(int32_t osAccountId, AuthDeviceTask *task, int64_t authReqId, CJson … in InitAuthDeviceTask()
65 static bool InitProcessDataTask(AuthDeviceTask *task, int64_t authReqId, in InitProcessDataTask()
102 AuthDeviceTask *task = (AuthDeviceTask *)HcMalloc(sizeof(AuthDeviceTask), 0); in AuthDevice() local
136 AuthDeviceTask *task = (AuthDeviceTask *)HcMalloc(sizeof(AuthDeviceTask), 0); in ProcessData() local
|
| /base/security/deviceauth/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/deviceauth/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_lite/services/loopevent/timer/ |
| D | le_timer.c | 42 static LE_STATUS HandleTimerEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleTimerEvent_()
69 BaseTask *task = (BaseTask *)taskHandle; in HandleTimerClose_() local
86 TimerTask *task = (TimerTask *)CreateTask(loopHandle, fd, &baseInfo, sizeof(TimerTask)); in LE_CreateTimer() local
102 TimerTask *task = (TimerTask *)timer; in LE_StartTimer() local
|
| /base/update/updater/services/script/threadpool/ |
| D | threadpool.cpp | 86 for (auto& task : taskQueue_) { in ~ThreadPool() local
93 void ThreadPool::AddTask(Task &&task) in AddTask()
100 void ThreadPool::AddNewTask(Task &&task) in AddNewTask()
146 void ThreadPool::RunTask(Task &&task, int32_t index) in RunTask()
|
| /base/security/deviceauth/deps_adapter/os_adapter/impl/src/ |
| D | hc_task_thread.c | 31 HcTaskWrap task; in IMPLEMENT_HC_VECTOR() local
40 static void PushTask(struct HcTaskThreadT* thread, HcTaskBase* task) in PushTask()
105 HcTaskBase* task = PopTask(thread); in TaskThreadLoop() local
|
| /base/security/deviceauth/services/authenticators/src/account_unrelated/iso_task/lite_exchange_task/ |
| D | iso_client_bind_exchange_task.c | 36 static void DestroyCreateClientBindExchangeTask(struct SymBaseCurTaskT *task) in DestroyCreateClientBindExchangeTask()
124 static int Process(struct SymBaseCurTaskT *task, IsoParams *params, const CJson *in, CJson *out, in… in Process()
156 static int ClientBindAesEncrypt(IsoClientBindExchangeTask *task, const IsoParams *params, in ClientBindAesEncrypt()
195 static int ClientBindExchangeStart(const IsoParams *params, IsoClientBindExchangeTask *task, CJson … in ClientBindExchangeStart()
239 …IsoClientBindExchangeTask *task = (IsoClientBindExchangeTask *)HcMalloc(sizeof(IsoClientBindExchan… in CreateClientBindExchangeTask() local
|
| D | iso_server_unbind_exchange_task.c | 33 static void DestroyServerUnbindExchangeTask(struct SymBaseCurTaskT *task) in DestroyServerUnbindExchangeTask()
38 static int Process(struct SymBaseCurTaskT *task, IsoParams *params, const CJson *in, CJson *out, in… in Process()
159 static int ServerUnbindExchangeStart(IsoParams *param, IsoServerUnbindExchangeTask *task, in ServerUnbindExchangeStart()
182 …IsoServerUnbindExchangeTask *task = (IsoServerUnbindExchangeTask *)HcMalloc(sizeof(IsoServerUnbind… in CreateServerUnbindExchangeTask() local
|
| D | iso_client_unbind_exchange_task.c | 31 static void DestroyClientUnbindExchangeTask(struct SymBaseCurTaskT *task) in DestroyClientUnbindExchangeTask()
36 static int Process(struct SymBaseCurTaskT *task, IsoParams *params, const CJson *in, CJson *out, in… in Process()
169 static int ClientUnbindExchangeStart(const IsoParams *params, IsoClientUnbindExchangeTask *task, CJ… in ClientUnbindExchangeStart()
202 …IsoClientUnbindExchangeTask *task = (IsoClientUnbindExchangeTask *)HcMalloc(sizeof(IsoClientUnbind… in CreateClientUnbindExchangeTask() local
|
| /base/security/deviceauth/services/group_auth/src/group_auth_manager_lite/ |
| D | group_auth_manager_lite.c | 70 void DoAuthDevice(HcTaskBase *task) in DoAuthDevice()
90 void DoProcessAuthData(HcTaskBase *task) in DoProcessAuthData()
|
| /base/security/deviceauth/services/group_auth/src/group_auth_manager/ |
| D | group_auth_manager.c | 71 void DoAuthDevice(HcTaskBase *task) in DoAuthDevice()
100 void DoProcessAuthData(HcTaskBase *task) in DoProcessAuthData()
|