/freebsd/sys/contrib/openzfs/module/os/linux/spl/ |
H A D | spl-taskq.c | 145 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 D | spl-proc.c | 195 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 D | taskq.c | 47 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 D | spl_taskq.c | 201 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 D | opensolaris_taskq.c | 68 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 D | kthread.h | 49 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 D | subr_taskqueue.c | 95 #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 D | subr_gtaskqueue.c | 117 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 D | linux_work.c | 119 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 D | lio_response_manager.c | 60 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 D | config.c | 153 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 D | state.c | 72 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 D | jailparse.y | 84 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 D | imx6q-mba6a.dts | 6 * 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 D | imx6qp-mba6b.dts | 4 * 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 D | imx6q-mba6b.dts | 6 * 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 D | imx6dl-mba6a.dts | 6 * 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 D | imx6dl-mba6b.dts | 6 * 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 D | imx6ul-tqma6ul2l-mba6ulx.dts | 4 * Author: Markus Niebel <Markus.Niebel@tq-group.com> 14 compatible = "tq,imx6ul-tqma6ul2l-mba6ulx", "tq,imx6ul-tqma6ul2l", "fsl,imx6ul";
|
H A D | imx6ull-tqma6ull2-mba6ulx.dts | 4 * Author: Markus Niebel <Markus.Niebel@tq-group.com> 14 compatible = "tq,imx6ull-tqma6ull2-mba6ulx", "tq,imx6ull-tqma6ull2", "fsl,imx6ull";
|
H A D | imx6ull-tqma6ull2l-mba6ulx.dts | 4 * 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 D | ixl_iw.c | 178 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 D | if_medium.c | 45 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 D | ex_tag.c | 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() 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 D | mlx4_en_cq.c | 73 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()
|