Home
last modified time | relevance | path

Searched refs:task (Results 1 – 25 of 203) sorted by relevance

123456789

/base/startup/init/services/loopevent/task/
Dle_task.c22 int CheckTaskFlags(const BaseTask *task, uint32_t flags) in CheckTaskFlags() argument
24 if (task == NULL) { in CheckTaskFlags()
27 return ((task->flags & flags) == flags); in CheckTaskFlags()
30 int GetSocketFd(const TaskHandle task) in GetSocketFd() argument
32 BaseTask *stream = (BaseTask *)task; in GetSocketFd()
41 BaseTask *task = (BaseTask *)calloc(1, size + info->userDataSize); in CreateTask() local
42 LE_CHECK(task != NULL, return NULL, "Failed to alloc for task"); in CreateTask()
43 HASHMAPInitNode(&task->hashNode); in CreateTask()
45 task->flags = info->flags; in CreateTask()
46 task->taskId.fd = fd; in CreateTask()
[all …]
Dle_streamtask.c131 BaseTask *task = (BaseTask *)taskHandle; in HandleStreamTaskClose_() local
132 CloseTask(loopHandle, task); in HandleStreamTaskClose_()
133 DelTask((EventLoop *)loopHandle, task); in HandleStreamTaskClose_()
134 if (task->taskId.fd > 0) { in HandleStreamTaskClose_()
135 close(task->taskId.fd); in HandleStreamTaskClose_()
172 StreamServerTask *task = (StreamServerTask *)CreateTask(loopHandle, fd, &info->baseInfo, in LE_CreateStreamServer() local
174 LE_CHECK(task != NULL, close(fd); in LE_CreateStreamServer()
176 task->base.handleEvent = HandleServerEvent_; in LE_CreateStreamServer()
177 task->base.innerClose = HandleStreamTaskClose_; in LE_CreateStreamServer()
178 task->incommingConnect = info->incommingConnect; in LE_CreateStreamServer()
[all …]
/base/security/device_auth/test/unittest/deviceauth/source/
Diso_auth_task_test.cpp72 TaskBase *task = CreateIsoAuthTask(nullptr, nullptr, nullptr); variable
73 EXPECT_EQ(task, nullptr);
82 task = CreateIsoAuthClientTask(inJson, outJson, &info);
83 EXPECT_EQ(task, nullptr);
87 task = CreateIsoAuthClientTask(inJson, outJson, &info);
88 EXPECT_EQ(task, nullptr);
92 task = CreateIsoAuthClientTask(inJson, outJson, &info);
93 EXPECT_EQ(task, nullptr);
97 task = CreateIsoAuthClientTask(inJson, outJson, &info);
98 EXPECT_EQ(task, nullptr);
[all …]
/base/startup/init/services/loopevent/signal/
Dle_signal.c27 static LE_STATUS HandleSignalEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleSignalEvent_() argument
33 ssize_t s = read(GetSocketFd(task), &fdsi, sizeof(fdsi)); in HandleSignalEvent_()
35 SignalTask *sigTask = (SignalTask *)task; in HandleSignalEvent_()
44 BaseTask *task = (BaseTask *)signalHandle; in HandleSignalTaskClose_() local
45 CloseTask(loopHandle, task); in HandleSignalTaskClose_()
46 DelTask((EventLoop *)loopHandle, task); in HandleSignalTaskClose_()
47 close(task->taskId.fd); in HandleSignalTaskClose_()
59 SignalTask *task = (SignalTask *)CreateTask(loopHandle, sfd, &info, sizeof(SignalTask)); in LE_CreateSignalTask() local
60 LE_CHECK(task != NULL, return LE_NO_MEMORY, "Failed to create task"); in LE_CreateSignalTask()
61 task->base.handleEvent = HandleSignalEvent_; in LE_CreateSignalTask()
[all …]
/base/security/device_auth/services/group_manager/src/
Dgroup_manager_common.c23 static int32_t InitGroupManagerTask(GroupManagerTask *task, GMTaskParams *taskParams, TaskFunc func) in InitGroupManagerTask() argument
25 task->base.doAction = func; in InitGroupManagerTask()
26 task->base.destroy = DestroyGroupManagerTask; in InitGroupManagerTask()
27 task->osAccountId = taskParams->osAccountId; in InitGroupManagerTask()
28 task->opCode = taskParams->opCode; in InitGroupManagerTask()
29 task->reqId = taskParams->reqId; in InitGroupManagerTask()
30 task->params = taskParams->params; in InitGroupManagerTask()
31 return BindCallbackToTask(task, taskParams->params); in InitGroupManagerTask()
47 int32_t BindCallbackToTask(GroupManagerTask *task, const CJson *jsonParams) in BindCallbackToTask() argument
54 task->cb = GetGMCallbackByAppId(appId); in BindCallbackToTask()
[all …]
/base/security/device_auth/services/authenticators/src/account_unrelated/pake_task/standard_exchange_task/
Dstandard_client_bind_exchange_task.c33 static int ExchangeRequest(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, i… in ExchangeRequest() argument
36 if (task->taskStatus != TASK_STATUS_CLIENT_BIND_EXCHANGE_BEGIN) { in ExchangeRequest()
37 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in ExchangeRequest()
41 StandardBindExchangeClientTask *realTask = (StandardBindExchangeClientTask *)task; in ExchangeRequest()
71 task->taskStatus = TASK_STATUS_CLIENT_BIND_EXCHANGE_REQUEST; in ExchangeRequest()
79 static int ExchangeConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, int *status) in ExchangeConfirm() argument
81 if (task->taskStatus < TASK_STATUS_CLIENT_BIND_EXCHANGE_REQUEST) { in ExchangeConfirm()
82 LOGE("Invalid taskStatus: %d", task->taskStatus); in ExchangeConfirm()
85 if (task->taskStatus > TASK_STATUS_CLIENT_BIND_EXCHANGE_REQUEST) { in ExchangeConfirm()
86 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in ExchangeConfirm()
[all …]
Dstandard_server_bind_exchange_task.c33 static int ExchangeStart(AsyBaseCurTask *task, PakeParams *params, CJson *out, int *status) in ExchangeStart() argument
36 if (task->taskStatus != TASK_STATUS_SERVER_BIND_EXCHANGE_BEGIN) { in ExchangeStart()
37 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in ExchangeStart()
60 task->taskStatus = TASK_STATUS_SERVER_BIND_EXCHANGE_START; in ExchangeStart()
65 static int ExchangeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, … in ExchangeResponse() argument
71 if (task->taskStatus < TASK_STATUS_SERVER_BIND_EXCHANGE_START) { in ExchangeResponse()
74 if (task->taskStatus > TASK_STATUS_SERVER_BIND_EXCHANGE_START) { in ExchangeResponse()
75 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in ExchangeResponse()
80 StandardBindExchangeServerTask *realTask = (StandardBindExchangeServerTask *)task; in ExchangeResponse()
118 task->taskStatus = TASK_STATUS_SERVER_BIND_EXCHANGE_RESPONSE; in ExchangeResponse()
[all …]
/base/security/device_auth/deps_adapter/os_adapter/impl/src/
Dhc_task_thread.c31 HcTaskWrap task; in IMPLEMENT_HC_VECTOR() local
32 HcBool ret = thread->tasks.popFront(&thread->tasks, &task); in IMPLEMENT_HC_VECTOR()
35 return task.task; in IMPLEMENT_HC_VECTOR()
40 static void PushTask(struct HcTaskThreadT* thread, HcTaskBase* task) in PushTask() argument
42 if (thread == NULL || task == NULL) { in PushTask()
48 taskWarp.task = task; in PushTask()
60 if (taskWarp->task->destroy) { in Clear()
61 taskWarp->task->destroy(taskWarp->task); in Clear()
63 HcFree(taskWarp->task); in Clear()
105 HcTaskBase* task = PopTask(thread); in TaskThreadLoop() local
[all …]
/base/startup/init/services/loopevent/timer/
Dle_timer.c41 static LE_STATUS HandleTimerEvent_(const LoopHandle loop, const TaskHandle task, uint32_t oper) in HandleTimerEvent_() argument
47 (void)read(GetSocketFd(task), &repeat, sizeof(repeat)); in HandleTimerEvent_()
48 TimerTask *timer = (TimerTask *)task; in HandleTimerEvent_()
49 int fd = GetSocketFd(task); in HandleTimerEvent_()
51 uint64_t userData = *(uint64_t *)LE_GetUserData(task); in HandleTimerEvent_()
52 timer->processTimer(task, (void *)userData); in HandleTimerEvent_()
68 BaseTask *task = (BaseTask *)taskHandle; in HandleTimerClose_() local
69 CloseTask(loopHandle, task); in HandleTimerClose_()
70 DelTask((EventLoop *)loopHandle, task); in HandleTimerClose_()
71 close(task->taskId.fd); in HandleTimerClose_()
[all …]
/base/request/request/services/service/rust/src/
Dtask_manager.rs27 use ylong_runtime::{builder::RuntimeBuilder, executor::Runtime, task::JoinHandle, time::sleep};
65 for (_, task) in app_task.iter() { in monitor_task()
68 let guard = task.status.lock().unwrap(); in monitor_task()
74 task.set_status(State::STOPPED, Reason::WaittingNetWorkOneday); in monitor_task()
75 remove_task.push(task.clone()); in monitor_task()
79 if task.conf.version == Version::API9 { in monitor_task()
82 if current_time - task.ctime > MILLISECONDS_IN_ONE_MONTH { in monitor_task()
83 task.set_status(State::STOPPED, Reason::TaskSurvivalOneMonth); in monitor_task()
84 remove_task.push(task.clone()); in monitor_task()
89 for task in remove_task.iter() { in monitor_task()
[all …]
/base/security/device_auth/services/authenticators/src/account_unrelated/iso_task/
Diso_client_task.c23 static int GetIsoClientTaskType(const struct SubTaskBaseT *task) in GetIsoClientTaskType() argument
25 IsoClientTask *realTask = (IsoClientTask *)task; in GetIsoClientTaskType()
33 static void DestroyIsoClientTask(struct SubTaskBaseT *task) in DestroyIsoClientTask() argument
35 IsoClientTask *innerTask = (IsoClientTask *)task; in DestroyIsoClientTask()
79 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process() argument
81 IsoClientTask *realTask = (IsoClientTask *)task; in Process()
99 IsoClientTask *task = (IsoClientTask *)HcMalloc(sizeof(IsoClientTask), 0); in CreateIsoClientTask() local
100 if (task == NULL) { in CreateIsoClientTask()
105 task->taskBase.getTaskType = GetIsoClientTaskType; in CreateIsoClientTask()
106 task->taskBase.destroyTask = DestroyIsoClientTask; in CreateIsoClientTask()
[all …]
Diso_server_task.c23 static int GetIsoServerTaskType(const struct SubTaskBaseT *task) in GetIsoServerTaskType() argument
25 IsoServerTask *realTask = (IsoServerTask *)task; in GetIsoServerTaskType()
33 static void DestroyIsoServerTask(struct SubTaskBaseT *task) in DestroyIsoServerTask() argument
35 IsoServerTask *innerTask = (IsoServerTask *)task; in DestroyIsoServerTask()
92 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int32_t *status) in Process() argument
94 IsoServerTask *realTask = (IsoServerTask *)task; in Process()
113 IsoServerTask *task = (IsoServerTask *)HcMalloc(sizeof(IsoServerTask), 0); in CreateIsoServerTask() local
114 if (task == NULL) { in CreateIsoServerTask()
119 task->taskBase.getTaskType = GetIsoServerTaskType; in CreateIsoServerTask()
120 task->taskBase.destroyTask = DestroyIsoServerTask; in CreateIsoServerTask()
[all …]
/base/update/updateservice/services/firmware/upgrade/flow/src/
Dfirmware_manager.cpp135 FirmwareTask task; in IsIdle() local
136 FirmwareTaskOperator().QueryTask(task); in IsIdle()
137 bool isIdle = !task.isExistTask; in IsIdle()
156 FirmwareTask task; in DoCancelDownload() local
157 FirmwareTaskOperator().QueryTask(task); in DoCancelDownload()
158 if (!task.isExistTask) { in DoCancelDownload()
214 FirmwareTask task; in CanInstall() local
216 firmwareTaskOperator.QueryTask(task); in CanInstall()
217 FIRMWARE_LOGI("check can install task.status:%{public}d", CAST_INT(task.status)); in CanInstall()
219 …return task.status == UpgradeStatus::DOWNLOAD_SUCCESS || task.status == UpgradeStatus::INSTALL_SUC… in CanInstall()
[all …]
/base/security/device_auth/services/authenticators/src/account_unrelated/pake_task/pake_v1_task/pake_v1_protocol_task/
Dpake_v1_client_protocol_task.c37 static void DestroyPakeV1ProtocolClientTask(struct AsyBaseCurTaskT *task) in DestroyPakeV1ProtocolClientTask() argument
39 HcFree(task); in DestroyPakeV1ProtocolClientTask()
42 static int PakeRequest(AsyBaseCurTask *task, PakeParams *params, CJson *out, int *status) in PakeRequest() argument
44 if (task->taskStatus != TASK_STATUS_CLIENT_PAKE_BEGIN) { in PakeRequest()
45 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in PakeRequest()
82 task->taskStatus = TASK_STATUS_CLIENT_PAKE_REQUEST; in PakeRequest()
138 static int PakeClientConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeClientConfirm() argument
141 if (task->taskStatus < TASK_STATUS_CLIENT_PAKE_REQUEST) { in PakeClientConfirm()
142 LOGE("Invalid taskStatus: %d", task->taskStatus); in PakeClientConfirm()
145 if (task->taskStatus > TASK_STATUS_CLIENT_PAKE_REQUEST) { in PakeClientConfirm()
[all …]
Dpake_v1_server_protocol_task.c36 static void DestroyPakeV1ProtocolServerTask(struct AsyBaseCurTaskT *task) in DestroyPakeV1ProtocolServerTask() argument
38 HcFree(task); in DestroyPakeV1ProtocolServerTask()
76 static int PakeResponse(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out, int … in PakeResponse() argument
79 if (task->taskStatus > TASK_STATUS_SERVER_PAKE_BEGIN) { in PakeResponse()
80 LOGI("The message is repeated, ignore it, status: %d", task->taskStatus); in PakeResponse()
121 task->taskStatus = TASK_STATUS_SERVER_PAKE_RESPONSE; in PakeResponse()
126 static int PakeServerConfirm(AsyBaseCurTask *task, PakeParams *params, const CJson *in, CJson *out,… in PakeServerConfirm() argument
129 if (task->taskStatus < TASK_STATUS_SERVER_PAKE_RESPONSE) { in PakeServerConfirm()
130 LOGE("Invalid taskStatus: %d", task->taskStatus); in PakeServerConfirm()
133 if (task->taskStatus > TASK_STATUS_SERVER_PAKE_RESPONSE) { in PakeServerConfirm()
[all …]
/base/request/request/test/unittest/js_test/requestAgentTaskTest/entry/src/main/ets/test/
DRequestOperateTask.test.ets61 * @tc.desc: Test start FOREGROUND task for callback
71 let task = await request.agent.create(context, conf);
72 await task.start(async (err) => {
74 await task.stop();
81 * @tc.desc: Test start FOREGROUND task for promise
92 let task = await request.agent.create(context, conf);
93 await task.start().then(async () => {
95 await task.stop();
105 * @tc.desc: Test start background task for callback
116 let task = await request.agent.create(context, conf);
[all …]
/base/security/device_auth/services/authenticators/src/account_related/
Daccount_task_main.c94 static void DestroyTaskT(AccountTask *task) in DestroyTaskT() argument
96 if (task == NULL) { in DestroyTaskT()
99 if (task->subTask != NULL) { in DestroyTaskT()
100 task->subTask->destroyTask(task->subTask); in DestroyTaskT()
102 HcFree(task); in DestroyTaskT()
133 static int32_t ProcessTaskT(AccountTask *task, const CJson *in, CJson *out, int32_t *status) in ProcessTaskT() argument
139 int32_t res = task->subTask->process(task->subTask, in, out, status); in ProcessTaskT()
142 int32_t operationCode = MapSubTaskTypeToOpCode(task->subTask->getTaskType()); in ProcessTaskT()
148 static int32_t NegotiateAndCreateSubTask(AccountTask *task, const CJson *in, CJson *out) in NegotiateAndCreateSubTask() argument
165 task->subTask = verInfo->createTask(in, out, verInfo); in NegotiateAndCreateSubTask()
[all …]
/base/update/updateservice/services/firmware/upgrade/data_processor/src/
Dfirmware_check_data_processor.cpp103 FirmwareTask task; in HasUndoneTask() local
104 FirmwareTaskOperator().QueryTask(task); in HasUndoneTask()
105 if (!task.isExistTask) { in HasUndoneTask()
110 FIRMWARE_LOGI("HasUndoneTask status %{public}d", task.status); in HasUndoneTask()
111 UpgradeStatus taskStatus = task.status; in HasUndoneTask()
121 FirmwareTask task; in IsUpdateOnStatus() local
122 FirmwareTaskOperator().QueryTask(task); in IsUpdateOnStatus()
123 if (!task.isExistTask) { in IsUpdateOnStatus()
128 FIRMWARE_LOGI("IsUpdateOnStatus status %{public}d", task.status); in IsUpdateOnStatus()
129 return task.status == UpgradeStatus::UPDATING; in IsUpdateOnStatus()
[all …]
/base/security/device_auth/services/authenticators/src/account_unrelated/
Ddas_task_main.c112 static void DestroyTaskT(Task *task) in DestroyTaskT() argument
114 if (task == NULL) { in DestroyTaskT()
119 FOR_EACH_HC_VECTOR(task->vec, index, ptr) { in DestroyTaskT()
122 DESTROY_HC_VECTOR(SubTaskVec, &(task->vec)); in DestroyTaskT()
123 HcFree(task); in DestroyTaskT()
126 static int ProcessMultiTask(Task *task, const CJson *in, CJson *out, int32_t *status) in ProcessMultiTask() argument
137 FOR_EACH_HC_VECTOR(task->vec, index, ptr) { in ProcessMultiTask()
170 static int NegotiateAndProcessTask(Task *task, const CJson *in, CJson *out, int32_t *status) in NegotiateAndProcessTask() argument
179 res = NegotiateVersion(&minVersionPeer, &curVersionPeer, &(task->versionInfo.curVersion)); in NegotiateAndProcessTask()
184 if (!IsVersionEqual(&(task->versionInfo.curVersion), &curVersionPeer)) { in NegotiateAndProcessTask()
[all …]
/base/security/device_auth/services/authenticators/src/account_unrelated/pake_task/pake_v1_task/
Dpake_v1_client_task.c25 static int GetPakeV1ClientTaskType(const struct SubTaskBaseT *task) in GetPakeV1ClientTaskType() argument
27 PakeV1ClientTask *realTask = (PakeV1ClientTask *)task; in GetPakeV1ClientTaskType()
35 static void DestroyPakeV1ClientTask(struct SubTaskBaseT *task) in DestroyPakeV1ClientTask() argument
37 PakeV1ClientTask *innerTask = (PakeV1ClientTask *)task; in DestroyPakeV1ClientTask()
98 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int *status) in Process() argument
100 PakeV1ClientTask *realTask = (PakeV1ClientTask *)task; in Process()
121 PakeV1ClientTask *task = (PakeV1ClientTask *)HcMalloc(sizeof(PakeV1ClientTask), 0); in CreatePakeV1ClientTask() local
122 if (task == NULL) { in CreatePakeV1ClientTask()
127 task->taskBase.getTaskType = GetPakeV1ClientTaskType; in CreatePakeV1ClientTask()
128 task->taskBase.destroyTask = DestroyPakeV1ClientTask; in CreatePakeV1ClientTask()
[all …]
Dpake_v1_server_task.c25 static int GetPakeV1ServerTaskType(const struct SubTaskBaseT *task) in GetPakeV1ServerTaskType() argument
27 PakeV1ServerTask *realTask = (PakeV1ServerTask *)task; in GetPakeV1ServerTaskType()
35 static void DestroyPakeV1ServerTask(struct SubTaskBaseT *task) in DestroyPakeV1ServerTask() argument
37 PakeV1ServerTask *innerTask = (PakeV1ServerTask *)task; in DestroyPakeV1ServerTask()
98 static int Process(struct SubTaskBaseT *task, const CJson *in, CJson *out, int *status) in Process() argument
100 PakeV1ServerTask *realTask = (PakeV1ServerTask *)task; in Process()
121 PakeV1ServerTask *task = (PakeV1ServerTask *)HcMalloc(sizeof(PakeV1ServerTask), 0); in CreatePakeV1ServerTask() local
122 if (task == NULL) { in CreatePakeV1ServerTask()
127 task->taskBase.getTaskType = GetPakeV1ServerTaskType; in CreatePakeV1ServerTask()
128 task->taskBase.destroyTask = DestroyPakeV1ServerTask; in CreatePakeV1ServerTask()
[all …]
/base/update/updateservice/services/firmware/upgrade/flow/include/
Dfirmware_manager.h58 void HandleBootInstallOnStatusProcess(FirmwareTask &task);
59 void HandleBootApplyOnStatusProcess(const FirmwareTask &task);
60 void HandleBootUpdateOnStatusProcess(const FirmwareTask &task);
61 void HandleBootDownloadOnStatusProcess(FirmwareTask &task);
62 void HandleBootDownloadPauseStatusProcess(FirmwareTask &task);
63 void HandleBootDownloadedStatusProcess(FirmwareTask &task);
64 …void HandleBootUpdateSuccess(const FirmwareTask &task, const std::map<std::string, UpdateResult> &…
65 …void HandleBootUpdateFail(const FirmwareTask &task, const std::map<std::string, UpdateResult> &res…
66 void DoAutoDownload(const FirmwareTask &task);
68 void HandleResumeDownload(FirmwareTask &task);
/base/update/updater/services/script/threadpool/
Dthreadpool.cpp69 taskQueue_[k].task.processor(threadIndex); in ThreadRun()
87 for (auto& task : taskQueue_) { in ~ThreadPool() local
88 for (auto c : task.subTaskFlag) { in ~ThreadPool()
94 void ThreadPool::AddTask(Task &&task) in AddTask() argument
97 g_threadPool->AddNewTask(std::move(task)); in AddTask()
101 void ThreadPool::AddNewTask(Task &&task) in AddNewTask() argument
108 if (task.workSize <= 1 || index < 0) { in AddNewTask()
109 for (int32_t i = 0; i < task.workSize; ++i) { in AddNewTask()
110 task.processor(i); in AddNewTask()
115 int32_t workSize = task.workSize; in AddNewTask()
[all …]
/base/startup/init/services/loopevent/loop/
Dle_loop.c29 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskKeyCompare() local
31 return (int)task->taskId.fd - taskId->taskId.fd; in TaskKeyCompare()
36 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskGetNodeHasCode() local
37 return task->taskId.fd; in TaskGetNodeHasCode()
48 BaseTask *task = HASHMAP_ENTRY(node, BaseTask, hashNode); in TaskNodeFree() local
49 CloseTask((const LoopHandle)context, task); in TaskNodeFree()
50 free(task); in TaskNodeFree()
89 BaseTask *task = GetTaskByFd((EventLoop *)loop, fd); in ProcessEvent() local
90 if (task != NULL) { in ProcessEvent()
92 task->flags |= TASK_FLAGS_INVALID; in ProcessEvent()
[all …]
/base/powermgr/power_manager/utils/ffrt/src/
Dffrt_utils.cpp20 void FFRTUtils::SubmitTask(const FFRTTask& task) in SubmitTask() argument
22 ffrt::submit(task); in SubmitTask()
25 void FFRTUtils::SubmitTaskSync(const FFRTTask& task) in SubmitTaskSync() argument
27 ffrt::submit(task); in SubmitTaskSync()
36 for (auto task : tasks) { in SubmitQueueTasks() local
37 queue.submit(task); in SubmitQueueTasks()
41 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue) in SubmitDelayTask() argument
46 return queue.submit_h(task, ffrt::task_attr().delay(us.count())); in SubmitDelayTask()
49 bool FFRTUtils::SubmitTimeoutTask(const FFRTTask& task, uint32_t timeoutMs) in SubmitTimeoutTask() argument
51 ffrt::future<void> future = ffrt::async(task); in SubmitTimeoutTask()

123456789