Home
last modified time | relevance | path

Searched refs:lk (Results 1 – 25 of 34) sorted by relevance

12

/packages/modules/Bluetooth/tools/rootcanal/test/
Dposix_socket_unittest.cc95 std::unique_lock<std::mutex> lk(m); in connectPair() local
97 cv.wait_for(lk, timeout, [&] { return sock1.get() != nullptr; })); in connectPair()
210 std::unique_lock<std::mutex> lk(m); in TEST_F() local
213 ASSERT_TRUE(cv.wait_for(lk, 250ms, [&] { return received; })); in TEST_F()
259 std::unique_lock<std::mutex> lk(m); in TEST_F() local
260 ASSERT_TRUE(cv.wait_for(lk, 250ms, [&] { return connected; })); in TEST_F()
287 std::unique_lock<std::mutex> lk(m); in TEST_F() local
288 ASSERT_TRUE(cv.wait_for(lk, 250ms, [&] { return connected; })); in TEST_F()
300 std::unique_lock<std::mutex> lk(m); in TEST_F() local
303 ASSERT_FALSE(cv.wait_for(lk, 250ms, [&] { return connected; })); in TEST_F()
Dasync_manager_unittest.cc43 std::unique_lock<std::mutex> lk(m_); in set() local
51 std::unique_lock<std::mutex> lk(m_); in wait_for() local
52 return cv_.wait_for(lk, timeout, [&] { return set_; }); in wait_for()
/packages/services/Car/cpp/computepipe/runner/debug_display_manager/
DEvsDisplayManager.cpp74 std::lock_guard<std::mutex> lk(mLock); in stopThread() local
118 std::unique_lock<std::mutex> lk(mLock); in threadFn() local
120 mWait.wait(lk, [this]() { return mNextFrame != nullptr || mStopThread; }); in threadFn()
157 std::lock_guard<std::mutex> lk(mLock); in setFreePacketCallback() local
162 std::lock_guard<std::mutex> lk(mLock); in displayFrame() local
177 std::lock_guard<std::mutex> lk(mLock); in handleExecutionPhase() local
/packages/modules/Virtualization/libs/android_display_backend/
Dcrosvm_android_display_client.cpp40 std::lock_guard lk(mSurfaceReadyMutex); in setSurface() local
53 std::lock_guard lk(mSurfaceReadyMutex); in removeSurface() local
65 std::unique_lock lk(mSurfaceReadyMutex); in getSurface() local
67 mSurfaceReady.wait(lk, [this] { return mCursorSurface != nullptr; }); in getSurface()
70 mSurfaceReady.wait(lk, [this] { return mSurface != nullptr; }); in getSurface()
/packages/services/Car/cpp/vhal/client/src/
DIVhalClient.cpp82 std::unique_lock<std::mutex> lk(s.lock); in getValueSync() local
83 s.cv.wait(lk, [&s] { return s.gotResult; }); in getValueSync()
108 std::unique_lock<std::mutex> lk(s.lock); in setValueSync() local
109 s.cv.wait(lk, [&s] { return s.gotResult; }); in setValueSync()
DAidlVhalClient.cpp179 std::lock_guard<std::mutex> lk(mLock); in addOnBinderDiedCallback() local
186 std::lock_guard<std::mutex> lk(mLock); in removeOnBinderDiedCallback() local
244 std::lock_guard<std::mutex> lk(mLock); in onBinderDiedWithContext() local
251 std::lock_guard<std::mutex> lk(mLock); in onBinderUnlinkedWithContext() local
256 std::lock_guard<std::mutex> lk(mLock); in countOnBinderDiedCallbacks() local
370 std::lock_guard<std::mutex> lk(mLock); in addGetValueRequest() local
383 std::lock_guard<std::mutex> lk(mLock); in addSetValueRequest() local
395 std::lock_guard<std::mutex> lk(mLock); in tryFinishGetValueRequest() local
401 std::lock_guard<std::mutex> lk(mLock); in tryFinishSetValueRequest() local
529 std::lock_guard<std::mutex> lk(mLock); in onTimeout() local
DHidlVhalClient.cpp153 std::lock_guard<std::mutex> lk(mLock); in addOnBinderDiedCallback() local
161 std::lock_guard<std::mutex> lk(mLock); in removeOnBinderDiedCallback() local
224 std::lock_guard<std::mutex> lk(mLock); in onBinderDied() local
/packages/modules/Bluetooth/system/test/headless/
Dmessenger.cc60 std::unique_lock<std::mutex> lk(mutex); in Push() local
75 std::unique_lock<std::mutex> lk(callback_data_.mutex); in await_callback() local
84 callback_data_.cv.wait_for(lk, context.timeout); in await_callback()
/packages/modules/adb/fdevent/
Dfdevent_test.cpp378 std::unique_lock lk(m); in TEST_F() local
383 cv.wait(lk, [&] { return looper_thread_latch; }); in TEST_F()
388 std::unique_lock lk(m); in TEST_F() local
389 cv.wait(lk, [&] { return main_thread_latch; }); in TEST_F()
399 std::lock_guard lk(m); in TEST_F() local
/packages/services/Car/cpp/computepipe/runner/client_interface/
DDebuggerImpl.cpp148 std::unique_lock<std::mutex> lk(mLock); in getPipeProfilingInfo() local
149 if (!mWait.wait_for(lk, kProfilingDataReadTimeout, [this]() { in getPipeProfilingInfo()
182 std::lock_guard<std::mutex> lk(mLock); in releaseDebugger() local
247 std::lock_guard<std::mutex> lk(mLock); in deliverGraphDebugInfo() local
/packages/modules/Bluetooth/system/test/headless/utils/
Dpower_mode_client.h92 std::unique_lock<std::mutex> lk(mutex); in CallbackReceived()
103 std::unique_lock<std::mutex> lk(mutex); in CommandSent()
109 std::unique_lock<std::mutex> lk(mutex); in PopFront()
/packages/services/Car/cpp/evs/manager/aidl/tests/unit/src/
DEvsEnumeratorHidlUnitTest_1_0.cpp362 std::lock_guard lk(m); in VerifyCameraStream() local
405 std::unique_lock lk(m); in VerifyCameraStream() local
408 cv.wait_for(lk, maxInterval, [&gotFrameCallback] { return gotFrameCallback; })); in VerifyCameraStream()
417 lk.unlock(); in VerifyCameraStream()
422 lk.lock(); in VerifyCameraStream()
423 EXPECT_TRUE(cv.wait_for(lk, stopTimeout, [&gotNullFrame] { return gotNullFrame; })); in VerifyCameraStream()
DEvsEnumeratorUnitTest.cpp672 std::lock_guard lk(m); in TEST_F() local
689 std::unique_lock lk(m); in TEST_F() local
690 EXPECT_TRUE(cv.wait_for(lk, /* rel_time= */ 1s, [&gotFirstFrame] { return gotFirstFrame; })); in TEST_F()
740 std::lock_guard lk(m); in VerifyCameraStream() local
758 std::lock_guard lk(m); in VerifyCameraStream() local
797 std::unique_lock lk(m); in VerifyCameraStream() local
800 cv.wait_for(lk, maxInterval, [&gotFrameCallback] { return gotFrameCallback; })); in VerifyCameraStream()
810 lk.unlock(); in VerifyCameraStream()
820 lk.lock(); in VerifyCameraStream()
821 cv.wait_for(lk, eventTimeout, [&gotEventCallback] { return gotEventCallback; }); in VerifyCameraStream()
DEvsEnumeratorHidlUnitTest.cpp920 std::lock_guard lk(m); in VerifyCameraStream() local
934 std::lock_guard lk(m); in VerifyCameraStream() local
970 std::unique_lock lk(m); in VerifyCameraStream() local
973 cv.wait_for(lk, maxInterval, [&gotFrameCallback] { return gotFrameCallback; })); in VerifyCameraStream()
982 lk.unlock(); in VerifyCameraStream()
1005 lk.lock(); in VerifyCameraStream()
1006 cv.wait_for(lk, eventTimeout, [&gotEventCallback] { return gotEventCallback; }); in VerifyCameraStream()
1026 std::lock_guard lk(m); in VerifyCameraStream_1_0() local
1069 std::unique_lock lk(m); in VerifyCameraStream_1_0() local
1072 cv.wait_for(lk, maxInterval, [&gotFrameCallback] { return gotFrameCallback; })); in VerifyCameraStream_1_0()
[all …]
/packages/modules/StatsD/statsd/tests/utils/
DMultiConditionTrigger_test.cpp252 std::unique_lock<std::mutex> lk(triggerTerminationFlagMutex); in TEST() local
254 lk, std::chrono::seconds(1), in TEST()
269 std::unique_lock<std::mutex> lk(triggerTerminationFlagMutex); in TEST() local
/packages/modules/DnsResolver/tests/
Ddoh_ffi_test.cpp117 std::unique_lock<std::mutex> lk(m); in TEST_F() local
118 EXPECT_EQ(cv.wait_for(lk, std::chrono::milliseconds(TIMEOUT_MS)), in TEST_F()
Dresolv_integration_test.cpp2604 std::unique_lock lk(cvMutex); in TEST_F() local
2607 EXPECT_EQ(std::cv_status::no_timeout, cv.wait_for(lk, std::chrono::seconds(1))); in TEST_F()
/packages/services/Car/cpp/vhal/client/test/
DAidlVhalClientTest.cpp72 std::unique_lock<std::mutex> lk(mLock); in ~MockVhal() local
73 mCv.wait_for(lk, std::chrono::milliseconds(1000), [this] { return mThreadCount == 0; }); in ~MockVhal()
345 std::unique_lock<std::mutex> lk(lock); in TEST_F() local
346 cv.wait_for(lk, std::chrono::milliseconds(1000), [&gotResult] { return gotResult; }); in TEST_F()
468 std::unique_lock<std::mutex> lk(lock); in TEST_F() local
469 cv.wait_for(lk, std::chrono::milliseconds(1000), [&gotResult] { return gotResult; }); in TEST_F()
606 std::unique_lock<std::mutex> lk(lock); in TEST_F() local
607 cv.wait_for(lk, std::chrono::milliseconds(1000), [&gotResult] { return gotResult; }); in TEST_F()
669 std::unique_lock<std::mutex> lk(lock); in TEST_F() local
670 cv.wait_for(lk, std::chrono::milliseconds(1000), [&gotResult] { return gotResult; }); in TEST_F()
/packages/modules/Bluetooth/system/gd/hal/
Dsnoop_logger_socket.cc199 std::unique_lock<std::mutex> lk(client_socket_mutex_); in WaitForClientSocketConnected() local
200 client_socket_cv_.wait(lk, [this] { return IsClientSocketConnected(); }); in WaitForClientSocketConnected()
/packages/modules/StatsD/statsd/src/external/
DStatsCallbackPuller.cpp67 lock_guard<mutex> lk(*cv_mutex); in PullInternal() local
/packages/modules/StatsD/statsd/src/
DStatsService.cpp1124 std::unique_lock<std::mutex> lk(mStatsdInitCompletedHandlerTerminationFlagMutex); in onStatsdInitCompleted() local
1126 lk, std::chrono::seconds(initEventDelaySecs), in onStatsdInitCompleted()
1169 std::unique_lock<std::mutex> lk(mStatsdInitCompletedHandlerTerminationFlagMutex); in onStatsdInitCompletedHandlerTermination() local
/packages/inputmethods/LatinIME/dictionaries/
Dfi_wordlist.combined.gz1dictionary=main:fi,locale=fi,description=Suomi,date=1393228135, ...
Dtr_wordlist.combined.gz1dictionary=main:tr,locale=tr,description=Türkçe,date=1414726261, ...
/packages/modules/AdServices/adservices/tests/unittest/service-core/assets/classifier/
Dprecomputed_test_app_list.csv257 lk.bhasha.helakuru 10184
/packages/modules/AdServices/adservices/apk/assets/classifier/
Dprecomputed_app_list.csv257 lk.bhasha.helakuru 10184

12