| /dports/math/clblas/clBLAS-2.10/src/tests/functional/ |
| H A D | func-queue.cpp | 42 void testQueue();
102 ec.testQueue(); in TEST()
107 ec.testQueue(); in TEST()
113 ec.testQueue(); in TEST()
119 ec.testQueue(); in TEST()
124 ec.testQueue(); in TEST()
129 ec.testQueue(); in TEST()
135 ec.testQueue(); in TEST()
141 ec.testQueue(); in TEST()
146 ec.testQueue(); in TEST()
[all …]
|
| /dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/src/test/util/ |
| H A D | PriorityQueueTest.cpp | 52 testQueue->add(next); in TEST_F()
70 testQueue->addOverflow(2); in TEST_F()
71 testQueue->addOverflow(3); in TEST_F()
72 testQueue->addOverflow(1); in TEST_F()
73 testQueue->addOverflow(5); in TEST_F()
74 testQueue->addOverflow(7); in TEST_F()
82 testQueue->add(2); in TEST_F()
83 testQueue->add(3); in TEST_F()
84 testQueue->add(1); in TEST_F()
86 testQueue->clear(); in TEST_F()
[all …]
|
| /dports/devel/libzookeeper/apache-zookeeper-3.7.0/zookeeper-server/src/test/java/org/apache/zookeeper/util/ |
| H A D | TestCircularBlockingQueue.java | 36 testQueue.offer(1); in testCircularBlockingQueue()
37 testQueue.offer(2); in testCircularBlockingQueue()
38 testQueue.offer(3); in testCircularBlockingQueue()
40 assertEquals(2, testQueue.size()); in testCircularBlockingQueue()
42 assertEquals(2, testQueue.take().intValue()); in testCircularBlockingQueue()
43 assertEquals(3, testQueue.take().intValue()); in testCircularBlockingQueue()
45 assertEquals(1L, testQueue.getDroppedCount()); in testCircularBlockingQueue()
46 assertEquals(0, testQueue.size()); in testCircularBlockingQueue()
47 assertEquals(true, testQueue.isEmpty()); in testCircularBlockingQueue()
60 return testQueue.take(); in testCircularBlockingQueueTakeBlock()
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/dop251/goja/ |
| H A D | tc39_race_test.go | 14 ctx.testQueue = append(ctx.testQueue, tc39Test{name: name, f: f})
15 if len(ctx.testQueue) >= tc39MaxTestGroupSize {
22 for _, tc := range ctx.testQueue {
30 ctx.testQueue = ctx.testQueue[:0]
|
| /dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/dop251/goja/ |
| H A D | tc39_race_test.go | 15 ctx.testQueue = append(ctx.testQueue, tc39Test{name: name, f: f})
16 if len(ctx.testQueue) >= tc39MaxTestGroupSize {
23 for _, tc := range ctx.testQueue {
31 ctx.testQueue = ctx.testQueue[:0]
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 52 testQueue(new LinkedBlockingQueue(10)); in test()
53 testQueue(new LinkedBlockingQueue()); in test()
54 testQueue(new LinkedBlockingDeque(10)); in test()
55 testQueue(new LinkedBlockingDeque()); in test()
56 testQueue(new ArrayBlockingQueue(10)); in test()
57 testQueue(new PriorityBlockingQueue(10)); in test()
58 testQueue(new ConcurrentLinkedDeque()); in test()
59 testQueue(new ConcurrentLinkedQueue()); in test()
60 testQueue(new LinkedTransferQueue()); in test()
67 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 52 testQueue(new LinkedBlockingQueue(10)); in test()
53 testQueue(new LinkedBlockingQueue()); in test()
54 testQueue(new LinkedBlockingDeque(10)); in test()
55 testQueue(new LinkedBlockingDeque()); in test()
56 testQueue(new ArrayBlockingQueue(10)); in test()
57 testQueue(new PriorityBlockingQueue(10)); in test()
58 testQueue(new ConcurrentLinkedDeque()); in test()
59 testQueue(new ConcurrentLinkedQueue()); in test()
60 testQueue(new LinkedTransferQueue()); in test()
67 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 63 testQueue(new LinkedBlockingQueue(10)); in test()
64 testQueue(new LinkedBlockingQueue()); in test()
65 testQueue(new LinkedBlockingDeque(10)); in test()
66 testQueue(new LinkedBlockingDeque()); in test()
67 testQueue(new ArrayBlockingQueue(10)); in test()
68 testQueue(new PriorityBlockingQueue(10)); in test()
69 testQueue(new ConcurrentLinkedDeque()); in test()
70 testQueue(new ConcurrentLinkedQueue()); in test()
71 testQueue(new LinkedTransferQueue()); in test()
74 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 63 testQueue(new LinkedBlockingQueue(10)); in test()
64 testQueue(new LinkedBlockingQueue()); in test()
65 testQueue(new LinkedBlockingDeque(10)); in test()
66 testQueue(new LinkedBlockingDeque()); in test()
67 testQueue(new ArrayBlockingQueue(10)); in test()
68 testQueue(new PriorityBlockingQueue(10)); in test()
69 testQueue(new ConcurrentLinkedDeque()); in test()
70 testQueue(new ConcurrentLinkedQueue()); in test()
71 testQueue(new LinkedTransferQueue()); in test()
74 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 63 testQueue(new LinkedBlockingQueue(10)); in test()
64 testQueue(new LinkedBlockingQueue()); in test()
65 testQueue(new LinkedBlockingDeque(10)); in test()
66 testQueue(new LinkedBlockingDeque()); in test()
67 testQueue(new ArrayBlockingQueue(10)); in test()
68 testQueue(new PriorityBlockingQueue(10)); in test()
69 testQueue(new ConcurrentLinkedDeque()); in test()
70 testQueue(new ConcurrentLinkedQueue()); in test()
71 testQueue(new LinkedTransferQueue()); in test()
74 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 63 testQueue(new LinkedBlockingQueue(10)); in test()
64 testQueue(new LinkedBlockingQueue()); in test()
65 testQueue(new LinkedBlockingDeque(10)); in test()
66 testQueue(new LinkedBlockingDeque()); in test()
67 testQueue(new ArrayBlockingQueue(10)); in test()
68 testQueue(new PriorityBlockingQueue(10)); in test()
69 testQueue(new ConcurrentLinkedDeque()); in test()
70 testQueue(new ConcurrentLinkedQueue()); in test()
71 testQueue(new LinkedTransferQueue()); in test()
74 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 66 testQueue(new LinkedBlockingQueue(10)); in test()
67 testQueue(new LinkedBlockingQueue()); in test()
68 testQueue(new LinkedBlockingDeque(10)); in test()
69 testQueue(new LinkedBlockingDeque()); in test()
70 testQueue(new ArrayBlockingQueue(10)); in test()
71 testQueue(new PriorityBlockingQueue(10)); in test()
72 testQueue(new ConcurrentLinkedDeque()); in test()
73 testQueue(new ConcurrentLinkedQueue()); in test()
74 testQueue(new LinkedTransferQueue()); in test()
77 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 66 testQueue(new LinkedBlockingQueue(10)); in test()
67 testQueue(new LinkedBlockingQueue()); in test()
68 testQueue(new LinkedBlockingDeque(10)); in test()
69 testQueue(new LinkedBlockingDeque()); in test()
70 testQueue(new ArrayBlockingQueue(10)); in test()
71 testQueue(new PriorityBlockingQueue(10)); in test()
72 testQueue(new ConcurrentLinkedDeque()); in test()
73 testQueue(new ConcurrentLinkedQueue()); in test()
74 testQueue(new LinkedTransferQueue()); in test()
77 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 66 testQueue(new LinkedBlockingQueue(10)); in test()
67 testQueue(new LinkedBlockingQueue()); in test()
68 testQueue(new LinkedBlockingDeque(10)); in test()
69 testQueue(new LinkedBlockingDeque()); in test()
70 testQueue(new ArrayBlockingQueue(10)); in test()
71 testQueue(new PriorityBlockingQueue(10)); in test()
72 testQueue(new ConcurrentLinkedDeque()); in test()
73 testQueue(new ConcurrentLinkedQueue()); in test()
74 testQueue(new LinkedTransferQueue()); in test()
77 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/test/jdk/java/util/concurrent/ConcurrentQueues/ |
| H A D | OfferRemoveLoops.java | 66 testQueue(new LinkedBlockingQueue(10)); in test()
67 testQueue(new LinkedBlockingQueue()); in test()
68 testQueue(new LinkedBlockingDeque(10)); in test()
69 testQueue(new LinkedBlockingDeque()); in test()
70 testQueue(new ArrayBlockingQueue(10)); in test()
71 testQueue(new PriorityBlockingQueue(10)); in test()
72 testQueue(new ConcurrentLinkedDeque()); in test()
73 testQueue(new ConcurrentLinkedQueue()); in test()
74 testQueue(new LinkedTransferQueue()); in test()
77 void testQueue(final Queue q) throws Throwable { in testQueue() method in OfferRemoveLoops
|
| /dports/devel/py-nose/nose-1.3.7/nose/plugins/ |
| H A D | multiprocess.py | 321 test_addr = self.addtask(testQueue,tasks,case)
323 len(tasks), test_addr, testQueue)
330 args=(iworker, testQueue,
365 testQueue = Queue()
469 if not any_alive and testQueue.empty():
509 testQueue.put('STOP', block=False)
529 def addtask(testQueue,tasks,case): argument
537 testQueue.put((test_addr,arg), block=False)
706 test.testQueue = testQueue
764 testQueue = None variable in NoSharedFixtureContextSuite
[all …]
|
| /dports/biology/py-crossmap/CrossMap-0.5.4/.eggs/nose-1.3.7-py3.6.egg/nose/plugins/ |
| H A D | multiprocess.py | 321 test_addr = self.addtask(testQueue,tasks,case)
323 len(tasks), test_addr, testQueue)
330 args=(iworker, testQueue,
365 testQueue = Queue()
469 if not any_alive and testQueue.empty():
509 testQueue.put('STOP', block=False)
529 def addtask(testQueue,tasks,case): argument
537 testQueue.put((test_addr,arg), block=False)
706 test.testQueue = testQueue
764 testQueue = None variable in NoSharedFixtureContextSuite
[all …]
|
| /dports/biology/py-crossmap/CrossMap-0.5.4/.eggs/nose-1.3.7-py3.7.egg/nose/plugins/ |
| H A D | multiprocess.py | 321 test_addr = self.addtask(testQueue,tasks,case)
323 len(tasks), test_addr, testQueue)
330 args=(iworker, testQueue,
365 testQueue = Queue()
469 if not any_alive and testQueue.empty():
509 testQueue.put('STOP', block=False)
529 def addtask(testQueue,tasks,case): argument
537 testQueue.put((test_addr,arg), block=False)
706 test.testQueue = testQueue
764 testQueue = None variable in NoSharedFixtureContextSuite
[all …]
|
| /dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/test/java/util/concurrent/BlockingQueue/ |
| H A D | LastElement.java | 36 testQueue(new LinkedBlockingQueue<Integer>()); in test()
37 testQueue(new LinkedBlockingDeque<Integer>()); in test()
38 testQueue(new ArrayBlockingQueue<Integer>(10, true)); in test()
39 testQueue(new ArrayBlockingQueue<Integer>(10, false)); in test()
40 testQueue(new LinkedTransferQueue<Integer>()); in test()
41 testQueue(new PriorityBlockingQueue<Integer>()); in test()
44 void testQueue(BlockingQueue<Integer> q) throws Throwable { in testQueue() method in LastElement
|
| /dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/test/java/util/concurrent/BlockingQueue/ |
| H A D | LastElement.java | 36 testQueue(new LinkedBlockingQueue<Integer>()); in test()
37 testQueue(new LinkedBlockingDeque<Integer>()); in test()
38 testQueue(new ArrayBlockingQueue<Integer>(10, true)); in test()
39 testQueue(new ArrayBlockingQueue<Integer>(10, false)); in test()
40 testQueue(new LinkedTransferQueue<Integer>()); in test()
41 testQueue(new PriorityBlockingQueue<Integer>()); in test()
44 void testQueue(BlockingQueue<Integer> q) throws Throwable { in testQueue() method in LastElement
|
| /dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/integration/ |
| H A D | v3_queue_test.go | 145 func newQueues(clus *ClusterV3, n int) (qs []testQueue) {
153 func newPriorityQueues(clus *ClusterV3, n int) (qs []testQueue) {
162 func testReadersWriters(t *testing.T, rqs []testQueue, wqs []testQueue) { argument
179 func manyReaders(qs []testQueue, totalReads int, errc chan<- error) { argument
182 go func(q testQueue) {
198 func manyWriters(qs []testQueue, writesEach int, errc chan<- error) { argument
200 go func(q testQueue) {
212 type testQueue interface { interface
|
| /dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/integration/ |
| H A D | v3_queue_test.go | 145 func newQueues(clus *ClusterV3, n int) (qs []testQueue) {
153 func newPriorityQueues(clus *ClusterV3, n int) (qs []testQueue) {
162 func testReadersWriters(t *testing.T, rqs []testQueue, wqs []testQueue) { argument
179 func manyReaders(qs []testQueue, totalReads int, errc chan<- error) { argument
182 go func(q testQueue) {
198 func manyWriters(qs []testQueue, writesEach int, errc chan<- error) { argument
200 go func(q testQueue) {
212 type testQueue interface { interface
|
| /dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/integration/ |
| H A D | v3_queue_test.go | 145 func newQueues(clus *ClusterV3, n int) (qs []testQueue) {
153 func newPriorityQueues(clus *ClusterV3, n int) (qs []testQueue) {
162 func testReadersWriters(t *testing.T, rqs []testQueue, wqs []testQueue) { argument
179 func manyReaders(qs []testQueue, totalReads int, errc chan<- error) { argument
182 go func(q testQueue) {
198 func manyWriters(qs []testQueue, writesEach int, errc chan<- error) { argument
200 go func(q testQueue) {
212 type testQueue interface { interface
|
| /dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/integration/ |
| H A D | v3_queue_test.go | 145 func newQueues(clus *ClusterV3, n int) (qs []testQueue) {
153 func newPriorityQueues(clus *ClusterV3, n int) (qs []testQueue) {
162 func testReadersWriters(t *testing.T, rqs []testQueue, wqs []testQueue) { argument
179 func manyReaders(qs []testQueue, totalReads int, errc chan<- error) { argument
182 go func(q testQueue) {
198 func manyWriters(qs []testQueue, writesEach int, errc chan<- error) { argument
200 go func(q testQueue) {
212 type testQueue interface { interface
|
| /dports/devel/etcd31/etcd-3.1.20/integration/ |
| H A D | v3_queue_test.go | 145 func newQueues(clus *ClusterV3, n int) (qs []testQueue) {
153 func newPriorityQueues(clus *ClusterV3, n int) (qs []testQueue) {
162 func testReadersWriters(t *testing.T, rqs []testQueue, wqs []testQueue) { argument
179 func manyReaders(qs []testQueue, totalReads int, errc chan<- error) { argument
182 go func(q testQueue) {
198 func manyWriters(qs []testQueue, writesEach int, errc chan<- error) { argument
200 go func(q testQueue) {
212 type testQueue interface { interface
|