Home
last modified time | relevance | path

Searched refs:condvar (Results 1 – 25 of 1673) sorted by relevance

12345678910>>...67

/dports/lang/ruby26/ruby-2.6.9/test/ruby/
H A Dtest_thread_cv.rb17 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 Dcondvar.cpp106 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 Dcondvar_win32.icc33 /* 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 Dchannel.scm29 (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 Dcondvar.scm13 (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 Dexternal-event.scm27 (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 D02_sql_lite.t35 $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 D01_fake_mysql.t44 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 Dlifetime_test.cc40 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 Dswitch_audio_compat.h33 #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 Dlifetime_test.cc41 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, &notification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, &notification, &state); in RunTests()
95 absl::CondVar condvar; in TestLocals() local
[all …]
/dports/devel/abseil/abseil-cpp-20211102.0/absl/synchronization/
H A Dlifetime_test.cc41 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, &notification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, &notification, &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 Dlifetime_test.cc41 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, &notification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, &notification, &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 Dlifetime_test.cc41 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, &notification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, &notification, &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 Dlifetime_test.cc41 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, &notification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, &notification, &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 Dlifetime_test.cc41 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, &notification, &state); in RunTests()
88 std::thread thread_two(ThreadTwo, mutex, condvar, &notification, &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 Dcondition_variable.hpp222 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 DSbCondVar.h43 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 D01-subscribe.t76 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 Dcloudabi.rs125 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 Dcloudabi.rs125 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 Dcloudabi.rs125 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 Dcloudabi.rs125 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 Dcloudabi.rs125 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 Dcloudabi.rs125 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 …]

12345678910>>...67