/third_party/boost/libs/thread/example/ |
D | shared_mutex.cpp | 74 boost::shared_mutex mut; variable 83 mut.lock_shared(); in reader() 86 mut.unlock_shared(); in reader() 98 mut.lock(); in writer() 103 mut.unlock(); in writer() 115 if (mut.try_lock_shared()) in try_reader() 119 mut.unlock_shared(); in try_reader() 132 if (mut.try_lock()) in try_writer() 138 mut.unlock(); in try_writer() 151 if (mut.try_lock_shared_for(boost::chrono::microseconds(5))) in try_for_reader() [all …]
|
/third_party/boost/libs/interprocess/test/ |
D | upgradable_mutex_test.cpp | 31 Mutex mut; in main() local 36 scoped_lock<Mutex> lock(mut); in main() 41 scoped_lock<Mutex> lock(mut); in main() 46 upgradable_lock<Mutex> u_lock(mut); in main() 51 upgradable_lock<Mutex> u_lock(mut); in main() 58 upgradable_lock<Mutex> u_lock(mut); in main() 63 upgradable_lock<Mutex> u_lock(mut); in main() 71 upgradable_lock<Mutex> u_lock(mut); in main() 77 upgradable_lock<Mutex> u_lock(mut); in main() 84 sharable_lock<Mutex> s_lock(mut); in main() [all …]
|
/third_party/protobuf/src/google/protobuf/ |
D | arenastring_unittest.cc | 71 std::string* mut = field2.Mutable(&default_value, NULL); in TEST() local 72 EXPECT_EQ(mut, field2.Mutable(&default_value, NULL)); in TEST() 73 EXPECT_EQ(mut, &field2.Get()); in TEST() 74 EXPECT_NE(&default_value, mut); in TEST() 75 EXPECT_EQ(std::string("default"), *mut); in TEST() 76 *mut = "Test long long long long value"; // ensure string allocates storage in TEST() 97 std::string* mut = field2.Mutable(&default_value, &arena); in TEST() local 98 EXPECT_EQ(mut, field2.Mutable(&default_value, &arena)); in TEST() 99 EXPECT_EQ(mut, &field2.Get()); in TEST() 100 EXPECT_NE(&default_value, mut); in TEST() [all …]
|
/third_party/python/Python/ |
D | ceval_gil.h | 54 #define MUTEX_INIT(mut) \ argument 55 if (PyMUTEX_INIT(&(mut))) { \ 56 Py_FatalError("PyMUTEX_INIT(" #mut ") failed"); }; 57 #define MUTEX_FINI(mut) \ argument 58 if (PyMUTEX_FINI(&(mut))) { \ 59 Py_FatalError("PyMUTEX_FINI(" #mut ") failed"); }; 60 #define MUTEX_LOCK(mut) \ argument 61 if (PyMUTEX_LOCK(&(mut))) { \ 62 Py_FatalError("PyMUTEX_LOCK(" #mut ") failed"); }; 63 #define MUTEX_UNLOCK(mut) \ argument [all …]
|
D | condvar.h | 56 #define PyMUTEX_INIT(mut) pthread_mutex_init((mut), NULL) argument 57 #define PyMUTEX_FINI(mut) pthread_mutex_destroy(mut) argument 58 #define PyMUTEX_LOCK(mut) pthread_mutex_lock(mut) argument 59 #define PyMUTEX_UNLOCK(mut) pthread_mutex_unlock(mut) argument 65 #define PyCOND_WAIT(cond, mut) pthread_cond_wait((cond), (mut)) argument 69 PyCOND_TIMEDWAIT(PyCOND_T *cond, PyMUTEX_T *mut, long long us) in PyCOND_TIMEDWAIT() argument 73 int ret = pthread_cond_timedwait(cond, mut, &abs); in PyCOND_TIMEDWAIT()
|
D | thread_pthread.h | 205 pthread_mutex_t mut; member 587 status = pthread_mutex_init(&lock->mut, NULL); in PyThread_allocate_lock() 594 _Py_ANNOTATE_PURE_HAPPENS_BEFORE_MUTEX(&lock->mut); in PyThread_allocate_lock() 624 status = pthread_mutex_destroy( &thelock->mut ); in PyThread_free_lock() 642 status = pthread_mutex_trylock( &thelock->mut ); in PyThread_acquire_lock_timed() 647 status = pthread_mutex_lock( &thelock->mut ); in PyThread_acquire_lock_timed() 667 &thelock->mut, &abs); in PyThread_acquire_lock_timed() 678 &thelock->mut); in PyThread_acquire_lock_timed() 695 status = pthread_mutex_unlock( &thelock->mut ); in PyThread_acquire_lock_timed() 714 status = pthread_mutex_lock( &thelock->mut ); in PyThread_release_lock() [all …]
|
/third_party/boost/libs/regex/test/static_mutex/ |
D | static_mutex_test.cpp | 35 static boost::static_mutex mut = BOOST_STATIC_MUTEX_INIT ; in failed_test() local 36 boost::static_mutex::scoped_lock guard(mut); in failed_test() 43 static boost::static_mutex mut = BOOST_STATIC_MUTEX_INIT ; in print_cycles() local 44 boost::static_mutex::scoped_lock guard(mut); in print_cycles() 51 static boost::static_mutex mut = BOOST_STATIC_MUTEX_INIT ; in sufficient_time() local 52 boost::static_mutex::scoped_lock guard(mut); in sufficient_time() 61 static boost::static_mutex mut = BOOST_STATIC_MUTEX_INIT ; in t1() local 65 boost::static_mutex::scoped_lock guard(mut); in t1() 76 static boost::static_mutex mut = BOOST_STATIC_MUTEX_INIT ; in t2() local 80 boost::static_mutex::scoped_lock guard(mut, false); in t2() [all …]
|
/third_party/boost/libs/thread/test/sync/conditions/condition_variable_any/ |
D | lost_notif_pass.cpp | 44 boost::mutex mut; variable 76 boost::unique_lock<boost::mutex> lk(mut); in test_posix_wait_function() 92 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_without_pred() 102 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_with_pred() 111 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_without_pred() 121 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_with_pred() 147 boost::unique_lock<boost::mutex> lk(mut); in test_chrono_wait_function() 163 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_without_pred() 173 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_with_pred() 182 boost::unique_lock<boost::mutex> lk(mut); in wait_until_steady_without_pred() [all …]
|
/third_party/boost/libs/thread/test/sync/conditions/condition_variable/ |
D | lost_notif_pass.cpp | 44 boost::mutex mut; variable 76 boost::unique_lock<boost::mutex> lk(mut); in test_posix_wait_function() 92 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_without_pred() 102 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_absolute_with_pred() 111 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_without_pred() 121 boost::unique_lock<boost::mutex> lk(mut); in timed_wait_relative_with_pred() 147 boost::unique_lock<boost::mutex> lk(mut); in test_chrono_wait_function() 163 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_without_pred() 173 boost::unique_lock<boost::mutex> lk(mut); in wait_until_system_with_pred() 182 boost::unique_lock<boost::mutex> lk(mut); in wait_until_steady_without_pred() [all …]
|
D | wait_for_pred_pass.cpp | 46 boost::mutex mut; variable 63 boost::unique_lock < boost::mutex > lk(mut); in f() 91 boost::unique_lock < boost::mutex > lk(mut); in main() 109 boost::unique_lock < boost::mutex > lk(mut); in main()
|
D | wait_for_pass.cpp | 31 boost::mutex mut; variable 49 boost::unique_lock<boost::mutex> lk(mut); in f() 81 boost::unique_lock<boost::mutex> lk(mut); in main() 99 boost::unique_lock<boost::mutex> lk(mut); in main()
|
D | wait_until_pass.cpp | 47 boost::mutex mut; variable 60 boost::unique_lock < boost::mutex > lk(mut); in f() 91 boost::unique_lock < boost::mutex > lk(mut); in main() 110 boost::unique_lock < boost::mutex > lk(mut); in main()
|
D | wait_pass.cpp | 31 boost::mutex mut; variable 41 boost::unique_lock<boost::mutex> lk(mut); in f() 58 boost::unique_lock<boost::mutex>lk(mut); in main()
|
D | wait_until_pred_pass.cpp | 64 boost::mutex mut; variable 76 boost::unique_lock<boost::mutex> lk(mut); in f() 110 boost::unique_lock<boost::mutex> lk(mut); in main() 128 boost::unique_lock<boost::mutex> lk(mut); in main()
|
/third_party/boost/boost/interprocess/sync/windows/ |
D | mutex.hpp | 81 winapi_mutex_functions mut(handles.obtain_mutex(this->id_)); in lock() local 82 mut.lock(); in lock() 90 winapi_mutex_functions mut(handles.obtain_mutex(this->id_)); in try_lock() local 91 return mut.try_lock(); in try_lock() 99 winapi_mutex_functions mut(handles.obtain_mutex(this->id_)); in timed_lock() local 100 return mut.timed_lock(abs_time); in timed_lock() 108 winapi_mutex_functions mut(handles.obtain_mutex(this->id_)); in unlock() local 109 return mut.unlock(); in unlock()
|
/third_party/boost/boost/interprocess/sync/spin/ |
D | condition.hpp | 98 void do_wait(InterprocessMutex &mut); 101 bool do_timed_wait(const boost::posix_time::ptime &abs_time, InterprocessMutex &mut); 105 …do_timed_wait(bool tout_enabled, const boost::posix_time::ptime &abs_time, InterprocessMutex &mut); 164 inline void spin_condition::do_wait(InterprocessMutex &mut) in do_wait() argument 166 this->do_timed_wait(false, boost::posix_time::ptime(), mut); in do_wait() 171 (const boost::posix_time::ptime &abs_time, InterprocessMutex &mut) in do_timed_wait() argument 173 return this->do_timed_wait(true, abs_time, mut); in do_timed_wait() 179 InterprocessMutex &mut) in do_timed_wait() argument 211 mut.unlock(); in do_timed_wait() 294 mut.lock(); in do_timed_wait()
|
/third_party/musl/libc-test/src/regression/ |
D | pthread_cond-smasher.c | 66 static mutex mut[phases]; variable 89 mutex_lock(&mut[i]); in client() 101 int ret = condition_timedwait(&cond_client, &mut[i], &ts); in client() 108 int ret = mutex_unlock(&mut[i]); in client() 124 mutex_init(&mut[i]); in main() 126 mutex_lock(&mut[0]); in main() 137 int ret = condition_timedwait(&cond_main, &mut[phase], &ts); in main() 148 mutex_lock(&mut[phase+1]); in main() 156 ret = mutex_unlock(&mut[phase-1]); in main() 177 mutex_destroy(&mut[i]); in main()
|
/third_party/boost/libs/config/test/ |
D | boost_has_pthreads.ipp | 24 pthread_mutex_t mut; 25 int result = pthread_mutex_init(&mut, 0); 33 result |= pthread_mutex_lock(&mut); 34 result |= pthread_mutex_unlock(&mut); 35 result |= pthread_mutex_trylock(&mut); 36 result |= pthread_mutex_unlock(&mut); 37 result |= pthread_mutex_destroy(&mut);
|
D | boost_has_bethreads.ipp | 19 sem_id mut = create_sem(1, "test"); 20 if(mut > 0) 22 acquire_sem(mut); 23 release_sem(mut); 24 delete_sem(mut);
|
/third_party/boost/libs/thread/test/ |
D | test_8455.cpp | 7 boost::mutex mut; variable 10 boost::mutex::scoped_lock lock(mut); in boostMutexImp1() 11 mut.unlock(); // A: with this X blocks in boostMutexImp1() 16 boost::mutex::scoped_lock lock(mut); // X: blocks with A in boostMutexImp2()
|
/third_party/boost/boost/interprocess/sync/posix/ |
D | condition.hpp | 121 void do_wait(posix_mutex &mut); 123 bool do_timed_wait(const boost::posix_time::ptime &abs_time, posix_mutex &mut); 170 inline void posix_condition::do_wait(posix_mutex &mut) in do_wait() argument 172 pthread_mutex_t* pmutex = &mut.m_mut; in do_wait() 179 (const boost::posix_time::ptime &abs_time, posix_mutex &mut) in do_timed_wait() argument 182 pthread_mutex_t* pmutex = &mut.m_mut; in do_timed_wait()
|
D | pthread_helpers.hpp | 82 mutex_initializer(pthread_mutex_t &mut, pthread_mutexattr_t &mut_attr) in mutex_initializer() argument 83 : mp_mut(&mut) in mutex_initializer() 145 barrier_initializer(pthread_barrier_t &mut, in barrier_initializer() argument 148 : mp_barrier(&mut) in barrier_initializer()
|
/third_party/ntfs-3g/libfuse-lite/ |
D | fuse_misc.h | 13 #define fuse_mutex_init(mut) pthread_mutex_init(mut, NULL) argument 15 static inline void fuse_mutex_init(pthread_mutex_t *mut) in fuse_mutex_init() argument 20 pthread_mutex_init(mut, &attr); in fuse_mutex_init()
|
/third_party/boost/libs/thread/test/sync/conditions/ |
D | notify_all_at_thread_exit_pass.cpp | 29 boost::mutex mut; variable 36 boost::unique_lock < boost::mutex > lk(mut); in func() 43 boost::unique_lock < boost::mutex > lk(mut); in main()
|
/third_party/boost/boost/regex/pending/ |
D | static_mutex.hpp | 46 scoped_static_mutex_lock(static_mutex& mut, bool lk = true); 96 scoped_static_mutex_lock(static_mutex& mut, bool lk = true); 157 scoped_static_mutex_lock(static_mutex& mut, bool lk = true);
|