| /frameworks/native/include/ftl/details/ |
| D | future.h | 77 std::future_status wait_for(const std::chrono::duration<Rep, Period>& timeout_duration) const {
82 return std::get<Impl>(self()).wait_for(timeout_duration);
104 std::future_status wait_for(const std::chrono::duration<Rep, Period>& timeout_duration) const {
109 return std::get<Impl>(self()).wait_for(timeout_duration);
|
| /frameworks/native/libs/ftl/ |
| D | future_test.cpp | 110 EXPECT_EQ(future.wait_for(1s), std::future_status::ready); in TEST()
111 EXPECT_EQ(future.wait_for(1s), std::future_status::ready); in TEST()
129 EXPECT_EQ(get_future.wait_for(0s), std::future_status::timeout); in TEST()
136 EXPECT_EQ(get_future.wait_for(1s), std::future_status::ready); in TEST()
|
| /frameworks/native/services/surfaceflinger/tests/unittests/ |
| D | SurfaceFlinger_NotifyPowerBoostTest.cpp | 44 auto waitForTimerReset = [&] { cv.wait_for(lock, 100ms, [&] { return didReset; }); }; in TEST_F()
45 auto waitForTimerExpired = [&] { cv.wait_for(lock, 100ms, [&] { return !didReset; }); }; in TEST_F()
|
| /frameworks/native/libs/binder/include/binder/ |
| D | RpcThreads.h | 60 std::cv_status wait_for(RpcMutexUniqueLock&, const Duration&) { in wait_for() function
65 bool wait_for(RpcMutexUniqueLock&, const Duration&, Predicate stop_waiting) { in wait_for() function
|
| /frameworks/native/services/powermanager/tests/ |
| D | IThermalManagerTest.cpp | 101 EXPECT_NE(mCallback->mCondition.wait_for(lock, 1s), std::cv_status::timeout); in SetUp()
125 EXPECT_NE(mCallback->mCondition.wait_for(lock, 1s), std::cv_status::timeout); in TEST_P()
|
| /frameworks/native/cmds/lshal/ |
| D | Timeout.h | 41 auto status = future.wait_for(wait); in timeoutIPC()
|
| /frameworks/base/libs/hwui/platform/host/thread/ |
| D | ThreadBase.h | 55 mCondition.wait_for(lock, duration); in waitForWork()
|
| /frameworks/native/services/surfaceflinger/tests/utils/ |
| D | WindowInfosListenerUtils.h | 41 bool satisfied = future.wait_for(std::chrono::seconds{5 * HwTimeoutMultiplier()}) == in waitForWindowInfosPredicate()
|
| /frameworks/native/libs/binder/ndk/tests/ |
| D | libbinder_ndk_unit_test.cpp | 570 EXPECT_TRUE(deathCv.wait_for(lockDeath, 1s, [&] { return deathReceived; })); in TEST()
574 EXPECT_TRUE(deathCv.wait_for(lockUnlink, 1s, [&] { return unlinkReceived; })); in TEST()
631 EXPECT_FALSE(deathCv.wait_for(lockDeath, 100ms, [&] { return deathReceived; })); in TEST()
637 EXPECT_TRUE(deathCv.wait_for(lockUnlink, 1s, [&] { return unlinkReceived; })); in TEST()
688 EXPECT_TRUE(deathCv.wait_for(lockDeath, 1s, [&] { return deathReceived; })); in TEST()
694 EXPECT_TRUE(deathCv.wait_for(lockUnlink, 100ms, [&] { return unlinkReceived; })); in TEST()
744 EXPECT_TRUE(unlinkCv.wait_for(lockUnlink, 5s, [&] { return unlinkReceived; })) in TEST()
930 cv.wait_for(lk, 1s, [] { return destroyed; }); in TEST()
|
| /frameworks/native/services/vibratorservice/ |
| D | VibratorCallbackScheduler.cpp | 96 mCondition.wait_for(lock, mQueue.top().getWaitForExpirationDuration()); in loop()
|
| /frameworks/native/services/inputflinger/tests/ |
| D | FakeInputDispatcherPolicy.cpp | 158 .wait_for(lock, 100ms, [this, enabled, window]() REQUIRES(mLock) { in assertSetPointerCaptureCalled()
179 if (mPointerCaptureChangedCondition.wait_for(lock, 100ms) != std::cv_status::timeout) { in assertSetPointerCaptureNotCalled()
226 if (!mFocusedDisplayNotifiedCondition.wait_for(lock, 100ms, in assertFocusedDisplayNotified()
336 condition.wait_for(lock, timeout, [&storage]() REQUIRES(mLock) { return !storage.empty(); }); in getItemFromStorageLockedInterruptible()
|
| D | FakeInputReaderPolicy.cpp | 48 mStylusGestureNotifiedCondition.wait_for(lock, WAIT_TIMEOUT, [this]() REQUIRES(mLock) { in assertStylusGestureNotified()
244 mDevicesChangedCondition.wait_for(lock, WAIT_TIMEOUT, [this]() REQUIRES(mLock) { in waitForInputDevices()
|
| /frameworks/native/services/surfaceflinger/Scheduler/tests/ |
| D | AsyncCallRecorder.h | 113 mCondition.wait_for(lock, timeout,
|
| /frameworks/av/services/oboeservice/ |
| D | AAudioCommandQueue.cpp | 65 mWaitWorkCond.wait_for(_l, std::chrono::nanoseconds(timeoutNanos), [this]() { in waitForCommand()
|
| /frameworks/native/include/input/ |
| D | BlockingQueue.h | 64 if (!mHasElements.wait_for(lock, duration, in popWithTimeout()
|
| /frameworks/av/media/libstagefright/tests/mediacodec/ |
| D | MediaCodecTest.cpp | 128 mCondition.wait_for( in waitFor()
276 reclaimCompleted.get_future().wait_for(std::chrono::seconds(5))) in TEST()
280 releaseCompleted.get_future().wait_for(std::chrono::seconds(5))) in TEST()
|
| /frameworks/native/services/vibratorservice/test/ |
| D | test_utils.h | 107 mCondVar.wait_for(lock, timeout, [&] { return mCount >= count; }); in tryWaitUntilCountIsAtLeast()
|
| /frameworks/base/media/jni/soundpool/ |
| D | SoundDecoder.cpp | 68 mQueueDataAvailable.wait_for( in run()
|
| /frameworks/native/services/sensorservice/ |
| D | SensorDeviceUtils.cpp | 160 return mCondition.wait_for(lk, std::chrono::milliseconds(TIMEOUT_MS), in wait()
|
| /frameworks/base/native/android/tests/activitymanager/nativeTests/src/ |
| D | ActivityManagerNativeTest.cpp | 46 mCondition.wait_for(lock, std::chrono::microseconds(timeoutUs)); in waitForImportance()
|
| /frameworks/av/media/tests/benchmark/src/native/common/ |
| D | BenchmarkC2Common.cpp | 85 mQueueCondition.wait_for(l, TIME_OUT); in waitOnInputConsumption()
|
| /frameworks/native/include/ftl/ |
| D | future.h | 54 using Base::wait_for;
|
| /frameworks/av/media/codec2/fuzzer/ |
| D | C2Fuzzer.cpp | 261 if (mWorkQueue.empty()) mQueueCondition.wait_for(lock, kC2FuzzerTimeOut); in decodeFrames()
300 mConditionalVariable.wait_for(waitForDecodeComplete, kC2FuzzerTimeOut, [this] { return mEos; }); in decodeFrames()
|
| /frameworks/av/media/libaaudio/tests/ |
| D | test_multiple_close_simultaneously.cpp | 135 isCompleted.cv.wait_for(completedLock, in openAndMultipleClose()
|
| /frameworks/base/tests/ChoreographerTests/jni/ |
| D | android_view_tests_ChoreographerNativeTest.cpp | 139 ASSERT(cb.condition.wait_for(cb.mutex, 2 * kMaxRuntime, [&cb] { return cb.callbacksComplete; }), in android_view_ChoreographerNativeTest_testPostVsyncCallbackAtFrameRate()
|