/freebsd-src/sys/contrib/openzfs/module/os/linux/spl/ |
H A D | spl-taskq.c | 106 case TQENT_LIST_DELAY: mod(tq, tasks_delayed); break; \ in taskq_find_by_name() local 121 task_alloc(taskq_t * tq,uint_t flags,unsigned long * irqflags) task_alloc() argument 187 task_free(taskq_t * tq,taskq_ent_t * t) task_free() argument 203 task_done(taskq_t * tq,taskq_ent_t * t) task_done() argument 233 taskq_t *tq = t->tqent_taskq; task_expire_impl() local 283 taskq_lowest_id(taskq_t * tq) taskq_lowest_id() argument 318 taskq_insert_in_order(taskq_t * tq,taskq_thread_t * tqt) taskq_insert_in_order() argument 342 taskq_find_list(taskq_t * tq,struct list_head * lh,taskqid_t id) taskq_find_list() argument 367 taskq_find(taskq_t * tq,taskqid_t id) taskq_find() argument 428 taskq_wait_id_check(taskq_t * tq,taskqid_t id) taskq_wait_id_check() argument 445 taskq_wait_id(taskq_t * tq,taskqid_t id) taskq_wait_id() argument 452 taskq_wait_outstanding_check(taskq_t * tq,taskqid_t id) taskq_wait_outstanding_check() argument 472 taskq_wait_outstanding(taskq_t * tq,taskqid_t id) taskq_wait_outstanding() argument 480 taskq_wait_check(taskq_t * tq) taskq_wait_check() argument 498 taskq_wait(taskq_t * tq) taskq_wait() argument 505 taskq_member(taskq_t * tq,kthread_t * t) taskq_member() argument 525 taskq_cancel_id(taskq_t * tq,taskqid_t id) taskq_cancel_id() argument 578 taskq_dispatch(taskq_t * tq,task_func_t func,void * arg,uint_t flags) taskq_dispatch() argument 642 taskq_dispatch_delay(taskq_t * tq,task_func_t func,void * arg,uint_t flags,clock_t expire_time) taskq_dispatch_delay() argument 689 taskq_dispatch_ent(taskq_t * tq,task_func_t func,void * arg,uint_t flags,taskq_ent_t * t) taskq_dispatch_ent() argument 780 taskq_next_ent(taskq_t * tq) taskq_next_ent() argument 800 taskq_t *tq = (taskq_t *)arg; taskq_thread_spawn_task() local 820 taskq_thread_spawn(taskq_t * tq) taskq_thread_spawn() argument 848 taskq_thread_should_stop(taskq_t * tq,taskq_thread_t * tqt) taskq_thread_should_stop() argument 874 taskq_t *tq; taskq_thread() local 1012 taskq_thread_create(taskq_t * tq) taskq_thread_create() argument 1047 taskq_t *tq; taskq_create() local 1153 taskq_destroy(taskq_t * tq) taskq_destroy() argument 1248 taskq_t *tq; taskq_create_synced() local 1290 taskq_t *tq = NULL; param_set_taskq_kick() local 1340 taskq_t *tq = list_entry(node, taskq_t, tq_hp_cb_node); spl_taskq_expand() local 1377 taskq_t *tq = list_entry(node, taskq_t, tq_hp_cb_node); spl_taskq_prepare_down() local [all...] |
H A D | spl-proc.c | 195 taskq_t *tq = p; taskq_seq_show_impl() local 353 taskq_t *tq = p; taskq_seq_next() local
|
/freebsd-src/sys/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() 137 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags, in taskq_dispatch_delay() 161 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, in taskq_dispatch_ent() 192 taskq_wait(taskq_t *tq) in taskq_wait() 201 taskq_wait_id(taskq_t *tq, taskqid_t id) in taskq_wait_id() 208 taskq_wait_outstanding(taskq_t *tq, taskqid_t id) in taskq_wait_outstanding() 217 taskq_t *tq = arg; in taskq_thread() local 258 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); in taskq_create() local [all …]
|
/freebsd-src/sys/cddl/compat/opensolaris/kern/ |
H A D | opensolaris_taskq.c | 68 taskq_t *tq; in taskq_create_impl() local 97 taskq_destroy(taskq_t *tq) in taskq_destroy() 105 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member() 122 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) in taskq_dispatch() 159 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, u_int flags, in taskq_dispatch_ent() 178 taskq_wait(taskq_t *tq) in taskq_wait() 184 taskq_wait_id(taskq_t *tq, taskqid_t id) in taskq_wait_id()
|
/freebsd-src/sys/contrib/openzfs/module/os/freebsd/spl/ |
H A D | spl_taskq.c | 214 tq = kmem_alloc(sizeof (*tq), KM_SLEEP); in taskq_create_impl() local 201 taskq_t *tq = context; taskq_tsd_set() local 248 taskq_destroy(taskq_t * tq) taskq_destroy() argument 288 taskq_t *tq; taskq_create_synced() local 337 taskq_member(taskq_t * tq,kthread_t * thread) taskq_member() argument 358 taskq_cancel_id(taskq_t * tq,taskqid_t tid) taskq_cancel_id() argument 403 taskq_dispatch_delay(taskq_t * tq,task_func_t func,void * arg,uint_t flags,clock_t expire_time) taskq_dispatch_delay() argument 437 taskq_dispatch(taskq_t * tq,task_func_t func,void * arg,uint_t flags) taskq_dispatch() argument 477 taskq_dispatch_ent(taskq_t * tq,task_func_t func,void * arg,uint32_t flags,taskq_ent_t * task) taskq_dispatch_ent() argument 508 taskq_wait(taskq_t * tq) taskq_wait() argument 514 taskq_wait_id(taskq_t * tq,taskqid_t tid) taskq_wait_id() argument 529 taskq_wait_outstanding(taskq_t * tq,taskqid_t id __unused) taskq_wait_outstanding() argument [all...] |
/freebsd-src/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 410 struct taskqueue *tq; in linux_cancel_work_sync() local 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 638 struct taskqueue *tq; in linux_work_busy() local
|
/freebsd-src/sys/kern/ |
H A D | subr_gtaskqueue.c | 87 #define TQ_LOCK(tq) \ argument 94 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument 96 #define TQ_UNLOCK(tq) \ argument 103 #define TQ_ASSERT_UNLOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_NOTOWNED) argument 115 TQ_SLEEP(struct gtaskqueue *tq, void *p, const char *wm) in TQ_SLEEP() 160 gtaskqueue_terminate(struct thread **pp, struct gtaskqueue *tq) in gtaskqueue_terminate() 451 struct gtaskqueue *tq; in _gtaskqueue_start_threads() local 522 gtaskqueue_run_callback(struct gtaskqueue *tq, in gtaskqueue_run_callback() 536 struct gtaskqueue **tqp, *tq; in gtaskqueue_thread_loop() local 574 struct gtaskqueue **tqp, *tq; in gtaskqueue_thread_enqueue() local
|
H A D | subr_taskqueue.c | 88 #define TQ_LOCK(tq) \ argument 95 #define TQ_ASSERT_LOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_OWNED) argument 97 #define TQ_UNLOCK(tq) \ argument 104 #define TQ_ASSERT_UNLOCKED(tq) mtx_assert(&(tq)->tq_mutex, MA_NOTOWNED) argument 119 TQ_SLEEP(struct taskqueue *tq, void *p, const char *wm) in TQ_SLEEP() 206 taskqueue_terminate(struct thread **pp, struct taskqueue *tq) in taskqueue_terminate() 705 struct taskqueue *tq; in _taskqueue_start_threads() local 807 taskqueue_run_callback(struct taskqueue *tq, in taskqueue_run_callback() 821 struct taskqueue **tqp, *tq; in taskqueue_thread_loop() local 859 struct taskqueue **tqp, *tq; in taskqueue_thread_enqueue() local
|
/freebsd-src/sys/dev/wtap/wtap_hal/ |
H A D | handler.h | 45 struct taskqueue *tq; member
|
/freebsd-src/sys/compat/linuxkpi/common/include/linux/ |
H A D | kthread.h | 49 struct taskqueue *tq; member 53 struct taskqueue *tq; member
|
/freebsd-src/sys/dev/ixl/ |
H A D | ixl_iw_int.h | 62 struct taskqueue *tq; member
|
/freebsd-src/usr.sbin/gstat/ |
H A D | gstat.c | 84 struct timespec tp, tq; in main() local
|
/freebsd-src/sys/dev/cfi/ |
H A D | cfi_disk.c | 62 struct taskqueue *tq; /* private task queue for i/o request */ member
|
/freebsd-src/sys/dev/bwn/ |
H A D | if_bwn.c | 1030 struct bwn_pio_txqueue *tq; in bwn_tx_isfull() local 1081 struct bwn_pio_txqueue *tq; in bwn_pio_tx_start() local 2637 bwn_pio_set_txqueue(struct bwn_mac * mac,struct bwn_pio_txqueue * tq,int index) bwn_pio_set_txqueue() argument 2710 bwn_destroy_pioqueue_tx(struct bwn_pio_txqueue * tq) bwn_destroy_pioqueue_tx() argument 2725 bwn_pio_read_2(struct bwn_mac * mac,struct bwn_pio_txqueue * tq,uint16_t offset) bwn_pio_read_2() argument 2755 bwn_pio_cancel_tx_packets(struct bwn_pio_txqueue * tq) bwn_pio_cancel_tx_packets() argument 6194 struct bwn_pio_txqueue *tq; bwn_pio_handle_txeof() local 6745 bwn_pio_write_multi_4(struct bwn_mac * mac,struct bwn_pio_txqueue * tq,uint32_t ctl,const void * _data,int len) bwn_pio_write_multi_4() argument 6782 bwn_pio_write_4(struct bwn_mac * mac,struct bwn_pio_txqueue * tq,uint16_t offset,uint32_t value) bwn_pio_write_4() argument 6790 bwn_pio_write_multi_2(struct bwn_mac * mac,struct bwn_pio_txqueue * tq,uint16_t ctl,const void * _data,int len) bwn_pio_write_multi_2() argument 6811 bwn_pio_write_mbuf_2(struct bwn_mac * mac,struct bwn_pio_txqueue * tq,uint16_t ctl,struct mbuf * m0) bwn_pio_write_mbuf_2() argument 6903 struct bwn_pio_txqueue *tq = NULL; bwn_pio_parse_cookie() local [all...] |
/freebsd-src/sys/dev/nvd/ |
H A D | nvd.c | 83 struct taskqueue *tq; member
|
/freebsd-src/contrib/llvm-project/compiler-rt/lib/tsan/rtl/ |
H A D | tsan_interceptors_libdispatch.cpp | 70 dispatch_queue_t tq = *( in GetTargetQueueFromQueue() local 76 dispatch_queue_t tq = GetTargetQueueFromQueue((dispatch_queue_t)source); in GetTargetQueueFromSource() local
|
/freebsd-src/sys/dev/ae/ |
H A D | if_aevar.h | 123 struct taskqueue *tq; member
|
/freebsd-src/sys/net/ |
H A D | if_epair.c | 126 struct taskqueue *tq[MAXCPU]; member
|
/freebsd-src/sys/dev/sume/ |
H A D | adapter.h | 190 struct taskqueue *tq; member
|
/freebsd-src/sys/contrib/openzfs/module/zfs/ |
H A D | vdev.c | 1888 taskq_t *tq = taskq_create("vdev_open", children, minclsyspri, vdev_open_children_impl() local 2301 taskq_t *tq = NULL; vdev_validate() local 3636 taskq_t *tq = NULL; vdev_load() local [all...] |
/freebsd-src/sys/dev/iser/ |
H A D | icl_iser.h | 330 struct taskqueue *tq; member
|
/freebsd-src/sys/dev/mxge/ |
H A D | if_mxge_var.h | 254 struct taskqueue *tq; member
|
/freebsd-src/sys/dev/hptnr/ |
H A D | ldm.h | 130 #define TQ_EMPTY(tq) ((tq)->head==0) argument
|
/freebsd-src/sys/dev/hptrr/ |
H A D | ldm.h | 129 #define TQ_EMPTY(tq) ((tq)->head==0) argument
|
/freebsd-src/sys/dev/hpt27xx/ |
H A D | ldm.h | 130 #define TQ_EMPTY(tq) ((tq)->head==0) argument
|