/dports/lang/ruby26/ruby-2.6.9/test/ruby/ |
H A D | test_thread_cv.rb | 17 condvar = ConditionVariable.new 23 condvar.signal 28 condvar.wait(mutex) 46 condvar.wait(mutex) 72 condvar.wait mutex 80 condvar.broadcast 124 condvar.wait mutex 202 condvar.dup 212 Marshal.dump(condvar) 215 condvar = DumpableCV.new [all …]
|
/dports/graphics/Coin/coin-Coin-4.0.0/src/threads/ |
H A D | condvar.cpp | 106 cc_condvar * condvar; in cc_condvar_construct() local 108 assert(condvar != NULL); in cc_condvar_construct() 109 cc_condvar_struct_init(condvar); in cc_condvar_construct() 110 return condvar; in cc_condvar_construct() 118 assert((condvar != NULL)); in cc_condvar_destruct() 119 cc_condvar_struct_clean(condvar); in cc_condvar_destruct() 120 free(condvar); in cc_condvar_destruct() 130 assert(condvar != NULL); in cc_condvar_wait() 145 assert(condvar != NULL); in cc_condvar_timed_wait() 157 assert(condvar != NULL); in cc_condvar_wake_one() [all …]
|
H A D | condvar_win32.icc | 33 /* This file should only be included from condvar.c */ 106 EnterCriticalSection(&condvar->w32thread.waiters_count_lock); 107 condvar->w32thread.waiters_count++; 118 condvar->w32thread.waiters_count--; 121 condvar->w32thread.waiters_count == 0; 145 internal_condvar_wait(cc_condvar * condvar, cc_mutex * mutex) 157 internal_condvar_wake_one(cc_condvar * condvar) 161 have_waiters = condvar->w32thread.waiters_count > 0; 165 SetEvent(condvar->w32thread.eventhandle[EVENT_SIGNAL]); 171 internal_condvar_wake_all(cc_condvar * condvar) [all …]
|
/dports/lang/scheme48/scheme48-1.9.2/scheme/rts/ |
H A D | channel.scm | 29 (note-channel-result! condvar 47 (note-channel-result! condvar 81 (let ((condvar (make-condvar))) 87 (condvar-value condvar)))))) 95 (if condvar 99 (note-channel-result! condvar 127 (if condvar 128 (note-channel-result! condvar 207 (let ((condvar (cdar condvars))) 210 (condvar-has-waiters? condvar)) [all …]
|
H A D | condvar.scm | 13 (define-synchronized-record-type condvar :condvar unknown 23 (lambda (condvar) 24 (if (condvar-id condvar) 25 (list 'condvar (condvar-id condvar)) 26 '(condvar)))) 38 (define (maybe-commit-and-set-condvar! condvar value) 39 (set-condvar-value! condvar value) 40 (set-condvar-has-value?! condvar #t) 41 (maybe-commit-and-make-ready (condvar-queue condvar))) 43 (define (condvar-has-waiters? condvar) [all …]
|
H A D | external-event.scm | 27 (define (add-external-event-condvar! uid condvar) 31 (define (notify-external-event-condvar! condvar) 33 (or (maybe-commit-and-set-condvar! condvar #t) 44 (add-external-event-condvar! uid condvar) 50 (condvar (make-condvar))) 52 (values event-uid condvar))) 55 (define (wait-for-external-event condvar) 57 (or (if (condvar-has-value? condvar) 88 (let ((condvar (cdar condvars))) 90 (if (condvar-has-waiters? condvar) [all …]
|
/dports/devel/p5-AnyEvent-DBI/AnyEvent-DBI-3.04/t/ |
H A D | 02_sql_lite.t | 35 $cv = AnyEvent->condvar; 49 $cv = AnyEvent->condvar; 57 $cv = AnyEvent->condvar; 64 $cv = AnyEvent->condvar; 71 $cv = AnyEvent->condvar; 78 $cv = AnyEvent->condvar; 86 $cv = AnyEvent->condvar; 92 $cv = AnyEvent->condvar; 99 $cv = AnyEvent->condvar; 115 $cv = AnyEvent->condvar; [all …]
|
H A D | 01_fake_mysql.t | 44 my $cv = AnyEvent->condvar; 62 $cv = AnyEvent->condvar; 81 $cv = AnyEvent->condvar; 96 $cv = AnyEvent->condvar; 115 $cv = AnyEvent->condvar; 157 $cv = AnyEvent->condvar; 176 $cv = AnyEvent->condvar; 195 $cv = AnyEvent->condvar; 211 $cv = AnyEvent->condvar; 280 $cv = AnyEvent->condvar; [all …]
|
/dports/devel/bloaty/bloaty-1.1/third_party/abseil-cpp/absl/synchronization/ |
H A D | lifetime_test.cc | 40 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument 53 condvar->Wait(mutex); in ThreadOne() 58 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument 68 condvar->Signal(); in ThreadTwo() 75 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar, in RunTests() argument 83 if (!condvar) { in RunTests() 84 condvar = &default_condvar; in RunTests() 90 std::thread thread_one(ThreadOne, mutex, condvar, notification, &state); in RunTests() 91 std::thread thread_two(ThreadTwo, mutex, condvar, notification, &state); in RunTests() 98 absl::CondVar condvar; in TestLocals() local [all …]
|
/dports/games/retroarch/RetroArch-1.9.7/audio/drivers/ |
H A D | switch_audio_compat.h | 33 #define compat_condvar_create(condvar) \ argument 34 condvarInit(condvar) 35 #define compat_condvar_wait(condvar, mutex) \ argument 36 condvarWait(condvar, mutex) 37 #define compat_condvar_wake_all(condvar) \ argument 38 condvarWakeAll(condvar) 79 #define compat_condvar_create(condvar) \ argument 80 trn_condvar_create(condvar) 82 trn_condvar_wait(condvar, mutex, -1) 83 #define compat_condvar_wake_all(condvar) \ argument [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/abseil-cpp/absl/synchronization/ |
H A D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument 54 condvar->Wait(mutex); in ThreadOne() 59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument 69 condvar->Signal(); in ThreadTwo() 76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument 83 if (!condvar) { in RunTests() 84 condvar = &default_condvar; in RunTests() 87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests() 88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests() 95 absl::CondVar condvar; in TestLocals() local [all …]
|
/dports/devel/abseil/abseil-cpp-20211102.0/absl/synchronization/ |
H A D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument 54 condvar->Wait(mutex); in ThreadOne() 59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument 69 condvar->Signal(); in ThreadTwo() 76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument 83 if (!condvar) { in RunTests() 84 condvar = &default_condvar; in RunTests() 87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests() 88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests() 95 absl::CondVar condvar; in TestLocals() local [all …]
|
/dports/net-im/tg_owt/tg_owt-d578c76/src/third_party/abseil-cpp/absl/synchronization/ |
H A D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument 54 condvar->Wait(mutex); in ThreadOne() 59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument 69 condvar->Signal(); in ThreadTwo() 76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument 83 if (!condvar) { in RunTests() 84 condvar = &default_condvar; in RunTests() 87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests() 88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests() 95 absl::CondVar condvar; in TestLocals() local [all …]
|
/dports/www/firefox/firefox-99.0/third_party/libwebrtc/third_party/abseil-cpp/absl/synchronization/ |
H A D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument 54 condvar->Wait(mutex); in ThreadOne() 59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument 69 condvar->Signal(); in ThreadTwo() 76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument 83 if (!condvar) { in RunTests() 84 condvar = &default_condvar; in RunTests() 87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests() 88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests() 95 absl::CondVar condvar; in TestLocals() local [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/abseil-cpp/absl/synchronization/ |
H A D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument 54 condvar->Wait(mutex); in ThreadOne() 59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument 69 condvar->Signal(); in ThreadTwo() 76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument 83 if (!condvar) { in RunTests() 84 condvar = &default_condvar; in RunTests() 87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests() 88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests() 95 absl::CondVar condvar; in TestLocals() local [all …]
|
/dports/devel/py-grpcio/grpcio-1.43.0/third_party/abseil-cpp/absl/synchronization/ |
H A D | lifetime_test.cc | 41 void ThreadOne(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadOne() argument 54 condvar->Wait(mutex); in ThreadOne() 59 void ThreadTwo(absl::Mutex* mutex, absl::CondVar* condvar, in ThreadTwo() argument 69 condvar->Signal(); in ThreadTwo() 76 void RunTests(absl::Mutex* mutex, absl::CondVar* condvar) { in RunTests() argument 83 if (!condvar) { in RunTests() 84 condvar = &default_condvar; in RunTests() 87 std::thread thread_one(ThreadOne, mutex, condvar, ¬ification, &state); in RunTests() 88 std::thread thread_two(ThreadTwo, mutex, condvar, ¬ification, &state); in RunTests() 95 absl::CondVar condvar; in TestLocals() local [all …]
|
/dports/devel/concurrentqueue/concurrentqueue-1.0.3-15-g0753496/tests/relacy/relacy/relacy/stdlib/ |
H A D | condition_variable.hpp | 222 class condvar class 225 condvar() in condvar() function in rl::condvar 230 condvar(condvar const&) in condvar() function in rl::condvar 235 condvar& operator = (condvar const&) in operator =() 240 ~condvar() in ~condvar() 301 class condition_variable_std : condvar<tag_t> 306 condvar<tag_t>::init(true, $); in condition_variable_std() 311 condvar<tag_t>::deinit($); in ~condition_variable_std() 316 condvar<tag_t>::notify_one(info); in notify_one() 321 condvar<tag_t>::notify_all(info); in notify_all() [all …]
|
/dports/graphics/Coin/coin-Coin-4.0.0/include/Inventor/threads/ |
H A D | SbCondVar.h | 43 SbCondVar(void) { this->condvar = cc_condvar_construct(); } in SbCondVar() 44 ~SbCondVar(void) { cc_condvar_destruct(this->condvar); } in ~SbCondVar() 47 return cc_condvar_wait(this->condvar, mutex.mutex) == CC_OK; in wait() 50 return cc_condvar_timed_wait(this->condvar, mutex.mutex, period.getValue()) == CC_OK; in timedWait() 53 void wakeOne(void) { cc_condvar_wake_one(this->condvar); } in wakeOne() 54 void wakeAll(void) { cc_condvar_wake_all(this->condvar); } in wakeAll() 57 cc_condvar * condvar;
|
/dports/net/p5-AnyEvent-MQTT/AnyEvent-MQTT-1.142640/t/ |
H A D | 01-subscribe.t | 76 my $t1_cv = AnyEvent->condvar; 83 my $t2_cv = AnyEvent->condvar; 92 my $t2_dup_cv = AnyEvent->condvar; 104 $t1_cv = AnyEvent->condvar; 105 my $t1_dup_cv = AnyEvent->condvar; 106 my $t1_dup_sub = AnyEvent->condvar; 122 $t1_cv = AnyEvent->condvar; 123 $t1_dup_cv = AnyEvent->condvar; 136 $t1_cv = AnyEvent->condvar; 137 $t1_dup_cv = AnyEvent->condvar; [all …]
|
/dports/multimedia/librespot/librespot-0.1.3/cargo-crates/parking_lot_core-0.6.2/src/thread_parker/ |
H A D | cloudabi.rs | 125 condvar: AtomicU32, field 140 condvar: abi::subscription_condvar { in wait() 141 condvar: self.ptr(), in wait() 167 condvar: self.ptr(), in wait_timeout() 207 fn ptr(&self) -> *mut abi::condvar { in ptr() argument 208 &self.condvar as *const AtomicU32 as *mut abi::condvar in ptr() 216 condvar: Condvar, field 228 condvar: Condvar::new(), in new() 247 self.condvar.wait(&guard); in park() 259 self.condvar.wait(&guard); in park_until() [all …]
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/parking_lot_core-0.6.2/src/thread_parker/ |
H A D | cloudabi.rs | 125 condvar: AtomicU32, field 140 condvar: abi::subscription_condvar { in wait() 141 condvar: self.ptr(), in wait() 167 condvar: self.ptr(), in wait_timeout() 207 fn ptr(&self) -> *mut abi::condvar { in ptr() argument 208 &self.condvar as *const AtomicU32 as *mut abi::condvar in ptr() 216 condvar: Condvar, field 228 condvar: Condvar::new(), in new() 247 self.condvar.wait(&guard); in park() 259 self.condvar.wait(&guard); in park_until() [all …]
|
/dports/devel/rust-cbindgen/cbindgen-0.20.0/cargo-crates/parking_lot_core-0.7.2/src/thread_parker/ |
H A D | cloudabi.rs | 125 condvar: AtomicU32, field 140 condvar: abi::subscription_condvar { in wait() 141 condvar: self.ptr(), in wait() 167 condvar: self.ptr(), in wait_timeout() 213 fn ptr(&self) -> *mut abi::condvar { in ptr() argument 214 &self.condvar as *const AtomicU32 as *mut abi::condvar in ptr() 222 condvar: Condvar, field 234 condvar: Condvar::new(), in new() 253 self.condvar.wait(&guard); in park() 265 self.condvar.wait(&guard); in park_until() [all …]
|
/dports/net-mgmt/nfs-exporter/freebsd-nfs-exporter-0.3.0/cargo-crates/parking_lot_core-0.6.2/src/thread_parker/ |
H A D | cloudabi.rs | 125 condvar: AtomicU32, field 140 condvar: abi::subscription_condvar { in wait() 141 condvar: self.ptr(), in wait() 167 condvar: self.ptr(), in wait_timeout() 207 fn ptr(&self) -> *mut abi::condvar { in ptr() argument 208 &self.condvar as *const AtomicU32 as *mut abi::condvar in ptr() 216 condvar: Condvar, field 228 condvar: Condvar::new(), in new() 247 self.condvar.wait(&guard); in park() 259 self.condvar.wait(&guard); in park_until() [all …]
|
/dports/editors/kibi/kibi-0.2.2/cargo-crates/parking_lot_core-0.7.2/src/thread_parker/ |
H A D | cloudabi.rs | 125 condvar: AtomicU32, field 140 condvar: abi::subscription_condvar { in wait() 141 condvar: self.ptr(), in wait() 167 condvar: self.ptr(), in wait_timeout() 213 fn ptr(&self) -> *mut abi::condvar { in ptr() argument 214 &self.condvar as *const AtomicU32 as *mut abi::condvar in ptr() 222 condvar: Condvar, field 234 condvar: Condvar::new(), in new() 253 self.condvar.wait(&guard); in park() 265 self.condvar.wait(&guard); in park_until() [all …]
|
/dports/www/ffsend/ffsend-ccd489ce2e75b91c0f17fbf13dbd91fe84f5ad98/cargo-crates/parking_lot_core-0.6.2/src/thread_parker/ |
H A D | cloudabi.rs | 125 condvar: AtomicU32, field 140 condvar: abi::subscription_condvar { in wait() 141 condvar: self.ptr(), in wait() 167 condvar: self.ptr(), in wait_timeout() 207 fn ptr(&self) -> *mut abi::condvar { in ptr() argument 208 &self.condvar as *const AtomicU32 as *mut abi::condvar in ptr() 216 condvar: Condvar, field 228 condvar: Condvar::new(), in new() 247 self.condvar.wait(&guard); in park() 259 self.condvar.wait(&guard); in park_until() [all …]
|