| /titanic_50/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 …]
|
| /titanic_50/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 …]
|
| /titanic_50/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
|
| /titanic_50/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()
|
| /titanic_50/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
|
| /titanic_50/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 | 77 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()
|
| /titanic_50/usr/src/uts/common/sys/ |
| H A D | taskq.h | 40 typedef struct taskq taskq_t;
|
| H A D | taskq_impl.h | 105 struct taskq { struct
|
| H A D | vnode.h | 812 struct taskq;
1255 void vn_rele_async(struct vnode *vp, struct taskq *taskq);
1341 #define VN_RELE_ASYNC(vp, taskq) { \ argument
1342 vn_rele_async(vp, taskq); \
|
| /titanic_50/usr/src/uts/common/sys/fibre-channel/fca/emlxs/ |
| H A D | emlxs_thread.h | 59 struct emlxs_taskq *taskq; member
|
| /titanic_50/usr/src/lib/libfakekernel/ |
| H A D | Makefile.com | 34 taskq.o \
|
| /titanic_50/usr/src/lib/libzpool/ |
| H A D | Makefile.com | 31 KERNEL_OBJS = kernel.o taskq.o util.o
|
| /titanic_50/usr/src/uts/common/fs/zfs/sys/ |
| H A D | dsl_pool.h | 90 struct taskq *dp_vnrele_taskq;
|
| /titanic_50/usr/src/lib/smbsrv/libfksmbsrv/common/sys/ |
| H A D | vnode.h | 807 struct taskq;
1252 void vn_rele_async(struct vnode *vp, struct taskq *taskq);
1340 #define VN_RELE_ASYNC(vp, taskq) { \ argument
1341 vn_rele_async(vp, taskq); \
|
| /titanic_50/usr/src/uts/common/io/hxge/ |
| H A D | hxge_txdma.c | 1899 tx_ring_p->taskq = ddi_taskq_create(hxgep->dip, qname, 1, in hxge_map_txdma_channel_buf_ring()
1901 if (tx_ring_p->taskq == NULL) { in hxge_map_txdma_channel_buf_ring()
1988 if (tx_ring_p->taskq) { in hxge_map_txdma_channel_buf_ring()
1989 ddi_taskq_destroy(tx_ring_p->taskq); in hxge_map_txdma_channel_buf_ring()
1990 tx_ring_p->taskq = NULL; in hxge_map_txdma_channel_buf_ring()
2065 if (tx_ring_p->taskq) { in hxge_unmap_txdma_channel_buf_ring()
2066 ddi_taskq_destroy(tx_ring_p->taskq); in hxge_unmap_txdma_channel_buf_ring()
2067 tx_ring_p->taskq = NULL; in hxge_unmap_txdma_channel_buf_ring()
|
| H A D | hxge_txdma.h | 128 ddi_taskq_t *taskq; member
|
| /titanic_50/usr/src/uts/common/sys/nxge/ |
| H A D | nxge_txdma.h | 156 ddi_taskq_t *taskq; member
|
| /titanic_50/usr/src/uts/common/io/nxge/ |
| H A D | nxge_txdma.c | 2581 tx_ring_p->taskq = ddi_taskq_create(nxgep->dip, qname, 1, in nxge_map_txdma_channel_buf_ring()
2583 if (tx_ring_p->taskq == NULL) { in nxge_map_txdma_channel_buf_ring()
2672 if (tx_ring_p->taskq) { in nxge_map_txdma_channel_buf_ring()
2673 ddi_taskq_destroy(tx_ring_p->taskq); in nxge_map_txdma_channel_buf_ring()
2674 tx_ring_p->taskq = NULL; in nxge_map_txdma_channel_buf_ring()
2748 if (tx_ring_p->taskq) { in nxge_unmap_txdma_channel_buf_ring()
2749 ddi_taskq_destroy(tx_ring_p->taskq); in nxge_unmap_txdma_channel_buf_ring()
2750 tx_ring_p->taskq = NULL; in nxge_unmap_txdma_channel_buf_ring()
|
| /titanic_50/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, \
|
| /titanic_50/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()
|
| /titanic_50/usr/src/man/man9f/ |
| H A D | Makefile | 470 taskq.9f \
1974 ddi_taskq_create.9f := LINKSRC = taskq.9f
1975 ddi_taskq_destroy.9f := LINKSRC = taskq.9f
1976 ddi_taskq_dispatch.9f := LINKSRC = taskq.9f
1977 ddi_taskq_resume.9f := LINKSRC = taskq.9f
1978 ddi_taskq_suspend.9f := LINKSRC = taskq.9f
1979 ddi_taskq_wait.9f := LINKSRC = taskq.9f
1980 taskq_suspended.9f := LINKSRC = taskq.9f
|