Home
last modified time | relevance | path

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

/f-stack/freebsd/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()
194 while (tq->tq_task.tqent_next != &tq->tq_task || tq->tq_active != 0) in taskq_wait()
195 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); in taskq_wait()
225 cv_wait(&tq->tq_dispatch_cv, &tq->tq_lock); in taskq_thread()
282 tq->tq_task.tqent_next = &tq->tq_task; in taskq_create()
283 tq->tq_task.tqent_prev = &tq->tq_task; in taskq_create()
290 task_free(tq, task_alloc(tq, KM_SLEEP)); in taskq_create()
314 cv_wait(&tq->tq_wait_cv, &tq->tq_lock); in taskq_destroy()
[all …]
/f-stack/freebsd/contrib/openzfs/module/os/linux/spl/
H A Dspl-taskq.c133 if (tq->tq_nalloc >= tq->tq_maxalloc) { in task_alloc()
201 if (tq->tq_nalloc <= tq->tq_minalloc) { in task_done()
476 rc = (tq->tq_lowest_id == tq->tq_next_id); in taskq_wait_check()
534 tq->tq_lowest_id = taskq_lowest_id(tq); in taskq_cancel_id()
584 ASSERT(tq->tq_nactive <= tq->tq_nthreads); in taskq_dispatch()
671 if (tq->tq_nactive == tq->tq_nthreads) in taskq_dispatch_delay()
737 if (tq->tq_nactive == tq->tq_nthreads) in taskq_dispatch_ent()
818 if ((tq->tq_nthreads + tq->tq_nspawn < tq->tq_maxthreads) && in taskq_thread_spawn()
890 if (tq->tq_nthreads >= tq->tq_maxthreads) in taskq_thread()
1068 kmem_free(tq, sizeof (*tq)); in taskq_create()
[all …]
H A Dspl-proc.c250 taskq_t *tq = p; in taskq_seq_show_impl() local
262 spin_lock_irqsave_nested(&tq->tq_lock, flags, tq->tq_lock_class); in taskq_seq_show_impl()
266 lheads[LHEAD_PEND] = &tq->tq_pend_list; in taskq_seq_show_impl()
267 lheads[LHEAD_PRIO] = &tq->tq_prio_list; in taskq_seq_show_impl()
268 lheads[LHEAD_DELAY] = &tq->tq_delay_list; in taskq_seq_show_impl()
295 snprintf(name, sizeof (name), "%s/%d", tq->tq_name, tq->tq_instance); in taskq_seq_show_impl()
298 tq->tq_nactive, tq->tq_nthreads, tq->tq_nspawn, in taskq_seq_show_impl()
299 tq->tq_maxthreads, tq->tq_pri, tq->tq_minalloc, tq->tq_maxalloc, in taskq_seq_show_impl()
300 tq->tq_nalloc, tq->tq_flags); in taskq_seq_show_impl()
408 taskq_t *tq = p; in taskq_seq_next() local
[all …]
/f-stack/freebsd/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_taskq.c202 taskq_t *tq = context; in taskq_tsd_set() local
208 tsd_set(taskq_tsd, tq); in taskq_tsd_set()
215 taskq_t *tq; in taskq_create_impl() local
220 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()
248 taskq_destroy(taskq_t *tq) in taskq_destroy() argument
251 taskqueue_free(tq->tq_queue); in taskq_destroy()
252 kmem_free(tq, sizeof (*tq)); in taskq_destroy()
415 taskq_wait(taskq_t *tq) in taskq_wait() argument
[all …]
/f-stack/freebsd/kern/
H A Dsubr_taskqueue.c124 if (tq->tq_spin) in TQ_SLEEP()
202 while (tq->tq_tcount > 0 || tq->tq_callouts > 0) { in taskqueue_terminate()
203 wakeup(tq); in taskqueue_terminate()
681 tq = *tqp; in _taskqueue_start_threads()
806 tq = *tqp; in taskqueue_thread_loop()
808 TQ_LOCK(tq); in taskqueue_thread_loop()
819 TQ_SLEEP(tq, tq, "-"); in taskqueue_thread_loop()
827 TQ_UNLOCK(tq); in taskqueue_thread_loop()
829 TQ_LOCK(tq); in taskqueue_thread_loop()
834 TQ_UNLOCK(tq); in taskqueue_thread_loop()
[all …]
H A Dsubr_gtaskqueue.c120 if (tq->tq_spin) in TQ_SLEEP()
166 while (tq->tq_tcount > 0 || tq->tq_callouts > 0) { in gtaskqueue_terminate()
167 wakeup(tq); in gtaskqueue_terminate()
461 tq = *tqp; in _gtaskqueue_start_threads()
542 tq = *tqp; in gtaskqueue_thread_loop()
544 TQ_LOCK(tq); in gtaskqueue_thread_loop()
555 TQ_SLEEP(tq, tq, "-"); in gtaskqueue_thread_loop()
563 TQ_UNLOCK(tq); in gtaskqueue_thread_loop()
565 TQ_LOCK(tq); in gtaskqueue_thread_loop()
570 TQ_UNLOCK(tq); in gtaskqueue_thread_loop()
[all …]
/f-stack/freebsd/contrib/device-tree/src/arm/
H A Dimx7s-mba7.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
17 compatible = "tq,imx7s-mba7", "fsl,imx7s";
H A Dimx53-mba53.dts12 compatible = "tq,mba53", "tq,tqma53", "fsl,imx53";
65 compatible = "tq,imx53-mba53-sgtl5000",
H A Dimx7d-mba7.dts6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
17 compatible = "tq,imx7d-mba7", "fsl,imx7d";
H A Dimx7s-tqma7.dtsi6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
H A Dimx7d-tqma7.dtsi6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
H A Dimx7-tqma7.dtsi6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
H A Dimx53-tqma53.dtsi11 compatible = "tq,tqma53", "fsl,imx53";
H A Dimx7-mba7.dtsi6 * Author: Markus Niebel <Markus.Niebel@tq-group.com>
/f-stack/dpdk/drivers/net/vmxnet3/
H A Dvmxnet3_rxtx.c170 vmxnet3_tx_queue_t *tq = txq; in vmxnet3_dev_tx_queue_release() local
172 if (tq != NULL) { in vmxnet3_dev_tx_queue_release()
174 vmxnet3_tx_cmd_ring_release_mbufs(&tq->cmd_ring); in vmxnet3_dev_tx_queue_release()
176 vmxnet3_cmd_ring_release(&tq->cmd_ring); in vmxnet3_dev_tx_queue_release()
178 rte_memzone_free(tq->mz); in vmxnet3_dev_tx_queue_release()
180 rte_free(tq); in vmxnet3_dev_tx_queue_release()
210 vmxnet3_tx_queue_t *tq = txq; in vmxnet3_dev_tx_queue_reset() local
211 struct vmxnet3_cmd_ring *ring = &tq->cmd_ring; in vmxnet3_dev_tx_queue_reset()
216 if (tq != NULL) { in vmxnet3_dev_tx_queue_reset()
218 vmxnet3_tx_cmd_ring_release_mbufs(&tq->cmd_ring); in vmxnet3_dev_tx_queue_reset()
[all …]
/f-stack/freebsd/contrib/openzfs/module/icp/core/
H A Dkcf_sched.c579 static inline int EMPTY_TASKQ(taskq_t *tq) in EMPTY_TASKQ() argument
582 return (tq->tq_lowest_id == tq->tq_next_id); in EMPTY_TASKQ()
584 return (tq->tq_task.tqent_next == &tq->tq_task || tq->tq_active == 0); in EMPTY_TASKQ()
/f-stack/dpdk/drivers/net/liquidio/
H A Dlio_ethdev.c1304 struct lio_instr_queue *tq = txq; in lio_dev_tx_queue_release() local
1308 if (tq) { in lio_dev_tx_queue_release()
1310 lio_delete_sglist(tq); in lio_dev_tx_queue_release()
1312 fw_mapped_iq_no = tq->txpciq.s.q_no; in lio_dev_tx_queue_release()
1313 lio_delete_instruction_queue(tq->lio_dev, fw_mapped_iq_no); in lio_dev_tx_queue_release()
/f-stack/freebsd/contrib/openzfs/module/zfs/
H A Ddmu_objset.c2737 taskq_t *tq = NULL; in dmu_objset_find_dp() local
2777 tq = taskq_create("dmu_objset_find", ntasks, maxclsyspri, ntasks, in dmu_objset_find_dp()
2779 if (tq == NULL) { in dmu_objset_find_dp()
2785 dcp->dc_tq = tq; in dmu_objset_find_dp()
2788 (void) taskq_dispatch(tq, dmu_objset_find_dp_cb, dcp, TQ_SLEEP); in dmu_objset_find_dp()
2799 taskq_wait(tq); in dmu_objset_find_dp()
2800 taskq_destroy(tq); in dmu_objset_find_dp()
H A Dspa.c987 taskq_t *tq; in spa_taskqs_init() local
997 tq = taskq_create_sysdc(name, value, 50, INT_MAX, in spa_taskqs_init()
1023 tq = taskq_create_proc(name, value, pri, 50, in spa_taskqs_init()
1027 tqs->stqs_taskq[i] = tq; in spa_taskqs_init()
1061 taskq_t *tq; in spa_taskq_dispatch_ent() local
1067 tq = tqs->stqs_taskq[0]; in spa_taskq_dispatch_ent()
1072 taskq_dispatch_ent(tq, func, arg, flags, ent); in spa_taskq_dispatch_ent()
1083 taskq_t *tq; in spa_taskq_dispatch_sync() local
1090 tq = tqs->stqs_taskq[0]; in spa_taskq_dispatch_sync()
1095 id = taskq_dispatch(tq, func, arg, flags); in spa_taskq_dispatch_sync()
[all …]
H A Dvdev.c1680 taskq_t *tq = taskq_create("vdev_open", children, minclsyspri, in vdev_open_children_impl() local
1690 if (tq == NULL || vdev_uses_zvols(vd)) { in vdev_open_children_impl()
1693 VERIFY(taskq_dispatch(tq, vdev_open_child, in vdev_open_children_impl()
1700 if (tq != NULL) { in vdev_open_children_impl()
1701 taskq_wait(tq); in vdev_open_children_impl()
1702 taskq_destroy(tq); in vdev_open_children_impl()
H A Dzio.c1909 taskq_t *tq = taskq_of_curthread(); in zio_taskq_member() local
1915 if (tqs->stqs_taskq[i] == tq) in zio_taskq_member()
/f-stack/freebsd/contrib/device-tree/Bindings/arm/
H A Dfsl.yaml299 - tq,imx7s-mba7 # i.MX7S TQ MBa7 with TQMa7S SoM
321 - tq,imx7d-mba7 # i.MX7D TQ MBa7 with TQMa7D SoM
/f-stack/freebsd/contrib/ipfilter/netinet/
H A Dip_state.c1698 ipftq_t *tq; local
1703 tq = ipf_addtimeoutqueue(softc,
1706 is->is_tqehead[0] = tq;
1710 tq = ipf_addtimeoutqueue(softc,
1713 is->is_tqehead[1] = tq;
H A Dip_nat.c381 ipftq_t *tq; local
492 for (i = 0, tq = softn->ipf_nat_tcptq; i < IPF_TCP_NSTATES; i++, tq++) {
493 if (tq->ifq_ttl < softn->ipf_nat_deficmpage)
494 tq->ifq_ttl = softn->ipf_nat_deficmpage;
496 else if (tq->ifq_ttl > softn->ipf_nat_defage)
497 tq->ifq_ttl = softn->ipf_nat_defage;
/f-stack/freebsd/contrib/device-tree/Bindings/
H A Dvendor-prefixes.yaml1075 "^tq,.*":