| /freebsd/sys/contrib/openzfs/module/os/linux/spl/ |
| H A D | spl-taskq.c | 105 #define TQSTAT_INC(tq, stat) wmsum_add(&tq->tq_sums.tqs_##stat, 1) argument
106 #define TQSTAT_DEC(tq, stat) wmsum_add(&tq->tq_sums.tqs_##stat, -1) argument
108 #define _TQSTAT_MOD_LIST(mod, tq, t) do { \ argument
116 #define TQSTAT_INC_LIST(tq, t) _TQSTAT_MOD_LIST(TQSTAT_INC, tq, t) argument
117 #define TQSTAT_DEC_LIST(tq, t) _TQSTAT_MOD_LIST(TQSTAT_DEC, tq, t) argument
187 taskq_t *tq; in taskq_find_by_name() local
202 task_alloc(taskq_t *tq, uint_t flags, unsigned long *irqflags) in task_alloc()
269 task_free(taskq_t *tq, taskq_ent_t *t) in task_free()
285 task_done(taskq_t *tq, taskq_ent_t *t) in task_done()
315 taskq_t *tq = t->tqent_taskq; in task_expire_impl() local
[all …]
|
| /freebsd/sys/contrib/openzfs/lib/libzpool/ |
| H A D | taskq.c | 43 task_alloc(taskq_t *tq, int tqflags) in task_alloc()
88 task_free(taskq_t *tq, taskq_ent_t *t) in task_free()
105 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags) in taskq_dispatch()
138 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, uint_t tqflags, in taskq_dispatch_delay()
162 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint_t flags, in taskq_dispatch_ent()
193 taskq_wait(taskq_t *tq) in taskq_wait()
202 taskq_wait_id(taskq_t *tq, taskqid_t id) in taskq_wait_id()
209 taskq_wait_outstanding(taskq_t *tq, taskqid_t id) in taskq_wait_outstanding()
218 taskq_t *tq = arg; in taskq_thread() local
259 taskq_t *tq = kmem_zalloc(sizeof (taskq_t), KM_SLEEP); in taskq_create() local
[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 | 197 taskq_t *tq = context; in taskq_tsd_set() local
210 taskq_t *tq; in taskq_create_impl() local
244 taskq_destroy(taskq_t *tq) in taskq_destroy()
284 taskq_t *tq; in taskq_create_synced() local
333 taskq_member(taskq_t *tq, kthread_t *thread) in taskq_member()
354 taskq_cancel_id(taskq_t *tq, taskqid_t tid) in taskq_cancel_id()
399 taskq_dispatch_delay(taskq_t *tq, task_func_t func, void *arg, in taskq_dispatch_delay()
433 taskq_dispatch(taskq_t *tq, task_func_t func, void *arg, uint_t flags) in taskq_dispatch()
473 taskq_dispatch_ent(taskq_t *tq, task_func_t func, void *arg, uint32_t flags, in taskq_dispatch_ent()
504 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
386 struct taskqueue *tq; in linux_cancel_work() local
417 struct taskqueue *tq; in linux_cancel_work_sync() local
478 struct taskqueue *tq; in linux_cancel_delayed_work() local
523 struct taskqueue *tq; in linux_cancel_delayed_work_sync_int() local
576 struct taskqueue *tq; in linux_flush_work() local
601 struct taskqueue *tq; in linux_flush_delayed_work() local
645 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/netipsec/ |
| H A D | ipsec_offload.c | 279 struct ipsec_accel_install_newkey_tq *tq; in ipsec_accel_sa_newkey_cb() local
338 struct ipsec_accel_install_newkey_tq *tq; in ipsec_accel_sa_newkey_act() local
378 struct ipsec_accel_install_newkey_tq *tq; in ipsec_accel_sa_newkey_impl() local
495 struct ipsec_accel_forget_tq *tq; in ipsec_accel_forget_sav_act() local
512 struct ipsec_accel_forget_tq *tq; in ipsec_accel_forget_sav_impl() local
701 struct ipsec_accel_adddel_sp_tq *tq; in ipsec_accel_spdadd_impl() local
760 struct ipsec_accel_adddel_sp_tq *tq; in ipsec_accel_spddel_impl() local
|
| /freebsd/sys/dev/wtap/wtap_hal/ |
| H A D | handler.h | 45 struct taskqueue *tq; member
|
| /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 | 1032 struct bwn_pio_txqueue *tq; in bwn_tx_isfull() local
1083 struct bwn_pio_txqueue *tq; in bwn_pio_tx_start() local
2639 bwn_pio_set_txqueue(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, in bwn_pio_set_txqueue()
2712 bwn_destroy_pioqueue_tx(struct bwn_pio_txqueue *tq) in bwn_destroy_pioqueue_tx()
2727 bwn_pio_read_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, in bwn_pio_read_2()
2757 bwn_pio_cancel_tx_packets(struct bwn_pio_txqueue *tq) in bwn_pio_cancel_tx_packets()
6188 struct bwn_pio_txqueue *tq; in bwn_pio_handle_txeof() local
6735 bwn_pio_write_multi_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, in bwn_pio_write_multi_4()
6772 bwn_pio_write_4(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, in bwn_pio_write_4()
6780 bwn_pio_write_multi_2(struct bwn_mac *mac, struct bwn_pio_txqueue *tq, in bwn_pio_write_multi_2()
[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 | 136 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 | 1992 taskq_t *tq = taskq_create("vdev_open", children, minclsyspri, in vdev_open_children_impl() local
2415 taskq_t *tq = NULL; in vdev_validate() local
3778 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
|