Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 631) sorted by relevance

12345678910>>...26

/openbsd-src/sys/dev/pci/drm/include/drm/
H A Dspsc_queue.h48 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init() argument
50 queue->head = NULL; in spsc_queue_init()
51 atomic_long_set(&queue->tail, (long)&queue->head); in spsc_queue_init()
52 atomic_set(&queue->job_count, 0); in spsc_queue_init()
55 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek() argument
57 return queue->head; in spsc_queue_peek()
60 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count() argument
62 return atomic_read(&queue->job_count); in spsc_queue_count()
65 static inline bool spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) in spsc_queue_push() argument
73 tail = (struct spsc_node **)atomic_long_xchg(&queue->tail, (long)&node->next); in spsc_queue_push()
[all …]
/openbsd-src/gnu/usr.bin/perl/dist/Thread-Queue/lib/Thread/
H A DQueue.pm19 my @queue :shared = map { shared_clone($_) } @_;
20 my %self :shared = ( 'queue' => \@queue );
36 my $queue = $$self{'queue'};
37 cond_wait(%$self) while ($$self{'LIMIT'} && (@$queue >= $$self{'LIMIT'}));
40 push(@$queue, map { shared_clone($_) } @_)
77 my $queue = $$self{'queue'};
82 cond_wait(%$self) while ((@$queue < $count) && ! $$self{'ENDED'});
89 my $item = shift(@$queue);
96 push(@items, shift(@$queue)) for (1..$count);
106 my $queue = $$self{'queue'};
[all …]
/openbsd-src/sys/dev/pci/drm/amd/amdkfd/
H A Dkfd_kernel_queue.c38 /* Initialize a kernel queue, including allocations of GART memory
39 * needed for the queue.
51 pr_debug("Initializing queue type %d size %d\n", KFD_QUEUE_TYPE_HIQ, in kq_initialize()
71 pr_err("Invalid queue type %d\n", type); in kq_initialize()
141 if (init_queue(&kq->queue, &prop) != 0) in kq_initialize()
144 kq->queue->device = dev; in kq_initialize()
145 kq->queue->process = kfd_get_process(current); in kq_initialize()
147 kq->queue->mqd_mem_obj = kq->mqd_mgr->allocate_mqd(kq->mqd_mgr->dev, in kq_initialize()
148 &kq->queue->properties); in kq_initialize()
149 if (!kq->queue in kq_initialize()
[all...]
/openbsd-src/gnu/lib/libstdc++/libstdc++/include/bits/
H A Dstl_queue.h71 class queue; variable
74 inline bool operator==(const queue<_Tp,_Seq>&, const queue<_Tp,_Seq>&);
77 inline bool operator<(const queue<_Tp,_Seq>&, const queue<_Tp,_Seq>&);
105 class queue
115 friend bool operator== (const queue<_Tp1, _Seq1>&,
116 const queue<_Tp1, _Seq1>&);
118 friend bool operator< (const queue<_Tp1, _Seq1>&,
119 const queue<_Tp1, _Seq1>&);
143 queue(const _Sequence& __c = _Sequence())
224 operator==(const queue<_Tp,_Sequence>& __x, const queue<_Tp,_Sequence>& __y)
[all …]
/openbsd-src/gnu/gcc/libstdc++-v3/include/bits/
H A Dstl_queue.h95 class queue in _GLIBCXX_BEGIN_NAMESPACE()
106 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_BEGIN_NAMESPACE()
110 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_BEGIN_NAMESPACE()
135 queue(const _Sequence& __c = _Sequence()) : c(__c) {} in _GLIBCXX_BEGIN_NAMESPACE()
239 operator==(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
257 operator<(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
263 operator!=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
269 operator>(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
275 operator<=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
281 operator>=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y)
/openbsd-src/regress/sbin/pfctl/
H A Dpf17.optimized3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf17.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf68.optimized3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf4.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf68.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf47.optimized3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf47.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf88.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf40.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf81.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf87.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf7.optimized3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf10.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf7.loaded3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
H A Dpf81.optimized3 [ queue: qname= qid=0 pqname= pqid=0 ]
7 [ queue: qname= qid=0 pqname= pqid=0 ]
11 [ queue: qname= qid=0 pqname= pqid=0 ]
15 [ queue: qname= qid=0 pqname= pqid=0 ]
19 [ queue: qname= qid=0 pqname= pqid=0 ]
23 [ queue: qname= qid=0 pqname= pqid=0 ]
27 [ queue: qname= qid=0 pqname= pqid=0 ]
31 [ queue: qname= qid=0 pqname= pqid=0 ]
35 [ queue: qname= qid=0 pqname= pqid=0 ]
39 [ queue: qname= qid=0 pqname= pqid=0 ]
[all …]
/openbsd-src/gnu/llvm/libcxx/include/
H A Dqueue14 queue synopsis
20 class queue
33 queue() = default;
34 ~queue() = default;
36 queue(const queue& q) = default;
37 queue(queue&& q) = default;
39 queue& operator=(const queue& q) = default;
40 queue& operator=(queue&& q) = default;
42 explicit queue(const container_type& c);
43 explicit queue(container_type&& c)
[all …]
/openbsd-src/gnu/usr.bin/perl/dist/Thread-Queue/t/
H A D11_limit.t28 # (1) Set queue limit, and report it
32 # (3) Fetch an item from queue
35 # Report queue count
49 # (2) Read queue limit from thread
55 # (5) Read queue count
59 # Report back the queue count
63 # Read an item from queue
67 # Report back the queue count
71 # 'insert' doesn't care about queue limit
76 # Read an item from queue
[all …]
H A D06_insert.t26 ok($q, 'New queue');
40 ok($q, 'New queue');
52 ok($q, 'New queue');
64 ok($q, 'New queue');
76 ok($q, 'New queue');
79 is_deeply(\@x, [1..3], 'Empty queue insert');
82 ok($q, 'New queue');
85 is_deeply(\@x, [1..3], 'Empty queue insert');
88 ok($q, 'New queue');
91 is_deeply(\@x, [1..3], 'Empty queue insert');
[all …]
/openbsd-src/usr.sbin/lpr/common_source/
H A Dcommon.c227 getq(struct queue ***namelist) in getq()
230 struct queue *q, **queue = NULL; in getq() local
248 queue = calloc(arraysz, sizeof(struct queue *)); in getq()
249 if (queue == NULL) in getq()
261 q = malloc(sizeof(struct queue)); in getq()
272 struct queue **newqueue; in getq()
273 newqueue = reallocarray(queue, in getq()
274 arraysz, 2 * sizeof(struct queue *)); in getq()
280 queue = newqueue; in getq()
282 queue[nitems++] = q; in getq()
[all …]
/openbsd-src/gnu/llvm/compiler-rt/lib/asan/tests/
H A Dasan_mac_test_helpers.mm93 dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
98 dispatch_async(queue, block);
103 dispatch_queue_t queue = dispatch_get_global_queue(2, 0);
108 dispatch_sync(queue, block);
115 dispatch_queue_t queue = dispatch_get_global_queue(0, 0);
119 dispatch_async(queue, block_alloc);
121 dispatch_async(queue, block_crash);
127 dispatch_queue_t queue[4];
128 queue[0] = dispatch_get_global_queue(2, 0);
129 queue[1] = dispatch_get_global_queue(0, 0);
[all …]

12345678910>>...26