Lines Matching defs:cv
261 ffrt::condition_variable cv;
278 ffrt::condition_variable* cvAddr = &m.cv;
526 ffrt::condition_variable cv;
532 cv.notify_one();
541 cv.wait_for(lk, 1us);
550 cv.wait_for(lk, 1us);
557 cv.notify_one();
565 static void NotifyOneTest(ffrt::mutex& mtx, ffrt::condition_variable& cv)
573 cv.wait(lk, [&] { return flag; });
587 cv.notify_one();
596 static void WaitUntilTimeoutTest(ffrt::mutex& mtx, ffrt::condition_variable& cv)
605 EXPECT_EQ(static_cast<int>(cv.wait_until(lk, std::chrono::steady_clock::now() + 30ms)),
617 cv.notify_one();
626 static void WaitUtilFlagTest_1(ffrt::mutex& mtx, ffrt::condition_variable& cv)
637 EXPECT_TRUE(!cv.wait_until(lk, std::chrono::steady_clock::now() + 30ms, [&] { return flag; }));
647 cv.notify_one();
656 static void WaitUtilFlagTest_2(ffrt::mutex& mtx, ffrt::condition_variable& cv)
664 EXPECT_TRUE(cv.wait_until(lk, std::chrono::steady_clock::now() + 30ms, [&] { return flag; }));
675 cv.notify_one();
684 static void WaitForTest_1(ffrt::mutex& mtx, ffrt::condition_variable& cv)
692 EXPECT_EQ(static_cast<int>(cv.wait_for(lk, 30ms)), static_cast<int>(ffrt::cv_status::timeout));
703 cv.notify_one();
712 static void WaitForTest_2(ffrt::mutex& mtx, ffrt::condition_variable& cv)
721 cv.notify_one();
724 EXPECT_EQ(static_cast<int>(cv.wait_for(lk, 30ms)), static_cast<int>(ffrt::cv_status::no_timeout));
736 static void WaitForTest_3(ffrt::mutex& mtx, ffrt::condition_variable& cv)
746 EXPECT_TRUE(!cv.wait_for(lk, 30ms, [&] { return flag; }));
756 cv.notify_one();
765 static void WaitForTest_4(ffrt::mutex& mtx, ffrt::condition_variable& cv)
773 EXPECT_TRUE(cv.wait_for(lk, 30ms, [&] { return flag; }));
784 cv.notify_one();
796 ffrt::condition_variable cv;
798 NotifyOneTest(mtx, cv);
799 WaitUntilTimeoutTest(mtx, cv);
800 WaitUtilFlagTest_1(mtx, cv);
801 WaitUtilFlagTest_2(mtx, cv);
802 WaitForTest_1(mtx, cv);
803 WaitForTest_2(mtx, cv);
804 WaitForTest_3(mtx, cv);
805 WaitForTest_4(mtx, cv);