Home
last modified time | relevance | path

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

12345678910>>...22

/freebsd-12.1/contrib/apr-util/misc/
H A Dapr_queue.c73 #define apr_queue_full(queue) ((queue)->nelts == (queue)->bounds) argument
187 queue->data[queue->in] = data; in apr_queue_push()
189 if (queue->in >= queue->bounds) in apr_queue_push()
190 queue->in -= queue->bounds; in apr_queue_push()
229 queue->data[queue->in] = data; in apr_queue_trypush()
231 if (queue->in >= queue->bounds) in apr_queue_trypush()
232 queue->in -= queue->bounds; in apr_queue_trypush()
301 *data = queue->data[queue->out]; in apr_queue_pop()
305 if (queue->out >= queue->bounds) in apr_queue_pop()
306 queue->out -= queue->bounds; in apr_queue_pop()
[all …]
/freebsd-12.1/sys/contrib/vchiq/interface/vchiq_arm/
H A Dvchiq_util.c46 queue->read = 0; in vchiu_queue_init()
69 return queue->read == queue->write; in vchiu_queue_is_empty()
74 return queue->write == queue->read + queue->size; in vchiu_queue_is_full()
82 while (queue->write == queue->read + queue->size) { in vchiu_queue_push()
94 queue->storage[queue->write & (queue->size - 1)] = header; in vchiu_queue_push()
102 queue->write++; in vchiu_queue_push()
109 while (queue->write == queue->read) { in vchiu_queue_peek()
123 return queue->storage[queue->read & (queue->size - 1)]; in vchiu_queue_peek()
130 while (queue->write == queue->read) { in vchiu_queue_pop()
142 header = queue->storage[queue->read & (queue->size - 1)]; in vchiu_queue_pop()
[all …]
/freebsd-12.1/sys/contrib/zstd/contrib/pzstd/utils/test/
H A DWorkQueueTest.cpp41 queue.push(5); in TEST()
45 queue.push(1); in TEST()
46 queue.push(2); in TEST()
52 queue.push(1); in TEST()
53 queue.push(2); in TEST()
54 queue.finish(); in TEST()
87 queue.finish(); in TEST()
153 queue.push(5); in TEST()
155 queue.push(5); in TEST()
157 queue.push(5); in TEST()
[all …]
/freebsd-12.1/sys/kern/
H A Dsubr_taskqueue.c161 return (queue); in _taskqueue_create()
207 TQ_LOCK(queue); in taskqueue_free()
209 taskqueue_terminate(queue->tq_threads, queue); in taskqueue_free()
258 queue->tq_enqueue(queue->tq_context); in taskqueue_enqueue_locked()
271 TQ_LOCK(queue); in taskqueue_enqueue()
299 TQ_LOCK(queue); in taskqueue_enqueue_timeout_sbt()
423 TQ_LOCK(queue); in taskqueue_block()
432 TQ_LOCK(queue); in taskqueue_unblock()
435 queue->tq_enqueue(queue->tq_context); in taskqueue_unblock()
485 TQ_LOCK(queue); in taskqueue_run()
[all …]
H A Dsubr_gtaskqueue.c142 if (!queue) { in _gtaskqueue_create()
158 return (queue); in _gtaskqueue_create()
179 TQ_LOCK(queue); in gtaskqueue_free()
181 gtaskqueue_terminate(queue->tq_threads, queue); in gtaskqueue_free()
205 TQ_LOCK(queue); in grouptask_block()
223 TQ_LOCK(queue); in grouptask_unblock()
237 TQ_LOCK(queue); in grouptaskqueue_enqueue()
250 queue->tq_enqueue(queue->tq_context); in grouptaskqueue_enqueue()
336 TQ_LOCK(queue); in gtaskqueue_block()
348 queue->tq_enqueue(queue->tq_context); in gtaskqueue_unblock()
[all …]
/freebsd-12.1/contrib/openmp/runtime/src/
H A Dkmp_taskq.cpp351 queue != NULL; queue = queue->tq_next_child) { in __kmp_aux_dump_task_queue_tree()
672 queue->tq_queue[(queue->tq_head)++].qs_thunk = thunk; in __kmp_enqueue_task()
674 if (queue->tq_head >= queue->tq_nslots) in __kmp_enqueue_task()
722 pt = queue->tq_queue[(queue->tq_tail)++].qs_thunk; in __kmp_dequeue_task()
724 if (queue->tq_tail >= queue->tq_nslots) in __kmp_dequeue_task()
797 (queue->tq_nfull <= queue->tq_hiwat)) { in __kmp_find_task_in_queue()
987 queue = queue->tq.tq_parent; in __kmp_find_task_in_ancestor_queue()
1042 queue->tq_prev_child->tq_next_child = queue->tq_next_child; in __kmp_remove_queue_from_tree()
1045 if (queue->tq.tq_parent->tq_first_child == queue) in __kmp_remove_queue_from_tree()
1054 __LINE__, global_tid, queue, queue->tq_ref_count)); in __kmp_remove_queue_from_tree()
[all …]
/freebsd-12.1/share/man/man3/
H A DMakefile18 queue.3 \
79 queue.3 LIST_EMPTY.3 \
80 queue.3 LIST_ENTRY.3 \
81 queue.3 LIST_FIRST.3 \
86 queue.3 LIST_HEAD.3 \
88 queue.3 LIST_INIT.3 \
92 queue.3 LIST_NEXT.3 \
93 queue.3 LIST_PREV.3 \
95 queue.3 LIST_SWAP.3 \
105 queue.3 SLIST_HEAD.3 \
[all …]
/freebsd-12.1/contrib/ntp/lib/isc/include/isc/
H A Dqueue.h55 (queue).head = (void *) &((queue).headnode); \
56 (queue).tail = (void *) &((queue).headnode); \
60 #define ISC_QUEUE_EMPTY(queue) ISC_TF((queue).head == (queue).tail) argument
73 LOCK(&(queue).taillock); \
75 (queue).tail = elt; \
76 UNLOCK(&(queue).taillock); \
82 LOCK(&(queue).headlock); \
85 UNLOCK(&(queue).headlock); \
90 LOCK(&(queue).taillock); \
91 (queue).tail = (queue).head; \
[all …]
/freebsd-12.1/sys/cam/
H A Dcam_queue.c102 if (queue != NULL) { in camq_free()
103 camq_fini(queue); in camq_free()
160 KASSERT(queue->entries < queue->array_size, in camq_insert()
162 queue->entries, queue->array_size)); in camq_insert()
163 queue->entries++; in camq_insert()
164 queue->queue_array[queue->entries] = new_entry; in camq_insert()
167 heap_up(queue->queue_array, queue->entries); in camq_insert()
188 queue->queue_array[index] = queue->queue_array[queue->entries]; in camq_remove()
190 heap_down(queue->queue_array, index, queue->entries - 1); in camq_remove()
193 queue->entries--; in camq_remove()
[all …]
H A Dcam_queue.h63 struct camq queue; member
124 void camq_free(struct camq *queue);
129 void camq_fini(struct camq *queue);
141 cam_pinfo *camq_remove(struct camq *queue, int index);
200 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
211 if (queue->entries == queue->array_size && in cam_ccbq_insert_ccb()
212 camq_resize(&ccbq->queue, queue->array_size * 2) != CAM_REQ_CMP) { in cam_ccbq_insert_ccb()
213 old_ccb = (struct ccb_hdr *)camq_remove(queue, queue->entries); in cam_ccbq_insert_ccb()
220 camq_insert(queue, &new_ccb->ccb_h.pinfo); in cam_ccbq_insert_ccb()
227 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
[all …]
/freebsd-12.1/contrib/dma/
H A Ddma.c198 LIST_FOREACH(tit, &queue->queue, next) { in add_recp()
244 go_background(struct queue *queue) in go_background() argument
260 LIST_FOREACH(it, &queue->queue, next) { in go_background()
376 run_queue(struct queue *queue) in run_queue() argument
380 if (LIST_EMPTY(&queue->queue)) in run_queue()
389 show_queue(struct queue *queue) in show_queue() argument
394 if (LIST_EMPTY(&queue->queue)) { in show_queue()
425 struct queue queue; in main() local
458 bzero(&queue, sizeof(queue)); in main()
459 LIST_INIT(&queue.queue); in main()
[all …]
H A Dspool.c73 newspoolf(struct queue *queue) in newspoolf() argument
155 readqueuef(struct queue *queue, char *queuefn) in readqueuef() argument
217 LIST_INSERT_HEAD(&queue->queue, it, next); in readqueuef()
233 linkspool(struct queue *queue) in linkspool() argument
244 LIST_FOREACH(it, &queue->queue, next) { in linkspool()
263 LIST_FOREACH(it, &queue->queue, next) { in linkspool()
272 LIST_FOREACH(it, &queue->queue, next) { in linkspool()
280 load_queue(struct queue *queue) in load_queue() argument
289 bzero(queue, sizeof(*queue)); in load_queue()
290 LIST_INIT(&queue->queue); in load_queue()
[all …]
H A Dmail.c50 struct queue bounceq; in bounce()
62 LIST_INIT(&bounceq.queue); in bounce()
166 parse_addrs(struct parse_state *ps, char *s, struct queue *queue) in parse_addrs() argument
348 writeline(struct queue *queue, const char *line, ssize_t linelen) in writeline() argument
364 if (fwrite("\n", 1, 1, queue->mailf) != 1) in writeline()
374 readmail(struct queue *queue, int nodot, int recp_from_header) in readmail() argument
391 error = fprintf(queue->mailf, in readmail()
398 queue->sender, in readmail()
399 queue->id, in readmail()
415 username, useruid, queue->sender); in readmail()
[all …]
/freebsd-12.1/contrib/subversion/subversion/libsvn_subr/
H A Dsorts.c408 char *lhs_value = queue->elements->elts + lhs * queue->elements->elt_size; in heap_is_less()
409 char *rhs_value = queue->elements->elts + rhs * queue->elements->elt_size; in heap_is_less()
425 char *lhs_value = queue->elements->elts + lhs * queue->elements->elt_size; in heap_swap()
426 char *rhs_value = queue->elements->elts + rhs * queue->elements->elt_size; in heap_swap()
481 svn_priority_queue__t *queue = apr_pcalloc(elements->pool, sizeof(*queue)); in svn_priority_queue__create() local
488 return queue; in svn_priority_queue__create()
500 return queue->elements->nelts ? queue->elements->elts : NULL; in svn_priority_queue__peek()
506 heap_bubble_up(queue, 0); in svn_priority_queue__update()
516 + (queue->elements->nelts - 1) * queue->elements->elt_size, in svn_priority_queue__pop()
530 memcpy(apr_array_push(queue->elements), element, queue->elements->elt_size); in svn_priority_queue__push()
[all …]
/freebsd-12.1/sys/contrib/octeon-sdk/
H A Dcvmx-pko.c309 for (queue = 0; queue < num_queues; queue++) in __cvmx_pko_iport_config()
318 queue) in __cvmx_pko_iport_config()
350 for (queue = 0; queue < num_queues; queue++) in __cvmx_pko_iport_config()
729 int queue; in cvmx_pko_shutdown() local
737 for (queue = 0; queue < CVMX_PKO_MAX_OUTPUT_QUEUES; queue++) in cvmx_pko_shutdown()
747 for (queue=0; queue<CVMX_PKO_MAX_OUTPUT_QUEUES; queue++) in cvmx_pko_shutdown()
753 config.s.queue = queue & 0x7f; in cvmx_pko_shutdown()
822 for (queue = 0; queue < num_queues; queue++) in cvmx_pko_config_port()
830 priority[queue] != CVMX_PKO_QUEUE_STATIC_PRIORITY && queue) in cvmx_pko_config_port()
871 for (queue = 0; queue < num_queues; queue++) in cvmx_pko_config_port()
[all …]
H A Dcvmx-zip.c96 int cvmx_zip_queue_initialize(int queue, int zcoremask) in cvmx_zip_queue_initialize() argument
123 cvmx_write_csr(CVMX_ZIP_QUEX_BUF(queue), zip_que_buf.u64); in cvmx_zip_queue_initialize()
126 que_map.u64 = cvmx_read_csr(CVMX_ZIP_QUEX_MAP(queue)); in cvmx_zip_queue_initialize()
128 cvmx_write_csr(CVMX_ZIP_QUEX_MAP(queue), que_map.u64); in cvmx_zip_queue_initialize()
132 que_ena.s.ena |= (1<<queue); in cvmx_zip_queue_initialize()
139 if (queue) in cvmx_zip_queue_initialize()
146 cvmx_read_csr(CVMX_ZIP_QUEX_BUF(queue)); in cvmx_zip_queue_initialize()
183 int cvmx_zip_queue_shutdown(int queue) in cvmx_zip_queue_shutdown() argument
187 if (cvmx_cmd_queue_length(CVMX_CMD_QUEUE_ZIP_QUE(queue))) in cvmx_zip_queue_shutdown()
198 cvmx_cmd_queue_shutdown(CVMX_CMD_QUEUE_ZIP_QUE(queue)); in cvmx_zip_queue_shutdown()
[all …]
/freebsd-12.1/contrib/ntp/lib/isc/tests/
H A Dqueue_test.c56 item_queue_t queue; in ATF_TC_BODY() local
62 ISC_QUEUE_INIT(queue, qlink); in ATF_TC_BODY()
75 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY()
84 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY()
90 ISC_QUEUE_PUSH(queue, p, qlink); in ATF_TC_BODY()
110 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY()
114 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY()
118 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY()
122 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY()
126 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY()
[all …]
/freebsd-12.1/share/examples/pf/
H A Dfaq-example317 # std_ext - the standard queue. also the default queue for
43 # std_int - the standard queue. also the default queue for outgoing
51 queue it_int bandwidth 500Kb cbq(borrow)
53 queue www_int bandwidth 99Mb cbq(red borrow)
70 queue internal_dmz bandwidth 99Mb cbq(borrow)
91 > 49151 } queue www_ext_misc
93 queue www_ext_http
101 pass in on dc0 from $it_net to any queue it_int
104 > 49151 } queue www_int
114 > 49151 } queue net_dmz_misc
[all …]
H A Dfaq-example213 # ACK queue.
21 # to this queue.
26 queue std_out priq(default)
28 queue dns_out priority 5
29 queue tcp_ack_out priority 6
40 # to this queue.
70 queue dns_out
72 queue(std_out, ssh_im_out)
84 queue dns_in
86 queue(std_in, ssh_im_in)
[all …]
H A Dqueue23 # advanced queue example.
12 queue std bandwidth 10% cbq(default)
14 queue developers bandwidth 75% cbq(borrow)
15 queue employees bandwidth 15%
18 queue ssh_interactive bandwidth 25% priority 7
19 queue ssh_bulk bandwidth 75% priority 0
21 block return out on $ext_if inet all queue std
23 queue developers
25 queue employees
27 queue(ssh_bulk, ssh_interactive)
[all …]
H A Dqueue17 queue { deflt, http, ssh, mail, rsets }
8 queue deflt bandwidth 10% priority 0 cbq(default ecn)
9 queue http bandwidth 1.5Mb priority 3 { http_vhosts, http_cust1 }
10 queue http_vhosts bandwidth 40% cbq(borrow red)
11 queue http_cust1 bandwidth 0.5Mb
12 queue mail bandwidth 10% priority 1
13 queue ssh bandwidth 100Kb priority 7 cbq(borrow)
14 queue rsets bandwidth 7500b priority 0 cbq(red)
16 block return in on $ext_if inet all queue rsets
17 pass in on $ext_if inet proto tcp from any to any port 80 queue http
[all …]
/freebsd-12.1/sys/contrib/ck/src/
H A Dck_barrier_combining.c43 if (queue->head != NULL) { in ck_barrier_combining_queue_dequeue()
44 front = queue->head; in ck_barrier_combining_queue_dequeue()
45 queue->head = queue->head->next; in ck_barrier_combining_queue_dequeue()
81 if (queue->head == NULL) { in ck_barrier_combining_queue_enqueue()
82 queue->head = queue->tail = node_value; in ck_barrier_combining_queue_enqueue()
86 queue->tail->next = node_value; in ck_barrier_combining_queue_enqueue()
87 queue->tail = node_value; in ck_barrier_combining_queue_enqueue()
99 struct ck_barrier_combining_queue queue; in ck_barrier_combining_group_init() local
101 queue.head = queue.tail = NULL; in ck_barrier_combining_group_init()
115 while (queue.head != NULL) { in ck_barrier_combining_group_init()
[all …]
/freebsd-12.1/sys/dev/vmware/vmci/
H A Dvmci_kernel_if.c469 struct vmci_queue *queue; in vmci_alloc_queue() local
474 sizeof(*queue) + sizeof(*(queue->kernel_if)) + dmas_size; in vmci_alloc_queue()
483 if (!queue) in vmci_alloc_queue()
486 queue->q_header = NULL; in vmci_alloc_queue()
487 queue->saved_header = NULL; in vmci_alloc_queue()
488 queue->kernel_if = (struct vmci_queue_kernel_if *)(queue + 1); in vmci_alloc_queue()
490 queue->kernel_if->dmas = (struct vmci_dma_alloc *)(queue->kernel_if + in vmci_alloc_queue()
502 queue->q_header = (void *)queue->kernel_if->dmas[0].dma_vaddr; in vmci_alloc_queue()
504 return ((void *)queue); in vmci_alloc_queue()
529 if (queue) { in vmci_free_queue()
[all …]
/freebsd-12.1/contrib/libc++/include/
H A Dqueue21 class queue
37 queue(const queue& q) = default;
38 queue(queue&& q) = default;
40 queue& operator=(const queue& q) = default;
41 queue& operator=(queue&& q) = default;
52 queue(const queue& q, const Alloc& a);
54 queue(queue&& q, const Alloc& a);
234 queue(const queue& __q) : c(__q.c) {}
241 queue(queue&& __q)
246 queue& operator=(queue&& __q)
[all …]
/freebsd-12.1/sys/sys/
H A Dtaskqueue.h82 int taskqueue_enqueue_timeout(struct taskqueue *queue,
90 int taskqueue_cancel_timeout(struct taskqueue *queue,
93 void taskqueue_drain_timeout(struct taskqueue *queue,
95 void taskqueue_drain_all(struct taskqueue *queue);
96 void taskqueue_quiesce(struct taskqueue *queue);
97 void taskqueue_free(struct taskqueue *queue);
98 void taskqueue_run(struct taskqueue *queue);
99 void taskqueue_block(struct taskqueue *queue);
100 void taskqueue_unblock(struct taskqueue *queue);
102 void taskqueue_set_callback(struct taskqueue *queue,
[all …]

12345678910>>...22