Home
last modified time | relevance | path

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

12345678910>>...26

/freebsd/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/sys/kern/
H A Dsubr_taskqueue.c173 return (queue); in _taskqueue_create()
219 TQ_LOCK(queue); in taskqueue_free()
221 taskqueue_terminate(queue->tq_threads, queue); in taskqueue_free()
295 queue->tq_enqueue(queue->tq_context); in taskqueue_enqueue_locked()
308 TQ_LOCK(queue); in taskqueue_enqueue_flags()
342 TQ_LOCK(queue); in taskqueue_enqueue_timeout_sbt()
366 if (queue->tq_spin && queue->tq_tcount == 1 && in taskqueue_enqueue_timeout_sbt()
467 TQ_LOCK(queue); in taskqueue_block()
476 TQ_LOCK(queue); in taskqueue_unblock()
479 queue->tq_enqueue(queue->tq_context); in taskqueue_unblock()
[all …]
H A Dsubr_gtaskqueue.c137 if (!queue) { in _gtaskqueue_create()
153 return (queue); in _gtaskqueue_create()
173 TQ_LOCK(queue); in gtaskqueue_free()
175 gtaskqueue_terminate(queue->tq_threads, queue); in gtaskqueue_free()
199 TQ_LOCK(queue); in grouptask_block()
217 TQ_LOCK(queue); in grouptask_unblock()
231 TQ_LOCK(queue); in grouptaskqueue_enqueue()
244 queue->tq_enqueue(queue->tq_context); in grouptaskqueue_enqueue()
323 TQ_LOCK(queue); in gtaskqueue_block()
332 TQ_LOCK(queue); in gtaskqueue_unblock()
[all …]
/freebsd/share/man/man3/
H A DMakefile25 queue.3 \
202 queue.3 LIST_EMPTY.3 \
203 queue.3 LIST_ENTRY.3 \
204 queue.3 LIST_FIRST.3 \
209 queue.3 LIST_HEAD.3 \
211 queue.3 LIST_INIT.3 \
215 queue.3 LIST_NEXT.3 \
216 queue.3 LIST_PREV.3 \
219 queue.3 LIST_SWAP.3 \
229 queue.3 SLIST_HEAD.3 \
[all …]
/freebsd/sys/cam/
H A Dcam_queue.c122 KASSERT(queue->entries < queue->array_size, in camq_insert()
124 queue->entries, queue->array_size)); in camq_insert()
125 queue->entries++; in camq_insert()
126 queue->queue_array[queue->entries] = new_entry; in camq_insert()
128 if (queue->entries != 0) in camq_insert()
129 heap_up(queue->queue_array, queue->entries); in camq_insert()
146 queue->entries); in camq_remove()
150 queue->queue_array[index] = queue->queue_array[queue->entries]; in camq_remove()
152 heap_down(queue->queue_array, index, queue->entries - 1); in camq_remove()
155 queue->entries--; in camq_remove()
[all …]
H A Dcam_queue.h61 struct camq queue; member
114 void camq_fini(struct camq *queue);
126 cam_pinfo *camq_remove(struct camq *queue, int index);
160 struct camq *queue = &ccbq->queue; in cam_ccbq_insert_ccb() local
171 if (queue->entries == queue->array_size && in cam_ccbq_insert_ccb()
172 camq_resize(&ccbq->queue, queue->array_size * 2) != CAM_REQ_CMP) { in cam_ccbq_insert_ccb()
173 old_ccb = (struct ccb_hdr *)camq_remove(queue, queue->entries); in cam_ccbq_insert_ccb()
180 camq_insert(queue, &new_ccb->ccb_h.pinfo); in cam_ccbq_insert_ccb()
187 struct camq *queue = &ccbq->queue; in cam_ccbq_remove_ccb() local
220 camq_insert(queue, &bccb->pinfo); in cam_ccbq_remove_ccb()
[all …]
/freebsd/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.c52 struct queue bounceq; in bounce()
64 LIST_INIT(&bounceq.queue); in bounce()
168 parse_addrs(struct parse_state *ps, char *s, struct queue *queue) in parse_addrs() argument
350 writeline(struct queue *queue, const char *line, ssize_t linelen) in writeline() argument
376 readmail(struct queue *queue, int nodot, int recp_from_header) in readmail() argument
395 error = fprintf(queue->mailf, in readmail()
402 queue->sender, in readmail()
403 queue->id, in readmail()
414 username, useruid, queue->sender); in readmail()
446 username, useruid, queue->sender); in readmail()
[all …]
/freebsd/share/examples/pf/
H A Dfaq-example316 # std_ext - the standard queue. also the default queue for
42 # std_int - the standard queue. also the default queue for outgoing
50 queue it_int bandwidth 500Kb cbq(borrow)
52 queue www_int bandwidth 99Mb cbq(red borrow)
69 queue internal_dmz bandwidth 99Mb cbq(borrow)
90 > 49151 } queue www_ext_misc
92 queue www_ext_http
100 pass in on dc0 from $it_net to any queue it_int
103 > 49151 } queue www_int
113 > 49151 } queue net_dmz_misc
[all …]
H A Dqueue22 # advanced queue example.
11 queue std bandwidth 10% cbq(default)
13 queue developers bandwidth 75% cbq(borrow)
14 queue employees bandwidth 15%
17 queue ssh_interactive bandwidth 25% priority 7
18 queue ssh_bulk bandwidth 75% priority 0
20 block return out on $ext_if inet all queue std
22 queue developers
24 queue employees
26 queue(ssh_bulk, ssh_interactive)
[all …]
H A Dfaq-example212 # ACK queue.
20 # to this queue.
25 queue std_out priq(default)
27 queue dns_out priority 5
28 queue tcp_ack_out priority 6
39 # to this queue.
69 queue dns_out
71 queue(std_out, ssh_im_out)
83 queue dns_in
85 queue(std_in, ssh_im_in)
[all …]
H A Dqueue16 queue { deflt, http, ssh, mail, rsets }
7 queue deflt bandwidth 10% priority 0 cbq(default ecn)
8 queue http bandwidth 1.5Mb priority 3 { http_vhosts, http_cust1 }
9 queue http_vhosts bandwidth 40% cbq(borrow red)
10 queue http_cust1 bandwidth 0.5Mb
11 queue mail bandwidth 10% priority 1
12 queue ssh bandwidth 100Kb priority 7 cbq(borrow)
13 queue rsets bandwidth 7500b priority 0 cbq(red)
15 block return in on $ext_if inet all queue rsets
16 pass in on $ext_if inet proto tcp from any to any port 80 queue http
[all …]
/freebsd/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/sys/contrib/device-tree/Bindings/net/
H A Dintel,ixp4xx-hss.yaml35 intel,queue-chl-rxtrig:
43 intel,queue-chl-txready:
51 intel,queue-pkt-rx:
59 intel,queue-pkt-tx:
68 intel,queue-pkt-rxfree:
78 intel,queue-pkt-txdone:
111 - intel,queue-chl-rxtrig
113 - intel,queue-pkt-rx
114 - intel,queue-pkt-tx
115 - intel,queue-pkt-rxfree
[all …]
/freebsd/sys/dev/vmware/vmci/
H A Dvmci_kernel_if.c513 struct vmci_queue *queue; in vmci_alloc_queue() local
518 sizeof(*queue) + sizeof(*(queue->kernel_if)) + dmas_size; in vmci_alloc_queue()
527 if (!queue) in vmci_alloc_queue()
530 queue->q_header = NULL; in vmci_alloc_queue()
531 queue->saved_header = NULL; in vmci_alloc_queue()
532 queue->kernel_if = (struct vmci_queue_kernel_if *)(queue + 1); in vmci_alloc_queue()
534 queue->kernel_if->dmas = (struct vmci_dma_alloc *)(queue->kernel_if + in vmci_alloc_queue()
546 queue->q_header = (void *)queue->kernel_if->dmas[0].dma_vaddr; in vmci_alloc_queue()
548 return ((void *)queue); in vmci_alloc_queue()
573 if (queue) { in vmci_free_queue()
[all …]
H A Dvmci_queue.h51 typedef int vmci_memcpy_to_queue_func(struct vmci_queue *queue,
55 const struct vmci_queue *queue, uint64_t queue_offset, size_t size,
75 int vmci_memcpy_to_queue(struct vmci_queue *queue, uint64_t queue_offset,
79 const struct vmci_queue *queue, uint64_t queue_offset, size_t size,
81 int vmci_memcpy_to_queue_local(struct vmci_queue *queue,
85 const struct vmci_queue *queue, uint64_t queue_offset, size_t size,
88 int vmci_memcpy_to_queue_v(struct vmci_queue *queue, uint64_t queue_offset,
92 const struct vmci_queue *queue, uint64_t queue_offset, size_t size,
101 return (vmci_memcpy_to_queue_v(queue, queue_offset, src, src_offset, in vmci_memcpy_to_queue_v_local()
107 const struct vmci_queue *queue, uint64_t queue_offset, size_t size, in vmci_memcpy_from_queue_v_local() argument
[all …]
/freebsd/sys/sys/
H A Dtaskqueue.h89 int taskqueue_enqueue_timeout(struct taskqueue *queue,
97 int taskqueue_cancel_timeout(struct taskqueue *queue,
100 void taskqueue_drain_timeout(struct taskqueue *queue,
102 void taskqueue_drain_all(struct taskqueue *queue);
103 void taskqueue_quiesce(struct taskqueue *queue);
104 void taskqueue_free(struct taskqueue *queue);
105 void taskqueue_run(struct taskqueue *queue);
106 void taskqueue_block(struct taskqueue *queue);
107 void taskqueue_unblock(struct taskqueue *queue);
109 void taskqueue_set_callback(struct taskqueue *queue,
[all …]
/freebsd/sys/dev/mana/
H A Dgdma_main.c474 queue->id, queue->head * GDMA_WQE_BU_SIZE, 0); in mana_gd_wq_ring_doorbell()
870 queue = malloc(sizeof(*queue), M_DEVBUF, M_WAITOK | M_ZERO); in mana_gd_create_hwc_queue()
871 if (!queue) in mana_gd_create_hwc_queue()
879 queue->head = 0; in mana_gd_create_hwc_queue()
880 queue->tail = 0; in mana_gd_create_hwc_queue()
1010 queue = malloc(sizeof(*queue), M_DEVBUF, M_WAITOK | M_ZERO); in mana_gd_create_mana_eq()
1011 if (!queue) in mana_gd_create_mana_eq()
1023 queue->head = 0; in mana_gd_create_mana_eq()
1058 queue = malloc(sizeof(*queue), M_DEVBUF, M_WAITOK | M_ZERO); in mana_gd_create_mana_wq_cq()
1059 if (!queue) in mana_gd_create_mana_wq_cq()
[all …]
/freebsd/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/sys/contrib/dev/iwlwifi/mvm/
H A Dsta.c405 queue, in iwl_mvm_disable_txq()
418 queue, mvm->queue_info[queue].tid_bitmap); in iwl_mvm_disable_txq()
443 queue, ret); in iwl_mvm_disable_txq()
585 queue, ret); in iwl_mvm_free_inactive_queue()
662 return queue; in iwl_mvm_get_shared_queue()
747 queue); in iwl_mvm_redirect_queue()
909 return queue; in iwl_mvm_tvqm_enable_txq()
985 queue, mvm->queue_info[queue].tid_bitmap); in iwl_mvm_update_txq_mapping()
1565 int queue; in iwl_mvm_reserve_sta_stream() local
2339 int queue; in iwl_mvm_send_add_bcast_sta() local
[all …]
/freebsd/sys/contrib/ck/include/spinlock/
H A Dmcs.h48 ck_spinlock_mcs_init(struct ck_spinlock_mcs **queue) in ck_spinlock_mcs_init() argument
51 *queue = NULL; in ck_spinlock_mcs_init()
57 ck_spinlock_mcs_trylock(struct ck_spinlock_mcs **queue, in ck_spinlock_mcs_trylock() argument
66 r = ck_pr_cas_ptr(queue, NULL, node); in ck_spinlock_mcs_trylock()
72 ck_spinlock_mcs_locked(struct ck_spinlock_mcs **queue) in ck_spinlock_mcs_locked() argument
76 r = ck_pr_load_ptr(queue) != NULL; in ck_spinlock_mcs_locked()
82 ck_spinlock_mcs_lock(struct ck_spinlock_mcs **queue, in ck_spinlock_mcs_lock() argument
100 previous = ck_pr_fas_ptr(queue, node); in ck_spinlock_mcs_lock()
116 ck_spinlock_mcs_unlock(struct ck_spinlock_mcs **queue, in ck_spinlock_mcs_unlock() argument
130 if (ck_pr_load_ptr(queue) == node && in ck_spinlock_mcs_unlock()
[all …]
/freebsd/contrib/ntp/ntpd/
H A Dntp_prio_q.c24 queue *debug_create_priority_queue( in debug_create_priority_queue()
32 queue *my_queue; in debug_create_priority_queue()
53 queue *my_queue in destroy_queue()
126 queue *my_queue in empty()
135 queue *q in queue_head()
149 queue *enqueue( in enqueue()
150 queue * my_queue, in enqueue()
181 queue *my_queue in dequeue()
199 queue *my_queue in get_no_of_elements()
216 queue *q1, in append_queue()
[all …]
/freebsd/contrib/llvm-project/libcxx/include/
H A Dqueue14 queue synopsis
20 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;
54 queue(const queue& q, const Alloc& a);
56 queue(queue&& q, const Alloc& a);
124 void swap(queue<T, Container>& x, queue<T, Container>& y)
278 // [queue.syn]
[all …]
/freebsd/usr.bin/posixmqcontrol/
H A Dposixmqcontrol.c135 sane_queue(const char *queue) in sane_queue() argument
139 if (queue[size] != '/') { in sane_queue()
145 if (queue[size] == '/') { in sane_queue()
147 NAME_MAX, queue); in sane_queue()
244 if (sane_queue(queue)) { in parse_queue()
247 n1->text = queue; in parse_queue()
255 if (sane_queue(queue)) { in parse_single_queue()
259 n1->text = queue; in parse_single_queue()
522 rm(const char *queue) in rm() argument
558 info(const char *queue) in info() argument
[all …]

12345678910>>...26