Home
last modified time | relevance | path

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

12345678910>>...71

/ohos5.0/foundation/resourceschedule/ffrt/src/eu/
H A Dco_routine.cpp93 if ((task->type != ffrt_normal_task) || (!task->taskLocal)) { in IsTaskLocalEnable()
200 free(task->tsd); in TaskTsdDeconstruct()
227 ffrt::CPUEUTask* task = co->task; in CoStartEntry() local
229 switch (task->type) { in CoStartEntry()
244 …FFRT_LOGE("CoStart unsupport task[%lu], type=%d, name[%s]", task->gid, task->type, task->label.c_s… in CoStartEntry()
329 task->coRoutine->task = task; in BindNewCoRoutione()
335 task->coRoutine->task = nullptr; in UnbindCoRoutione()
362 CoAlloc(task); in CoCreat()
409 FFRTTraceRecord::TaskRun(task->GetQos(), task); in CoStart()
416 FFRT_TASK_BEGIN(task->label, task->gid); in CoStart()
[all …]
H A Dcpu_worker.cpp50 switch (task->type) { in Run()
55 task->Execute(); in Run()
69 …FFRT_LOGE("run unsupport task[%lu], type=%d, name[%s]", task->gid, task->type, task->label.c_str()… in Run()
77 if (task == nullptr) { in Run()
94 func(task, qos); in Run()
128 ctx->task = task; in RunTask()
169 if (task->type == ffrt_normal_task && !task->notifyWorker_) { in GetTask()
175 return task; in GetTask()
183 return task; in GetTask()
194 return task; in GetTask()
[all …]
/ohos5.0/base/security/device_auth/test/fuzztest/authenticators/account_related/auth/isoauthtask_fuzzer/
H A Disoauthtask_fuzzer.cpp220 task->destroyTask(task); in IsoAuthTaskTest06()
240 task->destroyTask(task); in IsoAuthTaskTest07()
256 task->destroyTask(task); in IsoAuthTaskTest08()
275 task->destroyTask(task); in IsoAuthTaskTest09()
295 task->destroyTask(task); in IsoAuthTaskTest10()
313 task->destroyTask(task); in IsoAuthTaskTest11()
331 task->destroyTask(task); in IsoAuthTaskTest12()
349 task->destroyTask(task); in IsoAuthTaskTest13()
367 task->destroyTask(task); in IsoAuthTaskTest14()
385 task->destroyTask(task); in IsoAuthTaskTest15()
[all …]
/ohos5.0/base/security/device_auth/test/unittest/deviceauth/source/
H A Diso_auth_task_test.cpp277 task->destroyTask(task);
304 task->destroyTask(task);
328 task->destroyTask(task);
353 task->destroyTask(task);
379 task->destroyTask(task);
403 task->destroyTask(task);
427 task->destroyTask(task);
451 task->destroyTask(task);
475 task->destroyTask(task);
499 task->destroyTask(task);
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/components/custom_paint/
H A Dcustom_paint_component.cpp53 PushTask(task); in TransferFromImageBitmap()
62 PushTask(task); in DrawBitmapMesh()
88 PushTask(task); in WebGLUpdate()
94 PushTask(task); in SetAntiAlias()
100 PushTask(task); in FillRect()
106 PushTask(task); in StrokeRect()
112 PushTask(task); in ClearRect()
120 PushTask(task); in FillText()
128 PushTask(task); in StrokeText()
567 auto task = in UpdateSmoothingEnabled() local
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/sync/
H A Dwait_queue.cpp28 task = ctx->task; in TaskWithNode()
36 wn->task = task; in ThreadWait()
56 wn->task = task; in ThreadWaitUntil()
83 CPUEUTask* task = ctx->task; in SuspendAndWait() local
85 ThreadWait(&ctx->wn, lk, LegacyMode(task), task); in SuspendAndWait()
88 task->wue = new (std::nothrow) WaitUntilEntry(task); in SuspendAndWait()
99 delete task->wue; in SuspendAndWait()
129 CPUEUTask* task = ctx->task; in SuspendAndWaitUntil() local
133 task->wue = new WaitUntilEntry(task); in SuspendAndWaitUntil()
138 ffrt::CPUEUTask* task = wue->task; in SuspendAndWaitUntil() local
[all …]
H A Dmutex.cpp40 …uint64_t task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : Ge… in try_lock() local
51 uint64_t task; in lock() local
53 task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : GetTid(); in lock()
82 auto task = ctx->task; in try_lock() local
133 auto task = ctx->task; in lock() local
167 auto task = ctx->task; in unlock() local
219 auto task = ctx->task; in wait() local
220 if (ThreadWaitMode(task)) { in wait()
230 ctx->wn.task = task; in wait()
263 CPUEUTask* task = we->task; in wake() local
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/dm/
H A Dsdependence_manager.cpp90 …auto parent = (ctx->task && ctx->task->type == ffrt_normal_task) ? ctx->task : DependenceManager::… in onSubmit()
120 task->IncDeleteRef(); in onSubmit()
124 task->SetQos(qos); in onSubmit()
128 task->IncChildRef(); in onSubmit()
171 …auto baseTask = (ctx->task && ctx->task->type == ffrt_normal_task) ? ctx->task : DependenceManager… in onWait()
177 FFRT_LOGD("onWait name:%s gid=%lu", task->label.c_str(), task->gid); in onWait()
181 task->waitCond_.wait(lck, [task] { return task->childRefCnt == 0; }); in onWait()
206 …auto baseTask = (ctx->task && ctx->task->type == ffrt_normal_task) ? ctx->task : DependenceManager… in onWait()
244 FFRT_LOGD("onWait name:%s gid=%lu", task->label.c_str(), task->gid); in onWait()
248 task->waitCond_.wait(lck, [task] { return task->dataRefCnt.waitDep == 0; }); in onWait()
[all …]
/ohos5.0/base/startup/appspawn/test/moduletest/threadpool/
H A Dthread_manager.c61 TaskNode *task; member
112 task->taskId, mgr->executorCount, executor->task->taskId); in AddExecutor()
174 free(task); in DeleteTask()
188 return task; in PopTask()
227 if (task == NULL) { in ExecuteTask()
243 if (task->totalTask <= atomic_load(&task->finishTaskCount)) { in CheckTaskComplete()
245 task->finishProcess(task->taskId, task->context); in CheckTaskComplete()
262 DeleteTask(task); in TaskQueueDestroyProc()
374 node->task = task; in ThreadMgrAddExecutor()
379 task->totalTask++; in ThreadMgrAddExecutor()
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dtaskpool.cpp207 if (task == nullptr || !task->IsLongTask()) { in TerminateTask()
275 TaskManager::GetInstance().StoreTask(task->taskId_, task); in Execute()
342 if (!task->IsExecuted() || task->taskState_ == ExecuteState::CANCELED || in ExecuteDelayed()
460 napi_delete_serialization_data(task->env_, task->result_); in HandleTaskResultCallback()
485 UpdateGroupInfoByResult(task->env_, task, napiTaskResult, success); in HandleTaskResultCallback()
501 TriggerTask(task); in HandleTaskResultCallback()
511 TaskManager::GetInstance().DecreaseRefCount(task->env_, task->taskId_); in TriggerTask()
526 napi_reference_unref(task->env_, task->taskRef_, nullptr); in TriggerTask()
530 delete task; in TriggerTask()
694 TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, task->periodicTaskPriority_); in PeriodicTaskCallback()
[all …]
H A Dworker.cpp146 task(); in HandleDebuggerTask()
383 if (task == nullptr) { in PerformTask()
386 } else if (!task->IsValid() && task->ShouldDeleteTask(false)) { in PerformTask()
388 delete task; in PerformTask()
401 if (task->IsLongTask()) { in PerformTask()
432 delete task; in PerformTask()
439 task->DecreaseRefCount(); in PerformTask()
485 delete task; in NotifyHandleTaskResult()
510 task->DecreaseRefCount(); in TaskResultCallback()
513 uint64_t ioDuration = task->ioTime_ - task->startTime_; in TaskResultCallback()
[all …]
/ohos5.0/foundation/communication/netstack/test/unittest/http_client/
H A DHttpClientTaskTest.cpp113 bool result = task->SetOtherCurlOption(task->curlHandle_);
133 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
152 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
172 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
193 EXPECT_TRUE(task->SetOtherCurlOption(task->curlHandle_));
210 EXPECT_TRUE(task->SetUploadOptions(task->curlHandle_));
225 EXPECT_FALSE(task->SetUploadOptions(task->curlHandle_));
240 EXPECT_FALSE(task->SetUploadOptions(task->curlHandle_));
404 task->OnFail(
642 task->OnFail(
[all …]
/ohos5.0/base/startup/init/services/loopevent/task/
H A Dle_task.c24 if (task == NULL) { in CheckTaskFlags()
45 task->flags = info->flags; in CreateTask()
46 task->taskId.fd = fd; in CreateTask()
51 task->userDataOffset = size; in CreateTask()
52 task->close = info->close; in CreateTask()
53 return task; in CreateTask()
69 if (task->close != NULL) { in CloseTask()
70 task->close((TaskHandle)task); in CloseTask()
88 LoopMutexLock(&task->mutex); in IsBufferEmpty()
133 if (task == NULL) { in FreeBuffer()
[all …]
/ohos5.0/docs/en/device-dev/kernel/
H A Dkernel-small-basic-process-thread.md16 …er-priority task can preempt resources of a lower-priority task. The lower-priority task can be sc…
24 - Running: The task is running.
32 ![](figures/task-state-transition.png "task-state-transition")
74 …| Creates a task. If the priority of the created task is higher than that of the task in running a…
76 | LOS_TaskDelete | Deletes a task and reclaims the resources consumed by the task control block…
138 …task is complete. If the task attribute is **LOS_TASK_STATUS_DETACHED**, the task resources are au…
161 …/* Delay the task for 2 ticks. The task is suspended, and the remaining task with the highest prio…
169 /* Suspend the task. */
184 …/* Delay the task for 2 ticks. The task is suspended, and the remaining task with the highest prio…
216 …/* Create a task with higher priority. The task will not be executed immediately after being creat…
[all …]
H A Dkernel-mini-basic-task.md12 - A task represents a thread.
41 ![](figures/task-state-transitions.png "task-state-transitions")
55 …task is recovered (for example, the task is resumed, the delay period or semaphore read period tim…
71 A task ID is returned when a task is created. The task ID uniquely identifies a task in the system.…
91 …task has a task control block (TCB). A TCB contains task information, such as context stack pointe…
111 …task| **LOS_TaskCreateOnly**: creates a task and places the task in the Blocked state.<br>**LOS_Ta…
141 > - A running task cannot be suspended if task scheduling is locked.
149 > - Locking task scheduling must be used together with unlocking task scheduling.
193 /* Suspend the task. */
210 …/* Delay the task for 100 ticks. The task is then suspended, and the remaining task with the highe…
[all …]
/ohos5.0/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.cpp331 task->taskId_ = reinterpret_cast<uint64_t>(task); in CancelTask()
335 taskManager.StoreTask(task->taskId_, task); in CancelTask()
383 taskManager.StoreTask(task->taskId_, task); in EnqueueTaskId()
404 taskManager.StoreTask(task->taskId_, task); in GetTaskByPriority()
569 taskManager.StoreTask(task->taskId_, task); in ReleaseTaskData()
572 taskManager.StoreTask(task->taskId_, task); in ReleaseTaskData()
577 taskManager.StoreTask(task->taskId_, task); in ReleaseTaskData()
604 taskManager.StoreTask(task->taskId_, task); in CheckTask()
655 taskManager.StoreTask(task->taskId_, task); in CancelGroupTask()
810 taskManager.StoreTask(task->taskId_, task); in PerformTask()
[all …]
/ohos5.0/base/startup/init/services/loopevent/signal/
H A Dle_signal.c47 CloseTask(loopHandle, task); in HandleSignalTaskClose_()
48 close(task->taskId.fd); in HandleSignalTaskClose_()
67 INIT_CHECK(task != NULL, return); in DumpSignalTaskInfo_()
91 task->sigNumber = 0; in LE_CreateSignalTask()
92 sigemptyset(&task->mask); in LE_CreateSignalTask()
107 sigaddset(&task->mask, signal); in LE_AddSignal()
111 if (task->sigNumber == 0) { in LE_AddSignal()
116 task->sigNumber++; in LE_AddSignal()
129 sigdelset(&task->mask, signal); in LE_RemoveSignal()
130 task->sigNumber--; in LE_RemoveSignal()
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/base/thread/
H A Dtask_executor.h170 if (!task || type == TaskType::BACKGROUND) {
173 task();
191 if (!task || type == TaskType::BACKGROUND) { in PostSyncTaskTimeout()
194 task(); in PostSyncTaskTimeout()
212 return PostSyncTask(Task(task), type, name); in PostSyncTask()
226 if (!task || type == TaskType::BACKGROUND) { in PostSyncTask()
229 CancelableTask avatar(task); in PostSyncTask()
230 task(); in PostSyncTask()
310 … result = OnPostTask(Task(task), type, 0, name, priorityType) && task.WaitUntilComplete(timeoutMs);
315 … return OnPostTask(Task(task), type, 0, name, priorityType) && task.WaitUntilComplete(timeoutMs);
[all …]
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/canvas/
H A Dcanvas_pattern.cpp185 paintMethod_->PushTask(task); in SetAntiAlias()
197 paintMethod_->PushTask(task); in FillRect()
209 paintMethod_->PushTask(task); in StrokeRect()
221 paintMethod_->PushTask(task); in ClearRect()
233 paintMethod_->PushTask(task); in Fill()
245 paintMethod_->PushTask(task); in Fill()
257 paintMethod_->PushTask(task); in Stroke()
269 paintMethod_->PushTask(task); in Stroke()
281 paintMethod_->PushTask(task); in Clip()
293 paintMethod_->PushTask(task); in Clip()
[all …]
/ohos5.0/base/hiviewdfx/hiview/framework/native/unified_collection/decorator/
H A Dmemory_decorator.cpp32 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
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
85 auto task = [this] { return memoryCollector_->ExportAllAIProcess(); }; in ExportAllAIProcess() local
109 auto task = [this] { return memoryCollector_->CollectMemoryLimit(); }; in CollectMemoryLimit() local
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dqueue_handler.cpp125 if (task->GetQos() == qos_inherit || task->GetQos() == qos_default) { in Submit()
126 task->SetQos(qos_); in Submit()
131 FFRTTraceRecord::TaskSubmit(&(task->createTime), &(task->fromTid)); in Submit()
212 FFRT_LOGD("cancel task[%llu] %s succ", task->gid, task->label.c_str()); in Cancel()
213 task->Notify(); in Cancel()
214 task->Destroy(); in Cancel()
224 for (QueueTask* task = inTask; task != nullptr; task = nextTask) { in Dispatch() local
246 FFRTTraceRecord::TaskDone<ffrt_queue_task>(task->GetQos(), task); in Dispatch()
254 task->Notify(); in Dispatch()
309 task->IncDeleteRef(); in SetTimeoutMonitor()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/
H A Dsys_epoll.c26 if (task == NULL) { in RefreshEpollTask()
29 event.data.ptr = task; in RefreshEpollTask()
32 if (epoll_ctl(task->epollfd, EPOLL_CTL_MOD, task->taskfd, &event) < 0) { in RefreshEpollTask()
43 if (task == NULL) { in RegisterEpollTask()
46 event.data.ptr = task; in RegisterEpollTask()
48 if (epoll_ctl(task->epollfd, EPOLL_CTL_ADD, task->taskfd, &event) < 0) { in RegisterEpollTask()
57 if (task == NULL) { in DeRegisterEpollTask()
60 if (epoll_ctl(task->epollfd, EPOLL_CTL_DEL, task->taskfd, NULL) < 0) { in DeRegisterEpollTask()
76 EpollTask *task = NULL; in EpollLoop() local
97 task->readHandle(task); in EpollLoop()
[all …]
/ohos5.0/base/request/request/services/src/task/
H A Ddownload.rs18 use std::task::{Context, Poll};
28 use crate::task::info::State;
58 task: Arc<RequestTask>, in build_downloader()
113 task: Arc<RequestTask>, in download_inner()
120 task.prepare_download().await?; in download_inner()
207 task.get_file_info(&response)?; in download_inner()
210 .update_task_sizes(task.task_id(), &task.progress.lock().unwrap().sizes); in download_inner()
215 task.task_id(), in download_inner()
227 check_file_exist(&task)?; in download_inner()
241 let config = task.config(); in check_file_exist()
[all …]
H A Dupload.rs19 use std::task::{Context, Poll};
43 task, in new()
58 .task in poll_read()
141 task: Arc<RequestTask>, in build_stream_request()
176 task: Arc<RequestTask>, in build_multipart_request()
220 task: &Arc<RequestTask>, in build_request_common()
277 .update_task_sizes(task.task_id(), &task.progress.lock().unwrap().sizes); in upload()
304 task: Arc<RequestTask>, in upload_inner()
312 task.task_id(), in upload_inner()
356 task: Arc<RequestTask>, in upload_one_file()
[all …]
/ohos5.0/foundation/resourceschedule/ffrt/src/core/
H A Dtask_io.cpp34 task->status = ExecTaskStatus::ET_FINISH; in work_finish_callable()
35 task->work.destroy(task->work.data); in work_finish_callable()
36 delete task; in work_finish_callable()
47 FFRT_EXECUTOR_TASK_FINISH_MARKER(task); in ExecuteIOTask()
48 work_finish_callable(task); in ExecuteIOTask()
52 FFRT_EXECUTOR_TASK_BLOCK_MARKER(task); in ExecuteIOTask()
85 task->work.exec = exec;
86 task->work.destroy = destroy;
87 task->work.data = co;
101 void ffrt_wake_coroutine(void* task)
[all …]

12345678910>>...71