Home
last modified time | relevance | path

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

123

/hardware/google/graphics/common/libhwc2.1/libdrmresource/utils/
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()
/hardware/interfaces/broadcastradio/common/utils/
DWorkerThread.cpp41 lock_guard<mutex> lk(mMut); in ~WorkerThread() local
57 lock_guard<mutex> lk(mMut); in schedule() local
63 lock_guard<mutex> lk(mMut); in cancelAll() local
73 unique_lock<mutex> lk(mMut); in threadLoop() local
78 mCond.wait(lk); in threadLoop()
84 mCond.wait_until(lk, task.when); in threadLoop()
89 lk.unlock(); // what() might need to schedule another task in threadLoop()
/hardware/qcom/sm8150/display/libhistogram/
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
97 return collect_max_after(timestamp, ringbuffer.size(), lk); in collect_after()
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
[all …]
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()
/hardware/interfaces/broadcastradio/aidl/default/test/
DMockBroadcastRadioCallback.cpp35 std::lock_guard<std::mutex> lk(mLock); in onTuneFailed() local
44 std::lock_guard<std::mutex> lk(mLock); in onCurrentProgramInfoChanged() local
54 std::lock_guard<std::mutex> lk(mLock); in onProgramListUpdated() local
72 std::lock_guard<std::mutex> lk(mLock); in onAntennaStateChange() local
97 std::lock_guard<std::mutex> lk(mLock); in isTunerFailed() local
102 std::lock_guard<std::mutex> lk(mLock); in getCurrentProgramInfo() local
107 std::lock_guard<std::mutex> lk(mLock); in getProgramList() local
/hardware/qcom/sm7250/display/libhistogram/
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
107 return collect_max_after(timestamp, ringbuffer.size(), lk); in collect_after()
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
[all …]
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()
/hardware/interfaces/broadcastradio/1.1/default/
DTuner.cpp71 lock_guard<mutex> lk(mMut); in forceClose() local
106 lock_guard<mutex> lk(mMut); in setConfiguration() local
117 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
223 lock_guard<mutex> lk(mMut); in scan() local
233 lock_guard<mutex> lk(mMut); in step() local
252 lock_guard<mutex> lk(mMut); in step() local
276 lock_guard<mutex> lk(mMut); in tune() local
284 lock_guard<mutex> lk(mMut); in tuneByProgramSelector() local
[all …]
/hardware/google/pixel/power-libperfmgr/disp-power/
DInteractionHandler.cpp93 std::lock_guard<std::mutex> lk(mLock); in Init() local
117 std::unique_lock<std::mutex> lk(mLock); in Exit() local
123 lk.unlock(); in Exit()
149 std::lock_guard<std::mutex> lk(mLock); in Acquire() local
195 std::lock_guard<std::mutex> lk(mLock); in Release() local
264 std::unique_lock<std::mutex> lk(mLock, std::defer_lock); in Routine() local
267 lk.lock(); in Routine()
268 mCond.wait(lk, [&] { return mState != INTERACTION_STATE_IDLE; }); in Routine()
272 lk.unlock(); in Routine()
/hardware/nxp/uwb/halimpl/tml/
DphMessageQueue.h40 std::lock_guard<std::mutex> lk(lock_); in send()
45 std::unique_lock<std::mutex> lk(lock_); in recv()
46 cond_.wait(lk, [this] { return !items_.empty(); }); in recv()
53 std::lock_guard<std::mutex> lk(lock_); in clear()
/hardware/interfaces/broadcastradio/common/vts/utils/
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()
/hardware/interfaces/broadcastradio/common/tests/
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
/hardware/google/graphics/gs101/include/histogram/
DHistogramInfo.h30 std::unique_lock<std::mutex> lk(mSetHistInfoMutex); in setHistogramROI()
39 std::unique_lock<std::mutex> lk(mSetHistInfoMutex); in setHistogramWeights()
47 std::unique_lock<std::mutex> lk(mSetHistInfoMutex); in setHistogramThreshold()
52 std::unique_lock<std::mutex> lk(mSetHistInfoMutex); in getHistogramThreshold()
/hardware/interfaces/broadcastradio/2.0/default/
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
DVirtualRadio.cpp63 lock_guard<mutex> lk(mMut); in getProgramList() local
68 lock_guard<mutex> lk(mMut); in getProgram() local
/hardware/interfaces/automotive/vehicle/aidl/impl/vhal/test/
DMockVehicleCallback.cpp125 std::unique_lock lk(mLock); in waitForSetValueResults() local
126 return mCond.wait_for(lk, std::chrono::nanoseconds(timeoutInNano), [this, size] { in waitForSetValueResults()
133 std::unique_lock lk(mLock); in waitForGetValueResults() local
134 return mCond.wait_for(lk, std::chrono::nanoseconds(timeoutInNano), [this, size] { in waitForGetValueResults()
141 std::unique_lock lk(mLock); in waitForOnPropertyEventResults() local
142 return mCond.wait_for(lk, std::chrono::nanoseconds(timeoutInNano), [this, size] { in waitForOnPropertyEventResults()
/hardware/interfaces/camera/device/3.5/default/
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()
/hardware/interfaces/wifi/aidl/default/
Daidl_callback_util.h48 std::unique_lock<std::mutex> lk(callback_handler_lock_); in addCallback()
69 std::unique_lock<std::mutex> lk(callback_handler_lock_); in getCallbacks()
75 std::unique_lock<std::mutex> lk(callback_handler_lock_); in invalidate()
93 std::unique_lock<std::mutex> lk(callback_handler_lock_); in onCallbackDeath()
/hardware/google/graphics/gs201/histogram/
Dhistogram.h32 std::unique_lock<std::mutex> lk(mSetHistInfoMutex); in setHistogramPos()
36 std::unique_lock<std::mutex> lk(mSetHistInfoMutex); in getHistogramPos()
/hardware/libhardware/modules/sensors/dynamic_sensor/
DDynamicSensorManager.cpp85 std::lock_guard<std::mutex> lk(mLock); in activate() local
130 std::lock_guard<std::mutex> lk(mFifoLock); in poll() local
135 std::lock_guard<std::mutex> lk(mLock); in registerSensor() local
162 std::lock_guard<std::mutex> lk(mLock); in unregisterSensor() local
187 std::lock_guard<std::mutex> lk(mLock); in submitEvent() local
223 std::lock_guard<std::mutex> lk(mFifoLock); in submitEvent() local
291 std::lock_guard<std::mutex> lk(mLock); in operateSensor() local
/hardware/interfaces/broadcastradio/aidl/default/
DBroadcastRadio.cpp190 lock_guard<mutex> lk(mMutex); in getAmFmRegionConfig() local
219 lock_guard<mutex> lk(mMutex); in getProperties() local
262 lock_guard<mutex> lk(mMutex); in setTunerCallback() local
271 lock_guard<mutex> lk(mMutex); in unsetTunerCallback() local
292 lock_guard<mutex> lk(mMutex); in handleProgramInfoUpdateRadioCallback() local
295 lock_guard<mutex> lk(mMutex); in handleProgramInfoUpdateRadioCallback() local
299 lock_guard<mutex> lk(mMutex); in handleProgramInfoUpdateRadioCallback() local
306 lock_guard<mutex> lk(mMutex); in tune() local
332 lock_guard<mutex> lk(mMutex); in tune() local
463 lock_guard<mutex> lk(mMutex); in seek() local
[all …]
/hardware/google/graphics/common/libhwc2.1/
Dhistogram_mediator.cpp40 std::unique_lock<std::mutex> lk(mIDLHistogram->mDataCollectingMutex); in requestHist() local
62 std::unique_lock<std::mutex> lk(mDataCollectingMutex); in callbackHistogram() local
90 std::unique_lock<std::mutex> lk(mIDLHistogram->mDataCollectingMutex); in collectRoiLuma() local
92 mIDLHistogram->mHistData_cv.wait_for(lk, std::chrono::milliseconds(50), [this]() { in collectRoiLuma()
/hardware/interfaces/tests/multithread/1.0/default/
DMultithread.cpp35 std::unique_lock<std::mutex> lk(mCvMutex); in runNewThread() local
42 bool noTimeout = mCv.wait_for(lk, kTimeoutDuration, in runNewThread()
/hardware/interfaces/broadcastradio/common/vts/utils/include/broadcastradio-vts-utils/
Dmock-timeout.h78 std::lock_guard<std::mutex> lk(egmock_mut_##Method); \
156 std::unique_lock<std::mutex> lk((obj).egmock_mut_##Method); \
158 auto status = (obj).egmock_cond_##Method.wait_for(lk, timeout); \
/hardware/interfaces/camera/device/default/
DExternalCameraDeviceSession.cpp305 std::lock_guard<std::mutex> lk(mInflightFramesLock); in configureStreams() local
629 std::unique_lock<std::mutex> lk(mV4l2BufferLock); in processOneCaptureRequest() local
632 int waitRet = waitForV4L2BufferReturnLocked(lk); in processOneCaptureRequest()
670 std::lock_guard<std::mutex> lk(mInflightFramesLock); in processOneCaptureRequest() local
1024 std::lock_guard<std::mutex> lk(mAfTriggerLock); in fillCaptureResult() local
1226 std::unique_lock<std::mutex> lk(mV4l2BufferLock); in dequeueV4l2FrameLocked() local
1228 int waitRet = waitForV4L2BufferReturnLocked(lk); in dequeueV4l2FrameLocked()
1271 std::lock_guard<std::mutex> lk(mV4l2BufferLock); in dequeueV4l2FrameLocked() local
1295 std::lock_guard<std::mutex> lk(mV4l2BufferLock); in enqueueV4l2Frame() local
1417 std::lock_guard<std::mutex> lk(mV4l2BufferLock); in v4l2StreamOffLocked() local
[all …]

123