Lines Matching defs:wue
88 task->wue = new WaitUntilEntry(task);
92 push_back(task->wue);
98 delete task->wue;
99 task->wue = nullptr;
103 bool WeTimeoutProc(WaitQueue* wq, WaitUntilEntry* wue)
108 if (wue->status.load(std::memory_order_acquire) == we_status::INIT) {
109 // timeout processes wue first, cv will not be processed again. timeout is responsible for destroying wue.
110 wq->remove(wue);
111 delete wue;
112 wue = nullptr;
115 // notify is responsible for destroying wue.
116 wue->status.store(we_status::TIMEOUT_DONE, std::memory_order_release);
130 task->wue = new WaitUntilEntry(task);
131 task->wue->hasWaitTime = true;
132 task->wue->tp = tp;
133 task->wue->cb = ([&](WaitEntry* we) {
134 WaitUntilEntry* wue = static_cast<WaitUntilEntry*>(we);
135 ffrt::CPUEUTask* task = wue->task;
137 if (!WeTimeoutProc(this, wue)) {
147 WaitUntilEntry* we = task->wue;
168 task->wue = nullptr;