| /freebsd-12.1/sys/cddl/contrib/opensolaris/uts/common/sys/ |
| H A D | vnode.h | 372 struct taskq;
396 void vn_rele_async(struct vnode *vp, struct taskq *taskq);
406 #define VN_RELE_ASYNC(vp, taskq) { \ argument
407 vn_rele_async(vp, taskq); \
|
| H A D | taskq.h | 40 struct taskq { struct
44 typedef struct taskq taskq_t;
|
| /freebsd-12.1/sys/cddl/contrib/opensolaris/uts/common/fs/ |
| H A D | vnode.c | 86 vn_rele_async(vnode_t *vp, taskq_t *taskq) in vn_rele_async() argument
93 VERIFY(taskq_dispatch((taskq_t *)taskq, in vn_rele_async()
|
| /freebsd-12.1/sys/dev/netmap/ |
| H A D | if_ptnet.c | 139 struct taskqueue *taskq; member
537 if (pq->taskq) { in ptnet_detach()
538 taskqueue_drain(pq->taskq, &pq->task); in ptnet_detach()
702 taskqueue_thread_enqueue, &pq->taskq); in ptnet_irqs_init()
723 if (pq->taskq) { in ptnet_irqs_fini()
724 taskqueue_free(pq->taskq); in ptnet_irqs_fini()
725 pq->taskq = NULL; in ptnet_irqs_fini()
807 if (pq->taskq) { in ptnet_ioctl()
808 taskqueue_drain(pq->taskq, in ptnet_ioctl()
1313 taskqueue_enqueue(pq->taskq, &pq->task); in ptnet_tx_intr()
[all …]
|
| /freebsd-12.1/sys/dev/hyperv/pcib/ |
| H A D | vmbus_pcib.c | 415 struct taskqueue *taskq; member
845 taskqueue_enqueue(hbus->sc->taskq, &dr_wrk->task); in hv_pci_devices_present()
874 struct taskqueue *taskq; in hv_pci_eject_device() local
885 taskq = vmbus_chan_mgmt_tq(hbus->sc->chan); in hv_pci_eject_device()
886 taskqueue_enqueue(taskq, &hpdev->eject_task); in hv_pci_eject_device()
1328 taskqueue_drain_all(hbus->sc->taskq); in vmbus_pcib_pre_detach()
1397 sc->taskq = taskqueue_create("vmbus_pcib_tq", M_WAITOK, in vmbus_pcib_attach()
1398 taskqueue_thread_enqueue, &sc->taskq); in vmbus_pcib_attach()
1445 taskqueue_free(sc->taskq); in vmbus_pcib_attach()
1487 taskqueue_drain_all(hbus->sc->taskq); in vmbus_pcib_detach()
[all …]
|
| /freebsd-12.1/contrib/openmp/runtime/src/ |
| H A D | kmp_taskq.cpp | 35 kmpc_task_queue_t *taskq; in __kmp_taskq_eo() local
53 taskq = tq->tq_curr_thunk[tid]->th.th_shareds->sv_queue; in __kmp_taskq_eo()
55 KMP_WAIT_YIELD(&taskq->tq_tasknum_serving, my_token, KMP_EQ, NULL); in __kmp_taskq_eo()
88 kmpc_task_queue_t *taskq; in __kmp_taskq_check_ordered() local
96 taskq = thunk->th.th_shareds->sv_queue; in __kmp_taskq_check_ordered()
98 if (taskq->tq_tasknum_serving <= my_token) { in __kmp_taskq_check_ordered()
99 KMP_WAIT_YIELD(&taskq->tq_tasknum_serving, my_token, KMP_GE, NULL); in __kmp_taskq_check_ordered()
101 taskq->tq_tasknum_serving = my_token + 1; in __kmp_taskq_check_ordered()
181 kmpc_task_queue_t *taskq; in __kmp_dump_task_queue() local
290 for (taskq = tq->tq_freelist; taskq != NULL; taskq = taskq->tq.tq_next_free) in __kmp_dump_task_queue()
[all …]
|
| /freebsd-12.1/cddl/lib/libzpool/ |
| H A D | Makefile | 36 KERNEL_SRCS= kernel.c taskq.c util.c
|
| /freebsd-12.1/sys/cddl/contrib/opensolaris/uts/common/fs/zfs/sys/ |
| H A D | dsl_pool.h | 93 struct taskq *dp_vnrele_taskq;
|
| /freebsd-12.1/sys/dev/neta/ |
| H A D | if_mvnetavar.h | 177 struct taskqueue *taskq; member
|
| H A D | if_mvneta.c | 1297 if (tx->taskq != NULL) { in mvneta_ring_dealloc_tx_queue()
1299 while (taskqueue_cancel(tx->taskq, &tx->task, NULL) != 0) in mvneta_ring_dealloc_tx_queue()
1300 taskqueue_drain(tx->taskq, &tx->task); in mvneta_ring_dealloc_tx_queue()
1439 tx->taskq = taskqueue_create_fast("mvneta_tx_taskq", M_WAITOK, in mvneta_ring_init_tx_queue()
1440 taskqueue_thread_enqueue, &tx->taskq); in mvneta_ring_init_tx_queue()
1441 taskqueue_start_threads(&tx->taskq, 1, PI_NET, "%s: tx_taskq(%d)", in mvneta_ring_init_tx_queue()
1872 taskqueue_enqueue(tx->taskq, &tx->task); in mvneta_tx_task()
1965 taskqueue_enqueue(tx->taskq, &tx->task); in mvneta_transmit()
2012 taskqueue_enqueue(tx->taskq, &tx->task); in mvneta_start()
|
| /freebsd-12.1/cddl/contrib/opensolaris/lib/libzpool/common/sys/ |
| H A D | zfs_context.h | 386 typedef struct taskq taskq_t;
522 #define VN_RELE_ASYNC(vp, taskq) vn_close(vp, 0, NULL, NULL) argument
|
| /freebsd-12.1/cddl/contrib/opensolaris/lib/libzpool/common/ |
| H A D | taskq.c | 39 struct taskq { struct
|