Home
last modified time | relevance | path

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

12345678910>>...50

/netbsd-src/external/ibm-public/postfix/dist/src/oqmgr/
H A Dqmgr_queue.c116 #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 …]
H A Dqmgr_entry.c104 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 …]
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-src/external/ibm-public/postfix/dist/src/qmgr/
H A Dqmgr_queue.c122 #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 …]
H A Dqmgr_entry.c116 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 …]
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()
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 …]
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-src/sys/external/bsd/vchiq/dist/interface/vchiq_arm/
H A Dvchiq_util.c41 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/
H A DMakefile13 makedev.3 offsetof.3 param.3 paths.3 queue.3 rbtree.3 sigevent.3 \
19 USETBL= # used by queue.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
[all...]
/netbsd-src/sys/external/bsd/drm2/dist/drm/vmwgfx/
H A Dvmwgfx_marker.c42 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/
H A Daltq_wfq.c87 /* global value : pointer to wfq queue list */
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 in wfq_ifattach()
254 wfq *queue; wfq_ifenqueue() local
418 wfq *queue, *max_queue = NULL; wfq_maxqueue() local
438 wfq *queue; wfq_ifdequeue() local
517 wfq *queue; wfq_setweight() local
541 wfq *queue; wfq_getstats() local
566 wfq *queue; wfq_config() local
[all...]
/netbsd-src/sys/external/bsd/drm2/dist/include/drm/
H A Dspsc_queue.h50 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/
H A DMakefile.in151 cleanup_milter_test: cleanup_milter test-queue-file cleanup_milter.in1 \
153 cp test-queue-file test-queue-file.tmp
154 chmod u+w test-queue-file.tmp
156 $(SHLIB_ENV) $(VALGRIND) ../postcat/postcat -ov test-queue-file.tmp 2>/dev/null >cleanup_milter.tmp
158 rm -f test-queue-file.tmp cleanup_milter.tmp
160 cleanup_milter_test2: cleanup_milter test-queue-file2 cleanup_milter.in2 \
162 cp test-queue-file2 test-queue-file2.tmp
163 chmod u+w test-queue-file2.tmp
165 …$(SHLIB_ENV) $(VALGRIND) ../postcat/postcat -ov test-queue-file2.tmp 2>/dev/null >cleanup_milter.t…
167 rm -f test-queue-file2.tmp cleanup_milter.tmp
[all …]
/netbsd-src/external/gpl3/gdb/dist/sim/ppc/
H A Devents.c64 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/
H A Dfaq-example310 # 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 …]
H A Dfaq-example213 # 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 …]
H A Dqueue23 # 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 …]
H A Dqueue17 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/external/bsd/drm2/dist/drm/amd/amdkfd/
H A Dkfd_kernel_queue.c145 if (init_queue(&kq->queue, &prop) != 0) in kq_initialize()
148 kq->queue->device = dev; in kq_initialize()
149 kq->queue->process = kfd_get_process(current); in kq_initialize()
151 kq->queue->mqd_mem_obj = kq->mqd_mgr->allocate_mqd(kq->mqd_mgr->dev, in kq_initialize()
152 &kq->queue->properties); in kq_initialize()
153 if (!kq->queue->mqd_mem_obj) in kq_initialize()
155 kq->mqd_mgr->init_mqd(kq->mqd_mgr, &kq->queue->mqd, in kq_initialize()
156 kq->queue->mqd_mem_obj, in kq_initialize()
157 &kq->queue->gart_mqd_addr, in kq_initialize()
158 &kq->queue->properties); in kq_initialize()
[all …]
/netbsd-src/sys/dev/raidframe/
H A Drf_diskqueue.c293 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 …]
H A Drf_sstf.c120 _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/apache2/llvm/dist/libcxx/include/
H A Dqueue2 //===--------------------------- queue ------------------------------------===//
14 queue synopsis
20 class queue
33 queue() = default;
34 ~queue() = default;
36 queue(const queue& q) = default;
37 queue(queue&& q) = default;
39 queue& operator=(const queue& q) = default;
40 queue& operator=(queue&& q) = default;
42 explicit queue(const container_type& c);
[all …]
/netbsd-src/external/gpl3/gcc.old/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
55 return __sync_val_compare_and_swap (&queue->write_index, cmp_value, in __hsail_casqueuewriteindex()
62 phsa_queue_t *queue = (phsa_queue_t *) (uintptr_t) queue_addr; in __hsail_stqueuereadindex() local
63 queue->read_index = value; in __hsail_stqueuereadindex()
[all …]
/netbsd-src/external/gpl3/gcc.old/dist/libstdc++-v3/include/bits/
H A Dstl_queue.h96 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/include/
H A Dntp_prio_q.h37 } 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(

12345678910>>...50