/netbsd/external/ibm-public/postfix/dist/src/oqmgr/ |
H A D | qmgr_queue.c | 128 queue->window, queue->success, queue->failure, queue->fail_cohorts); 156 if (QMGR_QUEUE_READY(queue) && queue->todo.next == 0 && queue->busy.next == 0) in qmgr_queue_resume() 194 if (QMGR_QUEUE_READY(queue) && queue->todo.next == 0 && queue->busy.next == 0) in qmgr_queue_unthrottle_wrapper() 235 queue->window = queue->busy_refcount; in qmgr_queue_unthrottle() 238 queue->success = queue->failure = 0; in qmgr_queue_unthrottle() 293 myname, queue->name, queue->dsn->reason); in qmgr_queue_throttle() 311 queue->fail_cohorts += 1.0 / queue->window; in qmgr_queue_throttle() 363 for (queue = transport->queue_list.next; queue; queue = queue->peers.next) { in qmgr_queue_select() 364 if (queue->window > queue->busy_refcount && queue->todo.next != 0) { in qmgr_queue_select() 388 if (queue->todo.next || queue->busy.next) in qmgr_queue_done() [all …]
|
H A D | qmgr_entry.c | 111 queue->todo_refcount--; in qmgr_entry_select() 113 queue->busy_refcount++; in qmgr_entry_select() 217 QMGR_QUEUE *queue = entry->queue; in qmgr_entry_done() local 228 queue->busy_refcount--; in qmgr_entry_done() 255 if (queue->window > 1) in qmgr_entry_done() 257 myname, transport->name, queue->name, queue->window); in qmgr_entry_done() 272 if (queue->todo.next == 0 && queue->busy.next == 0) { in qmgr_entry_done() 324 entry->queue = queue; in qmgr_entry_create() 351 int queue_length = queue->todo_refcount + queue->busy_refcount; in qmgr_entry_create() 372 else if (queue->peers.next != queue->peers.prev) in qmgr_entry_create() [all …]
|
H A D | qmgr_enable.c | 81 QMGR_QUEUE *queue; in qmgr_enable_transport() local 92 for (queue = transport->queue_list.next; queue; queue = next) { in qmgr_enable_transport() 93 next = queue->peers.next; in qmgr_enable_transport() 94 qmgr_enable_queue(queue); in qmgr_enable_transport() 100 void qmgr_enable_queue(QMGR_QUEUE *queue) in qmgr_enable_queue() argument 102 if (QMGR_QUEUE_THROTTLED(queue)) { in qmgr_enable_queue() 104 msg_info("enable site %s/%s", queue->transport->name, queue->name); in qmgr_enable_queue() 105 qmgr_queue_unthrottle(queue); in qmgr_enable_queue() 107 if (QMGR_QUEUE_READY(queue) && queue->todo.next == 0 && queue->busy.next == 0) in qmgr_enable_queue() 108 qmgr_queue_done(queue); in qmgr_enable_queue()
|
/netbsd/external/ibm-public/postfix/dist/src/qmgr/ |
H A D | qmgr_queue.c | 134 queue->window, queue->success, queue->failure, queue->fail_cohorts); 171 if (QMGR_QUEUE_READY(queue) && queue->todo.next == 0 && queue->busy.next == 0) in qmgr_queue_resume() 211 if (QMGR_QUEUE_READY(queue) && queue->todo.next == 0 && queue->busy.next == 0) in qmgr_queue_unthrottle_wrapper() 252 queue->window = queue->busy_refcount; in qmgr_queue_unthrottle() 255 queue->success = queue->failure = 0; in qmgr_queue_unthrottle() 310 myname, queue->name, queue->dsn->reason); in qmgr_queue_throttle() 328 queue->fail_cohorts += 1.0 / queue->window; in qmgr_queue_throttle() 383 queue->busy_refcount + queue->todo_refcount); in qmgr_queue_done() 384 if (queue->todo.next || queue->busy.next) in qmgr_queue_done() 390 myname, queue->name, queue->dsn->reason); in qmgr_queue_done() [all …]
|
H A D | qmgr_entry.c | 116 QMGR_QUEUE *queue; in qmgr_entry_select() local 119 queue = entry->queue; in qmgr_entry_select() 187 QMGR_QUEUE *queue = entry->queue; in qmgr_entry_unselect() local 254 QMGR_QUEUE *queue = entry->queue; in qmgr_entry_done() local 314 myname, transport->name, queue->name, queue->window); in qmgr_entry_done() 344 if (queue->todo.next == 0 && queue->busy.next == 0) { in qmgr_entry_done() 365 QMGR_QUEUE *queue = peer->queue; in qmgr_entry_create() local 384 entry->queue = queue; in qmgr_entry_create() 412 int queue_length = queue->todo_refcount + queue->busy_refcount; in qmgr_entry_create() 433 else if (queue->peers.next != queue->peers.prev) in qmgr_entry_create() [all …]
|
H A D | qmgr_peer.c | 80 QMGR_PEER *qmgr_peer_create(QMGR_JOB *job, QMGR_QUEUE *queue) in qmgr_peer_create() argument 85 peer->queue = queue; in qmgr_peer_create() 100 QMGR_QUEUE *queue = peer->queue; in qmgr_peer_free() local 117 QMGR_PEER *qmgr_peer_find(QMGR_JOB *job, QMGR_QUEUE *queue) in qmgr_peer_find() argument 128 if ((peer = qmgr_peer_find(job, queue)) == 0) in qmgr_peer_obtain() 129 peer = qmgr_peer_create(job, queue); in qmgr_peer_obtain() 138 QMGR_QUEUE *queue; in qmgr_peer_select() local 145 queue = peer->queue; in qmgr_peer_select() 146 if (queue->window > queue->busy_refcount && peer->entry_list.next != 0) { in qmgr_peer_select() 150 job->message->queue_id, queue->transport->name, queue->name, in qmgr_peer_select() [all …]
|
H A D | qmgr_enable.c | 81 QMGR_QUEUE *queue; in qmgr_enable_transport() local 92 for (queue = transport->queue_list.next; queue; queue = next) { in qmgr_enable_transport() 93 next = queue->peers.next; in qmgr_enable_transport() 94 qmgr_enable_queue(queue); in qmgr_enable_transport() 100 void qmgr_enable_queue(QMGR_QUEUE *queue) in qmgr_enable_queue() argument 102 if (QMGR_QUEUE_THROTTLED(queue)) { in qmgr_enable_queue() 104 msg_info("enable site %s/%s", queue->transport->name, queue->name); in qmgr_enable_queue() 105 qmgr_queue_unthrottle(queue); in qmgr_enable_queue() 107 if (QMGR_QUEUE_READY(queue) && queue->todo.next == 0 && queue->busy.next == 0) in qmgr_enable_queue() 108 qmgr_queue_done(queue); in qmgr_enable_queue()
|
/netbsd/sys/external/bsd/vchiq/dist/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 …]
|
/netbsd/share/man/man3/ |
H A D | Makefile | 142 queue.3 LIST_EMPTY.3 \ 143 queue.3 LIST_ENTRY.3 \ 144 queue.3 LIST_FIRST.3 \ 147 queue.3 LIST_HEAD.3 \ 149 queue.3 LIST_INIT.3 \ 153 queue.3 LIST_NEXT.3 \ 155 queue.3 LIST_REPLACE.3 183 queue.3 SLIST_HEAD.3 \ 185 queue.3 SLIST_INIT.3 \ 188 queue.3 SLIST_NEXT.3 \ [all …]
|
/netbsd/sys/external/bsd/drm2/dist/drm/vmwgfx/ |
H A D | vmwgfx_marker.c | 45 queue->lag = 0; in vmw_marker_queue_init() 70 spin_lock(&queue->lock); in vmw_marker_push() 84 spin_lock(&queue->lock); in vmw_marker_pull() 88 queue->lag = 0; in vmw_marker_pull() 89 queue->lag_time = now; in vmw_marker_pull() 99 queue->lag_time = now; in vmw_marker_pull() 115 spin_lock(&queue->lock); in vmw_fifo_lag() 117 queue->lag += now - queue->lag_time; in vmw_fifo_lag() 118 queue->lag_time = now; in vmw_fifo_lag() 120 return queue->lag; in vmw_fifo_lag() [all …]
|
/netbsd/sys/altq/ |
H A D | altq_wfq.c | 150 new_wfqp->queue = queue; in wfq_ifattach() 155 queue->next = queue->prev = NULL; in wfq_ifattach() 156 queue->head = queue->tail = NULL; in wfq_ifattach() 157 queue->bytes = queue->quota = 0; in wfq_ifattach() 262 queue = &wfqp->queue[0]; in wfq_ifenqueue() 278 queue->next = queue->prev = queue; in wfq_ifenqueue() 453 if (queue->next == queue){ in wfq_ifdequeue() 495 queue = wfqp->rrp = queue->next; in wfq_ifdequeue() 529 queue = &wfqp->queue[swp->qid]; in wfq_setweight() 550 queue = &wfqp->queue[gsp->qid]; in wfq_getstats() [all …]
|
/netbsd/external/bsd/ntp/dist/lib/isc/include/isc/ |
H A D | queue.h | 57 (queue).head = (void *) &((queue).headnode); \ 58 (queue).tail = (void *) &((queue).headnode); \ 62 #define ISC_QUEUE_EMPTY(queue) ISC_TF((queue).head == (queue).tail) argument 75 LOCK(&(queue).taillock); \ 77 (queue).tail = elt; \ 78 UNLOCK(&(queue).taillock); \ 84 LOCK(&(queue).headlock); \ 87 UNLOCK(&(queue).headlock); \ 92 LOCK(&(queue).taillock); \ 93 (queue).tail = (queue).head; \ [all …]
|
/netbsd/sys/external/bsd/drm2/dist/include/drm/ |
H A D | spsc_queue.h | 52 queue->head = NULL; in spsc_queue_init() 53 atomic_long_set(&queue->tail, (long)&queue->head); in spsc_queue_init() 54 atomic_set(&queue->job_count, 0); in spsc_queue_init() 59 return queue->head; in spsc_queue_peek() 64 return atomic_read(&queue->job_count); in spsc_queue_count() 77 atomic_inc(&queue->job_count); in spsc_queue_push() 87 return tail == &queue->head; in spsc_queue_push() 98 node = READ_ONCE(queue->head); in spsc_queue_pop() 104 WRITE_ONCE(queue->head, next); in spsc_queue_pop() 109 if (atomic_long_cmpxchg(&queue->tail, in spsc_queue_pop() [all …]
|
/netbsd/external/ibm-public/postfix/dist/src/cleanup/ |
H A D | Makefile.in | 153 cp test-queue-file test-queue-file.tmp 162 cp test-queue-file2 test-queue-file2.tmp 171 cp test-queue-file3 test-queue-file3.tmp 181 cp test-queue-file4 test-queue-file4.tmp 186 cp test-queue-file4 test-queue-file4.tmp 191 cp test-queue-file4 test-queue-file4.tmp 200 cp test-queue-file5 test-queue-file5.tmp 212 cp test-queue-file6 test-queue-file6.tmp 221 cp test-queue-file6 test-queue-file6.tmp 230 cp test-queue-file6 test-queue-file6.tmp [all …]
|
/netbsd/external/gpl3/gdb/dist/sim/ppc/ |
H A D | events.c | 64 event_entry *queue; member 78 event_queue_schedule (queue, SIM_EVENTS_POLL_RATE, sim_events_poll, queue); in sim_events_poll() 113 event = queue->held; in event_queue_init() 119 queue->held = NULL; in event_queue_init() 120 queue->held_end = &queue->held; in event_queue_init() 127 event = queue->queue; in event_queue_init() 133 queue->queue = NULL; in event_queue_init() 136 queue->processing = 0; in event_queue_init() 141 event_queue_schedule (queue, 0, sim_events_poll, queue); in event_queue_init() 148 return queue->time_of_event - queue->time_from_event; in event_queue_time() [all …]
|
/netbsd/external/gpl3/gdb.old/dist/sim/ppc/ |
H A D | events.c | 64 event_entry *queue; member 78 event_queue_schedule (queue, SIM_EVENTS_POLL_RATE, sim_events_poll, queue); in sim_events_poll() 113 event = queue->held; in event_queue_init() 119 queue->held = NULL; in event_queue_init() 120 queue->held_end = &queue->held; in event_queue_init() 127 event = queue->queue; in event_queue_init() 133 queue->queue = NULL; in event_queue_init() 136 queue->processing = 0; in event_queue_init() 141 event_queue_schedule (queue, 0, sim_events_poll, queue); in event_queue_init() 148 return queue->time_of_event - queue->time_from_event; in event_queue_time() [all …]
|
/netbsd/dist/pf/share/pf/ |
H A D | faq-example3 | 17 # 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 D | faq-example2 | 13 # 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 D | queue2 | 3 # 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 …]
|
/netbsd/external/bsd/ntp/dist/lib/isc/tests/ |
H A D | queue_test.c | 58 item_queue_t queue; in ATF_TC_BODY() local 64 ISC_QUEUE_INIT(queue, qlink); in ATF_TC_BODY() 77 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY() 86 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY() 92 ISC_QUEUE_PUSH(queue, p, qlink); in ATF_TC_BODY() 112 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY() 116 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY() 120 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY() 124 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY() 128 ISC_QUEUE_POP(queue, qlink, p); in ATF_TC_BODY() [all …]
|
/netbsd/sys/dev/raidframe/ |
H A D | rf_diskqueue.c | 298 if (RF_OK_TO_DISPATCH(queue, req)) { in rf_DiskIOEnqueue() 300 rf_DispatchKernelIO(queue, req); in rf_DiskIOEnqueue() 304 req->queue = (void *) queue; in rf_DiskIOEnqueue() 305 (queue->qPtr->Enqueue) (queue->qHdr, req, pri); in rf_DiskIOEnqueue() 318 queue->numOutstanding--; in rf_DiskIOComplete() 326 req = (queue->qPtr->Dequeue) (queue->qHdr); in rf_DiskIOComplete() 333 rf_DispatchKernelIO(queue, req); in rf_DiskIOComplete() 338 queue->queueLength++; in rf_DiskIOComplete() 339 (queue->qPtr->Enqueue) (queue->qHdr, req, req->priority); in rf_DiskIOComplete() 361 if (!queue->qPtr->Promote) in rf_DiskIOPromote() [all …]
|
H A D | rf_sstf.c | 120 _r_ = (_q_)->queue; \ 122 (_q_)->queue = (_r_)->next; \ 144 (_q_)->queue = NULL; \ 171 for (r = queue->queue; r; r = r->next) { in closest_to_arm() 238 return (queue->queue); in closest_to_arm() 324 if (req == queue->queue) { in do_dequeue() 325 DO_HEAD_DEQ(req2, queue); in do_dequeue() 328 if (req == queue->qtail) { in do_dequeue() 329 DO_TAIL_DEQ(req2, queue); in do_dequeue() 335 queue->qlen--; in do_dequeue() [all …]
|
/netbsd/sys/external/bsd/drm2/dist/drm/amd/amdkfd/ |
H A D | kfd_kernel_queue.c | 148 kq->queue->device = dev; in kq_initialize() 156 kq->queue->mqd_mem_obj, in kq_initialize() 163 kq->queue->queue = KFD_CIK_HIQ_QUEUE; in kq_initialize() 165 kq->queue->pipe, kq->queue->queue, in kq_initialize() 180 print_queue(kq->queue); in kq_initialize() 184 kq->mqd_mgr->free_mqd(kq->mqd_mgr, kq->queue->mqd, kq->queue->mqd_mem_obj); in kq_initialize() 186 uninit_queue(kq->queue); in kq_initialize() 207 kq->queue->mqd, in kq_uninitialize() 210 kq->queue->pipe, in kq_uninitialize() 211 kq->queue->queue); in kq_uninitialize() [all …]
|
/netbsd/external/apache2/llvm/dist/libcxx/include/ |
H A D | queue | 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; 51 queue(const queue& q, const Alloc& a); 53 queue(queue&& q, const Alloc& a); 227 queue(const queue& __q) : c(__q.c) {} 234 queue(queue&& __q) 239 queue& operator=(queue&& __q) [all …]
|
/netbsd/external/gpl3/gcc/dist/libhsail-rt/rt/ |
H A D | queue.c | 32 phsa_queue_t *queue = (phsa_queue_t *) (uintptr_t) queue_addr; in __hsail_ldqueuereadindex() local 33 return queue->read_index; in __hsail_ldqueuereadindex() 39 phsa_queue_t *queue = (phsa_queue_t *) (uintptr_t) queue_addr; in __hsail_ldqueuewriteindex() local 40 return queue->write_index; in __hsail_ldqueuewriteindex() 46 phsa_queue_t *queue = (phsa_queue_t *) (uintptr_t) queue_addr; in __hsail_addqueuewriteindex() local 47 return __sync_fetch_and_add (&queue->write_index, value); in __hsail_addqueuewriteindex() 54 phsa_queue_t *queue = (phsa_queue_t *) (uintptr_t) queue_addr; in __hsail_casqueuewriteindex() local 62 phsa_queue_t *queue = (phsa_queue_t *) (uintptr_t) queue_addr; in __hsail_stqueuereadindex() local 63 queue->read_index = value; in __hsail_stqueuereadindex() 69 phsa_queue_t *queue = (phsa_queue_t *) (uintptr_t) queue_addr; in __hsail_stqueuewriteindex() local [all …]
|