Lines Matching refs:task
40 …uint64_t task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : Ge… in try_lock() local
41 MutexGraph::Instance().AddNode(task, 0, false); in try_lock()
42 owner.store(task, std::memory_order_relaxed); in try_lock()
51 uint64_t task; in lock() local
53 task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : GetTid(); in lock()
56 MutexGraph::Instance().AddNode(task, ownerTask, true); in lock()
58 MutexGraph::Instance().AddNode(task, 0, false); in lock()
74 owner.store(task, std::memory_order_relaxed); in lock()
82 auto task = ctx->task; in try_lock() local
83 if ((!USE_COROUTINE) || (task == nullptr)) { in try_lock()
112 taskLockNums = std::make_pair(task->gid | 0x8000000000000000, 1); in try_lock()
120 if (taskLockNums.first == (task->gid | 0x8000000000000000)) { in try_lock()
133 auto task = ctx->task; in lock() local
134 if ((!USE_COROUTINE) || (task == nullptr)) { in lock()
151 if (taskLockNums.first != (task->gid | 0x8000000000000000)) { in lock()
155 taskLockNums = std::make_pair(task->gid | 0x8000000000000000, 1); in lock()
167 auto task = ctx->task; in unlock() local
168 if ((!USE_COROUTINE) || (task == nullptr)) { in unlock()
188 if (taskLockNums.first != (task->gid | 0x8000000000000000)) { in unlock()
219 auto task = ctx->task; in wait() local
220 if (ThreadWaitMode(task)) { in wait()
228 if (FFRT_UNLIKELY(LegacyMode(task))) { in wait()
229 task->blockType = BlockType::BLOCK_THREAD; in wait()
230 ctx->wn.task = task; in wait()
236 FFRT_BLOCK_TRACER(task->gid, mtx); in wait()
237 CoWait([this](CPUEUTask* task) -> bool { in wait() argument
243 list.PushBack(task->fq_we.node); in wait()
263 CPUEUTask* task = we->task; in wake() local
264 if (ThreadNotifyMode(task) || we->weType == 2) { in wake()
267 if (BlockThread(task)) { in wake()
268 task->blockType = BlockType::BLOCK_COROUTINE; in wake()
269 we->task = nullptr; in wake()
275 CoRoutineFactory::CoWakeFunc(task, false); in wake()