Home
last modified time | relevance | path

Searched refs:barrier1 (Results 1 – 25 of 59) sorted by relevance

123

/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/sample/chatserver/
H A DChatTest.java148 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performDontReceiveMessageInNameState() local
160 barrier1.await(); in performDontReceiveMessageInNameState()
170 barrier1.await(); in performDontReceiveMessageInNameState()
197 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestUsernameAndMessage() local
209 barrier1.await(); in performTestUsernameAndMessage()
222 barrier1.await(); in performTestUsernameAndMessage()
237 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestConnectDisconnectConnect() local
257 barrier1.await(); in performTestConnectDisconnectConnect()
272 barrier1.await(); in performTestConnectDisconnectConnect()
304 barrier1.await(); in performTestUseName()
[all …]
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/sample/chatserver/
H A DChatTest.java148 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performDontReceiveMessageInNameState() local
160 barrier1.await(); in performDontReceiveMessageInNameState()
170 barrier1.await(); in performDontReceiveMessageInNameState()
197 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestUsernameAndMessage() local
209 barrier1.await(); in performTestUsernameAndMessage()
222 barrier1.await(); in performTestUsernameAndMessage()
237 final CyclicBarrier barrier1 = new CyclicBarrier(2); in performTestConnectDisconnectConnect() local
257 barrier1.await(); in performTestConnectDisconnectConnect()
272 barrier1.await(); in performTestConnectDisconnectConnect()
304 barrier1.await(); in performTestUseName()
[all …]
/dports/biology/stringtie/stringtie-2.1.1/SuperReads_RNA/global-1/quorum/include/jflib/
H A Dlocks_pthread.hpp148 Semaphore barrier1; // implement the barrier member in jflib::locks::pthread::barrier
153 : count(cnt), current(0), barrier1(0), barrier2(0) { in barrier()
165 barrier1.signal(); in wait()
169 barrier1.wait(); // wait for n threads to arrive in wait()
/dports/biology/stringtie/stringtie-2.1.1/SuperReads_RNA/global-1/jellyfish/include/jellyfish/
H A Dlocks_pthread.hpp167 Semaphore barrier1; // implement the barrier member in jellyfish::locks::pthread::barrier
172 : count(cnt), current(0), barrier1(0), barrier2(0) { in barrier()
184 barrier1.signal(); in wait()
188 barrier1.wait(); // wait for n threads to arrive in wait()
/dports/biology/jellyfish/jellyfish-2.3.0/include/jellyfish/
H A Dlocks_pthread.hpp159 Semaphore barrier1; // implement the barrier member in jellyfish::locks::pthread::barrier
164 : count(cnt), current(0), barrier1(0), barrier2(0) { in barrier()
176 barrier1.signal(); in wait()
180 barrier1.wait(); // wait for n threads to arrive in wait()
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Threading.Tasks.Dataflow/tests/Dataflow/
H A DActionBlockTests.cs206 Barrier barrier1 = new Barrier(2), barrier2 = new Barrier(2); in TestInputCount()
209 barrier1.SignalAndWait(); in TestInputCount()
223 barrier1.SignalAndWait(); in TestInputCount()
262 var barrier1 = new Barrier(2); in TestNonGreedy()
263 Action<int> body = _ => barrier1.SignalAndWait(); in TestNonGreedy()
278 barrier1.SignalAndWait(); in TestNonGreedy()
445 Barrier barrier1 = new Barrier(2), barrier2 = new Barrier(2); in TestReleasingOfPostponedMessages()
446 Action<int> body = i => { barrier1.SignalAndWait(); barrier2.SignalAndWait(); }; in TestReleasingOfPostponedMessages()
453 barrier1.SignalAndWait(); in TestReleasingOfPostponedMessages()
H A DTransformBlockTests.cs291 Barrier barrier1 = new Barrier(2), barrier2 = new Barrier(2); in TestInputCount()
293 barrier1.SignalAndWait(); in TestInputCount()
308 barrier1.SignalAndWait(); in TestInputCount()
/dports/sysutils/diskonaut/diskonaut-0.11.0/cargo-crates/mio-0.7.0/tests/
H A Dpoll.rs237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable
259 barrier1.wait(); in registry_operations_are_thread_safe()
260 barrier1.wait(); in registry_operations_are_thread_safe()
319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable
324 barrier1.wait(); in register_during_poll()
333 barrier1.wait(); in register_during_poll()
424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable
444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
/dports/graphics/viu/viu-1.1/cargo-crates/mio-0.7.0/tests/
H A Dpoll.rs237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable
259 barrier1.wait(); in registry_operations_are_thread_safe()
260 barrier1.wait(); in registry_operations_are_thread_safe()
319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable
324 barrier1.wait(); in register_during_poll()
333 barrier1.wait(); in register_during_poll()
424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable
444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
/dports/devel/gitui/gitui-0.10.1/cargo-crates/mio-0.7.0/tests/
H A Dpoll.rs237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable
259 barrier1.wait(); in registry_operations_are_thread_safe()
260 barrier1.wait(); in registry_operations_are_thread_safe()
319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable
324 barrier1.wait(); in register_during_poll()
333 barrier1.wait(); in register_during_poll()
424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable
444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
/dports/devel/desed/desed-1.2.0/cargo-crates/mio-0.7.0/tests/
H A Dpoll.rs237 let barrier1 = Arc::clone(&barrier); in registry_operations_are_thread_safe() localVariable
259 barrier1.wait(); in registry_operations_are_thread_safe()
260 barrier1.wait(); in registry_operations_are_thread_safe()
319 let barrier1 = Arc::clone(&barrier); in register_during_poll() localVariable
324 barrier1.wait(); in register_during_poll()
333 barrier1.wait(); in register_during_poll()
424 let barrier1 = Arc::clone(&barrier); in poll_ok_after_cancelling_pending_ops() localVariable
444 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
450 barrier1.wait(); in poll_ok_after_cancelling_pending_ops()
/dports/audio/spotify-tui/spotify-tui-0.25.0/cargo-crates/mio-0.7.0/tests/
H A Dpoll.rs237 let barrier1 = Arc::clone(&barrier);
259 barrier1.wait();
260 barrier1.wait();
319 let barrier1 = Arc::clone(&barrier);
324 barrier1.wait();
333 barrier1.wait();
424 let barrier1 = Arc::clone(&barrier);
444 barrier1.wait();
450 barrier1.wait();
/dports/java/eclipse/eclipse.platform.releng.aggregator-R4_16/eclipse.platform.runtime/tests/org.eclipse.core.tests.runtime/src/org/eclipse/core/tests/runtime/jobs/
H A DYieldTest.java99 final TestBarrier barrier1 = new TestBarrier(location, 0); in testExceptionWhenYieldingNotOwner() local
106 barrier1.waitForStatus(TestBarrier.STATUS_START); in testExceptionWhenYieldingNotOwner()
120 barrier1.setStatus(TestBarrier.STATUS_START); in testExceptionWhenYieldingNotOwner()
282 final TestBarrier barrier1 = new TestBarrier(location, 0); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume() local
287 barrier1.waitForStatus(TestBarrier.STATUS_START); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume()
288 barrier1.setStatus(TestBarrier.STATUS_RUNNING); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume()
292 barrier1.waitForStatus(TestBarrier.STATUS_DONE); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume()
302 barrier1.setStatus(TestBarrier.STATUS_DONE); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume()
317 barrier1.setStatus(TestBarrier.STATUS_START); in testYieldJobToJobAndEnsureConflictingRunsBeforeResume()
/dports/misc/visp/visp-3.4.0/3rdparty/pthreads4w/
H A DNmakefile.tests124 barrier1:: barrier1.c
244 barrier1 :test:
245 barrier2 :test: barrier1.c
/dports/devel/mingw32-pthreads/pthreads-w32-2-8-0-release/
H A DNmakefile.tests124 barrier1:: barrier1.c
244 barrier1 :test:
245 barrier2 :test: barrier1.c
/dports/multimedia/obs-studio/obs-studio-27.1.3/deps/w32-pthreads/
H A DNmakefile.tests124 barrier1:: barrier1.c
244 barrier1 :test:
245 barrier2 :test: barrier1.c
/dports/devel/hadoop/hadoop-1.2.1/src/test/org/apache/hadoop/metrics2/impl/
H A DTestMetricsSystemImpl.java108 final CyclicBarrier barrier1 = new CyclicBarrier(numThreads), in testMultiThreadedPublish() local
117 barrier1.await(2, TimeUnit.SECONDS); in testMultiThreadedPublish()
145 if (!safeAwait(mySource, barrier1)) return; in testMultiThreadedPublish()
/dports/finance/quantlib/QuantLib-1.20/test-suite/
H A Ddoublebarrieroption.cpp73 barrier1, barrier2, rebate, payoff, \ argument
84 << " barrier1: " << barrier1 << "\n" \
127 Real barrier1; member
494 values[i].barrier1, in testVannaVolgaDoubleBarrierValues()
528 values[i].barrier1, values[i].barrier2, in testVannaVolgaDoubleBarrierValues()
553 values[i].barrier1, values[i].barrier2, in testVannaVolgaDoubleBarrierValues()
/dports/multimedia/obs-studio/obs-studio-27.1.3/deps/w32-pthreads/tests/
H A DGNUmakefile111 barrier1 barrier2 barrier3 barrier4 barrier5 barrier6 \
150 barrier1 barrier2 barrier3 barrier4 barrier5 barrier6 \
250 barrier1.pass: semaphore4.pass
251 barrier2.pass: barrier1.pass
H A DMakefile107 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass barrier6.pass \
153 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass barrier6.pass \
317 barrier1.pass: semaphore4.pass
318 barrier2.pass: barrier1.pass
H A DWmakefile117 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass &
226 barrier1.pass:
227 barrier2.pass: barrier1.pass
/dports/devel/mingw32-pthreads/pthreads-w32-2-8-0-release/tests/
H A DGNUmakefile93 barrier1 barrier2 barrier3 barrier4 barrier5 \
188 barrier1.pass: semaphore4.pass
189 barrier2.pass: barrier1.pass
H A DMakefile103 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass \
278 barrier1.pass: semaphore4.pass
279 barrier2.pass: barrier1.pass
H A DWmakefile113 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass &
222 barrier1.pass:
223 barrier2.pass: barrier1.pass
H A DBmakefile99 barrier1.pass barrier2.pass barrier3.pass barrier4.pass barrier5.pass \
224 barrier1.pass: semaphore4.pass
225 barrier2.pass: barrier1.pass

123