| /dflybsd-src/sys/kern/ |
| H A D | subr_taskqueue.c | 72 _timeout_task_init(struct taskqueue *queue, struct timeout_task *timeout_task, in _timeout_task_init() argument
78 timeout_task->t.ta_queue = queue; in _timeout_task_init()
82 static void taskqueue_run(struct taskqueue *queue, int lock_held);
118 struct taskqueue *queue; in taskqueue_create() local
120 queue = kmalloc(sizeof(*queue), M_TASKQUEUE, mflags | M_ZERO); in taskqueue_create()
121 if (!queue) in taskqueue_create()
123 STAILQ_INIT(&queue->tq_queue); in taskqueue_create()
124 queue->tq_name = name; in taskqueue_create()
125 queue->tq_enqueue = enqueue; in taskqueue_create()
126 queue->tq_context = context; in taskqueue_create()
[all …]
|
| H A D | subr_gtaskqueue.c | 48 static int task_is_running(struct gtaskqueue *queue, struct gtask *gtask);
49 static void gtaskqueue_drain_locked(struct gtaskqueue *queue, struct gtask *gtask);
112 struct gtaskqueue *queue; in _gtaskqueue_create() local
114 queue = kmalloc(sizeof(struct gtaskqueue), in _gtaskqueue_create()
116 if (!queue) { in _gtaskqueue_create()
121 STAILQ_INIT(&queue->tq_queue); in _gtaskqueue_create()
122 LIST_INIT(&queue->tq_active); in _gtaskqueue_create()
123 queue->tq_enqueue = enqueue; in _gtaskqueue_create()
124 queue->tq_context = context; in _gtaskqueue_create()
125 queue->tq_name = name ? name : "taskqueue"; in _gtaskqueue_create()
[all …]
|
| /dflybsd-src/share/man/man3/ |
| H A D | Makefile | 4 MAN= assert.3 bitstring.3 end.3 fpgetround.3 intro.3 queue.3 \
16 MLINKS+=queue.3 LIST_EMPTY.3
17 MLINKS+=queue.3 LIST_ENTRY.3
18 MLINKS+=queue.3 LIST_FIRST.3
19 MLINKS+=queue.3 LIST_FOREACH.3
20 MLINKS+=queue.3 LIST_FOREACH_FROM.3
21 MLINKS+=queue.3 LIST_FOREACH_FROM_MUTABLE.3
22 MLINKS+=queue.3 LIST_FOREACH_MUTABLE.3
23 MLINKS+=queue.3 LIST_HEAD.3
24 MLINKS+=queue.3 LIST_HEAD_INITIALIZER.3
[all …]
|
| /dflybsd-src/sys/dev/disk/nvme/ |
| H A D | nvme.c | 128 nvme_subqueue_t *queue = &sc->subqueues[qid]; in nvme_alloc_subqueue() local
135 lockinit(&queue->lk, "nvqlk", 0, 0); in nvme_alloc_subqueue()
136 queue->sc = sc; in nvme_alloc_subqueue()
137 queue->nqe = sc->maxqe; in nvme_alloc_subqueue()
138 queue->qid = qid; in nvme_alloc_subqueue()
139 queue->subq_doorbell_reg = NVME_REG_SUBQ_BELL(qid, sc->dstrd4); in nvme_alloc_subqueue()
145 error = bus_dmamem_alloc(sc->sque_tag, (void **)&queue->ksubq, in nvme_alloc_subqueue()
146 BUS_DMA_ZERO, &queue->sque_map); in nvme_alloc_subqueue()
149 error = bus_dmamap_load(sc->sque_tag, queue->sque_map, in nvme_alloc_subqueue()
150 queue->ksubq, in nvme_alloc_subqueue()
[all …]
|
| /dflybsd-src/sys/bus/cam/ |
| H A D | cam_queue.c | 90 camq_free(struct camq *queue) in camq_free() argument
92 if (queue != NULL) { in camq_free()
93 camq_fini(queue); in camq_free()
94 kfree(queue, M_CAMQ); in camq_free()
99 camq_fini(struct camq *queue) in camq_fini() argument
101 if (queue->queue_array != NULL) { in camq_fini()
106 queue->queue_array++; in camq_fini()
107 kfree(queue->queue_array, M_CAMQ); in camq_fini()
112 camq_resize(struct camq *queue, int new_size) in camq_resize() argument
117 if (new_size < queue->entries) in camq_resize()
[all …]
|
| H A D | cam_queue.h | 59 struct camq queue; member
113 u_int32_t camq_resize(struct camq *queue, int new_size);
125 void camq_free(struct camq *queue);
130 void camq_fini(struct camq *queue);
136 void camq_insert(struct camq *queue, cam_pinfo *new_entry);
142 cam_pinfo *camq_remove(struct camq *queue, int index);
152 void camq_change_priority(struct camq *queue, int index,
171 cam_ccbq_send_ccb(struct cam_ccbq *queue, union ccb *send_ccb);
183 return (ccbq->queue.entries); in cam_ccbq_pending_ccb_count()
197 camq_insert(&ccbq->queue, &new_ccb->ccb_h.pinfo); in cam_ccbq_insert_ccb()
[all …]
|
| /dflybsd-src/libexec/dma/ |
| H A D | dma.c | 101 set_from(struct queue *queue, const char *osender) in set_from() argument
135 queue->sender = sender; in set_from()
159 do_alias(struct queue *queue, const char *addr) in do_alias() argument
169 if (add_recp(queue, sit->str, EXPAND_ADDR) != 0) in do_alias()
179 add_recp(struct queue *queue, const char *str, int expand) in add_recp() argument
193 it->sender = queue->sender; in add_recp()
200 LIST_FOREACH(tit, &queue->queue, next) { in add_recp()
208 LIST_INSERT_HEAD(&queue->queue, it, next); in add_recp()
217 aliased = do_alias(queue, it->addr); in add_recp()
219 aliased = do_alias(queue, "*"); in add_recp()
[all …]
|
| H A D | spool.c | 75 newspoolf(struct queue *queue) in newspoolf() argument
93 queue->tmpf = strdup(fn); in newspoolf()
94 if (queue->tmpf == NULL) in newspoolf()
102 if (asprintf(&queue->id, "%"PRIxMAX, (uintmax_t)st.st_ino) < 0) in newspoolf()
105 queue->mailf = fdopen(fd, "r+"); in newspoolf()
106 if (queue->mailf == NULL) in newspoolf()
111 t->str = queue->tmpf; in newspoolf()
117 if (queue->mailf != NULL) in newspoolf()
118 fclose(queue->mailf); in newspoolf()
157 readqueuef(struct queue *queue, char *queuefn) in readqueuef() argument
[all …]
|
| H A D | mail.c | 51 struct queue bounceq; in bounce()
63 LIST_INIT(&bounceq.queue); in bounce()
167 parse_addrs(struct parse_state *ps, char *s, struct queue *queue) in parse_addrs() argument
342 if (add_recp(queue, addr, EXPAND_WILDCARD) != 0) in parse_addrs()
349 writeline(struct queue *queue, const char *line, ssize_t linelen) in writeline() argument
359 if (fwrite(line, len, 1, queue->mailf) != 1) in writeline()
365 if (fwrite("\n", 1, 1, queue->mailf) != 1) in writeline()
375 readmail(struct queue *queue, int nodot, int recp_from_header) in readmail() argument
393 error = fprintf(queue->mailf, in readmail()
400 queue->sender, in readmail()
[all …]
|
| H A D | dma.h | 122 struct queue { struct
123 struct queueh queue; member
214 int add_recp(struct queue *, const char *, int);
215 void run_queue(struct queue *);
218 int newspoolf(struct queue *);
219 int linkspool(struct queue *);
220 int load_queue(struct queue *);
223 void dropspool(struct queue *, struct qitem *);
232 int readmail(struct queue *, int, int);
|
| /dflybsd-src/sys/dev/drm/include/drm/ |
| H A D | spsc_queue.h | 48 static inline void spsc_queue_init(struct spsc_queue *queue) in spsc_queue_init() argument
50 queue->head = NULL; in spsc_queue_init()
51 atomic_long_set(&queue->tail, (long)&queue->head); in spsc_queue_init()
52 atomic_set(&queue->job_count, 0); in spsc_queue_init()
55 static inline struct spsc_node *spsc_queue_peek(struct spsc_queue *queue) in spsc_queue_peek() argument
57 return queue->head; in spsc_queue_peek()
60 static inline int spsc_queue_count(struct spsc_queue *queue) in spsc_queue_count() argument
62 return atomic_read(&queue->job_count); in spsc_queue_count()
65 static inline bool spsc_queue_push(struct spsc_queue *queue, struct spsc_node *node) in spsc_queue_push() argument
73 tail = (struct spsc_node **)atomic_long_xchg(&queue->tail, (long)&node->next); in spsc_queue_push()
[all …]
|
| /dflybsd-src/share/examples/pf/ |
| H A 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 …]
|
| H A 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 …]
|
| H A 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 …]
|
| H A 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 keep state queue http
[all …]
|
| H A D | queue4 | 11 # whenever there is no backlogged sibling queue but when a queue gets
12 # backlogged, it is guaranteed that the queue gets its linkshare.
14 altq on dc0 bandwidth 16Mb hfsc queue { eng law art }
15 queue eng bandwidth 10Mb { cs ee ie }
16 queue cs hfsc( default linkshare 50% )
17 queue ee hfsc( linkshare 30% )
18 queue ie hfsc( linkshare 20% )
19 queue law bandwidth 3Mb
20 queue art bandwidth 3Mb
|
| H A D | queue3 | 7 altq on $ext_if priq bandwidth 10Mb queue { pri-low pri-med pri-high }
8 queue pri-low priority 0
9 queue pri-med priority 1 priq(default)
10 queue pri-high priority 2
13 queue(pri-med, pri-high)
14 pass out on $ext_if proto tcp from any to any port 80 keep state queue pri-med
15 pass in on $ext_if proto tcp from any to any port 80 keep state queue pri-low
|
| H A D | ackpri | 4 # Use a simple priority queue to prioritize empty (no payload) TCP ACKs,
12 # priority queue below, download drops only to 48 kB/s.
20 # value. If it's set too high, the priority queue is not effective, and
24 altq on $ext_if priq bandwidth 100Kb queue { q_pri, q_def }
25 queue q_pri priority 7
26 queue q_def priority 1 priq(default)
29 keep state queue (q_def, q_pri)
32 keep state queue (q_def, q_pri)
|
| /dflybsd-src/contrib/gcc-8.0/libstdc++-v3/include/bits/ |
| H A 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()
147 queue(const _Sequence& __c = _Sequence()) in _GLIBCXX_VISIBILITY()
152 queue() in _GLIBCXX_VISIBILITY()
156 queue(const _Sequence& __c) in _GLIBCXX_VISIBILITY()
160 queue(_Sequence&& __c) in _GLIBCXX_VISIBILITY()
165 queue(const _Alloc& __a) in _GLIBCXX_VISIBILITY()
169 queue(const _Sequence& __c, const _Alloc& __a) in _GLIBCXX_VISIBILITY()
173 queue(_Sequence&& __c, const _Alloc& __a) in _GLIBCXX_VISIBILITY()
[all …]
|
| /dflybsd-src/sys/sys/ |
| H A D | taskqueue.h | 79 int taskqueue_enqueue(struct taskqueue *queue, struct task *task);
80 int taskqueue_enqueue_optq(struct taskqueue *queue,
82 int taskqueue_enqueue_timeout(struct taskqueue *queue,
84 int taskqueue_cancel(struct taskqueue *queue, struct task *task,
87 int taskqueue_cancel_timeout(struct taskqueue *queue,
89 void taskqueue_drain(struct taskqueue *queue, struct task *task);
91 void taskqueue_drain_timeout(struct taskqueue *queue,
94 void taskqueue_free(struct taskqueue *queue);
95 void taskqueue_block(struct taskqueue *queue);
96 void taskqueue_unblock(struct taskqueue *queue);
[all …]
|
| /dflybsd-src/contrib/gcc-4.7/libstdc++-v3/include/bits/ |
| H A D | stl_queue.h | 92 class queue in _GLIBCXX_VISIBILITY()
103 operator==(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_VISIBILITY()
107 operator<(const queue<_Tp1, _Seq1>&, const queue<_Tp1, _Seq1>&); in _GLIBCXX_VISIBILITY()
133 queue(const _Sequence& __c = _Sequence()) in _GLIBCXX_VISIBILITY()
137 queue(const _Sequence& __c) in _GLIBCXX_VISIBILITY()
141 queue(_Sequence&& __c = _Sequence()) in _GLIBCXX_VISIBILITY()
245 swap(queue& __q) in _GLIBCXX_VISIBILITY()
267 operator==(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) in _GLIBCXX_VISIBILITY()
285 operator<(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) in _GLIBCXX_VISIBILITY()
291 operator!=(const queue<_Tp, _Seq>& __x, const queue<_Tp, _Seq>& __y) in _GLIBCXX_VISIBILITY()
[all …]
|
| /dflybsd-src/sys/dev/drm/ttm/ |
| H A D | ttm_lock.c | 49 init_waitqueue_head(&lock->queue); in ttm_lock_init()
61 wake_up_all(&lock->queue); in ttm_read_unlock()
90 ret = wait_event_interruptible(lock->queue, in ttm_read_lock()
96 wait_event(lock->queue, __ttm_read_lock(lock)); in ttm_read_lock()
135 (lock->queue, __ttm_read_trylock(lock, &locked)); in ttm_read_trylock()
140 wait_event(lock->queue, __ttm_read_trylock(lock, &locked)); in ttm_read_trylock()
156 wake_up_all(&lock->queue); in ttm_write_unlock()
188 ret = wait_event_interruptible(lock->queue, in ttm_write_lock()
194 wake_up_all(&lock->queue); in ttm_write_lock()
199 wait_event(lock->queue, __ttm_write_lock(lock)); in ttm_write_lock()
[all …]
|
| /dflybsd-src/sys/vm/ |
| H A D | vm_page.c | 251 if (m->queue) { in vm_add_new_page()
291 m->queue = PQ_NONE; in vm_add_new_page()
301 m->queue = m->pc + PQ_FREE; in vm_add_new_page()
306 vpq = &vm_page_queues[m->queue]; in vm_add_new_page()
580 if (m->queue != PQ_NONE) { in vm_numa_organize()
581 vpq = &vm_page_queues[m->queue]; in vm_numa_organize()
585 m->queue -= m->pc; in vm_numa_organize()
589 m->queue += m->pc; in vm_numa_organize()
590 vpq = &vm_page_queues[m->queue]; in vm_numa_organize()
687 KKASSERT(m->queue == PQ_FREE + iter); in vm_numa_organize_finalize()
[all …]
|
| H A D | vm_contig.c | 143 vm_contig_pg_clean(int queue, vm_pindex_t count) in vm_contig_pg_clean() argument
148 struct vpgqueues *pq = &vm_page_queues[queue]; in vm_contig_pg_clean()
156 marker.queue = queue; in vm_contig_pg_clean()
159 vm_page_queues_spin_lock(queue); in vm_contig_pg_clean()
161 vm_page_queues_spin_unlock(queue); in vm_contig_pg_clean()
176 KKASSERT(m->queue == queue); in vm_contig_pg_clean()
194 if (m->queue - m->pc != queue) { in vm_contig_pg_clean()
234 vm_page_queues_spin_lock(queue); in vm_contig_pg_clean()
236 vm_page_queues_spin_unlock(queue); in vm_contig_pg_clean()
306 pqtype = m->queue - m->pc; in vm_contig_pg_alloc()
[all …]
|
| H A D | vm_swapcache.c | 202 page_marker[q].queue = PQ_INACTIVE + q; in vm_swapcached_thread()
397 vm_page_queues_spin_lock(marker->queue); in vm_swapcache_writing()
400 KKASSERT(m->queue == marker->queue); in vm_swapcache_writing()
415 &vm_page_queues[marker->queue].pl, marker, pageq); in vm_swapcache_writing()
417 &vm_page_queues[marker->queue].pl, m, marker, pageq); in vm_swapcache_writing()
427 vm_page_queues_spin_unlock(marker->queue); in vm_swapcache_writing()
431 vm_page_queues_spin_lock(marker->queue); in vm_swapcache_writing()
438 vm_page_queues_spin_lock(marker->queue); in vm_swapcache_writing()
444 vm_page_queues_spin_lock(marker->queue); in vm_swapcache_writing()
452 vm_page_queues_spin_lock(marker->queue); in vm_swapcache_writing()
[all …]
|