| /onnv-gate/usr/src/uts/common/io/fibre-channel/fca/emlxs/ |
| H A D | emlxs_thread.c | 41 emlxs_taskq_t *taskq; in emlxs_taskq_thread() local
45 taskq = tthread->taskq; in emlxs_taskq_thread()
51 mutex_enter(&taskq->put_lock); in emlxs_taskq_thread()
52 tthread->next = taskq->put_head; in emlxs_taskq_thread()
53 taskq->put_head = tthread; in emlxs_taskq_thread()
54 taskq->put_count++; in emlxs_taskq_thread()
55 mutex_exit(&taskq->put_lock); in emlxs_taskq_thread()
68 func(taskq->hba, arg); in emlxs_taskq_thread()
87 emlxs_taskq_dispatch(emlxs_taskq_t *taskq, void (*func) (), void *arg) in emlxs_taskq_dispatch() argument
91 mutex_enter(&taskq->get_lock); in emlxs_taskq_dispatch()
[all …]
|
| /onnv-gate/usr/src/uts/common/crypto/core/ |
| H A D | kcf_sched.c | 583 taskq_t *taskq = new_pd->pd_taskq; in kcf_resubmit_request() local
585 if (taskq_dispatch(taskq, process_req_hwp, areq, TQ_NOSLEEP) == in kcf_resubmit_request()
623 taskq_t *taskq; in kcf_submit_request() local
637 taskq = pd->pd_taskq; in kcf_submit_request()
645 EMPTY_TASKQ(taskq)) { in kcf_submit_request()
674 ASSERT(taskq != NULL); in kcf_submit_request()
682 if (EMPTY_TASKQ(taskq) && in kcf_submit_request()
693 if (taskq->tq_nalloc >= crypto_taskq_maxalloc) { in kcf_submit_request()
694 taskq_wait(taskq); in kcf_submit_request()
697 (void) taskq_dispatch(taskq, process_req_hwp, in kcf_submit_request()
[all …]
|
| /onnv-gate/usr/src/uts/i86pc/io/tzmon/ |
| H A D | tzmon.c | 352 if (tzp->taskq != NULL) { in tzmon_free_zone_list()
358 ddi_taskq_destroy(tzp->taskq); in tzmon_free_zone_list()
506 if (tzp->taskq == NULL) { in tzmon_enumerate_zone()
511 tzp->taskq = ddi_taskq_create(tzmon_dip, in tzmon_enumerate_zone()
513 if (tzp->taskq == NULL) { in tzmon_enumerate_zone()
520 (void) ddi_taskq_dispatch(tzp->taskq, in tzmon_enumerate_zone()
|
| H A D | tzmon.h | 45 ddi_taskq_t *taskq; member
|
| /onnv-gate/usr/src/uts/sun4v/io/ |
| H A D | mdeg.c | 70 taskq_t *taskq; /* for internal processing */ member
170 mdeg.taskq = taskq_create("mdeg_taskq", 1, minclsyspri, 1, in mdeg_init()
190 taskq_destroy(mdeg.taskq); in mdeg_fini()
426 ASSERT(!taskq_member(mdeg.taskq, curthread)); in mdeg_register()
478 ASSERT(!taskq_member(mdeg.taskq, curthread)); in mdeg_unregister()
552 (void) taskq_dispatch(mdeg.taskq, mdeg_notify_client, in mdeg_notify_clients()
560 taskq_wait(mdeg.taskq); in mdeg_notify_clients()
|
| /onnv-gate/usr/src/uts/common/io/warlock/ |
| H A D | ib.wlcmd | 45 # ibnex reprobe function, called from taskq
52 # ibdm function called from taskq
|
| H A D | ibcm.wlcmd | 109 # CM internal taskq related callbacks
|
| /onnv-gate/usr/src/cmd/mdb/common/modules/genunix/ |
| H A D | taskq.h | 33 extern int taskq(uintptr_t, uint_t, int, const mdb_arg_t *);
|
| H A D | Makefile.files | 70 taskq.c \
|
| H A D | taskq.c | 137 taskq(uintptr_t addr, uint_t flags, int argc, const mdb_arg_t *argv) in taskq() function
183 int ret = taskq(tqi.tqi_array[idx].tq_addr, flags, in taskq()
|
| /onnv-gate/usr/src/uts/common/sys/ |
| H A D | taskq.h | 38 typedef struct taskq taskq_t;
|
| H A D | taskq_impl.h | 97 struct taskq { struct
|
| H A D | vnode.h | 810 struct taskq;
1253 void vn_rele_async(struct vnode *vp, struct taskq *taskq);
1338 #define VN_RELE_ASYNC(vp, taskq) { \ argument
1339 vn_rele_async(vp, taskq); \
|
| /onnv-gate/usr/src/uts/common/sys/fibre-channel/fca/emlxs/ |
| H A D | emlxs_thread.h | 59 struct emlxs_taskq *taskq; member
|
| H A D | emlxs_extern.h | 735 extern void emlxs_taskq_destroy(emlxs_taskq_t *taskq);
737 emlxs_taskq_t *taskq);
738 extern uint32_t emlxs_taskq_dispatch(emlxs_taskq_t *taskq,
|
| /onnv-gate/usr/src/lib/libzpool/ |
| H A D | Makefile.com | 30 KERNEL_OBJS = kernel.o taskq.o util.o
|
| /onnv-gate/usr/src/uts/common/fs/zfs/sys/ |
| H A D | dsl_pool.h | 78 struct taskq *dp_vnrele_taskq;
|
| /onnv-gate/usr/src/uts/common/io/hxge/ |
| H A D | hxge_txdma.c | 1898 tx_ring_p->taskq = ddi_taskq_create(hxgep->dip, qname, 1, in hxge_map_txdma_channel_buf_ring()
1900 if (tx_ring_p->taskq == NULL) { in hxge_map_txdma_channel_buf_ring()
1987 if (tx_ring_p->taskq) { in hxge_map_txdma_channel_buf_ring()
1988 ddi_taskq_destroy(tx_ring_p->taskq); in hxge_map_txdma_channel_buf_ring()
1989 tx_ring_p->taskq = NULL; in hxge_map_txdma_channel_buf_ring()
2064 if (tx_ring_p->taskq) { in hxge_unmap_txdma_channel_buf_ring()
2065 ddi_taskq_destroy(tx_ring_p->taskq); in hxge_unmap_txdma_channel_buf_ring()
2066 tx_ring_p->taskq = NULL; in hxge_unmap_txdma_channel_buf_ring()
|
| H A D | hxge_txdma.h | 128 ddi_taskq_t *taskq; member
|
| /onnv-gate/usr/src/uts/common/sys/nxge/ |
| H A D | nxge_txdma.h | 156 ddi_taskq_t *taskq; member
|
| /onnv-gate/usr/src/uts/common/io/nxge/ |
| H A D | nxge_txdma.c | 2580 tx_ring_p->taskq = ddi_taskq_create(nxgep->dip, qname, 1, in nxge_map_txdma_channel_buf_ring()
2582 if (tx_ring_p->taskq == NULL) { in nxge_map_txdma_channel_buf_ring()
2671 if (tx_ring_p->taskq) { in nxge_map_txdma_channel_buf_ring()
2672 ddi_taskq_destroy(tx_ring_p->taskq); in nxge_map_txdma_channel_buf_ring()
2673 tx_ring_p->taskq = NULL; in nxge_map_txdma_channel_buf_ring()
2747 if (tx_ring_p->taskq) { in nxge_unmap_txdma_channel_buf_ring()
2748 ddi_taskq_destroy(tx_ring_p->taskq); in nxge_unmap_txdma_channel_buf_ring()
2749 tx_ring_p->taskq = NULL; in nxge_unmap_txdma_channel_buf_ring()
|
| /onnv-gate/usr/src/uts/common/inet/ |
| H A D | sadb.h | 793 #define HANDLE_BUF_PKT(taskq, stack, dropper, buf_pkt) \ argument
796 if (taskq_dispatch(taskq, sadb_clear_buf_pkt, \
|
| /onnv-gate/usr/src/uts/common/io/usb/usba/ |
| H A D | usbai_util.c | 1730 taskq_t *taskq; in usba_async_ph_req() local
1744 taskq = ph_data->p_taskq; in usba_async_ph_req()
1746 taskq = system_taskq; in usba_async_ph_req()
1750 if (!taskq_dispatch(taskq, func, (void *)arg, tq_flag)) { in usba_async_ph_req()
|
| /onnv-gate/usr/src/lib/libzpool/common/ |
| H A D | taskq.c | 40 struct taskq { struct
|
| /onnv-gate/usr/src/uts/intel/io/scsi/adapters/arcmsr/ |
| H A D | arcmsr.h | 625 ddi_taskq_t *taskq; member
|