/aosp12/bionic/libc/bionic/ |
H A D | pthread_mutex.cpp | 166 if (mutex.counter == 0xffff) { in PIMutexTryLock() 169 mutex.counter++; in PIMutexTryLock() 180 int ret = PIMutexTryLock(mutex); in PIMutexTimedLock() 186 ret = -__futex_pi_lock_ex(&mutex.owner_tid, mutex.shared, use_realtime_clock, abs_timeout); in PIMutexTimedLock() 211 if (mutex.counter != 0u) { in PIMutexUnlock() 212 --mutex.counter; in PIMutexUnlock() 225 return -__futex_pi_unlock(&mutex.owner_tid, mutex.shared); in PIMutexUnlock() 261 PIMutex mutex; member 278 return IdToNode(id).mutex; in IdToPIMutex() 539 mutex->pi_mutex_id = id; in pthread_mutex_init() [all …]
|
H A D | pthread_cond.cpp | 197 pthread_mutex_unlock(mutex); in __pthread_cond_timedwait() 205 pthread_mutex_lock(mutex); in __pthread_cond_timedwait() 221 int pthread_cond_wait(pthread_cond_t* cond_interface, pthread_mutex_t* mutex) { in pthread_cond_wait() argument 223 return __pthread_cond_timedwait(cond, mutex, false, nullptr); in pthread_cond_wait() 226 int pthread_cond_timedwait(pthread_cond_t *cond_interface, pthread_mutex_t * mutex, in pthread_cond_timedwait() argument 234 pthread_mutex_t* mutex, in pthread_cond_timedwait_monotonic_np() argument 254 pthread_mutex_t* mutex, in pthread_cond_timedwait_monotonic() argument 256 return pthread_cond_timedwait_monotonic_np(cond_interface, mutex, abs_timeout); in pthread_cond_timedwait_monotonic() 262 pthread_mutex_t* mutex, in pthread_cond_timedwait_relative_np() argument 274 pthread_mutex_t* mutex, unsigned ms) { in pthread_cond_timeout_np() argument [all …]
|
/aosp12/system/netd/server/ |
H A D | ClatdController.h | 44 virtual ~ClatdController() EXCLUDES(mutex){}; in ~ClatdController() 47 void init(void) EXCLUDES(mutex); 50 std::string* v6Addr) EXCLUDES(mutex); 51 int stopClatd(const std::string& interface) EXCLUDES(mutex); 53 void dump(netdutils::DumpWriter& dw) EXCLUDES(mutex); 77 std::mutex mutex; variable 79 const NetworkController* mNetCtrl GUARDED_BY(mutex); 83 void dumpEgress(netdutils::DumpWriter& dw) REQUIRES(mutex); 84 void dumpIngress(netdutils::DumpWriter& dw) REQUIRES(mutex); 85 void dumpTrackers(netdutils::DumpWriter& dw) REQUIRES(mutex); [all …]
|
/aosp12/hardware/interfaces/bluetooth/1.0/default/test/ |
H A D | h4_protocol_unittest.cc | 69 ACTION_P2(Notify, mutex, condition) { in ACTION_P2() argument 71 std::unique_lock<std::mutex> lock(*mutex); in ACTION_P2() 130 std::mutex mutex; in WriteAndExpectInboundAclData() local 134 .WillOnce(Notify(&mutex, &done)); in WriteAndExpectInboundAclData() 140 std::unique_lock<std::mutex> lock(mutex); in WriteAndExpectInboundAclData() 155 std::mutex mutex; in WriteAndExpectInboundScoData() local 165 std::unique_lock<std::mutex> lock(mutex); in WriteAndExpectInboundScoData() 179 std::mutex mutex; in WriteAndExpectInboundEvent() local 186 std::unique_lock<std::mutex> lock(mutex); in WriteAndExpectInboundEvent() 203 std::mutex mutex; in WriteAndExpectInboundIsoData() local [all …]
|
H A D | mct_protocol_unittest.cc | 62 ACTION_P2(Notify, mutex, condition) { in ACTION_P2() argument 64 std::unique_lock<std::mutex> lock(*mutex); in ACTION_P2() 132 std::mutex mutex; in WriteAndExpectInboundAclData() local 136 .WillOnce(Notify(&mutex, &done)); in WriteAndExpectInboundAclData() 142 std::unique_lock<std::mutex> lock(mutex); in WriteAndExpectInboundAclData() 157 std::mutex mutex; in WriteAndExpectInboundEvent() local 161 .WillOnce(Notify(&mutex, &done)); in WriteAndExpectInboundEvent() 167 std::unique_lock<std::mutex> lock(mutex); in WriteAndExpectInboundEvent()
|
/aosp12/system/bt/osi/src/ |
H A D | fixed_queue.cc | 35 std::mutex* mutex; member 49 ret->mutex = new std::mutex; in fixed_queue_new() 99 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_is_empty() 106 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_length() 123 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_enqueue() 137 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_dequeue() 154 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_try_enqueue() 169 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_try_dequeue() 182 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_try_peek_first() 189 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_try_peek_last() [all …]
|
H A D | reactor.cc | 45 std::mutex* list_mutex; 56 std::mutex* mutex; // protects the lifetime of this object and all variables. member 88 ret->list_mutex = new std::mutex; in reactor_new() 151 object->mutex = new std::mutex; in reactor_register() 162 delete object->mutex; in reactor_register() 188 std::lock_guard<std::mutex> lock(*object->mutex); in reactor_change_registration() 223 obj->mutex->lock(); in reactor_unregister() 224 obj->mutex->unlock(); in reactor_unregister() 225 delete obj->mutex; in reactor_unregister() 273 std::lock_guard<std::mutex> obj_lock(*object->mutex); in run_reactor() [all …]
|
/aosp12/system/chre/util/tests/ |
H A D | conditional_lock_guard_test.cc | 44 MockMutex mutex; in TEST() local 45 ASSERT_EQ(mutex.getLockCount(), 0); in TEST() 48 ConditionalLockGuard<MockMutex> lock(mutex, true); in TEST() 49 EXPECT_EQ(mutex.getLockCount(), 1); in TEST() 52 EXPECT_EQ(mutex.getLockCount(), 0); in TEST() 56 MockMutex mutex; in TEST() local 57 ASSERT_EQ(mutex.getLockCount(), 0); in TEST() 60 ConditionalLockGuard<MockMutex> lock(mutex, false); in TEST() 61 EXPECT_EQ(mutex.getLockCount(), 0); in TEST() 64 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
|
/aosp12/bionic/benchmarks/ |
H A D | pthread_benchmark.cpp | 72 pthread_mutex_lock(&mutex); in BM_pthread_mutex_lock() 73 pthread_mutex_unlock(&mutex); in BM_pthread_mutex_lock() 82 pthread_mutex_lock(&mutex); in BM_pthread_mutex_lock_ERRORCHECK() 83 pthread_mutex_unlock(&mutex); in BM_pthread_mutex_lock_ERRORCHECK() 92 pthread_mutex_lock(&mutex); in BM_pthread_mutex_lock_RECURSIVE() 93 pthread_mutex_unlock(&mutex); in BM_pthread_mutex_lock_RECURSIVE() 100 pthread_mutex_t mutex; member 112 pthread_mutex_destroy(&mutex); in ~PIMutex() 121 pthread_mutex_lock(&m.mutex); in BM_pthread_mutex_lock_PI() 131 pthread_mutex_lock(&m.mutex); in BM_pthread_mutex_lock_ERRORCHECK_PI() [all …]
|
/aosp12/hardware/qcom/camera/msm8998/QCamera2/stack/common/ |
H A D | cam_semaphore.h | 49 pthread_mutex_t mutex; member 55 pthread_mutex_init(&(s->mutex), NULL); in cam_sem_init() 62 pthread_mutex_lock(&(s->mutex)); in cam_sem_post() 65 pthread_mutex_unlock(&(s->mutex)); in cam_sem_post() 71 pthread_mutex_lock(&(s->mutex)); in cam_sem_wait() 73 rc = pthread_cond_wait(&(s->cond), &(s->mutex)); in cam_sem_wait() 75 pthread_mutex_unlock(&(s->mutex)); in cam_sem_wait() 82 pthread_mutex_lock(&(s->mutex)); in cam_sem_timedwait() 84 rc = pthread_cond_timedwait(&(s->cond), &(s->mutex), abs_timeout); in cam_sem_timedwait() 89 pthread_mutex_unlock(&(s->mutex)); in cam_sem_timedwait() [all …]
|
/aosp12/system/chre/chpp/platform/linux/ |
H A D | notifier.c | 35 chppMutexInit(¬ifier->mutex); in chppPlatformNotifierInit() 41 chppMutexDeinit(¬ifier->mutex); in chppPlatformNotifierDeinit() 45 chppMutexLock(¬ifier->mutex); in chppPlatformNotifierGetSignal() 50 chppMutexUnlock(¬ifier->mutex); in chppPlatformNotifierGetSignal() 55 chppMutexLock(¬ifier->mutex); in chppPlatformNotifierWait() 58 pthread_cond_wait(¬ifier->cond, ¬ifier->mutex.lock); in chppPlatformNotifierWait() 63 chppMutexUnlock(¬ifier->mutex); in chppPlatformNotifierWait() 77 chppMutexLock(¬ifier->mutex); in chppPlatformNotifierTimedWait() 92 chppMutexUnlock(¬ifier->mutex); in chppPlatformNotifierTimedWait() 99 chppMutexLock(¬ifier->mutex); in chppPlatformNotifierSignal() [all …]
|
/aosp12/hardware/interfaces/graphics/composer/2.4/utils/vts/ |
H A D | GraphicsComposerCallback.cpp | 22 std::lock_guard<std::mutex> lock(mMutex); in setVsyncAllowed() 27 std::lock_guard<std::mutex> lock(mMutex); in getDisplays() 32 std::lock_guard<std::mutex> lock(mMutex); in getInvalidHotplugCount() 37 std::lock_guard<std::mutex> lock(mMutex); in getInvalidRefreshCount() 42 std::lock_guard<std::mutex> lock(mMutex); in getInvalidVsyncCount() 47 std::lock_guard<std::mutex> lock(mMutex); in getInvalidVsync_2_4Count() 52 std::lock_guard<std::mutex> lock(mMutex); in getInvalidVsyncPeriodChangeCount() 57 std::lock_guard<std::mutex> lock(mMutex); in getInvalidSeamlessPossibleCount() 63 std::lock_guard<std::mutex> lock(mMutex); in takeLastVsyncPeriodChangeTimeline() 72 std::lock_guard<std::mutex> lock(mMutex); in onHotplug() [all …]
|
/aosp12/hardware/google/camera/common/apex_update_listener/ |
H A D | apex_update_listener_test.cc | 47 std::mutex mutex; in TEST() local 72 .WillOnce([&mutex, &wait_cv]() { in TEST() 73 std::lock_guard<std::mutex> lock(mutex); in TEST() 82 std::unique_lock<std::mutex> lock(mutex); in TEST() 90 std::mutex mutex; in TEST() local 103 .WillOnce([&mutex, &wait_cv]() { in TEST() 104 std::lock_guard<std::mutex> lock(mutex); in TEST() 112 std::unique_lock<std::mutex> lock(mutex); in TEST()
|
/aosp12/system/chre/chpp/platform/linux/include/chpp/platform/ |
H A D | platform_mutex.h | 30 static inline void chppMutexInit(struct ChppMutex *mutex) { in chppMutexInit() argument 31 pthread_mutex_init(&mutex->lock, NULL); in chppMutexInit() 34 static inline void chppMutexDeinit(struct ChppMutex *mutex) { in chppMutexDeinit() argument 35 pthread_mutex_destroy(&mutex->lock); in chppMutexDeinit() 38 static inline void chppMutexLock(struct ChppMutex *mutex) { in chppMutexLock() argument 39 pthread_mutex_lock(&mutex->lock); in chppMutexLock() 42 static inline void chppMutexUnlock(struct ChppMutex *mutex) { in chppMutexUnlock() argument 43 pthread_mutex_unlock(&mutex->lock); in chppMutexUnlock()
|
/aosp12/frameworks/av/media/libmediatranscoding/transcoder/tests/ |
H A D | TranscoderTestUtils.h | 88 std::unique_lock<std::mutex> lock(mMutex); in onTrackFormatAvailable() 94 std::unique_lock<std::mutex> lock(mMutex); in onTrackFinished() 100 std::unique_lock<std::mutex> lock(mMutex); in onTrackStopped() 107 std::unique_lock<std::mutex> lock(mMutex); in onTrackError() 115 std::unique_lock<std::mutex> lock(mMutex); in waitUntilFinished() 123 std::unique_lock<std::mutex> lock(mMutex); in waitUntilTrackFormatAvailable() 136 std::mutex mMutex; 147 std::unique_lock<std::mutex> lock(mMutex); in onFinished() 155 std::unique_lock<std::mutex> lock(mMutex); in onError() 199 std::mutex mMutex; [all …]
|
/aosp12/system/bt/stack/a2dp/ |
H A D | a2dp_vendor_ldac_decoder.cc | 96 pthread_mutex_t mutex; member 183 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_init() 192 pthread_mutex_unlock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_init() 197 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_cleanup() 201 pthread_mutex_unlock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_cleanup() 209 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_decode_packet() 233 pthread_mutex_unlock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_decode_packet() 238 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_start() 242 pthread_mutex_unlock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_start() 246 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_suspend() [all …]
|
/aosp12/hardware/qcom/sdm845/display/libhistogram/ |
H A D | ringbuffer.cpp | 61 std::unique_lock<decltype(mutex)> lk(mutex); in insert() 73 std::unique_lock<decltype(mutex)> lk(mutex); in resize() 83 std::unique_lock<decltype(mutex)> lk(mutex); in collect_cumulative() 90 std::unique_lock<decltype(mutex)> lk(mutex); in collect_ringbuffer_all() 96 std::unique_lock<decltype(mutex)> lk(mutex); in collect_after() 101 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max() 107 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max_after() 112 uint32_t max_frames, std::unique_lock<std::mutex> const&) const { in collect_max() 133 nsecs_t timestamp, uint32_t max_frames, std::unique_lock<std::mutex> const& lk) const { in collect_max_after()
|
/aosp12/hardware/qcom/sm8150/display/libhistogram/ |
H A D | ringbuffer.cpp | 61 std::unique_lock<decltype(mutex)> lk(mutex); in insert() 73 std::unique_lock<decltype(mutex)> lk(mutex); in resize() 83 std::unique_lock<decltype(mutex)> lk(mutex); in collect_cumulative() 90 std::unique_lock<decltype(mutex)> lk(mutex); in collect_ringbuffer_all() 96 std::unique_lock<decltype(mutex)> lk(mutex); in collect_after() 101 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max() 107 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max_after() 112 uint32_t max_frames, std::unique_lock<std::mutex> const&) const { in collect_max() 133 nsecs_t timestamp, uint32_t max_frames, std::unique_lock<std::mutex> const& lk) const { in collect_max_after()
|
/aosp12/frameworks/native/libs/renderengine/gl/ |
H A D | ImageManager.cpp | 48 std::lock_guard<std::mutex> lock(mMutex); in ~ImageManager() 61 std::lock_guard<std::mutex> lock(barrier->mutex); in cacheAsync() 77 std::lock_guard<std::mutex> lock(barrier->mutex); in cache() 78 barrier->condition.wait(barrier->mutex, in cache() 79 [&]() REQUIRES(barrier->mutex) { return barrier->isOpen; }); in cache() 91 std::lock_guard<std::mutex> lock(mMutex); in queueOperation() 102 std::lock_guard<std::mutex> lock(mMutex); in threadMain() 108 std::lock_guard<std::mutex> lock(mMutex); in threadMain() 135 std::lock_guard<std::mutex> entryLock(entry.barrier->mutex); in threadMain()
|
/aosp12/frameworks/av/media/libstagefright/renderfright/gl/ |
H A D | ImageManager.cpp | 50 std::lock_guard<std::mutex> lock(mMutex); in ~ImageManager() 63 std::lock_guard<std::mutex> lock(barrier->mutex); in cacheAsync() 79 std::lock_guard<std::mutex> lock(barrier->mutex); in cache() 80 barrier->condition.wait(barrier->mutex, in cache() 81 [&]() REQUIRES(barrier->mutex) { return barrier->isOpen; }); in cache() 93 std::lock_guard<std::mutex> lock(mMutex); in queueOperation() 104 std::lock_guard<std::mutex> lock(mMutex); in threadMain() 110 std::lock_guard<std::mutex> lock(mMutex); in threadMain() 137 std::lock_guard<std::mutex> entryLock(entry.barrier->mutex); in threadMain()
|
/aosp12/hardware/google/gchips/gralloc4/src/hidl_common/ |
H A D | RegisteredHandlePool.cpp | 23 std::lock_guard<std::mutex> lock(mutex); in add() 31 std::lock_guard<std::mutex> lock(mutex); in remove() 39 std::lock_guard<std::mutex> lock(mutex); in get() 45 std::lock_guard<std::mutex> lock(mutex); in for_each()
|
/aosp12/hardware/ti/am57x/libhwcomposer/ |
H A D | display.cpp | 41 std::unique_lock<std::mutex> lock(this->mutex); in setup_composition_pipes() 61 std::unique_lock<std::mutex> lock(display->mutex); in page_flip_handler() 106 std::unique_lock<std::mutex> lock(display->mutex); in vblank_handler() 120 std::unique_lock<std::mutex> lock(this->mutex); in set_vsync_state() 156 std::unique_lock<std::mutex> lock(this->mutex); in update_display() 193 std::unique_lock<std::mutex> lock(this->mutex); in blank() 220 std::unique_lock<std::mutex> lock(this->mutex); in get_display_configs() 239 std::unique_lock<std::mutex> lock(this->mutex); in get_display_attributes()
|
/aosp12/hardware/qcom/sm7250/display/libhistogram/ |
H A D | ringbuffer.cpp | 68 std::unique_lock<decltype(mutex)> lk(mutex); in insert() 84 std::unique_lock<decltype(mutex)> lk(mutex); in resize() 94 std::unique_lock<decltype(mutex)> lk(mutex); in collect_cumulative() 101 std::unique_lock<decltype(mutex)> lk(mutex); in collect_ringbuffer_all() 106 std::unique_lock<decltype(mutex)> lk(mutex); in collect_after() 111 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max() 117 std::unique_lock<decltype(mutex)> lk(mutex); in collect_max_after() 122 uint32_t max_frames, std::unique_lock<std::mutex> const &) const { in collect_max() 144 nsecs_t timestamp, uint32_t max_frames, std::unique_lock<std::mutex> const &lk) const { in collect_max_after()
|
/aosp12/packages/modules/adb/daemon/ |
H A D | property_monitor_test.cpp | 38 std::unordered_map<std::string, std::vector<std::string>> changes GUARDED_BY(mutex); 39 std::mutex mutex; member 67 std::lock_guard<std::mutex> lock(output->mutex); in RegisterCallback() 92 std::lock_guard<std::mutex> lock(output.mutex); in TEST() 115 std::lock_guard<std::mutex> lock(output.mutex); in TEST() 126 std::lock_guard<std::mutex> lock(output.mutex); in TEST() 157 std::lock_guard<std::mutex> lock(output.mutex); in TEST() 174 std::lock_guard<std::mutex> lock(output.mutex); in TEST()
|
/aosp12/hardware/qcom/camera/msm8998/QCamera2/HAL3/ |
H A D | QCamera3HdrPlusListenerThread.cpp | 47 std::unique_lock<std::mutex> l(mCallbackLock); in onOpened() 58 std::unique_lock<std::mutex> l(mCallbackLock); in onOpenFailed() 70 std::unique_lock<std::mutex> l(mCallbackLock); in onFatalError() 82 std::unique_lock<std::mutex> l(mCallbackLock); in onCaptureResult() 96 std::unique_lock<std::mutex> l(mCallbackLock); in onFailedCaptureResult() 110 std::unique_lock<std::mutex> l(mCallbackLock); in onShutter() 121 std::unique_lock<std::mutex> l(mCallbackLock); in onNextCaptureReady() 133 std::unique_lock<std::mutex> l(mCallbackLock); in onPostview() 151 std::unique_lock<std::mutex> l(mCallbackLock); in requestExit() 209 std::unique_lock<std::mutex> l(mCallbackLock); in handleNextCaptureReady() [all …]
|