28     task = ctx->task;  in TaskWithNode()
31 void WaitQueue::ThreadWait(WaitUntilEntry* wn, mutexPrivate* lk, bool legacyMode, CPUEUTask* task)  in ThreadWait()  argument
35         task->blockType = BlockType::BLOCK_THREAD;  in ThreadWait()
36         wn->task = task;  in ThreadWait()
49     const TimePoint& tp, bool legacyMode, CPUEUTask* task)  in ThreadWaitUntil()  argument
55         task->blockType = BlockType::BLOCK_THREAD;  in ThreadWaitUntil()
56         wn->task = task;  in ThreadWaitUntil()
83     CPUEUTask* task = ctx->task;  in SuspendAndWait()  local
84     if (ThreadWaitMode(task)) {  in SuspendAndWait()
85         ThreadWait(&ctx->wn, lk, LegacyMode(task), task);  in SuspendAndWait()
88     task->wue = new (std::nothrow) WaitUntilEntry(task);  in SuspendAndWait()
89     FFRT_COND_RETURN_VOID(task->wue == nullptr, "new WaitUntilEntry failed");  in SuspendAndWait()
90     FFRT_BLOCK_TRACER(task->gid, cnd);  in SuspendAndWait()
91     CoWait([&](CPUEUTask* task) -> bool {  in SuspendAndWait()  argument
93         push_back(task->wue);  in SuspendAndWait()
99     delete task->wue;  in SuspendAndWait()
100     task->wue = nullptr;  in SuspendAndWait()
129     CPUEUTask* task = ctx->task;  in SuspendAndWaitUntil()  local
130     if (ThreadWaitMode(task)) {  in SuspendAndWaitUntil()
131         return ThreadWaitUntil(&ctx->wn, lk, tp, LegacyMode(task), task);  in SuspendAndWaitUntil()
133     task->wue = new WaitUntilEntry(task);  in SuspendAndWaitUntil()
134     task->wue->hasWaitTime = true;  in SuspendAndWaitUntil()
135     task->wue->tp = tp;  in SuspendAndWaitUntil()
136     task->wue->cb = ([&](WaitEntry* we) {  in SuspendAndWaitUntil()
138         ffrt::CPUEUTask* task = wue->task;  in SuspendAndWaitUntil()  local
142         FFRT_LOGD("task(%d) time is up", task->gid);  in SuspendAndWaitUntil()
143         CoRoutineFactory::CoWakeFunc(task, true);  in SuspendAndWaitUntil()
145     FFRT_BLOCK_TRACER(task->gid, cnt);  in SuspendAndWaitUntil()
146     CoWait([&](CPUEUTask* task) -> bool {  in SuspendAndWaitUntil()  argument
147         WaitUntilEntry* we = task->wue;  in SuspendAndWaitUntil()
160             task->wakeupTimeOut = true;  in SuspendAndWaitUntil()
164     ret = task->wakeupTimeOut;  in SuspendAndWaitUntil()
165     task->wue = nullptr;  in SuspendAndWaitUntil()
166     task->wakeupTimeOut = false;  in SuspendAndWaitUntil()
212         CPUEUTask* task = we->task;  in Notify()  local
213         if (ThreadNotifyMode(task) || we->weType == 2) {  in Notify()
216             if (BlockThread(task)) {  in Notify()
217                 task->blockType = BlockType::BLOCK_COROUTINE;  in Notify()
218                 we->task = nullptr;  in Notify()
227             CoRoutineFactory::CoWakeFunc(task, false);  in Notify()