| /dports/net-p2p/libktorrent/libktorrent-21.12.3/src/peer/tests/ |
| H A D | connectionlimittest.cpp | 34 bt::ConnectionLimit::Token::Ptr t = climit.acquire(hash); in testGlobalLimit()
39 bt::ConnectionLimit::Token::Ptr t = climit.acquire(hash); in testGlobalLimit()
44 t = climit.acquire(hash); in testGlobalLimit()
56 bt::ConnectionLimit::Token::Ptr t = climit.acquire(hash); in testTorrentLimit()
61 bt::ConnectionLimit::Token::Ptr t = climit.acquire(hash); in testTorrentLimit()
66 t = climit.acquire(hash); in testTorrentLimit()
84 bt::ConnectionLimit::Token::Ptr t = climit.acquire(hash1); in testMulitpleTorrents()
89 QVERIFY(climit.acquire(hash1).isNull()); in testMulitpleTorrents()
97 bt::ConnectionLimit::Token::Ptr t = climit.acquire(hash1); in testMulitpleTorrents()
100 t = climit.acquire(hash2); in testMulitpleTorrents()
[all …]
|
| /dports/www/moinmoin/moin-1.9.11/MoinMoin/util/_tests/ |
| H A D | test_lock.py | 51 assert lock.acquire(0.1)
59 if not lock.acquire(0.1):
62 assert lock.acquire(0.1)
67 if not lock.acquire(0.1):
76 if not lock.acquire(0.1):
84 if not lock.acquire(0.1):
94 if not lock.acquire(0.1):
104 if not first.acquire(0.1):
106 assert not second.acquire(0.1)
116 if not first.acquire(0.1):
[all …]
|
| /dports/www/restbed/restbed-4.8/dependency/catch/projects/SelfTest/IntrospectiveTests/ |
| H A D | PartTracker.tests.cpp | 28 ITracker& testCase = SectionTracker::acquire( ctx, makeNAL( "Testcase" ) );
31 ITracker& s1 = SectionTracker::acquire( ctx, makeNAL( "S1" ) );
59 ITracker& s1b = SectionTracker::acquire( ctx, makeNAL( "S1" ) );
72 ITracker& s1b = SectionTracker::acquire( ctx, makeNAL( "S1" ) );
75 ITracker& s2 = SectionTracker::acquire( ctx, makeNAL( "S2" ) );
90 ITracker& s2 = SectionTracker::acquire( ctx, makeNAL( "S2" ) );
101 ITracker& s1b = SectionTracker::acquire( ctx, makeNAL( "S1" ) );
104 ITracker& s2b = SectionTracker::acquire( ctx, makeNAL( "S2" ) );
134 ITracker& s1c = SectionTracker::acquire( ctx, makeNAL( "S1" ) );
137 ITracker& s2c = SectionTracker::acquire( ctx, makeNAL( "S2" ) );
[all …]
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 79 lock.acquire(); in realRun()
92 lock.acquire(); in realRun()
123 acquire() { in acquire() method
125 s.acquire(); in acquire()
170 acquire(s, 1); in acquire()
175 acquire(s); in acquire()
490 s.acquire(); in testSerialization()
491 s.acquire(); in testSerialization()
499 clone.acquire(); in testSerialization()
500 clone.acquire(); in testSerialization()
[all …]
|
| /dports/science/py-paida/paida-3.2.1_2.10.1/paida/paida_gui/batch/ |
| H A D | PRoot.py | 45 rootCondition.acquire()
67 rootCondition.acquire()
69 lock.acquire()
136 treeCondition.acquire()
159 treeCondition.acquire()
235 self.getLock().acquire()
240 self.getLock().acquire()
245 self.getLock().acquire()
250 self.getLock().acquire()
273 self.getLock().acquire()
[all …]
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 79 lock.acquire(); in realRun()
92 lock.acquire(); in realRun()
123 acquire() { in acquire() enumConstant
125 s.acquire(); in acquire()
170 acquire(s, 1); in acquire()
175 acquire(s); in acquire()
490 s.acquire(); in testSerialization()
491 s.acquire(); in testSerialization()
499 clone.acquire(); in testSerialization()
500 clone.acquire(); in testSerialization()
[all …]
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 79 lock.acquire(); in realRun()
92 lock.acquire(); in realRun()
123 acquire() { in acquire() enumConstant
125 s.acquire(); in acquire()
170 acquire(s, 1); in acquire()
175 acquire(s); in acquire()
490 s.acquire(); in testSerialization()
491 s.acquire(); in testSerialization()
499 clone.acquire(); in testSerialization()
500 clone.acquire(); in testSerialization()
[all …]
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 78 lock.acquire(); in realRun()
91 lock.acquire(); in realRun()
122 acquire() { in acquire() method
124 s.acquire(); in acquire()
169 acquire(s, 1); in acquire()
174 acquire(s); in acquire()
487 s.acquire(); in testSerialization()
488 s.acquire(); in testSerialization()
496 clone.acquire(); in testSerialization()
497 clone.acquire(); in testSerialization()
[all …]
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 78 lock.acquire(); in realRun()
91 lock.acquire(); in realRun()
122 acquire() { in acquire() enumConstant
124 s.acquire(); in acquire()
169 acquire(s, 1); in acquire()
174 acquire(s); in acquire()
487 s.acquire(); in testSerialization()
488 s.acquire(); in testSerialization()
496 clone.acquire(); in testSerialization()
497 clone.acquire(); in testSerialization()
[all …]
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 78 lock.acquire(); in realRun()
91 lock.acquire(); in realRun()
122 acquire() { in acquire() method
124 s.acquire(); in acquire()
169 acquire(s, 1); in acquire()
174 acquire(s); in acquire()
487 s.acquire(); in testSerialization()
488 s.acquire(); in testSerialization()
496 clone.acquire(); in testSerialization()
497 clone.acquire(); in testSerialization()
[all …]
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 79 lock.acquire(); in realRun()
92 lock.acquire(); in realRun()
123 acquire() { in acquire() enumConstant
125 s.acquire(); in acquire()
170 acquire(s, 1); in acquire()
175 acquire(s); in acquire()
490 s.acquire(); in testSerialization()
491 s.acquire(); in testSerialization()
499 clone.acquire(); in testSerialization()
500 clone.acquire(); in testSerialization()
[all …]
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/util/concurrent/tck/ |
| H A D | SemaphoreTest.java | 78 lock.acquire(); in realRun()
91 lock.acquire(); in realRun()
122 acquire() { in acquire() enumConstant
124 s.acquire(); in acquire()
169 acquire(s, 1); in acquire()
174 acquire(s); in acquire()
487 s.acquire(); in testSerialization()
488 s.acquire(); in testSerialization()
496 clone.acquire(); in testSerialization()
497 clone.acquire(); in testSerialization()
[all …]
|
| /dports/devel/stxxl/stxxl-1.4.1/tests/mng/ |
| H A D | test_block_scheduler.cpp | 161 bs.acquire(sbi); in test1()
162 bs.acquire(sbi); in test1()
187 bs.acquire(sbi); in test1()
188 bs.acquire(sbi); in test1()
205 bs.acquire(sbi); in test1()
206 bs.acquire(sbi); in test1()
290 bs.acquire(sbi); in test3()
302 bs.acquire(sbi); in test3()
315 bs.acquire(sbi); in test3()
327 bs.acquire(sbi); in test3()
[all …]
|
| /dports/misc/thrill/thrill-12c5b59bca66df93b66628b3829027bd0f110dd9/extlib/foxxll/tests/mng/ |
| H A D | test_block_scheduler.cpp | 165 bs.acquire(sbi); in test1()
166 bs.acquire(sbi); in test1()
192 bs.acquire(sbi); in test1()
193 bs.acquire(sbi); in test1()
208 bs.acquire(sbi); in test1()
209 bs.acquire(sbi); in test1()
292 bs.acquire(sbi); in test3()
304 bs.acquire(sbi); in test3()
317 bs.acquire(sbi); in test3()
329 bs.acquire(sbi); in test3()
[all …]
|
| /dports/www/firefox/firefox-99.0/third_party/python/ecdsa/ecdsa/ |
| H A D | _rwlock.py | 48 self.__readers_queue.acquire()
49 self.__no_readers.acquire()
50 self.__read_switch.acquire(self.__no_writers)
58 self.__write_switch.acquire(self.__no_readers)
59 self.__no_writers.acquire()
73 def acquire(self, lock): member in _LightSwitch
74 self.__mutex.acquire()
77 lock.acquire()
81 self.__mutex.acquire()
|
| /dports/mail/thunderbird/thunderbird-91.8.0/third_party/python/ecdsa/ecdsa/ |
| H A D | _rwlock.py | 48 self.__readers_queue.acquire()
49 self.__no_readers.acquire()
50 self.__read_switch.acquire(self.__no_writers)
58 self.__write_switch.acquire(self.__no_readers)
59 self.__no_writers.acquire()
73 def acquire(self, lock): member in _LightSwitch
74 self.__mutex.acquire()
77 lock.acquire()
81 self.__mutex.acquire()
|
| /dports/security/py-ecdsa/ecdsa-0.16.0/src/ecdsa/ |
| H A D | _rwlock.py | 48 self.__readers_queue.acquire()
49 self.__no_readers.acquire()
50 self.__read_switch.acquire(self.__no_writers)
58 self.__write_switch.acquire(self.__no_readers)
59 self.__no_writers.acquire()
74 def acquire(self, lock): member in _LightSwitch
75 self.__mutex.acquire()
78 lock.acquire()
82 self.__mutex.acquire()
|
| /dports/www/firefox-esr/firefox-91.8.0/third_party/python/ecdsa/ecdsa/ |
| H A D | _rwlock.py | 48 self.__readers_queue.acquire()
49 self.__no_readers.acquire()
50 self.__read_switch.acquire(self.__no_writers)
58 self.__write_switch.acquire(self.__no_readers)
59 self.__no_writers.acquire()
73 def acquire(self, lock): member in _LightSwitch
74 self.__mutex.acquire()
77 lock.acquire()
81 self.__mutex.acquire()
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/ecdsa/src/ecdsa/ |
| H A D | _rwlock.py | 48 self.__readers_queue.acquire()
49 self.__no_readers.acquire()
50 self.__read_switch.acquire(self.__no_writers)
58 self.__write_switch.acquire(self.__no_readers)
59 self.__no_writers.acquire()
73 def acquire(self, lock): member in _LightSwitch
74 self.__mutex.acquire()
77 lock.acquire()
81 self.__mutex.acquire()
|
| /dports/devel/llvm80/llvm-8.0.1.src/test/CodeGen/X86/ |
| H A D | atomic16.ll | 11 %t1 = atomicrmw add i16* @sc16, i16 1 acquire
16 %t2 = atomicrmw add i16* @sc16, i16 3 acquire
21 %t3 = atomicrmw add i16* @sc16, i16 5 acquire
26 %t4 = atomicrmw add i16* @sc16, i16 %t3 acquire
39 %t1 = atomicrmw sub i16* @sc16, i16 1 acquire
44 %t2 = atomicrmw sub i16* @sc16, i16 3 acquire
49 %t3 = atomicrmw sub i16* @sc16, i16 5 acquire
67 %t1 = atomicrmw and i16* @sc16, i16 3 acquire
72 %t2 = atomicrmw and i16* @sc16, i16 5 acquire
92 %t1 = atomicrmw or i16* @sc16, i16 3 acquire
[all …]
|
| /dports/devel/llvm70/llvm-7.0.1.src/test/CodeGen/X86/ |
| H A D | atomic16.ll | 11 %t1 = atomicrmw add i16* @sc16, i16 1 acquire
16 %t2 = atomicrmw add i16* @sc16, i16 3 acquire
21 %t3 = atomicrmw add i16* @sc16, i16 5 acquire
26 %t4 = atomicrmw add i16* @sc16, i16 %t3 acquire
39 %t1 = atomicrmw sub i16* @sc16, i16 1 acquire
44 %t2 = atomicrmw sub i16* @sc16, i16 3 acquire
49 %t3 = atomicrmw sub i16* @sc16, i16 5 acquire
67 %t1 = atomicrmw and i16* @sc16, i16 3 acquire
72 %t2 = atomicrmw and i16* @sc16, i16 5 acquire
92 %t1 = atomicrmw or i16* @sc16, i16 3 acquire
[all …]
|
| /dports/devel/sccache/sccache-0.2.15/cargo-crates/tokio-0.2.24/src/sync/tests/ |
| H A D | loom_semaphore_batch.rs | 24 shared.semaphore.acquire(1).await.unwrap(); in basic_usage()
59 block_on(semaphore.acquire(1)).unwrap(); in release()
64 block_on(semaphore.acquire(1)).unwrap(); in release()
119 let mut acquire1 = Some(semaphore.acquire(1)); in concurrent_cancel()
120 let mut acquire2 = Some(semaphore.acquire(1)); in concurrent_cancel()
125 if let Some(acquire) = acquire1.take() { in concurrent_cancel()
126 pin!(acquire); in concurrent_cancel()
127 let _ = acquire.poll(cx); in concurrent_cancel()
129 if let Some(acquire) = acquire2.take() { in concurrent_cancel()
130 pin!(acquire); in concurrent_cancel()
[all …]
|
| /dports/net/gemserv/gemserv-v0.4.5/cargo-crates/tokio-0.2.24/src/sync/tests/ |
| H A D | loom_semaphore_batch.rs | 24 shared.semaphore.acquire(1).await.unwrap(); in basic_usage()
59 block_on(semaphore.acquire(1)).unwrap(); in release()
64 block_on(semaphore.acquire(1)).unwrap(); in release()
119 let mut acquire1 = Some(semaphore.acquire(1)); in concurrent_cancel()
120 let mut acquire2 = Some(semaphore.acquire(1)); in concurrent_cancel()
125 if let Some(acquire) = acquire1.take() { in concurrent_cancel()
126 pin!(acquire); in concurrent_cancel()
127 let _ = acquire.poll(cx); in concurrent_cancel()
129 if let Some(acquire) = acquire2.take() { in concurrent_cancel()
130 pin!(acquire); in concurrent_cancel()
[all …]
|
| /dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/cargo-crates/tokio-1.10.1/src/sync/tests/ |
| H A D | loom_semaphore_batch.rs | 24 shared.semaphore.acquire(1).await.unwrap(); in basic_usage()
59 block_on(semaphore.acquire(1)).unwrap(); in release()
64 block_on(semaphore.acquire(1)).unwrap(); in release()
119 let mut acquire1 = Some(semaphore.acquire(1)); in concurrent_cancel()
120 let mut acquire2 = Some(semaphore.acquire(1)); in concurrent_cancel()
125 if let Some(acquire) = acquire1.take() { in concurrent_cancel()
126 pin!(acquire); in concurrent_cancel()
127 let _ = acquire.poll(cx); in concurrent_cancel()
129 if let Some(acquire) = acquire2.take() { in concurrent_cancel()
130 pin!(acquire); in concurrent_cancel()
[all …]
|
| /dports/security/vaultwarden/vaultwarden-1.23.1/cargo-crates/tokio-1.14.0/src/sync/tests/ |
| H A D | loom_semaphore_batch.rs | 24 shared.semaphore.acquire(1).await.unwrap(); in basic_usage()
59 block_on(semaphore.acquire(1)).unwrap(); in release()
64 block_on(semaphore.acquire(1)).unwrap(); in release()
119 let mut acquire1 = Some(semaphore.acquire(1)); in concurrent_cancel()
120 let mut acquire2 = Some(semaphore.acquire(1)); in concurrent_cancel()
125 if let Some(acquire) = acquire1.take() { in concurrent_cancel()
126 pin!(acquire); in concurrent_cancel()
127 let _ = acquire.poll(cx); in concurrent_cancel()
129 if let Some(acquire) = acquire2.take() { in concurrent_cancel()
130 pin!(acquire); in concurrent_cancel()
[all …]
|