Home
last modified time | relevance | path

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

1234567

/freebsd/sys/contrib/openzfs/module/os/linux/spl/
H A Dspl-taskq.c145 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
213 if (tq->tq_nalloc <= tq->tq_minalloc) { in task_done()
486 rc = (tq->tq_lowest_id == tq->tq_next_id); in taskq_wait_check()
544 tq->tq_lowest_id = taskq_lowest_id(tq); in taskq_cancel_id()
594 ASSERT(tq->tq_nactive <= tq->tq_nthreads); in taskq_dispatch()
680 if (tq->tq_nactive == tq->tq_nthreads) in taskq_dispatch_delay()
746 if (tq->tq_nactive == tq->tq_nthreads) in taskq_dispatch_ent()
828 if ((tq->tq_nthreads + tq->tq_nspawn < tq->tq_maxthreads) && in taskq_thread_spawn()
903 if (tq->tq_nthreads >= tq->tq_maxthreads) in taskq_thread()
1076 kmem_free(tq, sizeof (*tq)); in taskq_create()
[all …]
H A Dspl-proc.c195 taskq_t *tq = p; in taskq_seq_show_impl() local
207 spin_lock_irqsave_nested(&tq->tq_lock, flags, tq->tq_lock_class); in taskq_seq_show_impl()
211 lheads[LHEAD_PEND] = &tq->tq_pend_list; in taskq_seq_show_impl()
212 lheads[LHEAD_PRIO] = &tq->tq_prio_list; in taskq_seq_show_impl()
213 lheads[LHEAD_DELAY] = &tq->tq_delay_list; in taskq_seq_show_impl()
240 snprintf(name, sizeof (name), "%s/%d", tq->tq_name, tq->tq_instance); in taskq_seq_show_impl()
243 tq->tq_nactive, tq->tq_nthreads, tq->tq_nspawn, in taskq_seq_show_impl()
244 tq->tq_maxthreads, tq->tq_pri, tq->tq_minalloc, tq->tq_maxalloc, in taskq_seq_show_impl()
245 tq->tq_nalloc, tq->tq_flags); in taskq_seq_show_impl()
353 taskq_t *tq = p; in taskq_seq_next() local
[all …]
/freebsd/sys/contrib/openzfs/lib/libzpool/
H A Dtaskq.c47 again: if ((t = tq->tq_freelist) != NULL && tq->tq_nalloc >= tq->tq_minalloc) { in task_alloc()
51 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
89 if (tq->tq_nalloc <= tq->tq_minalloc) { in task_free()
195 while (tq->tq_task.tqent_next != &tq->tq_task || tq->tq_active != 0) in taskq_wait()
196 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); in taskq_wait()
228 cv_wait(&tq->tq_dispatch_cv, &tq->tq_lock); in taskq_thread()
285 tq->tq_task.tqent_next = &tq->tq_task; in taskq_create()
286 tq->tq_task.tqent_prev = &tq->tq_task; in taskq_create()
293 task_free(tq, task_alloc(tq, KM_SLEEP)); in taskq_create()
317 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); in taskq_destroy()
[all …]
/freebsd/sys/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c201 taskq_t *tq = context; in taskq_tsd_set() local
207 tsd_set(taskq_tsd, tq); in taskq_tsd_set()
214 taskq_t *tq; in taskq_create_impl() local
219 tq = kmem_alloc(sizeof (*tq), KM_SLEEP); in taskq_create_impl()
224 taskq_tsd_set, tq); in taskq_create_impl()
230 return ((taskq_t *)tq); in taskq_create_impl()
252 kmem_free(tq, sizeof (*tq)); in taskq_destroy()
288 taskq_t *tq; in taskq_create_synced() local
297 VERIFY(tq != NULL); in taskq_create_synced()
323 taskq_wait(tq); in taskq_create_synced()
[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()
75 &tq->tq_queue); 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()
178 taskq_wait(taskq_t *tq) in taskq_wait() argument
180 taskqueue_quiesce(tq->tq_queue); in taskq_wait()
184 taskq_wait_id(taskq_t *tq, taskqid_t id) in taskq_wait_id() argument
[all …]
/freebsd/sys/compat/linuxkpi/common/include/linux/
H A Dkthread.h49 struct taskqueue *tq; member
53 struct taskqueue *tq; member
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()
137 work->tq = worker->tq; in kthread_queue_work()
146 if (work->tq != NULL && in kthread_cancel_work_sync()
148 taskqueue_drain(work->tq, &work->task); in kthread_cancel_work_sync()
156 if (work->tq != NULL) in kthread_flush_work()
[all …]
/freebsd/sys/kern/
H A Dsubr_taskqueue.c95 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument
121 if (tq->tq_spin) in TQ_SLEEP()
209 while (tq->tq_tcount > 0 || tq->tq_callouts > 0) { in taskqueue_terminate()
210 wakeup(tq); in taskqueue_terminate()
712 tq = *tqp; in _taskqueue_start_threads()
824 tq = *tqp; in taskqueue_thread_loop()
826 TQ_LOCK(tq); in taskqueue_thread_loop()
837 TQ_SLEEP(tq, tq, "-"); in taskqueue_thread_loop()
845 TQ_UNLOCK(tq); in taskqueue_thread_loop()
847 TQ_LOCK(tq); in taskqueue_thread_loop()
[all …]
H A Dsubr_gtaskqueue.c117 if (tq->tq_spin) in TQ_SLEEP()
163 while (tq->tq_tcount > 0 || tq->tq_callouts > 0) { in gtaskqueue_terminate()
164 wakeup(tq); in gtaskqueue_terminate()
458 tq = *tqp; in _gtaskqueue_start_threads()
539 tq = *tqp; in gtaskqueue_thread_loop()
541 TQ_LOCK(tq); in gtaskqueue_thread_loop()
552 TQ_SLEEP(tq, tq, "-"); in gtaskqueue_thread_loop()
560 TQ_UNLOCK(tq); in gtaskqueue_thread_loop()
562 TQ_LOCK(tq); in gtaskqueue_thread_loop()
567 TQ_UNLOCK(tq); in gtaskqueue_thread_loop()
[all …]
/freebsd/sys/compat/linuxkpi/common/src/
H A Dlinux_work.c119 struct taskqueue *tq; in linux_delayed_work_enqueue() local
379 struct taskqueue *tq; in linux_cancel_work() local
386 tq = work->work_queue->taskqueue; 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()
426 tq = work->work_queue->taskqueue; in linux_cancel_work_sync()
471 struct taskqueue *tq; in linux_cancel_delayed_work() local
516 struct taskqueue *tq; in linux_cancel_delayed_work_sync_int() local
569 struct taskqueue *tq; in linux_flush_work() local
594 struct taskqueue *tq; in linux_flush_delayed_work() local
[all …]
/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()
62 if (ctq->tq == NULL) { in lio_setup_response_list()
67 TIMEOUT_TASK_INIT(ctq->tq, &ctq->work, 0, lio_poll_req_completion, in lio_setup_response_list()
72 taskqueue_start_threads(&ctq->tq, 1, PI_NET, "lio%d_dma_comp", in lio_setup_response_list()
74 taskqueue_enqueue_timeout(ctq->tq, &ctq->work, lio_ms_to_ticks(50)); in lio_setup_response_list()
83 if (oct->dma_comp_tq.tq != NULL) { in lio_delete_response_list()
84 while (taskqueue_cancel_timeout(oct->dma_comp_tq.tq, in lio_delete_response_list()
86 taskqueue_drain_timeout(oct->dma_comp_tq.tq, in lio_delete_response_list()
88 taskqueue_free(oct->dma_comp_tq.tq); in lio_delete_response_list()
[all …]
/freebsd/usr.sbin/jail/
H A Dconfig.c153 TAILQ_FOREACH(j, &cfjails, tq) { in load_config()
169 TAILQ_FOREACH(wj, &wild, tq) { in load_config()
171 TAILQ_FOREACH(p, &opp, tq) in load_config()
180 TAILQ_FOREACH(p, &opp, tq) in load_config()
215 tq); in load_config()
223 STAILQ_NEXT(v, tq))) { in load_config()
265 TAILQ_REMOVE(&wild, wj, tq); in load_config()
377 TAILQ_FOREACH(s, &p->val, tq) { in add_param()
788 TAILQ_FOREACH(s, &p->val, tq) in import_params()
888 TAILQ_REMOVE(pp, p, tq); in free_param()
[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()
316 TAILQ_FOREACH_SAFE(j, &cfjails, tq, tj) { in start_state()
390 TAILQ_REMOVE(j->queue, j, tq); in requeue()
391 TAILQ_INSERT_TAIL(queue, j, tq); in requeue()
399 TAILQ_REMOVE(j->queue, j, tq); in requeue_head()
[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/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-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 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 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 Dimx6ull-tqma6ull2-mba6ulx.dts4 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
14 compatible = "tq,imx6ull-tqma6ull2-mba6ulx", "tq,imx6ull-tqma6ull2", "fsl,imx6ull";
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/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()
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()
481 taskqueue_free(ixl_iw.tq); in ixl_iw_unregister()
[all …]
/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.c317 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()
368 if (tqp == TAILQ_FIRST(exp->tq)) in ex_tag_pop()
392 if (TAILQ_EMPTY(exp->tq)) { in ex_tag_top()
438 tqp = TAILQ_FIRST(exp->tq); in tag_pop()
470 if (TAILQ_EMPTY(exp->tq)) { in ex_tag_display()
696 TAILQ_REMOVE(exp->tq, tqp, q); in tagq_free()
725 if (TAILQ_EMPTY(exp->tq)) { in tagq_push()
764 if (TAILQ_EMPTY(exp->tq)) { in tagq_push()
[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()

1234567