Home
last modified time | relevance | path

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

12345678910>>...57

/netbsd/external/ibm-public/postfix/dist/src/oqmgr/
H A Dqmgr_queue.c128 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 Dqmgr_entry.c111 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 Dqmgr_enable.c81 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 Dqmgr_queue.c134 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 Dqmgr_entry.c116 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 Dqmgr_peer.c80 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 Dqmgr_enable.c81 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 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 …]
/netbsd/share/man/man3/
H A DMakefile142 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 Dvmwgfx_marker.c45 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 Daltq_wfq.c150 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 Dqueue.h57 (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 Dspsc_queue.h52 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 DMakefile.in153 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 Devents.c64 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 Devents.c64 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 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 …]
/netbsd/external/bsd/ntp/dist/lib/isc/tests/
H A Dqueue_test.c58 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 Drf_diskqueue.c298 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 Drf_sstf.c120 _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 Dkfd_kernel_queue.c148 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 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);
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 Dqueue.c32 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 …]

12345678910>>...57