| /src/contrib/jemalloc/src/ |
| H A D | mutex.c | 47 JEMALLOC_EXPORT int _pthread_mutex_init_calloc_cb(pthread_mutex_t *mutex, 53 _pthread_mutex_init_calloc_cb(pthread_mutex_t *mutex, in _pthread_mutex_init_calloc_cb() argument 58 __libc_interposing[INTERPOS__pthread_mutex_init_calloc_cb])(mutex, in _pthread_mutex_init_calloc_cb() 65 malloc_mutex_lock_slow(malloc_mutex_t *mutex) { in malloc_mutex_lock_slow() argument 66 mutex_prof_data_t *data = &mutex->prof_data; in malloc_mutex_lock_slow() 76 if (!atomic_load_b(&mutex->locked, ATOMIC_RELAXED) in malloc_mutex_lock_slow() 77 && !malloc_mutex_trylock_final(mutex)) { in malloc_mutex_lock_slow() 85 malloc_mutex_lock_final(mutex); in malloc_mutex_lock_slow() 96 if (!malloc_mutex_trylock_final(mutex)) { in malloc_mutex_lock_slow() 103 malloc_mutex_lock_final(mutex); in malloc_mutex_lock_slow() [all …]
|
| /src/contrib/jemalloc/include/jemalloc/internal/ |
| H A D | mutex.h | 136 bool malloc_mutex_init(malloc_mutex_t *mutex, const char *name, 138 void malloc_mutex_prefork(tsdn_t *tsdn, malloc_mutex_t *mutex); 139 void malloc_mutex_postfork_parent(tsdn_t *tsdn, malloc_mutex_t *mutex); 140 void malloc_mutex_postfork_child(tsdn_t *tsdn, malloc_mutex_t *mutex); 143 void malloc_mutex_prof_data_reset(tsdn_t *tsdn, malloc_mutex_t *mutex); 145 void malloc_mutex_lock_slow(malloc_mutex_t *mutex); 148 malloc_mutex_lock_final(malloc_mutex_t *mutex) { in malloc_mutex_lock_final() argument 149 MALLOC_MUTEX_LOCK(mutex); in malloc_mutex_lock_final() 150 atomic_store_b(&mutex->locked, true, ATOMIC_RELAXED); in malloc_mutex_lock_final() 154 malloc_mutex_trylock_final(malloc_mutex_t *mutex) { in malloc_mutex_trylock_final() argument [all …]
|
| /src/contrib/openbsm/libbsm/ |
| H A D | bsm_control.c | 71 static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; variable 324 pthread_mutex_lock(&mutex); in setac() 328 pthread_mutex_unlock(&mutex); in setac() 340 pthread_mutex_lock(&mutex); in endac() 348 pthread_mutex_unlock(&mutex); in endac() 366 pthread_mutex_lock(&mutex); in getacdir() 376 pthread_mutex_unlock(&mutex); in getacdir() 382 pthread_mutex_unlock(&mutex); in getacdir() 388 pthread_mutex_unlock(&mutex); in getacdir() 394 pthread_mutex_unlock(&mutex); in getacdir() [all …]
|
| H A D | bsm_class.c | 55 static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; variable 139 pthread_mutex_lock(&mutex); in getauclassent_r() 143 pthread_mutex_unlock(&mutex); in getauclassent_r() 162 pthread_mutex_lock(&mutex); in getauclassent() 166 pthread_mutex_unlock(&mutex); in getauclassent() 189 pthread_mutex_lock(&mutex); in setauclass() 193 pthread_mutex_unlock(&mutex); in setauclass() 209 pthread_mutex_lock(&mutex); in getauclassnam_r() 215 pthread_mutex_unlock(&mutex); in getauclassnam_r() 221 pthread_mutex_unlock(&mutex); in getauclassnam_r() [all …]
|
| /src/contrib/xz/src/common/ |
| H A D | mythread.h | 50 #define mythread_sync(mutex) mythread_sync_helper1(mutex, __LINE__) argument 51 #define mythread_sync_helper1(mutex, line) mythread_sync_helper2(mutex, line) argument 52 #define mythread_sync_helper2(mutex, line) \ argument 55 ? (mythread_mutex_unlock(&(mutex)), 0) \ 56 : (mythread_mutex_lock(&(mutex)), 1); \ 206 mythread_mutex_init(mythread_mutex *mutex) in mythread_mutex_init() argument 208 return pthread_mutex_init(mutex, NULL); in mythread_mutex_init() 212 mythread_mutex_destroy(mythread_mutex *mutex) in mythread_mutex_destroy() argument 214 int ret = pthread_mutex_destroy(mutex); in mythread_mutex_destroy() 220 mythread_mutex_lock(mythread_mutex *mutex) in mythread_mutex_lock() argument [all …]
|
| /src/contrib/llvm-project/compiler-rt/lib/rtsan/tests/ |
| H A D | rtsan_test_functional.cpp | 82 std::mutex mutex; in TEST() local 83 auto Func = [&]() { mutex.lock(); }; in TEST() 89 std::mutex mutex; in TEST() local 90 mutex.lock(); in TEST() 91 auto Func = [&]() { mutex.unlock(); }; in TEST() 99 std::shared_mutex mutex; in TEST() local 100 auto Func = [&]() { mutex.lock(); }; in TEST() 106 std::shared_mutex mutex; in TEST() local 107 mutex.lock(); in TEST() 108 auto Func = [&]() { mutex.unlock(); }; in TEST() [all …]
|
| /src/crypto/openssl/crypto/thread/arch/ |
| H A D | thread_posix.c | 98 pthread_mutex_t *mutex; in ossl_crypto_mutex_new() local 100 if ((mutex = OPENSSL_zalloc(sizeof(*mutex))) == NULL) in ossl_crypto_mutex_new() 102 if (pthread_mutex_init(mutex, NULL) != 0) { in ossl_crypto_mutex_new() 103 OPENSSL_free(mutex); in ossl_crypto_mutex_new() 106 return (CRYPTO_MUTEX *)mutex; in ossl_crypto_mutex_new() 109 int ossl_crypto_mutex_try_lock(CRYPTO_MUTEX *mutex) in ossl_crypto_mutex_try_lock() argument 113 mutex_p = (pthread_mutex_t *)mutex; in ossl_crypto_mutex_try_lock() 121 void ossl_crypto_mutex_lock(CRYPTO_MUTEX *mutex) in ossl_crypto_mutex_lock() argument 126 mutex_p = (pthread_mutex_t *)mutex; in ossl_crypto_mutex_lock() 131 void ossl_crypto_mutex_unlock(CRYPTO_MUTEX *mutex) in ossl_crypto_mutex_unlock() argument [all …]
|
| /src/contrib/netbsd-tests/lib/libpthread/ |
| H A D | t_cond.c | 45 static pthread_mutex_t mutex; variable 59 PTHREAD_REQUIRE(pthread_mutex_lock(&mutex)); in signal_delay_wait_threadfunc() 64 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in signal_delay_wait_threadfunc() 83 PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL)); in ATF_TC_BODY() 86 PTHREAD_REQUIRE(pthread_mutex_lock(&mutex)); in ATF_TC_BODY() 96 PTHREAD_REQUIRE(pthread_cond_wait(&cond, &mutex)); in ATF_TC_BODY() 102 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in ATF_TC_BODY() 118 PTHREAD_REQUIRE(pthread_mutex_lock(&mutex)); in signal_before_unlock_threadfunc() 125 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in signal_before_unlock_threadfunc() 144 PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL)); in ATF_TC_BODY() [all …]
|
| H A D | t_mutex.c | 52 static pthread_mutex_t mutex; variable 90 mutex_lock(&mutex, &ts_lengthy); in mutex1_threadfunc() 95 pthread_mutex_unlock(&mutex); in mutex1_threadfunc() 113 PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL)); in ATF_TC_BODY() 115 PTHREAD_REQUIRE(mutex_lock(&mutex, &ts_lengthy)); in ATF_TC_BODY() 122 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in ATF_TC_BODY() 126 PTHREAD_REQUIRE(mutex_lock(&mutex, &ts_lengthy)); in ATF_TC_BODY() 131 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in ATF_TC_BODY() 163 PTHREAD_REQUIRE(mutex_lock(&mutex, &ts_lengthy)); in mutex2_threadfunc() 169 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in mutex2_threadfunc() [all …]
|
| H A D | t_barrier.c | 45 pthread_mutex_t mutex; variable 59 PTHREAD_REQUIRE(pthread_mutex_lock(&mutex)); in threadfunc() 63 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in threadfunc() 79 PTHREAD_REQUIRE(pthread_mutex_init(&mutex, NULL)); in ATF_TC_BODY() 83 PTHREAD_REQUIRE(pthread_mutex_lock(&mutex)); in ATF_TC_BODY() 85 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in ATF_TC_BODY() 93 PTHREAD_REQUIRE(pthread_mutex_lock(&mutex)); in ATF_TC_BODY() 95 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in ATF_TC_BODY() 99 PTHREAD_REQUIRE(pthread_mutex_lock(&mutex)); in ATF_TC_BODY() 101 PTHREAD_REQUIRE(pthread_mutex_unlock(&mutex)); in ATF_TC_BODY()
|
| /src/contrib/llvm-project/libcxx/src/ |
| H A D | mutex_destructor.cpp | 29 class _LIBCPP_EXPORTED_FROM_ABI mutex { class 33 _LIBCPP_ALWAYS_INLINE _LIBCPP_HIDE_FROM_ABI constexpr mutex() = default; 34 mutex(const mutex&) = delete; 35 mutex& operator=(const mutex&) = delete; 36 ~mutex() noexcept; 39 mutex::~mutex() noexcept { __libcpp_mutex_destroy(&__m_); } in ~mutex()
|
| H A D | mutex.cpp | 28 void mutex::lock() { in lock() 34 bool mutex::try_lock() noexcept { return __libcpp_mutex_trylock(&__m_); } in try_lock() 36 void mutex::unlock() noexcept { in unlock() 76 timed_mutex::~timed_mutex() { lock_guard<mutex> _(__m_); } in ~timed_mutex() 79 unique_lock<mutex> lk(__m_); in lock() 86 unique_lock<mutex> lk(__m_, try_to_lock); in try_lock() 95 lock_guard<mutex> _(__m_); in unlock() 104 recursive_timed_mutex::~recursive_timed_mutex() { lock_guard<mutex> _(__m_); } in ~recursive_timed_mutex() 108 unique_lock<mutex> lk(__m_); in lock() 123 unique_lock<mutex> lk(__m_, try_to_lock); in try_lock() [all …]
|
| /src/lib/libthr/thread/ |
| H A D | thr_mutex.c | 65 int __pthread_mutex_timedlock(pthread_mutex_t * __restrict mutex, 67 int _pthread_mutex_getspinloops_np(pthread_mutex_t *mutex, int *count); 68 int _pthread_mutex_setspinloops_np(pthread_mutex_t *mutex, int count); 69 int __pthread_mutex_setspinloops_np(pthread_mutex_t *mutex, int count); 70 int _pthread_mutex_setyieldloops_np(pthread_mutex_t *mutex, int count); 71 int _pthread_mutex_getyieldloops_np(pthread_mutex_t *mutex, int *count); 72 int __pthread_mutex_setyieldloops_np(pthread_mutex_t *mutex, int count); 275 mutex_init(pthread_mutex_t *mutex, in mutex_init() argument 295 *mutex = pmutex; in mutex_init() 300 init_static(struct pthread *thread, pthread_mutex_t *mutex) in init_static() argument [all …]
|
| /src/contrib/llvm-project/libcxx/include/__mutex/ |
| H A D | mutex.h | 24 class _LIBCPP_EXPORTED_FROM_ABI _LIBCPP_THREAD_SAFETY_ANNOTATION(capability("mutex")) mutex { 28 _LIBCPP_HIDE_FROM_ABI _LIBCPP_CONSTEXPR mutex() = default; 30 mutex(const mutex&) = delete; 31 mutex& operator=(const mutex&) = delete; 34 _LIBCPP_HIDE_FROM_ABI ~mutex() = default; 36 ~mutex() _NOEXCEPT; 47 static_assert(is_nothrow_default_constructible<mutex>::value, "the default constructor for std::mut…
|
| /src/sys/contrib/dev/rtw88/ |
| H A D | mac80211.c | 58 mutex_lock(&rtwdev->mutex); in rtw_ops_start() 60 mutex_unlock(&rtwdev->mutex); in rtw_ops_start() 69 mutex_lock(&rtwdev->mutex); in rtw_ops_stop() 71 mutex_unlock(&rtwdev->mutex); in rtw_ops_stop() 82 mutex_lock(&rtwdev->mutex); in rtw_ops_config() 104 mutex_unlock(&rtwdev->mutex); in rtw_ops_config() 168 mutex_lock(&rtwdev->mutex); in rtw_ops_add_interface() 172 mutex_unlock(&rtwdev->mutex); in rtw_ops_add_interface() 178 mutex_unlock(&rtwdev->mutex); in rtw_ops_add_interface() 207 mutex_unlock(&rtwdev->mutex); in rtw_ops_add_interface() [all …]
|
| /src/sys/dev/iicbus/controller/vybrid/ |
| H A D | vf_i2c.c | 155 mtx_init(&sc->mutex, device_get_nameunit(dev), "I2C", MTX_DEF); in vf_i2c_attach_common() 159 mtx_destroy(&sc->mutex); in vf_i2c_attach_common() 168 mtx_lock(&sc->mutex); in vf_i2c_attach_common() 185 mtx_unlock(&sc->mutex); in vf_i2c_attach_common() 191 mtx_destroy(&sc->mutex); in vf_i2c_attach_common() 216 mtx_lock(&sc->mutex); in i2c_detach() 225 mtx_unlock(&sc->mutex); in i2c_detach() 227 mtx_destroy(&sc->mutex); in i2c_detach() 298 mtx_lock(&sc->mutex); in i2c_repeated_start() 302 mtx_unlock(&sc->mutex); in i2c_repeated_start() [all …]
|
| /src/contrib/llvm-project/lldb/source/Host/posix/ |
| H A D | PipePosix.cpp | 68 std::scoped_lock<std::mutex, std::mutex, std::mutex, std::mutex> guard( in operator =() 81 std::scoped_lock<std::mutex, std::mutex> guard(m_read_mutex, m_write_mutex); in CreateNew() 111 std::scoped_lock<std::mutex, std::mutex> guard(m_read_mutex, m_write_mutex); in CreateNew() 149 std::scoped_lock<std::mutex, std::mutex> guard(m_read_mutex, m_write_mutex); in OpenAsReader() 172 std::lock_guard<std::mutex> guard(m_write_mutex); in OpenAsWriterWithTimeout() 209 std::lock_guard<std::mutex> guard(m_read_mutex); in GetReadFileDescriptor() 218 std::lock_guard<std::mutex> guard(m_write_mutex); in GetWriteFileDescriptor() 227 std::lock_guard<std::mutex> guard(m_read_mutex); in ReleaseReadFileDescriptor() 238 std::lock_guard<std::mutex> guard(m_write_mutex); in ReleaseWriteFileDescriptor() 249 std::scoped_lock<std::mutex, std::mutex> guard(m_read_mutex, m_write_mutex); in Close() [all …]
|
| /src/sys/fs/nfsserver/ |
| H A D | nfs_nfsdcache.c | 382 struct mtx *mutex; in nfsrc_getudp() local 384 mutex = nfsrc_cachemutex(newrp); in nfsrc_getudp() 387 mtx_lock(mutex); in nfsrc_getudp() 395 (void)mtx_sleep(rp, mutex, PVFS | PDROP, in nfsrc_getudp() 406 mtx_unlock(mutex); in nfsrc_getudp() 413 mtx_unlock(mutex); in nfsrc_getudp() 421 mtx_unlock(mutex); in nfsrc_getudp() 451 mtx_unlock(mutex); in nfsrc_getudp() 469 struct mtx *mutex; in nfsrvd_updatecache() local 475 mutex = nfsrc_cachemutex(rp); in nfsrvd_updatecache() [all …]
|
| /src/contrib/ofed/opensm/complib/ |
| H A D | cl_event.c | 60 pthread_mutex_init(&p_event->mutex, NULL); in cl_event_init() 76 pthread_mutex_destroy(&p_event->mutex); in cl_event_destroy() 87 pthread_mutex_lock(&p_event->mutex); in cl_event_signal() 95 pthread_mutex_unlock(&p_event->mutex); in cl_event_signal() 105 pthread_mutex_lock(&p_event->mutex); in cl_event_reset() 107 pthread_mutex_unlock(&p_event->mutex); in cl_event_reset() 124 pthread_mutex_lock(&p_event->mutex); in cl_event_wait_on() 131 pthread_mutex_unlock(&p_event->mutex); in cl_event_wait_on() 137 pthread_mutex_unlock(&p_event->mutex); in cl_event_wait_on() 143 if (pthread_cond_wait(&p_event->condvar, &p_event->mutex)) in cl_event_wait_on() [all …]
|
| H A D | cl_timer.c | 56 pthread_mutex_t mutex; member 85 pthread_mutex_init(&gp_timer_prov->mutex, NULL); in __cl_timer_prov_create() 105 pthread_mutex_lock(&gp_timer_prov->mutex); in __cl_timer_prov_destroy() 108 pthread_mutex_unlock(&gp_timer_prov->mutex); in __cl_timer_prov_destroy() 112 pthread_mutex_destroy(&gp_timer_prov->mutex); in __cl_timer_prov_destroy() 128 pthread_mutex_lock(&gp_timer_prov->mutex); in __cl_timer_prov_cb() 143 &gp_timer_prov->mutex); in __cl_timer_prov_cb() 154 &gp_timer_prov->mutex, in __cl_timer_prov_cb() 183 pthread_mutex_unlock(&gp_timer_prov->mutex); in __cl_timer_prov_cb() 188 pthread_mutex_lock(&gp_timer_prov->mutex); in __cl_timer_prov_cb() [all …]
|
| /src/crypto/heimdal/lib/ipc/ |
| H A D | common.c | 96 HEIMDAL_MUTEX mutex; member 114 HEIMDAL_MUTEX_init(&s->mutex); in heim_ipc_semaphore_create() 136 HEIMDAL_MUTEX_lock(&s->mutex); in heim_ipc_semaphore_wait() 142 ret = pthread_cond_wait(&s->cond, &s->mutex); in heim_ipc_semaphore_wait() 147 ret = pthread_cond_timedwait(&s->cond, &s->mutex, &ts); in heim_ipc_semaphore_wait() 150 HEIMDAL_MUTEX_unlock(&s->mutex); in heim_ipc_semaphore_wait() 154 HEIMDAL_MUTEX_unlock(&s->mutex); in heim_ipc_semaphore_wait() 170 HEIMDAL_MUTEX_lock(&s->mutex); in heim_ipc_semaphore_signal() 172 HEIMDAL_MUTEX_unlock(&s->mutex); in heim_ipc_semaphore_signal() 187 HEIMDAL_MUTEX_lock(&s->mutex); in heim_ipc_semaphore_release() [all …]
|
| /src/crypto/heimdal/lib/krb5/ |
| H A D | error_string.c | 50 HEIMDAL_MUTEX_lock(context->mutex); in krb5_clear_error_message() 55 HEIMDAL_MUTEX_unlock(context->mutex); in krb5_clear_error_message() 108 HEIMDAL_MUTEX_lock(context->mutex); in krb5_vset_error_message() 117 HEIMDAL_MUTEX_unlock(context->mutex); in krb5_vset_error_message() 169 HEIMDAL_MUTEX_lock(context->mutex); in krb5_vprepend_error_message() 171 HEIMDAL_MUTEX_unlock(context->mutex); in krb5_vprepend_error_message() 175 HEIMDAL_MUTEX_unlock(context->mutex); in krb5_vprepend_error_message() 190 HEIMDAL_MUTEX_unlock(context->mutex); in krb5_vprepend_error_message() 211 HEIMDAL_MUTEX_lock(context->mutex); in krb5_get_error_string() 214 HEIMDAL_MUTEX_unlock(context->mutex); in krb5_get_error_string() [all …]
|
| /src/contrib/llvm-project/lldb/source/Interpreter/ |
| H A D | OptionValue.cpp | 19 std::lock_guard<std::mutex> lock(other.m_mutex); in OptionValue() 28 std::scoped_lock<std::mutex, std::mutex> lock(m_mutex, other.m_mutex); in operator =() 274 std::lock_guard<std::mutex> lock(m_mutex); in GetBooleanValue() 281 std::lock_guard<std::mutex> lock(m_mutex); in SetBooleanValue() 290 std::lock_guard<std::mutex> lock(m_mutex); in GetCharValue() 297 std::lock_guard<std::mutex> lock(m_mutex); in SetCharValue() 306 std::lock_guard<std::mutex> lock(m_mutex); in GetEnumerationValue() 313 std::lock_guard<std::mutex> lock(m_mutex); in SetEnumerationValue() 322 std::lock_guard<std::mutex> lock(m_mutex); in GetFileSpecValue() 329 std::lock_guard<std::mutex> lock(m_mutex); in SetFileSpecValue() [all …]
|
| /src/contrib/ofed/libibverbs/ |
| H A D | device.c | 143 err = pthread_mutex_init(&cq->mutex, NULL); in verbs_init_cq() 151 pthread_mutex_lock(&context->mutex); in verbs_init_cq() 153 pthread_mutex_unlock(&context->mutex); in verbs_init_cq() 163 pthread_mutex_destroy(&cq->mutex); in verbs_init_cq() 171 pthread_mutex_destroy(&cq->mutex); in verbs_cleanup_cq() 230 if (pthread_mutex_init(&context->mutex, NULL)) { in __ibv_open_device() 256 if (pthread_mutex_init(&context->mutex, NULL)) in __ibv_open_device() 289 pthread_mutex_destroy(&context->mutex); in __ibv_open_device() 307 pthread_mutex_destroy(&context->mutex); in __ibv_close_device() 377 pthread_mutex_lock(&cq->mutex); in __ibv_ack_async_event() [all …]
|
| /src/lib/libthr/ |
| H A D | plockstat.d | 30 probe mutex__acquire(void *mutex, int rec, int spincount); 31 probe mutex__release(void *mutex, int rec); 32 probe mutex__block(void *mutex); 33 probe mutex__spin(void *mutex); 34 probe mutex__spun(void *mutex, int success, int spincount); 35 probe mutex__blocked(void *mutex, int success); 36 probe mutex__error(void *mutex, int err);
|