Home
last modified time | relevance | path

Searched refs:wue (Results 1 - 6 of 6) sorted by relevance

/foundation/resourceschedule/ffrt/src/sync/
H A Dwait_queue.cpp88 task->wue = new WaitUntilEntry(task); in SuspendAndWait()
92 push_back(task->wue); in SuspendAndWait()
98 delete task->wue; in SuspendAndWait()
99 task->wue = nullptr; in SuspendAndWait()
103 bool WeTimeoutProc(WaitQueue* wq, WaitUntilEntry* wue) in WeTimeoutProc() argument
108 if (wue->status.load(std::memory_order_acquire) == we_status::INIT) { in WeTimeoutProc()
109 // timeout processes wue first, cv will not be processed again. timeout is responsible for destroying wue. in WeTimeoutProc()
110 wq->remove(wue); in WeTimeoutProc()
111 delete wue; in WeTimeoutProc()
[all...]
H A Dshared_mutex.cpp135 WaitUntilEntry* wue = static_cast<WaitUntilEntry*>(we); in NotifyOne() local
136 std::unique_lock<std::mutex> lk(wue->wl); in NotifyOne()
137 wue->cv.notify_one(); in NotifyOne()
156 WaitUntilEntry* wue = static_cast<WaitUntilEntry*>(we); in NotifyAll() local
157 std::unique_lock<std::mutex> lk(wue->wl); in NotifyAll()
158 wue->cv.notify_one(); in NotifyAll()
H A Dwait_queue.h109 WaitUntilEntry *wue = pop_front(); in ReleaseAll() local
110 (void)WeNotifyProc(wue); in ReleaseAll()
151 friend bool WeTimeoutProc(WaitQueue* wq, WaitUntilEntry* wue);
H A Dmutex.cpp265 WaitUntilEntry* wue = static_cast<WaitUntilEntry*>(we); in wake() local
266 std::unique_lock lk(wue->wl); in wake()
272 wue->cv.notify_one(); in wake()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dinherit_test.cpp60 printf("cputask.wue Addr %" PRIx64 "\n", reinterpret_cast<uint64_t>(&cputask->wue)); in HWTEST_F()
/foundation/resourceschedule/ffrt/src/tm/
H A Dtask_base.h61 WaitUntilEntry* wue = nullptr; member in ffrt::CoTask

Completed in 3 milliseconds