Searched refs:tq (Results 1 - 25 of 70) sorted by relevance

123

/freebsd-13-stable/sys/contrib/openzfs/lib/libzpool/
H A Dtaskq.c42 task_alloc(taskq_t *tq, int tqflags) argument
47 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) {
49 tq->tq_freelist = t->tqent_next;
51 if (tq->tq_nalloc >= tq->tq_maxalloc) {
65 tq->tq_maxalloc_wait++;
66 rv = cv_timedwait(&tq->tq_maxalloc_cv,
67 &tq
87 task_free(taskq_t *tq, taskq_ent_t *t) argument
104 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) argument
137 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags, clock_t expire_time) argument
160 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument
191 taskq_wait(taskq_t *tq) argument
200 taskq_wait_id(taskq_t *tq, taskqid_t id) argument
206 taskq_wait_outstanding(taskq_t *tq, taskqid_t id) argument
214 taskq_t *tq = arg; local
255 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); local
302 taskq_destroy(taskq_t *tq) argument
336 taskq_member(taskq_t *tq, kthread_t *t) argument
357 taskq_cancel_id(taskq_t *tq, taskqid_t id) argument
[all...]
/freebsd-13-stable/sys/contrib/openzfs/module/os/linux/spl/
H A Dspl-taskq.c94 taskq_t *tq; local
97 tq = list_entry(tql, taskq_t, tq_taskqs);
98 if (strcmp(name, tq->tq_name) == 0)
99 return (tq->tq_instance);
105 * NOTE: Must be called with tq->tq_lock held, returns a list_t which
109 task_alloc(taskq_t *tq, uint_t flags, unsigned long *irqflags) argument
114 ASSERT(tq);
117 if (!list_empty(&tq->tq_free_list) && !(flags & TQ_NEW)) {
118 t = list_entry(tq->tq_free_list.next, taskq_ent_t, tqent_list);
133 if (tq
175 task_free(taskq_t *tq, taskq_ent_t *t) argument
191 task_done(taskq_t *tq, taskq_ent_t *t) argument
221 taskq_t *tq = t->tqent_taskq; local
271 taskq_lowest_id(taskq_t *tq) argument
306 taskq_insert_in_order(taskq_t *tq, taskq_thread_t *tqt) argument
330 taskq_find_list(taskq_t *tq, struct list_head *lh, taskqid_t id) argument
355 taskq_find(taskq_t *tq, taskqid_t id) argument
416 taskq_wait_id_check(taskq_t *tq, taskqid_t id) argument
433 taskq_wait_id(taskq_t *tq, taskqid_t id) argument
440 taskq_wait_outstanding_check(taskq_t *tq, taskqid_t id) argument
460 taskq_wait_outstanding(taskq_t *tq, taskqid_t id) argument
468 taskq_wait_check(taskq_t *tq) argument
486 taskq_wait(taskq_t *tq) argument
493 taskq_member(taskq_t *tq, kthread_t *t) argument
513 taskq_cancel_id(taskq_t *tq, taskqid_t id) argument
566 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument
631 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t flags, clock_t expire_time) argument
677 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, taskq_ent_t *t) argument
769 taskq_next_ent(taskq_t *tq) argument
789 taskq_t *tq = (taskq_t *)arg; local
809 taskq_thread_spawn(taskq_t *tq) argument
836 taskq_thread_should_stop(taskq_t *tq, taskq_thread_t *tqt) argument
859 taskq_t *tq; local
1002 taskq_thread_create(taskq_t *tq) argument
1037 taskq_t *tq; local
1143 taskq_destroy(taskq_t *tq) argument
1244 taskq_t *tq = NULL; local
1294 taskq_t *tq = list_entry(node, taskq_t, tq_hp_cb_node); local
1330 taskq_t *tq = list_entry(node, taskq_t, tq_hp_cb_node); local
[all...]
H A Dspl-proc.c191 taskq_t *tq = p; local
203 spin_lock_irqsave_nested(&tq->tq_lock, flags, tq->tq_lock_class);
204 spin_lock_irqsave(&tq->tq_wait_waitq.lock, wflags);
207 lheads[LHEAD_PEND] = &tq->tq_pend_list;
208 lheads[LHEAD_PRIO] = &tq->tq_prio_list;
209 lheads[LHEAD_DELAY] = &tq->tq_delay_list;
211 lheads[LHEAD_WAIT] = &tq->tq_wait_waitq.head;
213 lheads[LHEAD_WAIT] = &tq->tq_wait_waitq.task_list;
215 lheads[LHEAD_ACTIVE] = &tq
349 taskq_t *tq = p; local
[all...]
/freebsd-13-stable/sys/dev/wtap/wtap_hal/
H A Dhandler.h47 struct taskqueue *tq; member in struct:eventhandler
/freebsd-13-stable/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c71 taskq_t *tq; local
76 tq = kmem_alloc(sizeof(*tq), KM_SLEEP);
77 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue,
78 &tq->tq_queue);
79 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri,
82 return ((taskq_t *)tq);
100 taskq_destroy(taskq_t *tq) argument
103 taskqueue_free(tq->tq_queue);
104 kmem_free(tq, sizeo
108 taskq_member(taskq_t *tq, kthread_t *thread) argument
125 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument
162 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags, taskq_ent_t *task) argument
181 taskq_wait(taskq_t *tq) argument
187 taskq_wait_id(taskq_t *tq, taskqid_t id) argument
[all...]
/freebsd-13-stable/usr.sbin/jail/
H A Djailparse.y80 TAILQ_INSERT_TAIL(&j->params, $2, tq);
88 TAILQ_CONCAT(&$$->params, $3, tq);
101 TAILQ_INSERT_TAIL($$, $2, tq);
117 TAILQ_CONCAT(&$$->val, $3, tq);
123 TAILQ_CONCAT(&$$->val, $3, tq);
130 TAILQ_CONCAT(&$$->val, $2, tq);
162 TAILQ_INSERT_TAIL($$, $1, tq);
167 TAILQ_INSERT_TAIL($$, $3, tq);
193 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
214 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
[all...]
H A Dconfig.c155 TAILQ_FOREACH_SAFE(j, &cfjails, tq, tj) {
161 TAILQ_FOREACH(j, &cfjails, tq) {
164 TAILQ_CONCAT(&opp, &j->params, tq);
177 TAILQ_FOREACH(wj, &wild, tq) {
179 TAILQ_FOREACH(p, &opp, tq)
184 TAILQ_FOREACH(p, &wj->params, tq)
188 TAILQ_FOREACH(p, &opp, tq)
193 TAILQ_FOREACH(p, &j->params, tq) {
196 TAILQ_FOREACH(s, &p->val, tq) {
198 TAILQ_FOREACH(vp, &j->params, tq)
[all...]
H A Dstate.c74 TAILQ_FOREACH(s, &p->val, tq) {
86 TAILQ_FOREACH(j, &cfjails, tq)
90 TAILQ_FOREACH(j, &cfjails, tq)
97 TAILQ_FOREACH(j, &cfjails, tq) {
101 TAILQ_FOREACH(s, &p->val, tq) {
145 TAILQ_FOREACH(j, &cfjails, tq)
146 STAILQ_FOREACH(d, &j->dep[DEP_FROM], tq[DEP_FROM])
175 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfrom]) {
247 STAILQ_FOREACH(d, &j->dep[depto], tq[depto]) {
276 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfro
[all...]
H A Djailp.h145 STAILQ_ENTRY(cfvar) tq; member in struct:cfvar
153 TAILQ_ENTRY(cfstring) tq; member in struct:cfstring
162 TAILQ_ENTRY(cfparam) tq; member in struct:cfparam
173 TAILQ_ENTRY(cfjail) tq; member in struct:cfjail
194 STAILQ_ENTRY(cfdepend) tq[2]; member in struct:cfdepend
/freebsd-13-stable/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c202 taskq_t *tq = context; local
208 tsd_set(taskq_tsd, tq);
215 taskq_t *tq; local
220 tq = kmem_alloc(sizeof (*tq), KM_SLEEP);
221 tq->tq_queue = taskqueue_create(name, M_WAITOK,
222 taskqueue_thread_enqueue, &tq->tq_queue);
223 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_INIT,
224 taskq_tsd_set, tq);
225 taskqueue_set_callback(tq
248 taskq_destroy(taskq_t *tq) argument
256 taskq_member(taskq_t *tq, kthread_t *thread) argument
277 taskq_cancel_id(taskq_t *tq, taskqid_t tid) argument
320 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t flags, clock_t expire_time) argument
355 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) argument
394 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint32_t flags, taskq_ent_t *task) argument
415 taskq_wait(taskq_t *tq) argument
421 taskq_wait_id(taskq_t *tq, taskqid_t tid) argument
435 taskq_wait_outstanding(taskq_t *tq, taskqid_t id __unused) argument
[all...]
/freebsd-13-stable/sys/dev/liquidio/base/
H A Dlio_response_manager.c61 ctq->tq = taskqueue_create("lio_dma_comp", M_WAITOK,
62 taskqueue_thread_enqueue, &ctq->tq);
63 if (ctq->tq == NULL) {
68 TIMEOUT_TASK_INIT(ctq->tq, &ctq->work, 0, lio_poll_req_completion,
73 taskqueue_start_threads(&ctq->tq, 1, PI_NET, "lio%d_dma_comp",
75 taskqueue_enqueue_timeout(ctq->tq, &ctq->work, lio_ms_to_ticks(50));
84 if (oct->dma_comp_tq.tq != NULL) {
85 while (taskqueue_cancel_timeout(oct->dma_comp_tq.tq,
87 taskqueue_drain_timeout(oct->dma_comp_tq.tq,
89 taskqueue_free(oct->dma_comp_tq.tq);
[all...]
H A Dlio_request_manager.c161 db_tq->tq = taskqueue_create("lio_check_db_timeout", M_WAITOK,
162 taskqueue_thread_enqueue, &db_tq->tq);
163 if (db_tq->tq == NULL) {
169 TIMEOUT_TASK_INIT(db_tq->tq, &db_tq->work, 0, lio_check_db_timeout,
174 taskqueue_start_threads(&db_tq->tq, 1, PI_NET,
177 taskqueue_enqueue_timeout(db_tq->tq, &db_tq->work, 1);
202 if (oct->check_db_tq[iq_no].tq != NULL) {
203 while (taskqueue_cancel_timeout(oct->check_db_tq[iq_no].tq,
206 taskqueue_drain_timeout(oct->check_db_tq[iq_no].tq,
208 taskqueue_free(oct->check_db_tq[iq_no].tq);
[all...]
/freebsd-13-stable/sys/dev/wtap/
H A Dif_medium.c47 eh->tq = taskqueue_create("wtap_tx_taskq", M_NOWAIT | M_ZERO,
48 taskqueue_thread_enqueue, &eh->tq);
49 taskqueue_start_threads(&eh->tq, 1, PI_NET, "%s taskq", "wtap_medium");
60 taskqueue_free(md->tx_handler->tq);
83 taskqueue_enqueue(md->tx_handler->tq, &md->tx_handler->proc);
/freebsd-13-stable/sys/kern/
H A Dsubr_taskqueue.c90 #define TQ_LOCK(tq) \
92 if ((tq)->tq_spin) \
93 mtx_lock_spin(&(tq)->tq_mutex); \
95 mtx_lock(&(tq)->tq_mutex); \
97 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED)
99 #define TQ_UNLOCK(tq) \
101 if ((tq)->tq_spin) \
102 mtx_unlock_spin(&(tq)->tq_mutex); \
104 mtx_unlock(&(tq)
121 TQ_SLEEP(struct taskqueue *tq, void *p, const char *wm) argument
195 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) argument
669 struct taskqueue *tq; local
771 taskqueue_run_callback(struct taskqueue *tq, enum taskqueue_callback_type cb_type) argument
785 struct taskqueue **tqp, *tq; local
823 struct taskqueue **tqp, *tq; local
[all...]
H A Dsubr_gtaskqueue.c90 #define TQ_LOCK(tq) \
92 if ((tq)->tq_spin) \
93 mtx_lock_spin(&(tq)->tq_mutex); \
95 mtx_lock(&(tq)->tq_mutex); \
97 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED)
99 #define TQ_UNLOCK(tq) \
101 if ((tq)->tq_spin) \
102 mtx_unlock_spin(&(tq)->tq_mutex); \
104 mtx_unlock(&(tq)
118 TQ_SLEEP(struct gtaskqueue *tq, void *p, const char *wm) argument
163 gtaskqueue_terminate(struct thread **pp, struct gtaskqueue *tq) argument
454 struct gtaskqueue *tq; local
525 gtaskqueue_run_callback(struct gtaskqueue *tq, enum taskqueue_callback_type cb_type) argument
539 struct gtaskqueue **tqp, *tq; local
577 struct gtaskqueue **tqp, *tq; local
[all...]
/freebsd-13-stable/sys/compat/linuxkpi/common/src/
H A Dlinux_work.c121 struct taskqueue *tq; local
123 tq = dwork->work.work_queue->taskqueue;
124 taskqueue_enqueue(tq, &dwork->work.work_task);
376 struct taskqueue *tq; local
387 tq = work->work_queue->taskqueue;
388 if (taskqueue_cancel(tq, &work->work_task, NULL) != 0)
389 taskqueue_drain(tq, &work->work_task);
392 tq = work->work_queue->taskqueue;
393 if (taskqueue_cancel(tq, &work->work_task, NULL) != 0)
394 taskqueue_drain(tq,
437 struct taskqueue *tq; local
476 struct taskqueue *tq; local
520 struct taskqueue *tq; local
545 struct taskqueue *tq; local
589 struct taskqueue *tq; local
[all...]
/freebsd-13-stable/sys/dev/ixl/
H A Dixl_iw_int.h63 struct taskqueue *tq; member in struct:ixl_iw_state
H A Dixl_iw.c179 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
210 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
407 ixl_iw.tq = taskqueue_create("ixl_iw", M_NOWAIT,
408 taskqueue_thread_enqueue, &ixl_iw.tq);
409 if (ixl_iw.tq == NULL) {
414 taskqueue_start_threads(&ixl_iw.tq, 1, PI_NET, "ixl iw");
420 taskqueue_free(ixl_iw.tq);
432 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
473 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task);
481 taskqueue_drain(ixl_iw.tq,
[all...]
/freebsd-13-stable/sys/dev/mlx4/mlx4_en/
H A Dmlx4_en_cq.c73 cq->tq = taskqueue_create_fast("mlx4_en_que", M_NOWAIT,
74 taskqueue_thread_enqueue, &cq->tq);
77 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s rx cq",
82 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s tx cq",
187 taskqueue_drain(cq->tq, &cq->cq_task);
188 taskqueue_free(cq->tq);
203 taskqueue_drain(cq->tq, &cq->cq_task);
/freebsd-13-stable/contrib/nvi/ex/
H A Dex_tag.c147 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) {
187 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) {
317 if (TAILQ_EMPTY(exp->tq)) {
325 dtqp = TAILQ_FIRST(exp->tq);
337 TAILQ_FOREACH(tqp, exp->tq, q)
350 for (tqp = TAILQ_FIRST(exp->tq); tqp;
353 if (tqp == TAILQ_FIRST(exp->tq))
368 if (tqp == TAILQ_FIRST(exp->tq))
392 if (TAILQ_EMPTY(exp->tq)) {
398 return (tag_pop(sp, TAILQ_PREV(TAILQ_LAST(exp->tq, _tq
[all...]
/freebsd-13-stable/sbin/devfs/
H A Ddevfs.c175 STAILQ_ENTRY(ptrstq) tq;
206 STAILQ_INSERT_TAIL(&plist, pt, tq);
220 STAILQ_REMOVE_HEAD(&plist, tq);
/freebsd-13-stable/sys/dev/cfi/
H A Dcfi_disk.c65 struct taskqueue *tq; /* private task queue for i/o request */ member in struct:cfi_disk_softc
130 sc->tq = taskqueue_create("cfid_taskq", M_NOWAIT,
131 taskqueue_thread_enqueue, &sc->tq);
132 taskqueue_start_threads(&sc->tq, 1, PI_DISK, "cfid taskq");
146 taskqueue_free(sc->tq);
333 taskqueue_enqueue(sc->tq, &sc->iotask);
/freebsd-13-stable/usr.sbin/gstat/
H A Dgstat.c86 struct timespec tp, tq; local
219 geom_stats_snapshot_timestamp(sq, &tq);
225 dt = tp.tv_sec - tq.tv_sec;
226 dt += (tp.tv_nsec - tq.tv_nsec) * 1e-9;
227 tq = tp;
230 "%F %T",localtime(&tq.tv_sec));
232 "%s.%.9ld",ts,tq.tv_nsec);
/freebsd-13-stable/crypto/openssh/
H A Dssh-keyscan.c114 TAILQ_HEAD(conlist, Connection) tq; /* Timeout Queue */
395 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link);
418 TAILQ_REMOVE(&tq, &fdcon[s], c_link);
426 TAILQ_REMOVE(&tq, &fdcon[s], c_link);
429 TAILQ_INSERT_TAIL(&tq, &fdcon[s], c_link);
563 c = TAILQ_FIRST(&tq);
596 c = TAILQ_FIRST(&tq);
659 TAILQ_INIT(&tq);
/freebsd-13-stable/sys/dev/bwn/
H A Dif_bwn.c1034 struct bwn_pio_txqueue *tq; local
1047 tq = bwn_pio_select(mac, M_WME_GETAC(m));
1048 if (tq->tq_free == 0 || pktlen > tq->tq_size ||
1049 pktlen > (tq->tq_size - tq->tq_used))
1085 struct bwn_pio_txqueue *tq; local
1098 tq = bwn_pio_select(mac, M_WME_GETAC(m));
1099 KASSERT(!TAILQ_EMPTY(&tq->tq_pktlist), ("%s: fail", __func__));
1100 tp = TAILQ_FIRST(&tq
2641 bwn_pio_set_txqueue(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, int index) argument
2714 bwn_destroy_pioqueue_tx(struct bwn_pio_txqueue *tq) argument
2729 bwn_pio_read_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t offset) argument
2759 bwn_pio_cancel_tx_packets(struct bwn_pio_txqueue *tq) argument
6201 struct bwn_pio_txqueue *tq; local
6752 bwn_pio_write_multi_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint32_t ctl, const void *_data, int len) argument
6789 bwn_pio_write_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t offset, uint32_t value) argument
6797 bwn_pio_write_multi_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t ctl, const void *_data, int len) argument
6818 bwn_pio_write_mbuf_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, uint16_t ctl, struct mbuf *m0) argument
6910 struct bwn_pio_txqueue *tq = NULL; local
[all...]

Completed in 229 milliseconds

123