| /f-stack/freebsd/contrib/openzfs/module/os/linux/spl/ |
| H A D | spl-taskq.c | 94 taskq_t *tq; in taskq_find_by_name() local 221 taskq_t *tq = t->tqent_taskq; in task_expire_impl() local 271 taskq_lowest_id(taskq_t *tq) in taskq_lowest_id() 470 taskq_wait_check(taskq_t *tq) in taskq_wait_check() 488 taskq_wait(taskq_t *tq) in taskq_wait() 771 taskq_next_ent(taskq_t *tq) in taskq_next_ent() 791 taskq_t *tq = (taskq_t *)arg; in taskq_thread_spawn_task() local 861 taskq_t *tq; in taskq_thread() local 1038 taskq_t *tq; in taskq_create() local 1144 taskq_destroy(taskq_t *tq) in taskq_destroy() [all …]
|
| H A D | spl-proc.c | 250 taskq_t *tq = p; in taskq_seq_show_impl() local 408 taskq_t *tq = p; in taskq_seq_next() local
|
| /f-stack/freebsd/contrib/openzfs/lib/libzpool/ |
| H A D | taskq.c | 42 task_alloc(taskq_t *tq, int tqflags) in task_alloc() 87 task_free(taskq_t *tq, taskq_ent_t *t) in task_free() 104 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) in taskq_dispatch() 191 taskq_wait(taskq_t *tq) in taskq_wait() 200 taskq_wait_id(taskq_t *tq, taskqid_t id) in taskq_wait_id() 206 taskq_wait_outstanding(taskq_t *tq, taskqid_t id) in taskq_wait_outstanding() 214 taskq_t *tq = arg; in taskq_thread() local 255 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); in taskq_create() local 302 taskq_destroy(taskq_t *tq) in taskq_destroy() 336 taskq_member(taskq_t *tq, kthread_t *t) in taskq_member() [all …]
|
| /f-stack/freebsd/contrib/openzfs/module/os/freebsd/spl/ |
| H A D | spl_taskq.c | 202 taskq_t *tq = context; in taskq_tsd_set() local 215 taskq_t *tq; in taskq_create_impl() local 248 taskq_destroy(taskq_t *tq) in taskq_destroy() 256 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member() 277 taskq_cancel_id(taskq_t *tq, taskqid_t tid) in taskq_cancel_id() 320 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, in taskq_dispatch_delay() 355 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) in taskq_dispatch() 394 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint32_t flags, in taskq_dispatch_ent() 415 taskq_wait(taskq_t *tq) in taskq_wait() 421 taskq_wait_id(taskq_t *tq, taskqid_t tid) in taskq_wait_id() [all …]
|
| /f-stack/freebsd/kern/ |
| H A D | subr_gtaskqueue.c | 90 #define TQ_LOCK(tq) \ argument 97 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument 99 #define TQ_UNLOCK(tq) \ argument 106 #define TQ_ASSERT_UNLOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_NOTOWNED) argument 118 TQ_SLEEP(struct gtaskqueue *tq, void *p, const char *wm) in TQ_SLEEP() 163 gtaskqueue_terminate(struct thread **pp, struct gtaskqueue *tq) in gtaskqueue_terminate() 454 struct gtaskqueue *tq; in _gtaskqueue_start_threads() local 525 gtaskqueue_run_callback(struct gtaskqueue *tq, in gtaskqueue_run_callback() 539 struct gtaskqueue **tqp, *tq; in gtaskqueue_thread_loop() local 577 struct gtaskqueue **tqp, *tq; in gtaskqueue_thread_enqueue() local
|
| H A D | subr_taskqueue.c | 90 #define TQ_LOCK(tq) \ argument 97 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument 99 #define TQ_UNLOCK(tq) \ argument 106 #define TQ_ASSERT_UNLOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_NOTOWNED) argument 122 TQ_SLEEP(struct taskqueue *tq, void *p, const char *wm) in TQ_SLEEP() 199 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) in taskqueue_terminate() 674 struct taskqueue *tq; in _taskqueue_start_threads() local 789 taskqueue_run_callback(struct taskqueue *tq, in taskqueue_run_callback() 803 struct taskqueue **tqp, *tq; in taskqueue_thread_loop() local 841 struct taskqueue **tqp, *tq; in taskqueue_thread_enqueue() local
|
| /f-stack/dpdk/drivers/net/vmxnet3/ |
| H A D | vmxnet3_rxtx.c | 170 vmxnet3_tx_queue_t *tq = txq; in vmxnet3_dev_tx_queue_release() local 210 vmxnet3_tx_queue_t *tq = txq; in vmxnet3_dev_tx_queue_reset() local
|
| /f-stack/freebsd/contrib/openzfs/module/icp/core/ |
| H A D | kcf_sched.c | 579 static inline int EMPTY_TASKQ(taskq_t *tq) in EMPTY_TASKQ()
|
| /f-stack/dpdk/drivers/net/liquidio/ |
| H A D | lio_ethdev.c | 1304 struct lio_instr_queue *tq = txq; in lio_dev_tx_queue_release() local
|
| /f-stack/freebsd/contrib/openzfs/module/zfs/ |
| H A D | spa.c | 987 taskq_t *tq; in spa_taskqs_init() local 1061 taskq_t *tq; in spa_taskq_dispatch_ent() local 1083 taskq_t *tq; in spa_taskq_dispatch_sync() local
|
| H A D | dmu_objset.c | 2737 taskq_t *tq = NULL; in dmu_objset_find_dp() local
|
| H A D | vdev.c | 1680 taskq_t *tq = taskq_create("vdev_open", children, minclsyspri, in vdev_open_children_impl() local
|
| H A D | zio.c | 1909 taskq_t *tq = taskq_of_curthread(); in zio_taskq_member() local
|
| /f-stack/freebsd/contrib/ipfilter/netinet/ |
| H A D | ip_state.c | 1698 ipftq_t *tq; local
|
| H A D | ip_nat.c | 381 ipftq_t *tq; local
|