Home
last modified time | relevance | path

Searched refs:tq (Results 1 – 25 of 136) sorted by relevance

123456

/freebsd/sys/contrib/openzfs/lib/libzpool/
H A Dtaskq.c42 task_alloc(taskq_t *tq, int tqflags) in task_alloc() argument
47 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { in task_alloc()
49 tq->tq_freelist = t->tqent_next; in task_alloc()
51 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
65 tq->tq_maxalloc_wait++; in task_alloc()
66 rv = cv_timedwait(&tq->tq_maxalloc_cv, in task_alloc()
67 &tq in task_alloc()
87 task_free(taskq_t * tq,taskq_ent_t * t) task_free() argument
104 taskq_dispatch(taskq_t * tq,task_func_t func,void * arg,uint_t tqflags) taskq_dispatch() argument
137 taskq_dispatch_delay(taskq_t * tq,task_func_t func,void * arg,uint_t tqflags,clock_t expire_time) taskq_dispatch_delay() argument
161 taskq_dispatch_ent(taskq_t * tq,task_func_t func,void * arg,uint_t flags,taskq_ent_t * t) taskq_dispatch_ent() argument
192 taskq_wait(taskq_t * tq) taskq_wait() argument
201 taskq_wait_id(taskq_t * tq,taskqid_t id) taskq_wait_id() argument
208 taskq_wait_outstanding(taskq_t * tq,taskqid_t id) taskq_wait_outstanding() argument
217 taskq_t *tq = arg; taskq_thread() local
258 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); taskq_create() local
305 taskq_destroy(taskq_t * tq) taskq_destroy() argument
350 taskq_t *tq; taskq_create_synced() local
371 taskq_member(taskq_t * tq,kthread_t * t) taskq_member() argument
392 taskq_cancel_id(taskq_t * tq,taskqid_t id) taskq_cancel_id() argument
[all...]
/freebsd/sys/contrib/openzfs/module/os/linux/spl/
H A Dspl-taskq.c98 #define TQSTAT_INC(tq, stat) wmsum_add(&tq->tq_sums.tqs_##stat, 1) argument
99 #define TQSTAT_DEC(tq, stat) wmsum_add(&tq->tq_sums.tqs_##stat, -1) argument
101 #define _TQSTAT_MOD_LIST(mod, tq, t) do { \ argument
104 case TQENT_LIST_PENDING: mod(tq, tasks_pending); break; \
105 case TQENT_LIST_PRIORITY: mod(tq, tasks_priority); break; \
106 case TQENT_LIST_DELAY: mod(tq, tasks_delayed); break; \
109 #define TQSTAT_INC_LIST(tq, t) _TQSTAT_MOD_LIST(TQSTAT_INC, tq, t) argument
110 #define TQSTAT_DEC_LIST(tq, t) _TQSTAT_MOD_LIST(TQSTAT_DEC, tq, t) argument
180 taskq_t *tq; in taskq_find_by_name() local
183 tq = list_entry(tql, taskq_t, tq_taskqs); in taskq_find_by_name()
[all …]
/freebsd/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c196 taskq_t *tq = context; in taskq_tsd_set() local
202 tsd_set(taskq_tsd, tq); in taskq_tsd_set()
209 taskq_t *tq; in taskq_create_impl() local
214 tq = kmem_alloc(sizeof (*tq), KM_SLEEP); in taskq_create_impl()
215 tq->tq_nthreads = nthreads; in taskq_create_impl()
216 tq->tq_queue = taskqueue_create(name, M_WAITOK, in taskq_create_impl()
217 taskqueue_thread_enqueue, &tq->tq_queue); in taskq_create_impl()
218 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_INIT, in taskq_create_impl()
219 taskq_tsd_set, tq); in taskq_create_impl()
220 taskqueue_set_callback(tq->tq_queue, TASKQUEUE_CALLBACK_TYPE_SHUTDOWN, in taskq_create_impl()
[all …]
/freebsd/sys/cddl/compat/opensolaris/kern/
H A Dopensolaris_taskq.c68 taskq_t *tq; in taskq_create_impl() local
73 tq = kmem_alloc(sizeof(*tq), KM_SLEEP); in taskq_create_impl()
74 tq->tq_queue = taskqueue_create(name, M_WAITOK, taskqueue_thread_enqueue, in taskq_create_impl()
75 &tq->tq_queue); in taskq_create_impl()
76 (void) taskqueue_start_threads_in_proc(&tq->tq_queue, nthreads, pri, in taskq_create_impl()
79 return ((taskq_t *)tq); in taskq_create_impl()
97 taskq_destroy(taskq_t *tq) in taskq_destroy() argument
100 taskqueue_free(tq->tq_queue); in taskq_destroy()
101 kmem_free(tq, sizeof(*tq)); in taskq_destroy()
105 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member() argument
[all …]
/freebsd/sys/compat/linuxkpi/common/include/linux/
H A Dkthread.h49 struct taskqueue *tq; member
53 struct taskqueue *tq; member
104 __w->tq = taskqueue_create("lkpi kthread taskq", M_WAITOK, \
105 taskqueue_thread_enqueue, &__w->tq); \
106 taskqueue_start_threads(&__w->tq, 1, PWAIT, fmt, ##__VA_ARGS__);\
108 taskqueue_enqueue(__w->tq, &__task); \
109 taskqueue_drain(__w->tq, &__task); \
116 taskqueue_drain_all(worker->tq); in kthread_destroy_worker()
117 taskqueue_free(worker->tq); in kthread_destroy_worker()
124 work->tq = NULL; in kthread_init_work()
[all …]
/freebsd/sys/kern/
H A Dsubr_taskqueue.c88 #define TQ_LOCK(tq) \ argument
90 if ((tq)->tq_spin) \
91 mtx_lock_spin(&(tq)->tq_mutex); \
93 mtx_lock(&(tq)->tq_mutex); \
95 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument
97 #define TQ_UNLOCK(tq) \ argument
99 if ((tq)->tq_spin) \
100 mtx_unlock_spin(&(tq)->tq_mutex); \
102 mtx_unlock(&(tq)->tq_mutex); \
104 #define TQ_ASSERT_UNLOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_NOTOWNED) argument
[all …]
H A Dsubr_gtaskqueue.c87 #define TQ_LOCK(tq) \ argument
89 if ((tq)->tq_spin) \
90 mtx_lock_spin(&(tq)->tq_mutex); \
92 mtx_lock(&(tq)->tq_mutex); \
94 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument
96 #define TQ_UNLOCK(tq) \ argument
98 if ((tq)->tq_spin) \
99 mtx_unlock_spin(&(tq)->tq_mutex); \
101 mtx_unlock(&(tq)->tq_mutex); \
103 #define TQ_ASSERT_UNLOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_NOTOWNED) argument
[all …]
/freebsd/sys/compat/linuxkpi/common/src/
H A Dlinux_work.c119 struct taskqueue *tq; in linux_delayed_work_enqueue() local
121 tq = dwork->work.work_queue->taskqueue; in linux_delayed_work_enqueue()
122 taskqueue_enqueue(tq, &dwork->work.work_task); in linux_delayed_work_enqueue()
379 struct taskqueue *tq; in linux_cancel_work() local
386 tq = work->work_queue->taskqueue; in linux_cancel_work()
387 if (taskqueue_cancel(tq, &work->work_task, NULL) == 0) in linux_cancel_work()
410 struct taskqueue *tq; in linux_cancel_work_sync() local
421 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
422 if (taskqueue_cancel(tq, &work->work_task, NULL) != 0) in linux_cancel_work_sync()
423 taskqueue_drain(tq, &work->work_task); in linux_cancel_work_sync()
[all …]
/freebsd/sys/netipsec/
H A Dipsec_offload.c275 struct ipsec_accel_install_newkey_tq *tq; in ipsec_accel_sa_newkey_cb() local
280 tq = arg; in ipsec_accel_sa_newkey_cb()
285 be32toh(tq->sav->spi), tq->sav->flags, tq->sav->seq); in ipsec_accel_sa_newkey_cb()
288 if (tq->sav->accel_ifname != NULL && in ipsec_accel_sa_newkey_cb()
289 strcmp(tq->sav->accel_ifname, if_name(ifp)) != 0) { in ipsec_accel_sa_newkey_cb()
290 error = ipsec_accel_handle_sav(tq->sav, in ipsec_accel_sa_newkey_cb()
298 be32toh(tq->sav->spi)); in ipsec_accel_sa_newkey_cb()
301 error = ifp->if_ipsec_accel_m->if_sa_newkey(ifp, tq->sav, in ipsec_accel_sa_newkey_cb()
307 if_name(ifp), be32toh(tq->sav->spi)); in ipsec_accel_sa_newkey_cb()
308 error = ipsec_accel_handle_sav(tq->sav, in ipsec_accel_sa_newkey_cb()
[all …]
/freebsd/usr.sbin/jail/
H A Dconfig.c147 TAILQ_FOREACH_SAFE(j, &cfjails, tq, tj) { in load_config()
153 TAILQ_FOREACH(j, &cfjails, tq) { in load_config()
156 TAILQ_CONCAT(&opp, &j->params, tq); in load_config()
169 TAILQ_FOREACH(wj, &wild, tq) { in load_config()
171 TAILQ_FOREACH(p, &opp, tq) in load_config()
176 TAILQ_FOREACH(p, &wj->params, tq) in load_config()
180 TAILQ_FOREACH(p, &opp, tq) in load_config()
185 TAILQ_FOREACH(p, &j->params, tq) { in load_config()
188 TAILQ_FOREACH(s, &p->val, tq) { in load_config()
190 TAILQ_FOREACH(vp, &j->params, tq) in load_config()
[all …]
H A Dstate.c72 TAILQ_FOREACH(s, &p->val, tq) { in dep_setup()
84 TAILQ_FOREACH(j, &cfjails, tq) in dep_setup()
88 TAILQ_FOREACH(j, &cfjails, tq) in dep_setup()
95 TAILQ_FOREACH(j, &cfjails, tq) { in dep_setup()
99 TAILQ_FOREACH(s, &p->val, tq) { in dep_setup()
143 TAILQ_FOREACH(j, &cfjails, tq) in dep_setup()
144 STAILQ_FOREACH(d, &j->dep[DEP_FROM], tq[DEP_FROM]) in dep_setup()
173 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfrom]) { in dep_check()
245 STAILQ_FOREACH(d, &j->dep[depto], tq[depto]) { in dep_done()
274 STAILQ_FOREACH(d, &j->dep[depfrom], tq[depfrom]) in dep_reset()
[all …]
H A Djailparse.y84 TAILQ_INSERT_TAIL(&j->params, $2, tq);
130 TAILQ_CONCAT(&$$->val, $3, tq);
136 TAILQ_CONCAT(&$$->val, $3, tq);
143 TAILQ_CONCAT(&$$->val, $2, tq);
174 TAILQ_INSERT_TAIL($$, $1, tq);
179 TAILQ_INSERT_TAIL($$, $3, tq);
205 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
226 STAILQ_INSERT_TAIL(&$$->vars, v, tq);
262 TAILQ_FOREACH(s, &p->val, tq) { in special_param()
/freebsd/sys/dev/liquidio/base/
H A Dlio_response_manager.c60 ctq->tq = taskqueue_create("lio_dma_comp", M_WAITOK, in lio_setup_response_list()
61 taskqueue_thread_enqueue, &ctq->tq); in lio_setup_response_list()
63 TIMEOUT_TASK_INIT(ctq->tq, &ctq->work, 0, lio_poll_req_completion, in lio_setup_response_list()
68 taskqueue_start_threads(&ctq->tq, 1, PI_NET, "lio%d_dma_comp", in lio_setup_response_list()
70 taskqueue_enqueue_timeout(ctq->tq, &ctq->work, lio_ms_to_ticks(50)); in lio_setup_response_list()
79 if (oct->dma_comp_tq.tq != NULL) { in lio_delete_response_list()
80 while (taskqueue_cancel_timeout(oct->dma_comp_tq.tq, in lio_delete_response_list()
82 taskqueue_drain_timeout(oct->dma_comp_tq.tq, in lio_delete_response_list()
84 taskqueue_free(oct->dma_comp_tq.tq); in lio_delete_response_list()
85 oct->dma_comp_tq.tq = NULL; in lio_delete_response_list()
[all …]
/freebsd/sys/dev/ixl/
H A Dixl_iw.c178 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task); in ixl_iw_pf_init()
209 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task); in ixl_iw_pf_stop()
406 ixl_iw.tq = taskqueue_create("ixl_iw", M_NOWAIT, in ixl_iw_register()
407 taskqueue_thread_enqueue, &ixl_iw.tq); in ixl_iw_register()
408 if (ixl_iw.tq == NULL) { in ixl_iw_register()
413 taskqueue_start_threads(&ixl_iw.tq, 1, PI_NET, "ixl iw"); in ixl_iw_register()
419 taskqueue_free(ixl_iw.tq); in ixl_iw_register()
431 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task); in ixl_iw_register()
472 taskqueue_enqueue(ixl_iw.tq, &pf_entry->iw_task); in ixl_iw_unregister()
480 taskqueue_drain(ixl_iw.tq, &pf_entry->iw_task); in ixl_iw_unregister()
[all …]
/freebsd/sys/contrib/device-tree/src/arm/nxp/imx/
H A Dimx6q-mba6a.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
18 compatible = "tq,imx6q-mba6x-a", "tq,mba6a",
19 "tq,imx6q-tqma6q-a", "fsl,imx6q";
H A Dimx6qp-mba6b.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
16 compatible = "tq,imx6qp-mba6x-b", "tq,mba6b",
17 "tq,imx6qp-tqma6qp-b", "fsl,imx6qp";
H A Dimx6q-mba6b.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
18 compatible = "tq,imx6q-mba6x-b", "tq,mba6b",
19 "tq,imx6q-tqma6q-b", "fsl,imx6q";
H A Dimx6dl-mba6b.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
19 compatible = "tq,imx6dl-mba6x-b", "tq,mba6b",
20 "tq,imx6dl-tqma6dl-b", "fsl,imx6dl";
H A Dimx6dl-mba6a.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
19 compatible = "tq,imx6dl-mba6x-a", "tq,mba6a",
20 "tq,imx6dl-tqma6dl-a", "fsl,imx6dl";
H A Dimx6ul-tqma6ul2l-mba6ulx.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
14 compatible = "tq,imx6ul-tqma6ul2l-mba6ulx", "tq,imx6ul-tqma6ul2l", "fsl,imx6ul";
H A Dimx6ul-tqma6ul2-mba6ulx.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
14 compatible = "tq,imx6ul-tqma6ul2-mba6ulx", "tq,imx6ul-tqma6ul2", "fsl,imx6ul";
H A Dimx6ull-tqma6ull2l-mba6ulx.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
14 compatible = "tq,imx6ull-tqma6ull2l-mba6ulx", "tq,imx6ull-tqma6ull2l", "fsl,imx6ull";
/freebsd/sys/dev/wtap/
H A Dif_medium.c45 eh->tq = taskqueue_create("wtap_tx_taskq", M_NOWAIT | M_ZERO, in init_medium()
46 taskqueue_thread_enqueue, &eh->tq); in init_medium()
47 taskqueue_start_threads(&eh->tq, 1, PI_NET, "%s taskq", "wtap_medium"); in init_medium()
58 taskqueue_free(md->tx_handler->tq); in deinit_medium()
81 taskqueue_enqueue(md->tx_handler->tq, &md->tx_handler->proc); in medium_transmit()
/freebsd/contrib/nvi/ex/
H A Dex_tag.c147 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) { in ex_tag_next()
187 if ((tqp = TAILQ_FIRST(exp->tq)) == NULL) { in ex_tag_prev()
317 if (TAILQ_EMPTY(exp->tq)) { in ex_tag_pop()
325 dtqp = TAILQ_FIRST(exp->tq); in ex_tag_pop()
337 TAILQ_FOREACH(tqp, exp->tq, q) in ex_tag_pop()
350 for (tqp = TAILQ_FIRST(exp->tq); tqp; in ex_tag_pop()
353 if (tqp == TAILQ_FIRST(exp->tq)) in ex_tag_pop()
368 if (tqp == TAILQ_FIRST(exp->tq)) in ex_tag_pop()
392 if (TAILQ_EMPTY(exp->tq)) { in ex_tag_top()
398 return (tag_pop(sp, TAILQ_PREV(TAILQ_LAST(exp->tq, _tqh), _tqh, q), in ex_tag_top()
[all …]
/freebsd/sys/dev/mlx4/mlx4_en/
H A Dmlx4_en_cq.c73 cq->tq = taskqueue_create_fast("mlx4_en_que", M_NOWAIT, in mlx4_en_create_cq()
74 taskqueue_thread_enqueue, &cq->tq); in mlx4_en_create_cq()
77 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s rx cq", in mlx4_en_create_cq()
82 taskqueue_start_threads(&cq->tq, 1, PI_NET, "%s tx cq", in mlx4_en_create_cq()
187 taskqueue_drain(cq->tq, &cq->cq_task); in mlx4_en_destroy_cq()
188 taskqueue_free(cq->tq); in mlx4_en_destroy_cq()
203 taskqueue_drain(cq->tq, &cq->cq_task); in mlx4_en_deactivate_cq()

123456