/freebsd/sys/contrib/vchiq/interface/vchiq_arm/ |
H A D | vchiq_util.c | 46 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 D | subr_taskqueue.c | 173 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 D | subr_gtaskqueue.c | 137 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 D | Makefile | 25 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 D | cam_queue.c | 122 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 D | cam_queue.h | 61 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 D | dma.c | 198 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 D | spool.c | 75 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 D | mail.c | 52 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 D | faq-example3 | 16 # 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 D | queue2 | 2 # 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 D | faq-example2 | 12 # 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 D | queue1 | 6 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 D | ck_barrier_combining.c | 43 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 D | intel,ixp4xx-hss.yaml | 35 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 D | vmci_kernel_if.c | 513 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 D | vmci_queue.h | 51 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 D | taskqueue.h | 89 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 D | gdma_main.c | 474 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 D | ntp_prio_q.h | 35 } 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 D | sta.c | 405 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 D | mcs.h | 48 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 D | ntp_prio_q.c | 24 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 D | queue | 14 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 D | posixmqcontrol.c | 135 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 …]
|