Home
last modified time | relevance | path

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

12345

/aosp12/art/test/1930-monitor-info/src/art/
H A DTest1930.java26 executeLocked(() -> { printMonitorUsage(lk); }, lk); in testSingleThread()
30 executeLockedNative(() -> { printMonitorUsage(lk); }, lk); in testSingleThreadNative()
35 executeLocked(() -> { executeLocked(() -> { printMonitorUsage(lk); }, lk); }, lk); in testLockedTwice()
40 executeLockedNative(() -> { executeLockedNative(() -> { printMonitorUsage(lk); }, lk); }, lk); in testLockedTwiceNJ()
45 executeLockedNative(() -> { executeLockedNative(() -> { printMonitorUsage(lk); }, lk); }, lk); in testLockedTwiceJN()
50 executeLockedNative(() -> { executeLockedNative(() -> { printMonitorUsage(lk); }, lk); }, lk); in testLockedTwiceNative()
62 synchronized (lk) { in testLockWait()
66 synchronized (lk) { in testLockWait()
99 lk.DoWait(); in testNotifyWait()
108 synchronized (lk) { in testNotifyWait()
[all …]
/aosp12/art/test/1932-monitor-events-misc/src/art/
H A DTest1932.java109 public static native void doNativeLockPrint(Monitors.NamedLock lk); in doNativeLockPrint() argument
113 "Lock state is: " + Monitors.getObjectMonitorUsage(lk)); in printLockState()
135 doNativeLockPrint(lk); in testNativeLockStateThrowEnter()
165 doNativeLockPrint(lk); in testNativeLockStateThrowEntered()
176 Monitors.LockController controller1 = new Monitors.LockController(lk); in testRecursiveMontiorEnteredLock()
177 Monitors.LockController controller2 = new Monitors.LockController(lk); in testRecursiveMontiorEnteredLock()
182 synchronized (lk) { in testRecursiveMontiorEnteredLock()
209 synchronized (lk) { in testWaitedMonitorEnter()
240 synchronized (lk) { in testWaitMonitorEnter()
522 Monitors.LockController controller1 = new Monitors.LockController(lk); in testLockThrowEnter()
[all …]
/aosp12/hardware/google/graphics/common/libhwc2.1/libdrmresource/utils/
H A Dworker.cpp32 std::lock_guard<std::mutex> lk(mutex_); in InitWorker() local
45 std::unique_lock<std::mutex> lk(mutex_); in Exit() local
48 lk.unlock(); in Exit()
60 std::unique_lock<std::mutex> lk(mutex_, std::adopt_lock); in WaitForSignalOrExitLocked() local
62 cond_.wait(lk); in WaitForSignalOrExitLocked()
64 cond_.wait_for(lk, std::chrono::nanoseconds(max_nanoseconds))) { in WaitForSignalOrExitLocked()
73 lk.release(); in WaitForSignalOrExitLocked()
89 std::unique_lock<std::mutex> lk(mutex_, std::defer_lock); in InternalRoutine() local
92 lk.lock(); in InternalRoutine()
95 lk.unlock(); in InternalRoutine()
/aosp12/art/test/1931-monitor-events/src/art/
H A DTest1931.java122 final Monitors.LockController controller1 = new Monitors.LockController(lk); in testInteruptWait()
155 synchronized (lk) { in testUnlockedWait()
159 m.invoke(lk); in testUnlockedWait()
169 public static void testLock(Monitors.NamedLock lk) throws Exception { in testLock() argument
170 Monitors.LockController controller1 = new Monitors.LockController(lk); in testLock()
171 Monitors.LockController controller2 = new Monitors.LockController(lk); in testLock()
184 public static void testWait(Monitors.NamedLock lk) throws Exception { in testWait() argument
185 Monitors.LockController controller1 = new Monitors.LockController(lk); in testWait()
186 Monitors.LockController controller2 = new Monitors.LockController(lk); in testWait()
203 public static void testTimedWait(Monitors.NamedLock lk) throws Exception { in testTimedWait() argument
[all …]
/aosp12/art/test/1933-monitor-current-contended/src/art/
H A DTest1933.java31 public static void testNormalWaitMonitor(final Monitors.NamedLock lk) throws Exception { in testNormalWaitMonitor() argument
32 final Monitors.LockController controller1 = new Monitors.LockController(lk); in testNormalWaitMonitor()
42 synchronized (lk) { in testNormalWaitMonitor()
43 lk.DoNotifyAll(); in testNormalWaitMonitor()
48 public static void testNormalContendedMonitor(final Monitors.NamedLock lk) throws Exception { in testNormalContendedMonitor() argument
49 final Monitors.LockController controller1 = new Monitors.LockController(lk); in testNormalContendedMonitor()
50 final Monitors.LockController controller2 = new Monitors.LockController(lk); in testNormalContendedMonitor()
61 public static void testNoContention(final Monitors.NamedLock lk) throws Exception { in testNoContention() argument
62 synchronized (lk) { in testNoContention()
/aosp12/frameworks/av/media/mtp/
H A DPosixAsyncIO.cpp40 std::unique_lock<std::mutex> lk(gLock); in work_func() local
41 gWait.wait(lk, []{return gWorkQueue.size() > 0 || gSuspended;}); in work_func()
57 std::unique_lock<std::mutex> lk(aiocbp->lock); in work_func() local
72 std::unique_lock<std::mutex> lk(gLock); in aio_add() local
85 std::unique_lock<std::mutex> lk(gLock); in aiocb() local
99 std::unique_lock<std::mutex> lk(gLock); in ~aiocb() local
104 lk.unlock(); in ~aiocb()
107 lk.lock(); in ~aiocb()
135 std::unique_lock<std::mutex> lk(aiocbp[i]->lock); in aio_suspend() local
136 aiocbp[i]->cv.wait(lk, [aiocbp, i]{return !aiocbp[i]->queued;}); in aio_suspend()
/aosp12/hardware/qcom/sdm845/display/libhistogram/
H A Dringbuffer.cpp61 std::unique_lock<decltype(mutex)> lk(mutex); in insert() local
73 std::unique_lock<decltype(mutex)> lk(mutex); in resize() local
83 std::unique_lock<decltype(mutex)> lk(mutex); in collect_cumulative() local
90 std::unique_lock<decltype(mutex)> lk(mutex); in collect_ringbuffer_all() local
91 return collect_max(ringbuffer.size(), lk); in collect_ringbuffer_all()
96 std::unique_lock<decltype(mutex)> lk(mutex); in collect_after() local
101 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max() local
102 return collect_max(max_frames, lk); in collect_max()
107 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max_after() local
108 return collect_max_after(timestamp, max_frames, lk); in collect_max_after()
[all …]
/aosp12/hardware/qcom/sm8150/display/libhistogram/
H A Dringbuffer.cpp61 std::unique_lock<decltype(mutex)> lk(mutex); in insert() local
73 std::unique_lock<decltype(mutex)> lk(mutex); in resize() local
83 std::unique_lock<decltype(mutex)> lk(mutex); in collect_cumulative() local
90 std::unique_lock<decltype(mutex)> lk(mutex); in collect_ringbuffer_all() local
91 return collect_max(ringbuffer.size(), lk); in collect_ringbuffer_all()
96 std::unique_lock<decltype(mutex)> lk(mutex); in collect_after() local
101 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max() local
102 return collect_max(max_frames, lk); in collect_max()
107 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max_after() local
108 return collect_max_after(timestamp, max_frames, lk); in collect_max_after()
[all …]
H A Dhistogram_collector.cpp146 std::unique_lock<decltype(mutex)> lk(mutex); in start() local
157 std::unique_lock<decltype(mutex)> lk(mutex); in stop() local
164 lk.unlock(); in stop()
171 std::unique_lock<decltype(mutex)> lk(mutex); in notify_histogram_event() local
188 std::unique_lock<decltype(mutex)> lk(mutex); in blob_processing_thread() local
191 cv.wait(lk, [this] { return !started || work_available; }); in blob_processing_thread()
198 lk.unlock(); in blob_processing_thread()
202 lk.lock(); in blob_processing_thread()
208 lk.lock(); in blob_processing_thread()
/aosp12/hardware/qcom/sm7250/display/libhistogram/
H A Dringbuffer.cpp68 std::unique_lock<decltype(mutex)> lk(mutex); in insert() local
84 std::unique_lock<decltype(mutex)> lk(mutex); in resize() local
94 std::unique_lock<decltype(mutex)> lk(mutex); in collect_cumulative() local
101 std::unique_lock<decltype(mutex)> lk(mutex); in collect_ringbuffer_all() local
102 return collect_max(ringbuffer.size(), lk); in collect_ringbuffer_all()
106 std::unique_lock<decltype(mutex)> lk(mutex); in collect_after() local
111 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max() local
112 return collect_max(max_frames, lk); in collect_max()
117 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max_after() local
118 return collect_max_after(timestamp, max_frames, lk); in collect_max_after()
[all …]
H A Dhistogram_collector.cpp141 std::unique_lock<decltype(mutex)> lk(mutex); in start() local
153 std::unique_lock<decltype(mutex)> lk(mutex); in stop() local
160 lk.unlock(); in stop()
167 std::unique_lock<decltype(mutex)> lk(mutex); in notify_histogram_event() local
184 std::unique_lock<decltype(mutex)> lk(mutex); in blob_processing_thread() local
187 cv.wait(lk, [this] { return !started || work_available; }); in blob_processing_thread()
194 lk.unlock(); in blob_processing_thread()
198 lk.lock(); in blob_processing_thread()
204 lk.lock(); in blob_processing_thread()
/aosp12/hardware/interfaces/broadcastradio/common/utils/
H A DWorkerThread.cpp38 lock_guard<mutex> lk(mMut); in ~WorkerThread() local
48 lock_guard<mutex> lk(mMut); in schedule() local
54 lock_guard<mutex> lk(mMut); in cancelAll() local
60 unique_lock<mutex> lk(mMut); in threadLoop() local
62 mCond.wait(lk); in threadLoop()
68 mCond.wait_until(lk, task.when); in threadLoop()
73 lk.unlock(); // what() might need to schedule another task in threadLoop()
/aosp12/hardware/interfaces/broadcastradio/1.1/default/
H A DTuner.cpp71 lock_guard<mutex> lk(mMut); in forceClose() local
106 lock_guard<mutex> lk(mMut); in setConfiguration() local
127 lock_guard<mutex> lk(mMut); in getConfiguration() local
178 lock_guard<mutex> lk(mMut); in scan() local
233 lock_guard<mutex> lk(mMut); in step() local
284 lock_guard<mutex> lk(mMut); in tuneByProgramSelector() local
321 lock_guard<mutex> lk(mMut); in cancel() local
330 lock_guard<mutex> lk(mMut); in cancelAnnouncement() local
344 lock_guard<mutex> lk(mMut); in getProgramInformation_1_1() local
358 lock_guard<mutex> lk(mMut); in startBackgroundScan() local
[all …]
/aosp12/hardware/google/pixel/power-libperfmgr/disp-power/
H A DInteractionHandler.cpp92 std::lock_guard<std::mutex> lk(mLock); in Init() local
116 std::unique_lock<std::mutex> lk(mLock); in Exit() local
122 lk.unlock(); in Exit()
148 std::lock_guard<std::mutex> lk(mLock); in Acquire() local
194 std::lock_guard<std::mutex> lk(mLock); in Release() local
263 std::unique_lock<std::mutex> lk(mLock, std::defer_lock); in Routine() local
266 lk.lock(); in Routine()
267 mCond.wait(lk, [&] { return mState != INTERACTION_STATE_IDLE; }); in Routine()
271 lk.unlock(); in Routine()
/aosp12/hardware/interfaces/broadcastradio/2.0/default/
H A DTunerSession.cpp95 lock_guard<mutex> lk(mMut); in tune() local
112 lock_guard<mutex> lk(mMut); in tune() local
123 lock_guard<mutex> lk(mMut); in scan() local
166 lock_guard<mutex> lk(mMut); in scan() local
176 lock_guard<mutex> lk(mMut); in step() local
205 lock_guard<mutex> lk(mMut); in step() local
224 lock_guard<mutex> lk(mMut); in cancel() local
234 lock_guard<mutex> lk(mMut); in startProgramListUpdates() local
245 lock_guard<mutex> lk(mMut); in startProgramListUpdates() local
291 lock_guard<mutex> lk(mMut); in close() local
/aosp12/system/vold/
H A DIdleMaint.cpp213 std::unique_lock<std::mutex> lk(cv_m, std::defer_lock); in waitForGc() local
238 lk.lock(); in waitForGc()
241 lk.unlock(); in waitForGc()
406 std::unique_lock<std::mutex> lk(cv_m); in RunIdleMaint() local
416 lk.unlock(); in RunIdleMaint()
435 lk.lock(); in RunIdleMaint()
437 lk.unlock(); in RunIdleMaint()
462 std::unique_lock<std::mutex> lk(cv_m); in AbortIdleMaint() local
465 lk.unlock(); in AbortIdleMaint()
467 lk.lock(); in AbortIdleMaint()
[all …]
/aosp12/hardware/interfaces/camera/device/3.5/default/
H A DExternalCameraDeviceSession.cpp96 std::lock_guard<std::mutex> lk(mLock); in requestBufferStart() local
112 std::unique_lock<std::mutex> lk(mLock); in waitForBufferRequestDone() local
120 auto st = mRequestDoneCond.wait_for(lk, timeout); in waitForBufferRequestDone()
134 std::unique_lock<std::mutex> lk(mLock); in waitForNextRequest() local
141 auto st = mRequestCond.wait_for(lk, timeout); in waitForNextRequest()
182 std::unique_lock<std::mutex> lk(mLock); in threadLoop() local
214 lk.unlock(); in threadLoop()
219 lk.lock(); in threadLoop()
247 lk.unlock(); in threadLoop()
/aosp12/hardware/interfaces/broadcastradio/common/tests/
H A DWorkerThread_test.cpp82 lock_guard<mutex> lk(mut); in TEST() local
89 lock_guard<mutex> lk(mut); in TEST() local
96 lock_guard<mutex> lk(mut); in TEST() local
103 lock_guard<mutex> lk(mut); in TEST() local
110 lock_guard<mutex> lk(mut); in TEST() local
/aosp12/packages/services/Car/cpp/computepipe/runner/debug_display_manager/
H A 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
/aosp12/frameworks/base/services/core/jni/BroadcastRadio/
H A DNativeCallbackThread.cpp54 unique_lock<mutex> lk(mQueueMutex); in threadLoop() local
59 mQueueCond.wait(lk); in threadLoop()
85 lock_guard<mutex> lk(mQueueMutex); in enqueue() local
101 lock_guard<mutex> lk(mQueueMutex); in stop() local
/aosp12/hardware/interfaces/broadcastradio/common/vts/utils/
H A Dcall-barrier.cpp28 lock_guard<mutex> lk(mMut); in call() local
34 unique_lock<mutex> lk(mMut); in waitForCall() local
38 auto status = mCond.wait_for(lk, timeout); in waitForCall()
/aosp12/frameworks/native/services/sensorservice/
H A DRecentEventLogger.cpp43 std::lock_guard<std::mutex> lk(mLock); in addEvent() local
53 std::lock_guard<std::mutex> lk(mLock); in setLastEventStale() local
58 std::lock_guard<std::mutex> lk(mLock); in dump() local
98 std::lock_guard<std::mutex> lk(mLock); in dump() local
132 std::lock_guard<std::mutex> lk(mLock); in populateLastEventIfCurrent() local
H A DSensorDeviceUtils.cpp136 std::lock_guard<std::mutex> lk(mLock); in onRegistration() local
144 std::lock_guard<std::mutex> lk(mLock); in reset() local
159 std::unique_lock<std::mutex> lk(mLock); in wait() local
160 return mCondition.wait_for(lk, std::chrono::milliseconds(TIMEOUT_MS), in wait()
/aosp12/system/memory/libmemunreachable/
H A DSemaphore.h33 std::unique_lock<std::mutex> lk(m_); in Wait()
34 cv_.wait_for(lk, ms, [&] { in Wait()
44 std::lock_guard<std::mutex> lk(m_); in Post()
H A DPtracerThread.cpp79 std::unique_lock<std::mutex> lk(m_); in PtracerThread() local
80 lk.unlock(); in PtracerThread()
93 std::unique_lock<std::mutex> lk(m_); in Start() local
111 lk.unlock(); in Start()

12345