| /freebsd/sys/contrib/openzfs/module/os/linux/spl/ |
| H A D | spl-taskq.c | 98 #define TQSTAT_INC(tq, stat) wmsum_add(&tq->tq_sums.tqs_##stat, 1) argument
99 #define TQSTAT_DEC(tq, stat) wmsum_add(&tq->tq_sums.tqs_##stat, -1) argument
101 #define _TQSTAT_MOD_LIST(mod, tq, t) do { \ argument
109 #define TQSTAT_INC_LIST(tq, t) _TQSTAT_MOD_LIST(TQSTAT_INC, tq, t) argument
110 #define TQSTAT_DEC_LIST(tq, t) _TQSTAT_MOD_LIST(TQSTAT_DEC, tq, t) argument
184 taskq_t *tq; in taskq_find_by_name() local
199 task_alloc(taskq_t *tq, uint_t flags, unsigned long *irqflags) in task_alloc()
266 task_free(taskq_t *tq, taskq_ent_t *t) in task_free()
282 task_done(taskq_t *tq, taskq_ent_t *t) in task_done()
312 taskq_t *tq = t->tqent_taskq; in task_expire_impl() local
[all …]
|
| /freebsd/sys/contrib/openzfs/lib/libzpool/ |
| H A D | taskq.c | 42 task_alloc(taskq_t *tq, int tqflags) in task_alloc() argument
87 task_free(taskq_t * tq,taskq_ent_t * t) task_free() argument
104 taskq_dispatch(taskq_t * tq,task_func_t func,void * arg,uint_t tqflags) taskq_dispatch() argument
137 taskq_dispatch_delay(taskq_t * tq,task_func_t func,void * arg,uint_t tqflags,clock_t expire_time) taskq_dispatch_delay() argument
161 taskq_dispatch_ent(taskq_t * tq,task_func_t func,void * arg,uint_t flags,taskq_ent_t * t) taskq_dispatch_ent() argument
192 taskq_wait(taskq_t * tq) taskq_wait() argument
201 taskq_wait_id(taskq_t * tq,taskqid_t id) taskq_wait_id() argument
208 taskq_wait_outstanding(taskq_t * tq,taskqid_t id) taskq_wait_outstanding() argument
217 taskq_t *tq = arg; taskq_thread() local
258 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); taskq_create() local
305 taskq_destroy(taskq_t * tq) taskq_destroy() argument
350 taskq_t *tq; taskq_create_synced() local
371 taskq_member(taskq_t * tq,kthread_t * t) taskq_member() argument
392 taskq_cancel_id(taskq_t * tq,taskqid_t id) taskq_cancel_id() argument
[all...] |
| /freebsd/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/sys/contrib/openzfs/module/os/freebsd/spl/ |
| H A D | spl_taskq.c | 196 taskq_t *tq = context; in taskq_tsd_set() local
209 taskq_t *tq; in taskq_create_impl() local
243 taskq_destroy(taskq_t *tq) in taskq_destroy()
283 taskq_t *tq; in taskq_create_synced() local
332 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member()
353 taskq_cancel_id(taskq_t *tq, taskqid_t tid) in taskq_cancel_id()
398 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, in taskq_dispatch_delay()
432 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) in taskq_dispatch()
472 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint32_t flags, in taskq_dispatch_ent()
503 taskq_wait(taskq_t *tq) in taskq_wait()
[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
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/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/sys/dev/wtap/wtap_hal/ |
| H A D | handler.h | 45 struct taskqueue *tq; member
|
| /freebsd/sys/netipsec/ |
| H A D | ipsec_offload.c | 275 struct ipsec_accel_install_newkey_tq *tq; in ipsec_accel_sa_newkey_cb() local
334 struct ipsec_accel_install_newkey_tq *tq; in ipsec_accel_sa_newkey_act() local
374 struct ipsec_accel_install_newkey_tq *tq; in ipsec_accel_sa_newkey_impl() local
487 struct ipsec_accel_forget_tq *tq; in ipsec_accel_forget_sav_act() local
504 struct ipsec_accel_forget_tq *tq; in ipsec_accel_forget_sav_impl() local
693 struct ipsec_accel_adddel_sp_tq *tq; in ipsec_accel_spdadd_impl() local
752 struct ipsec_accel_adddel_sp_tq *tq; in ipsec_accel_spddel_impl() local
|
| /freebsd/sys/compat/linuxkpi/common/include/linux/ |
| H A D | kthread.h | 49 struct taskqueue *tq; member
53 struct taskqueue *tq; member
|
| /freebsd/sys/dev/ixl/ |
| H A D | ixl_iw_int.h | 62 struct taskqueue *tq; member
|
| /freebsd/usr.sbin/gstat/ |
| H A D | gstat.c | 84 struct timespec tp, tq; in main() local
|
| /freebsd/sys/dev/cfi/ |
| H A D | cfi_disk.c | 62 struct taskqueue *tq; /* private task queue for i/o request */ member
|
| /freebsd/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/sys/dev/nvd/ |
| H A D | nvd.c | 83 struct taskqueue *tq; member
|
| /freebsd/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/sys/dev/ae/ |
| H A D | if_aevar.h | 123 struct taskqueue *tq; member
|
| /freebsd/sys/net/ |
| H A D | if_epair.c | 126 struct taskqueue *tq[MAXCPU]; member
|
| /freebsd/sys/dev/sume/ |
| H A D | adapter.h | 190 struct taskqueue *tq; member
|
| /freebsd/sys/contrib/openzfs/module/zfs/ |
| H A D | vdev.c | 1907 taskq_t *tq = taskq_create("vdev_open", children, minclsyspri, in vdev_open_children_impl() local
2322 taskq_t *tq = NULL; in vdev_validate() local
3680 taskq_t *tq = NULL; in vdev_load() local
|
| /freebsd/sys/dev/iser/ |
| H A D | icl_iser.h | 330 struct taskqueue *tq; member
|
| /freebsd/sys/dev/mxge/ |
| H A D | if_mxge_var.h | 254 struct taskqueue *tq; member
|
| /freebsd/sys/dev/hpt27xx/ |
| H A D | ldm.h | 130 #define TQ_EMPTY(tq) ((tq)->head==0) argument
|
| /freebsd/sys/dev/hptnr/ |
| H A D | ldm.h | 130 #define TQ_EMPTY(tq) ((tq)->head==0) argument
|
| /freebsd/sys/dev/hptrr/ |
| H A D | ldm.h | 129 #define TQ_EMPTY(tq) ((tq)->head==0) argument
|