| /netbsd/src/external/ibm-public/postfix/dist/src/oqmgr/ |
| D | qmgr_queue.c | 116 #define QMGR_ERROR_OR_RETRY_QUEUE(queue) \ argument
117 (strcmp(queue->transport->name, MAIL_SERVICE_RETRY) == 0 \
118 || strcmp(queue->transport->name, MAIL_SERVICE_ERROR) == 0)
121 if (var_conc_feedback_debug && !QMGR_ERROR_OR_RETRY_QUEUE(queue)) \
124 #define QMGR_LOG_WINDOW(queue) \ argument
125 if (var_conc_feedback_debug && !QMGR_ERROR_OR_RETRY_QUEUE(queue)) \
127 myname, queue->name, queue->transport->dest_concurrency_limit, \
128 queue->window, queue->success, queue->failure, queue->fail_cohorts);
134 QMGR_QUEUE *queue = (QMGR_QUEUE *) context; in qmgr_queue_resume() local
140 if (!QMGR_QUEUE_SUSPENDED(queue)) in qmgr_queue_resume()
[all …]
|
| D | qmgr_entry.c | 104 QMGR_ENTRY *qmgr_entry_select(QMGR_QUEUE *queue) in qmgr_entry_select() argument
109 if ((entry = queue->todo.prev) != 0) { in qmgr_entry_select()
110 QMGR_LIST_UNLINK(queue->todo, QMGR_ENTRY *, entry); in qmgr_entry_select()
111 queue->todo_refcount--; in qmgr_entry_select()
112 QMGR_LIST_APPEND(queue->busy, entry); in qmgr_entry_select()
113 queue->busy_refcount++; in qmgr_entry_select()
132 (queue->busy_refcount > 1 || BACK_TO_BACK_DELIVERY()) in qmgr_entry_select()
135 (queue->last_done + 1 >= event_time()) in qmgr_entry_select()
143 if ((queue->dflags & DEL_REQ_FLAG_CONN_STORE) == 0) { in qmgr_entry_select()
147 myname, queue->name); in qmgr_entry_select()
[all …]
|
| 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()
|
| D | qmgr_deliver.c | 184 | entry->queue->dflags in qmgr_deliver_send_request()
193 SEND_ATTR_STR(MAIL_ATTR_NEXTHOP, entry->queue->nexthop), in qmgr_deliver_send_request()
222 msg_warn("write to process (%s): %m", entry->queue->transport->name); in qmgr_deliver_send_request()
226 msg_info("qmgr_deliver: site `%s'", entry->queue->name); in qmgr_deliver_send_request()
236 QMGR_QUEUE *queue = entry->queue; in qmgr_deliver_abort() local
237 QMGR_TRANSPORT *transport = queue->transport; in qmgr_deliver_abort()
249 QMGR_QUEUE *queue = entry->queue; in qmgr_deliver_update() local
250 QMGR_TRANSPORT *transport = queue->transport; in qmgr_deliver_update()
322 qmgr_entry_unselect(queue, entry); in qmgr_deliver_update()
352 if (QMGR_QUEUE_READY(queue)) { in qmgr_deliver_update()
[all …]
|
| /netbsd/src/external/ibm-public/postfix/dist/src/qmgr/ |
| D | qmgr_queue.c | 122 #define QMGR_ERROR_OR_RETRY_QUEUE(queue) \ argument
123 (strcmp(queue->transport->name, MAIL_SERVICE_RETRY) == 0 \
124 || strcmp(queue->transport->name, MAIL_SERVICE_ERROR) == 0)
127 if (var_conc_feedback_debug && !QMGR_ERROR_OR_RETRY_QUEUE(queue)) \
130 #define QMGR_LOG_WINDOW(queue) \ argument
131 if (var_conc_feedback_debug && !QMGR_ERROR_OR_RETRY_QUEUE(queue)) \
133 myname, queue->name, queue->transport->dest_concurrency_limit, \
134 queue->window, queue->success, queue->failure, queue->fail_cohorts);
140 QMGR_QUEUE *queue = (QMGR_QUEUE *) context; in qmgr_queue_resume() local
146 if (!QMGR_QUEUE_SUSPENDED(queue)) in qmgr_queue_resume()
[all …]
|
| D | qmgr_entry.c | 116 QMGR_QUEUE *queue; in qmgr_entry_select() local
119 queue = entry->queue; in qmgr_entry_select()
120 QMGR_LIST_UNLINK(queue->todo, QMGR_ENTRY *, entry, queue_peers); in qmgr_entry_select()
121 queue->todo_refcount--; in qmgr_entry_select()
122 QMGR_LIST_APPEND(queue->busy, entry, queue_peers); in qmgr_entry_select()
123 queue->busy_refcount++; in qmgr_entry_select()
144 (queue->busy_refcount > 1 || BACK_TO_BACK_DELIVERY()) in qmgr_entry_select()
147 (queue->last_done + 1 >= event_time()) in qmgr_entry_select()
155 if ((queue->dflags & DEL_REQ_FLAG_CONN_STORE) == 0) { in qmgr_entry_select()
159 myname, queue->name); in qmgr_entry_select()
[all …]
|
| 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()
88 htable_enter(job->peer_byname, queue->name, (void *) peer); in qmgr_peer_create()
100 QMGR_QUEUE *queue = peer->queue; in qmgr_peer_free() local
108 msg_panic("%s: entry list not empty: %s", myname, queue->name); in qmgr_peer_free()
111 htable_delete(job->peer_byname, queue->name, (void (*) (void *)) 0); in qmgr_peer_free()
117 QMGR_PEER *qmgr_peer_find(QMGR_JOB *job, QMGR_QUEUE *queue) in qmgr_peer_find() argument
119 return ((QMGR_PEER *) htable_find(job->peer_byname, queue->name)); in qmgr_peer_find()
124 QMGR_PEER *qmgr_peer_obtain(QMGR_JOB *job, QMGR_QUEUE *queue) in qmgr_peer_obtain() argument
128 if ((peer = qmgr_peer_find(job, queue)) == 0) in qmgr_peer_obtain()
[all …]
|
| 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/src/sys/external/bsd/vchiq/dist/interface/vchiq_arm/ |
| D | vchiq_util.c | 41 int vchiu_queue_init(VCHIU_QUEUE_T *queue, int size) in vchiu_queue_init() argument
45 queue->size = size; in vchiu_queue_init()
46 queue->read = 0; in vchiu_queue_init()
47 queue->write = 0; in vchiu_queue_init()
48 queue->initialized = 1; in vchiu_queue_init()
50 _sema_init(&queue->pop, 0); in vchiu_queue_init()
51 _sema_init(&queue->push, 0); in vchiu_queue_init()
53 queue->storage = kzalloc(size * sizeof(VCHIQ_HEADER_T *), GFP_KERNEL); in vchiu_queue_init()
54 if (queue->storage == NULL) { in vchiu_queue_init()
55 vchiu_queue_delete(queue); in vchiu_queue_init()
[all …]
|
| /netbsd/src/share/man/man3/ |
| D | Makefile | 13 makedev.3 offsetof.3 param.3 paths.3 queue.3 rbtree.3 sigevent.3 \
142 MLINKS+=queue.3 LIST.3 \
143 queue.3 LIST_EMPTY.3 \
144 queue.3 LIST_ENTRY.3 \
145 queue.3 LIST_FIRST.3 \
146 queue.3 LIST_FOREACH.3 \
147 queue.3 LIST_FOREACH_SAFE.3 \
148 queue.3 LIST_HEAD.3 \
149 queue.3 LIST_HEAD_INITIALIZER.3 \
150 queue.3 LIST_INIT.3 \
[all …]
|
| /netbsd/src/sys/external/bsd/drm2/dist/drm/vmwgfx/ |
| D | vmwgfx_marker.c | 42 void vmw_marker_queue_init(struct vmw_marker_queue *queue) in vmw_marker_queue_init() argument
44 INIT_LIST_HEAD(&queue->head); in vmw_marker_queue_init()
45 queue->lag = 0; in vmw_marker_queue_init()
46 queue->lag_time = ktime_get_raw_ns(); in vmw_marker_queue_init()
47 spin_lock_init(&queue->lock); in vmw_marker_queue_init()
50 void vmw_marker_queue_takedown(struct vmw_marker_queue *queue) in vmw_marker_queue_takedown() argument
54 list_for_each_entry_safe(marker, next, &queue->head, head) { in vmw_marker_queue_takedown()
57 spin_lock_destroy(&queue->lock); in vmw_marker_queue_takedown()
60 int vmw_marker_push(struct vmw_marker_queue *queue, in vmw_marker_push() argument
70 spin_lock(&queue->lock); in vmw_marker_push()
[all …]
|
| /netbsd/src/sys/altq/ |
| D | altq_wfq.c | 117 wfq *queue; in wfq_ifattach() local
138 queue = malloc(sizeof(wfq) * DEFAULT_QSIZE, M_DEVBUF, M_WAITOK|M_ZERO); in wfq_ifattach()
139 if (queue == NULL) { in wfq_ifattach()
150 new_wfqp->queue = queue; in wfq_ifattach()
154 for (i = 0; i < new_wfqp->nums; i++, 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()
158 queue->weight = 100; in wfq_ifattach()
167 free(queue, M_DEVBUF); in wfq_ifattach()
[all …]
|
| /netbsd/src/sys/external/bsd/drm2/dist/include/drm/ |
| D | spsc_queue.h | 50 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init() argument
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()
57 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek() argument
59 return queue->head; in spsc_queue_peek()
62 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count() argument
64 return atomic_read(&queue->job_count); in spsc_queue_count()
67 static inline bool spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) in spsc_queue_push() argument
75 tail = (struct spsc_node **)atomic_long_xchg(&queue->tail, (long)&node->next); in spsc_queue_push()
[all …]
|
| /netbsd/src/external/ibm-public/postfix/dist/src/cleanup/ |
| D | Makefile.in | 149 cleanup_milter_test: cleanup_milter test-queue-file cleanup_milter.in1 \
151 cp test-queue-file test-queue-file.tmp
152 chmod u+w test-queue-file.tmp
154 …$(SHLIB_ENV) $(VALGRIND) ../postcat/postcat -ov test-queue-file.tmp 2>/dev/null >cleanup_milter.tmp
156 rm -f test-queue-file.tmp cleanup_milter.tmp
158 cleanup_milter_test2: cleanup_milter test-queue-file2 cleanup_milter.in2 \
160 cp test-queue-file2 test-queue-file2.tmp
161 chmod u+w test-queue-file2.tmp
163 …$(SHLIB_ENV) $(VALGRIND) ../postcat/postcat -ov test-queue-file2.tmp 2>/dev/null >cleanup_milter.t…
165 rm -f test-queue-file2.tmp cleanup_milter.tmp
[all …]
|
| /netbsd/src/external/gpl3/gdb/dist/sim/ppc/ |
| D | events.c | 64 event_entry *queue; member
76 event_queue *queue = data; in sim_events_poll() local
78 event_queue_schedule (queue, SIM_EVENTS_POLL_RATE, sim_events_poll, queue); in sim_events_poll()
90 new_event_queue->queue = NULL; in event_queue_create()
101 event_queue_init(event_queue *queue) in event_queue_init() argument
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()
[all …]
|
| /netbsd/src/dist/pf/share/pf/ |
| D | faq-example3 | 10 # enable queueing on the external interface to queue packets going out
12 # each queue can be controlled. the max outgoing bandwidth is 1.5Mbps.
14 altq on fxp0 cbq bandwidth 1.5Mb queue { std_ext, www_ext, boss_ext }
17 # std_ext - the standard queue. also the default queue for
19 # www_ext - container queue for WWW server queues. limit to
25 queue std_ext bandwidth 500Kb cbq(default borrow)
26 queue www_ext bandwidth 500Kb { www_ext_http, www_ext_misc }
27 queue www_ext_http bandwidth 50% priority 3 cbq(red borrow)
28 queue www_ext_misc bandwidth 50% priority 1 cbq(borrow)
29 queue boss_ext bandwidth 500Kb priority 3 cbq(borrow)
[all …]
|
| D | faq-example2 | 13 # ACK queue.
15 altq on fxp0 priq bandwidth 610Kb queue { std_out, ssh_im_out, dns_out, \
19 # std_out - the standard queue. any filter rule below that does not
20 # explicitly specify a queue will have its traffic added
21 # to this queue.
26 queue std_out priq(default)
27 queue ssh_im_out priority 4 priq(red)
28 queue dns_out priority 5
29 queue tcp_ack_out priority 6
35 altq on dc0 cbq bandwidth 2Mb queue { std_in, ssh_im_in, dns_in, bob_in }
[all …]
|
| D | queue2 | 3 # advanced queue example.
10 altq on $ext_if cbq bandwidth 5Mb queue { std, http, mail, ssh }
12 queue std bandwidth 10% cbq(default)
13 queue http bandwidth 60% priority 2 cbq(borrow red) { employees, developers }
14 queue developers bandwidth 75% cbq(borrow)
15 queue employees bandwidth 15%
16 queue mail bandwidth 10% priority 0 cbq(borrow ecn)
17 queue ssh bandwidth 20% cbq(borrow) { ssh_interactive, ssh_bulk }
18 queue ssh_interactive bandwidth 25% priority 7
19 queue ssh_bulk bandwidth 75% priority 0
[all …]
|
| D | queue1 | 7 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 …]
|
| /netbsd/src/sys/dev/raidframe/ |
| D | rf_diskqueue.c | 293 rf_DiskIOEnqueue(RF_DiskQueue_t *queue, RF_DiskQueueData_t *req, int pri) in rf_DiskIOEnqueue() argument
304 RF_LOCK_QUEUE_MUTEX(queue, "DiskIOEnqueue"); in rf_DiskIOEnqueue()
305 if (RF_OK_TO_DISPATCH(queue, req)) { in rf_DiskIOEnqueue()
306 … Dprintf2("Dispatching pri %d regular op to c %d (ok to dispatch)\n", pri, queue->col); in rf_DiskIOEnqueue()
307 rf_DispatchKernelIO(queue, req); in rf_DiskIOEnqueue()
309 … queue->queueLength++; /* increment count of number of requests waiting in this queue */ in rf_DiskIOEnqueue()
310 … Dprintf2("Enqueueing pri %d regular op to c %d (not ok to dispatch)\n", pri, queue->col); in rf_DiskIOEnqueue()
311 req->queue = (void *) queue; in rf_DiskIOEnqueue()
312 (queue->qPtr->Enqueue) (queue->qHdr, req, pri); in rf_DiskIOEnqueue()
314 RF_UNLOCK_QUEUE_MUTEX(queue, "DiskIOEnqueue"); in rf_DiskIOEnqueue()
[all …]
|
| D | rf_sstf.c | 120 _r_ = (_q_)->queue; \
122 (_q_)->queue = (_r_)->next; \
126 RF_ASSERT((_q_)->queue == NULL); \
130 RF_ASSERT((_q_)->queue->prev == (_r_)); \
131 (_q_)->queue->prev = NULL; \
142 RF_ASSERT((_r_) == (_q_)->queue); \
144 (_q_)->queue = NULL; \
153 if (SNUM_DIFF((_q_)->queue->sectorOffset,_l_) \
164 closest_to_arm(RF_SstfQ_t *queue, RF_SectorNum_t arm_pos, int *dir, int allow_reverse) in closest_to_arm() argument
171 for (r = queue->queue; r; r = r->next) { in closest_to_arm()
[all …]
|
| /netbsd/src/external/bsd/ntp/dist/include/ |
| D | ntp_prio_q.h | 37 } queue; typedef
46 void destroy_queue(queue *my_queue);
49 int empty(queue *my_queue);
50 void *queue_head(queue *my_queue);
51 queue *enqueue(queue *my_queue, void *my_node);
52 void append_queue(queue *q1, queue *q2);
53 void *dequeue(queue *my_queue);
54 int get_no_of_elements(queue *my_queue);
69 queue *debug_create_priority_queue(
|
| /netbsd/src/external/gpl3/gcc/dist/libstdc++-v3/include/bits/ |
| D | stl_queue.h | 96 class queue in _GLIBCXX_VISIBILITY()
111 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_VISIBILITY()
115 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_VISIBILITY()
120 operator<=>(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_VISIBILITY()
161 queue(const _Sequence& __c = _Sequence()) in _GLIBCXX_VISIBILITY()
166 queue() in _GLIBCXX_VISIBILITY()
170 queue(const _Sequence& __c) in _GLIBCXX_VISIBILITY()
174 queue(_Sequence&& __c) in _GLIBCXX_VISIBILITY()
179 queue(const _Alloc& __a) in _GLIBCXX_VISIBILITY()
183 queue(const _Sequence& __c, const _Alloc& __a) in _GLIBCXX_VISIBILITY()
[all …]
|
| /netbsd/src/external/bsd/ntp/dist/ntpd/ |
| D | ntp_prio_q.c | 26 queue *debug_create_priority_queue( in debug_create_priority_queue()
34 queue *my_queue; in debug_create_priority_queue()
37 my_queue = emalloc(sizeof(queue)); in debug_create_priority_queue()
40 my_queue = debug_erealloc(NULL, sizeof(queue), sourcefile, line_num); in debug_create_priority_queue()
55 queue *my_queue in destroy_queue()
128 queue *my_queue in empty()
137 queue *q in queue_head()
151 queue *enqueue( in enqueue()
152 queue * my_queue, in enqueue()
183 queue *my_queue in dequeue()
[all …]
|
| /netbsd/src/external/ibm-public/postfix/dist/src/smtpd/ |
| D | smtpd_check_dsn.ref | 17 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.1_dsn[1.2.3.4]: 554 5.0.0 <4.1.1_dsn[1.2.3.4]>:…
21 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.2_dsn[1.2.3.4]: 554 5.0.0 <4.1.2_dsn[1.2.3.4]>:…
25 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.3_dsn[1.2.3.4]: 554 5.0.0 <4.1.3_dsn[1.2.3.4]>:…
29 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.4_dsn[1.2.3.4]: 554 5.0.0 <4.1.4_dsn[1.2.3.4]>:…
33 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.5_dsn[1.2.3.4]: 554 5.0.0 <4.1.5_dsn[1.2.3.4]>:…
37 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.6_dsn[1.2.3.4]: 554 5.0.0 <4.1.6_dsn[1.2.3.4]>:…
41 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.7_dsn[1.2.3.4]: 554 5.0.0 <4.1.7_dsn[1.2.3.4]>:…
45 ./smtpd_check: <queue id>: reject: CONNECT from 4.1.8_dsn[1.2.3.4]: 554 5.0.0 <4.1.8_dsn[1.2.3.4]>:…
48 ./smtpd_check: <queue id>: reject: CONNECT from 4.4.0_dsn[1.2.3.4]: 554 5.4.0 <4.4.0_dsn[1.2.3.4]>:…
59 ./smtpd_check: <queue id>: reject: HELO from dummy[dummy]: 554 5.0.0 <4.1.1_dsn>: Helo command reje…
[all …]
|