| /illumos-gate/usr/src/uts/common/io/fibre-channel/fca/emlxs/ |
| H A D | emlxs_thread.c | 40 emlxs_taskq_t *taskq; in emlxs_taskq_thread() local
44 taskq = tthread->taskq; in emlxs_taskq_thread()
50 mutex_enter(&taskq->put_lock); in emlxs_taskq_thread()
51 tthread->next = taskq->put_head; in emlxs_taskq_thread()
52 taskq->put_head = tthread; in emlxs_taskq_thread()
53 taskq->put_count++; in emlxs_taskq_thread()
54 mutex_exit(&taskq->put_lock); in emlxs_taskq_thread()
67 func(taskq->hba, arg); in emlxs_taskq_thread()
84 emlxs_taskq_dispatch(emlxs_taskq_t *taskq, void (*func) (), void *arg) in emlxs_taskq_dispatch() argument
88 mutex_enter(&taskq->get_lock); in emlxs_taskq_dispatch()
[all …]
|
| /illumos-gate/usr/src/uts/common/crypto/core/ |
| H A D | kcf_sched.c | 563 taskq_t *taskq = new_pd->pd_taskq; in kcf_resubmit_request() local
565 if (taskq_dispatch(taskq, process_req_hwp, areq, TQ_NOSLEEP) == in kcf_resubmit_request()
603 taskq_t *taskq; in kcf_submit_request() local
617 taskq = pd->pd_taskq; in kcf_submit_request()
625 EMPTY_TASKQ(taskq)) { in kcf_submit_request()
654 ASSERT(taskq != NULL); in kcf_submit_request()
662 if (EMPTY_TASKQ(taskq) && in kcf_submit_request()
673 if (taskq->tq_nalloc >= crypto_taskq_maxalloc) { in kcf_submit_request()
674 taskq_wait(taskq); in kcf_submit_request()
677 (void) taskq_dispatch(taskq, process_req_hwp, in kcf_submit_request()
[all …]
|
| /illumos-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 | 43 ddi_taskq_t *taskq; member
|
| /illumos-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()
|
| /illumos-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 | 79 taskq.c \
|
| H A D | taskq.c | 145 taskq(uintptr_t addr, uint_t flags, int argc, const mdb_arg_t *argv) in taskq() function
191 int ret = taskq(tqi.tqi_array[idx].tq_addr, flags, in taskq()
|
| /illumos-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 | 811 extern void emlxs_taskq_destroy(emlxs_taskq_t *taskq);
813 emlxs_taskq_t *taskq);
814 extern uint32_t emlxs_taskq_dispatch(emlxs_taskq_t *taskq,
|
| /illumos-gate/usr/src/uts/common/sys/ |
| H A D | taskq.h | 42 typedef struct taskq taskq_t;
|
| H A D | taskq_impl.h | 111 struct taskq { struct
|
| H A D | vnode.h | 894 struct taskq;
1339 void vn_rele_async(struct vnode *vp, struct taskq *taskq);
1465 #define VN_RELE_ASYNC(vp, taskq) { \ argument
1466 vn_rele_async(vp, taskq); \
|
| /illumos-gate/usr/src/uts/common/fs/smbclnt/smbfs/ |
| H A D | smbfs.h | 118 struct taskq *smi_taskq; /* for async work */
|
| /illumos-gate/usr/src/lib/libfakekernel/ |
| H A D | Makefile.com | 39 taskq.o \
|
| /illumos-gate/usr/src/uts/common/io/hxge/ |
| H A D | hxge_txdma.c | 1889 tx_ring_p->taskq = ddi_taskq_create(hxgep->dip, qname, 1, in hxge_map_txdma_channel_buf_ring()
1891 if (tx_ring_p->taskq == NULL) { in hxge_map_txdma_channel_buf_ring()
1978 if (tx_ring_p->taskq) { in hxge_map_txdma_channel_buf_ring()
1979 ddi_taskq_destroy(tx_ring_p->taskq); in hxge_map_txdma_channel_buf_ring()
1980 tx_ring_p->taskq = NULL; in hxge_map_txdma_channel_buf_ring()
2055 if (tx_ring_p->taskq) { in hxge_unmap_txdma_channel_buf_ring()
2056 ddi_taskq_destroy(tx_ring_p->taskq); in hxge_unmap_txdma_channel_buf_ring()
2057 tx_ring_p->taskq = NULL; in hxge_unmap_txdma_channel_buf_ring()
|
| H A D | hxge_txdma.h | 128 ddi_taskq_t *taskq; member
|
| /illumos-gate/usr/src/uts/common/fs/zfs/sys/ |
| H A D | dsl_pool.h | 96 struct taskq *dp_unlinked_drain_taskq;
|
| /illumos-gate/usr/src/uts/common/io/nxge/ |
| H A D | nxge_txdma.c | 2569 tx_ring_p->taskq = ddi_taskq_create(nxgep->dip, qname, 1, in nxge_map_txdma_channel_buf_ring()
2571 if (tx_ring_p->taskq == NULL) { in nxge_map_txdma_channel_buf_ring()
2660 if (tx_ring_p->taskq) { in nxge_map_txdma_channel_buf_ring()
2661 ddi_taskq_destroy(tx_ring_p->taskq); in nxge_map_txdma_channel_buf_ring()
2662 tx_ring_p->taskq = NULL; in nxge_map_txdma_channel_buf_ring()
2736 if (tx_ring_p->taskq) { in nxge_unmap_txdma_channel_buf_ring()
2737 ddi_taskq_destroy(tx_ring_p->taskq); in nxge_unmap_txdma_channel_buf_ring()
2738 tx_ring_p->taskq = NULL; in nxge_unmap_txdma_channel_buf_ring()
|
| /illumos-gate/usr/src/uts/common/sys/nxge/ |
| H A D | nxge_txdma.h | 156 ddi_taskq_t *taskq; member
|
| /illumos-gate/usr/src/uts/common/io/usb/usba/ |
| H A D | usbai_util.c | 1731 taskq_t *taskq; in usba_async_ph_req() local
1745 taskq = ph_data->p_taskq; in usba_async_ph_req()
1747 taskq = system_taskq; in usba_async_ph_req()
1751 if (taskq_dispatch(taskq, func, arg, tq_flag) == TASKQID_INVALID) { in usba_async_ph_req()
|
| /illumos-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, \
|
| /illumos-gate/usr/src/lib/libfakekernel/common/ |
| H A D | taskq.c | 75 struct taskq { struct
|
| /illumos-gate/usr/src/uts/common/sys/sata/impl/ |
| H A D | sata.h | 88 struct taskq *satahba_taskq; /* cmd completion task queue */
|
| /illumos-gate/usr/src/uts/intel/io/scsi/adapters/arcmsr/ |
| H A D | arcmsr.h | 762 ddi_taskq_t *taskq; member
|