| /frameworks/av/media/mtp/ |
| D | PosixAsyncIO.cpp | 40 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()
|
| /frameworks/base/services/core/jni/BroadcastRadio/ |
| D | NativeCallbackThread.cpp | 54 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
|
| D | Tuner.cpp | 116 lock_guard<mutex> lk(gContextMutex); in nativeInit() local
129 lock_guard<mutex> lk(gContextMutex); in nativeFinalize() local
159 lock_guard<mutex> lk(gContextMutex); in assignHalInterfaces() local
189 lock_guard<mutex> lk(gContextMutex); in getHalTuner() local
194 lock_guard<mutex> lk(gContextMutex); in getHalTuner11() local
208 lock_guard<mutex> lk(gContextMutex); in nativeClose() local
230 lock_guard<mutex> lk(gContextMutex); in nativeSetConfiguration() local
285 lock_guard<mutex> lk(gContextMutex); in nativeTune() local
369 lock_guard<mutex> lk(gContextMutex); in nativeGetImage() local
|
| D | TunerCallback.cpp | 196 lock_guard<mutex> lk(mMut); in tuneComplete() local
276 lock_guard<mutex> lk(mMut); in newMetadata() local
359 lock_guard<mutex> lk(gContextMutex); in nativeInit() local
372 lock_guard<mutex> lk(gContextMutex); in nativeFinalize() local
380 lock_guard<mutex> lk(gContextMutex); in nativeDetach() local
389 lock_guard<mutex> lk(gContextMutex); in getNativeCallback() local
|
| D | BroadcastRadioService.cpp | 105 lock_guard<mutex> lk(gContextMutex); in nativeInit() local
114 lock_guard<mutex> lk(gContextMutex); in nativeFinalize() local
122 lock_guard<mutex> lk(gContextMutex); in nativeLoadModules() local
207 lock_guard<mutex> lk(gContextMutex); in nativeOpenTuner() local
|
| /frameworks/native/services/sensorservice/ |
| D | RecentEventLogger.cpp | 43 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
|
| D | SensorDeviceUtils.cpp | 136 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()
|
| D | SensorList.h | 118 std::lock_guard<std::mutex> lk(mLock); in forEachEntry()
129 std::lock_guard<std::mutex> lk(mLock); in getOne()
|
| D | SensorList.cpp | 33 std::lock_guard<std::mutex> lk(mLock); in add() local
45 std::lock_guard<std::mutex> lk(mLock); in remove() local
73 std::lock_guard<std::mutex> lk(mLock); in isNewHandle() local
|
| /frameworks/native/libs/gui/tests/ |
| D | RegionSampling_test.cpp | 38 std::unique_lock<decltype(mutex_)> lk(mutex_); in notify() local
58 std::unique_lock<decltype(mutex_)> lk(mutex_); in wait_vsync_notify() local
59 cv_.wait(lk, [this] { return notification_arrived_; }); in wait_vsync_notify()
140 std::unique_lock<decltype(mutex)> lk(mutex); in onSampleCollected() local
147 std::unique_lock<decltype(mutex)> lk(mutex); in wait_event() local
148 return cv.wait_for(lk, timeout, [this] { return received; }); in wait_event()
152 std::unique_lock<decltype(mutex)> lk(mutex); in luma() local
157 std::unique_lock<decltype(mutex)> lk(mutex); in reset() local
|
| /frameworks/native/services/surfaceflinger/Scheduler/ |
| D | VSyncDispatchTimerQueue.cpp | 159 std::lock_guard<std::mutex> lk(mRunningMutex); in callback() local
165 std::lock_guard<std::mutex> lk(mRunningMutex); in callback() local
171 std::unique_lock<std::mutex> lk(mRunningMutex); in ensureNotRunning() local
172 mCv.wait(lk, [this]() REQUIRES(mRunningMutex) { return !mRunning; }); in ensureNotRunning()
176 std::lock_guard<std::mutex> lk(mRunningMutex); in dump() local
|
| /frameworks/base/core/java/android/content/ |
| D | UriMatcher.java | 250 int lk = u.length();
251 for (int k=0; k<lk; k++) {
|
| /frameworks/av/services/camera/libcameraservice/device3/ |
| D | Camera3OfflineSession.cpp | 162 std::unique_lock<std::mutex> lk(mOutputLock); in waitForNextFrame() local
165 auto st = mResultSignal.wait_for(lk, std::chrono::nanoseconds(timeout)); in waitForNextFrame()
|
| /frameworks/av/media/libstagefright/ |
| D | MediaAdapter.cpp | 122 std::unique_lock<std::mutex> lk(mBufferGatingMutex); in pushBuffer() local
|
| D | MPEG4Writer.cpp | 1260 std::unique_lock<std::mutex> lk(mResetMutex, std::defer_lock); in reset() local
1265 lk.lock(); in reset()
1266 } else if (!lk.try_lock()) { in reset()
|
| /frameworks/native/libs/binder/ndk/tests/ |
| D | libbinder_ndk_unit_test.cpp | 633 std::unique_lock<std::mutex> lk(dMutex); in TEST() local
634 cv.wait_for(lk, 1s, [] { return destroyed; }); in TEST()
|