Home
last modified time | relevance | path

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

12345678910>>...23

/freebsd-13.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-13.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-13.1/sys/kern/
H A Dsubr_taskqueue.c162 return (queue); in _taskqueue_create()
208 TQ_LOCK(queue); in taskqueue_free()
210 taskqueue_terminate(queue->tq_threads, queue); in taskqueue_free()
268 queue->tq_enqueue(queue->tq_context); in taskqueue_enqueue_locked()
281 TQ_LOCK(queue); in taskqueue_enqueue()
309 TQ_LOCK(queue); in taskqueue_enqueue_timeout_sbt()
428 TQ_LOCK(queue); in taskqueue_block()
437 TQ_LOCK(queue); in taskqueue_unblock()
440 queue->tq_enqueue(queue->tq_context); in taskqueue_unblock()
491 TQ_LOCK(queue); in taskqueue_run()
[all …]
H A Dsubr_gtaskqueue.c140 if (!queue) { in _gtaskqueue_create()
156 return (queue); in _gtaskqueue_create()
176 TQ_LOCK(queue); in gtaskqueue_free()
178 gtaskqueue_terminate(queue->tq_threads, queue); in gtaskqueue_free()
202 TQ_LOCK(queue); in grouptask_block()
220 TQ_LOCK(queue); in grouptask_unblock()
234 TQ_LOCK(queue); in grouptaskqueue_enqueue()
247 queue->tq_enqueue(queue->tq_context); in grouptaskqueue_enqueue()
326 TQ_LOCK(queue); in gtaskqueue_block()
335 TQ_LOCK(queue); in gtaskqueue_unblock()
[all …]
/freebsd-13.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-13.1/share/man/man3/
H A DMakefile27 queue.3 \
189 queue.3 LIST_EMPTY.3 \
190 queue.3 LIST_ENTRY.3 \
191 queue.3 LIST_FIRST.3 \
196 queue.3 LIST_HEAD.3 \
198 queue.3 LIST_INIT.3 \
202 queue.3 LIST_NEXT.3 \
203 queue.3 LIST_PREV.3 \
205 queue.3 LIST_SWAP.3 \
215 queue.3 SLIST_HEAD.3 \
[all …]
/freebsd-13.1/sys/cam/
H A Dcam_queue.c92 queue->queue_array++; in camq_fini()
136 KASSERT(queue->entries < queue->array_size, in camq_insert()
138 queue->entries, queue->array_size)); in camq_insert()
139 queue->entries++; in camq_insert()
140 queue->queue_array[queue->entries] = new_entry; in camq_insert()
143 heap_up(queue->queue_array, queue->entries); in camq_insert()
160 queue->entries); in camq_remove()
164 queue->queue_array[index] = queue->queue_array[queue->entries]; in camq_remove()
166 heap_down(queue->queue_array, index, queue->entries - 1); in camq_remove()
169 queue->entries--; in camq_remove()
[all …]
H A Dcam_queue.h63 struct camq queue; member
116 void camq_fini(struct camq *queue);
128 cam_pinfo *camq_remove(struct camq *queue, int index);
186 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
197 if (queue->entries == queue->array_size && in cam_ccbq_insert_ccb()
198 camq_resize(&ccbq->queue, queue->array_size * 2) != CAM_REQ_CMP) { in cam_ccbq_insert_ccb()
199 old_ccb = (struct ccb_hdr *)camq_remove(queue, queue->entries); in cam_ccbq_insert_ccb()
206 camq_insert(queue, &new_ccb->ccb_h.pinfo); in cam_ccbq_insert_ccb()
213 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
246 camq_insert(queue, &bccb->pinfo); in cam_ccbq_remove_ccb()
[all …]
/freebsd-13.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()
426 struct queue queue; in main() local
462 bzero(&queue, sizeof(queue)); in main()
463 LIST_INIT(&queue.queue); in main()
[all …]
H A Dspool.c75 newspoolf(struct queue *queue) in newspoolf() argument
157 readqueuef(struct queue *queue, char *queuefn) in readqueuef() argument
219 LIST_INSERT_HEAD(&queue->queue, it, next); in readqueuef()
235 linkspool(struct queue *queue) in linkspool() argument
246 LIST_FOREACH(it, &queue->queue, next) { in linkspool()
265 LIST_FOREACH(it, &queue->queue, next) { in linkspool()
274 LIST_FOREACH(it, &queue->queue, next) { in linkspool()
282 load_queue(struct queue *queue) in load_queue() argument
291 bzero(queue, sizeof(*queue)); in load_queue()
292 LIST_INIT(&queue->queue); in load_queue()
[all …]
H A Dmail.c51 struct queue bounceq; in bounce()
63 LIST_INIT(&bounceq.queue); in bounce()
167 parse_addrs(struct parse_state *ps, char *s, struct queue *queue) in parse_addrs() argument
349 writeline(struct queue *queue, const char *line, ssize_t linelen) in writeline() argument
375 readmail(struct queue *queue, int nodot, int recp_from_header) in readmail() argument
394 error = fprintf(queue->mailf, in readmail()
401 queue->sender, in readmail()
402 queue->id, in readmail()
415 username, useruid, queue->sender); in readmail()
441 username, useruid, queue->sender); in readmail()
[all …]
/freebsd-13.1/contrib/subversion/subversion/libsvn_subr/
H A Dsorts.c419 char *lhs_value = queue->elements->elts + lhs * queue->elements->elt_size; in heap_is_less()
420 char *rhs_value = queue->elements->elts + rhs * queue->elements->elt_size; in heap_is_less()
436 char *lhs_value = queue->elements->elts + lhs * queue->elements->elt_size; in heap_swap()
437 char *rhs_value = queue->elements->elts + rhs * queue->elements->elt_size; in heap_swap()
492 svn_priority_queue__t *queue = apr_pcalloc(elements->pool, sizeof(*queue)); in svn_priority_queue__create() local
499 return queue; in svn_priority_queue__create()
511 return queue->elements->nelts ? queue->elements->elts : NULL; in svn_priority_queue__peek()
517 heap_bubble_up(queue, 0); in svn_priority_queue__update()
527 + (queue->elements->nelts - 1) * queue->elements->elt_size, in svn_priority_queue__pop()
541 memcpy(apr_array_push(queue->elements), element, queue->elements->elt_size); in svn_priority_queue__push()
[all …]
/freebsd-13.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-13.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-13.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 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 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 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-13.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-13.1/sys/dev/vmware/vmci/
H A Dvmci_kernel_if.c515 struct vmci_queue *queue; in vmci_alloc_queue() local
520 sizeof(*queue) + sizeof(*(queue->kernel_if)) + dmas_size; in vmci_alloc_queue()
529 if (!queue) in vmci_alloc_queue()
532 queue->q_header = NULL; in vmci_alloc_queue()
533 queue->saved_header = NULL; in vmci_alloc_queue()
534 queue->kernel_if = (struct vmci_queue_kernel_if *)(queue + 1); in vmci_alloc_queue()
536 queue->kernel_if->dmas = (struct vmci_dma_alloc *)(queue->kernel_if + in vmci_alloc_queue()
548 queue->q_header = (void *)queue->kernel_if->dmas[0].dma_vaddr; in vmci_alloc_queue()
550 return ((void *)queue); in vmci_alloc_queue()
575 if (queue) { in vmci_free_queue()
[all …]
/freebsd-13.1/sys/sys/
H A Dtaskqueue.h85 int taskqueue_enqueue_timeout(struct taskqueue *queue,
93 int taskqueue_cancel_timeout(struct taskqueue *queue,
96 void taskqueue_drain_timeout(struct taskqueue *queue,
98 void taskqueue_drain_all(struct taskqueue *queue);
99 void taskqueue_quiesce(struct taskqueue *queue);
100 void taskqueue_free(struct taskqueue *queue);
101 void taskqueue_run(struct taskqueue *queue);
102 void taskqueue_block(struct taskqueue *queue);
103 void taskqueue_unblock(struct taskqueue *queue);
105 void taskqueue_set_callback(struct taskqueue *queue,
[all …]
/freebsd-13.1/contrib/llvm-project/libcxx/include/
H A Dqueue20 class queue
36 queue(const queue& q) = default;
37 queue(queue&& q) = default;
39 queue& operator=(const queue& q) = default;
40 queue& operator=(queue&& q) = default;
51 queue(const queue& q, const Alloc& a);
53 queue(queue&& q, const Alloc& a);
229 queue(const queue& __q) : c(__q.c) {}
236 queue(queue&& __q)
241 queue& operator=(queue&& __q)
[all …]
/freebsd-13.1/contrib/ntp/include/
H A Dntp_prio_q.h35 } queue; typedef
44 void destroy_queue(queue *my_queue);
47 int empty(queue *my_queue);
48 void *queue_head(queue *my_queue);
49 queue *enqueue(queue *my_queue, void *my_node);
50 void append_queue(queue *q1, queue *q2);
51 void *dequeue(queue *my_queue);
52 int get_no_of_elements(queue *my_queue);
67 queue *debug_create_priority_queue(
/freebsd-13.1/sys/contrib/dev/iwlwifi/mvm/
H A Dsta.c340 .u.remove.queue = cpu_to_le32(queue), in iwl_mvm_disable_txq()
368 queue, in iwl_mvm_disable_txq()
381 queue, mvm->queue_info[queue].tid_bitmap); in iwl_mvm_disable_txq()
402 queue, ret); in iwl_mvm_disable_txq()
617 return queue; in iwl_mvm_get_shared_queue()
702 queue); in iwl_mvm_redirect_queue()
821 return queue; in iwl_mvm_tvqm_enable_txq()
896 queue, mvm->queue_info[queue].tid_bitmap); in iwl_mvm_update_txq_mapping()
1466 int queue; in iwl_mvm_reserve_sta_stream() local
2196 int queue; in iwl_mvm_send_add_bcast_sta() local
[all …]

12345678910>>...23