/illumos-gate/usr/src/uts/common/os/ |
H A D | waitq.c | 44 waitq_init(waitq_t *wq) argument 46 DISP_LOCK_INIT(&wq->wq_lock); 47 wq->wq_first = NULL; 48 wq->wq_count = 0; 49 wq->wq_blocked = B_TRUE; 53 waitq_fini(waitq_t *wq) argument 55 ASSERT(wq->wq_count == 0); 56 ASSERT(wq->wq_first == NULL); 57 ASSERT(wq->wq_blocked == B_TRUE); 58 ASSERT(!DISP_LOCK_HELD(&wq 119 waitq_link(waitq_t *wq, kthread_t *t) argument 154 waitq_unlink(waitq_t *wq, kthread_t *t) argument 203 waitq_enqueue(waitq_t *wq, kthread_t *t) argument 245 waitq_t *wq = t->t_waitq; local 257 waitq_dequeue(waitq_t *wq, kthread_t *t) argument 279 waitq_isempty(waitq_t *wq) argument 291 waitq_t *wq = t->t_waitq; local 306 waitq_takeone(waitq_t *wq) argument 326 waitq_runfirst(waitq_t *wq) argument 348 waitq_runone(waitq_t *wq) argument 357 waitq_runall(waitq_t *wq) argument 369 waitq_block(waitq_t *wq) argument 383 waitq_unblock(waitq_t *wq) argument [all...] |
/illumos-gate/usr/src/tools/ctf/cvt/ |
H A D | ctfmerge.c | 276 finalize_phase_one(workqueue_t *wq) argument 292 for (startslot = -1, i = 0; i < wq->wq_nwipslots; i++) { 293 if (wq->wq_wip[i].wip_batchid == wq->wq_lastdonebatch + 1) { 301 for (i = startslot; i < startslot + wq->wq_nwipslots; i++) { 302 int slotnum = i % wq->wq_nwipslots; 303 wip_t *wipslot = &wq->wq_wip[slotnum]; 312 fifo_add(wq->wq_donequeue, wipslot->wip_td); 313 wq->wq_wip[slotnum].wip_td = NULL; 317 wq 324 init_phase_two(workqueue_t *wq) argument 352 wip_save_work(workqueue_t *wq, wip_t *slot, int slotnum) argument 390 worker_runphase1(workqueue_t *wq) argument 437 worker_runphase2(workqueue_t *wq) argument 508 worker_thread(workqueue_t *wq) argument 542 workqueue_t *wq = arg; local 621 wq_init(workqueue_t *wq, int nfiles) argument 682 start_threads(workqueue_t *wq) argument 705 join_threads(workqueue_t *wq) argument 730 static workqueue_t wq; variable [all...] |
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/oce/ |
H A D | oce_tx.c | 31 static void oce_free_wqed(struct oce_wq *wq, oce_wqe_desc_t *wqed); 32 static int oce_map_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, 34 static int oce_bcopy_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, mblk_t *mp, 36 static void oce_wqb_dtor(struct oce_wq *wq, oce_wq_bdesc_t *wqbd); 37 static int oce_wqb_ctor(oce_wq_bdesc_t *wqbd, struct oce_wq *wq, 39 static inline oce_wq_bdesc_t *oce_wqb_alloc(struct oce_wq *wq); 40 static void oce_wqb_free(struct oce_wq *wq, oce_wq_bdesc_t *wqbd); 42 static void oce_wqmd_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd); 43 static void oce_wqm_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd); 44 static oce_wq_mdesc_t *oce_wqm_alloc(struct oce_wq *wq); 94 oce_wqm_dtor(struct oce_wq *wq, oce_wq_mdesc_t *wqmd) argument 112 oce_wqm_ctor(oce_wq_mdesc_t *wqmd, struct oce_wq *wq) argument 133 oce_wqm_cache_create(struct oce_wq *wq) argument 172 oce_wqm_cache_destroy(struct oce_wq *wq) argument 195 oce_wqb_cache_create(struct oce_wq *wq, size_t buf_size) argument 235 oce_wqb_cache_destroy(struct oce_wq *wq) argument 257 oce_wqb_ctor(oce_wq_bdesc_t *wqbd, struct oce_wq *wq, size_t size, int flags) argument 281 oce_wqb_dtor(struct oce_wq *wq, oce_wq_bdesc_t *wqbd) argument 294 oce_wqb_alloc(struct oce_wq *wq) argument 308 oce_wqb_free(struct oce_wq *wq, oce_wq_bdesc_t *wqbd) argument 321 oce_wqm_alloc(struct oce_wq *wq) argument 335 oce_wqm_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd) argument 349 oce_wqmd_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd) argument 401 struct oce_wq *wq; local 425 oce_fill_ring_descs(struct oce_wq *wq, oce_wqe_desc_t *wqed) argument 451 oce_bcopy_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, mblk_t *mp, uint32_t pkt_len) argument 507 oce_map_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, mblk_t *mp, uint32_t pkt_len) argument 556 oce_process_tx_compl(struct oce_wq *wq, boolean_t rearm) argument 614 struct oce_wq *wq; local 676 oce_send_packet(struct oce_wq *wq, mblk_t *mp) argument 901 oce_free_wqed(struct oce_wq *wq, oce_wqe_desc_t *wqed) argument 929 oce_start_wq(struct oce_wq *wq) argument 943 oce_clean_wq(struct oce_wq *wq) argument [all...] |
H A D | oce_queue.c | 53 static void oce_wq_fini(struct oce_dev *dev, struct oce_wq *wq); 54 static int oce_wq_create(struct oce_wq *wq, struct oce_eq *eq); 55 static void oce_wq_del(struct oce_dev *dev, struct oce_wq *wq); 458 struct oce_wq *wq; local 472 /* allocate wq */ 473 wq = kmem_zalloc(sizeof (struct oce_wq), KM_NOSLEEP); 474 if (wq == NULL) { 480 /* Set the wq config */ 481 wq->cfg.q_len = q_len; 482 wq 559 oce_wq_fini(struct oce_dev *dev, struct oce_wq *wq) argument 579 oce_wq_create(struct oce_wq *wq, struct oce_eq *eq) argument 663 oce_wq_del(struct oce_dev *dev, struct oce_wq *wq) argument [all...] |
H A D | oce_gld.c | 99 (void) oce_start_wq(dev->wq[qidx]); 141 mutex_enter(&dev->wq[qidx]->tx_lock); 146 oce_clean_wq(dev->wq[qidx]); 150 mutex_exit(&dev->wq[qidx]->tx_lock); 283 struct oce_wq *wq; local 293 * Hash to pick a wq 295 wq = oce_get_wq(dev, mp); 301 /* Hardcode wq since we have only one */ 302 rmp = oce_send_packet(wq, mp); 305 wq 569 oce_m_ioctl(void *arg, queue_t *wq, mblk_t *mp) argument [all...] |
/illumos-gate/usr/src/uts/common/io/ib/clients/rdsv3/ |
H A D | rdsv3_impl.c | 522 rdsv3_workqueue_struct_t *wq = arg; local 525 RDSV3_DPRINTF4("rdsv3_worker_thread", "Enter(wq: 0x%p)", wq); 527 mutex_enter(&wq->wq_lock); 528 work = list_remove_head(&wq->wq_queue); 530 mutex_exit(&wq->wq_lock); 535 mutex_enter(&wq->wq_lock); 536 work = list_remove_head(&wq->wq_queue); 540 if (wq->wq_state != RDSV3_WQ_THREAD_EXITING) { 541 wq 550 rdsv3_flush_workqueue(rdsv3_workqueue_struct_t *wq) argument 583 rdsv3_queue_work(rdsv3_workqueue_struct_t *wq, rdsv3_work_t *wp) argument 661 rdsv3_queue_delayed_work(rdsv3_workqueue_struct_t *wq, rdsv3_delayed_work_t *dwp, uint_t delay) argument 728 rdsv3_destroy_task_workqueue(rdsv3_workqueue_struct_t *wq) argument 770 rdsv3_workqueue_struct_t *wq; local [all...] |
/illumos-gate/usr/src/uts/common/io/ |
H A D | bufmod.c | 281 sbioc(queue_t *wq, mblk_t *mp) argument 284 struct sb *sbp = (struct sb *)wq->q_ptr; 295 miocack(wq, mp, 0, 0); 305 miocnak(wq, mp, 0, EINVAL); 317 miocnak(wq, mp, 0, EINVAL); 325 miocack(wq, mp, 0, 0); 346 qreply(wq, mop); 350 miocack(wq, mp, 0, 0); 356 miocack(wq, mp, 0, 0); 387 qreply(wq, mo 407 sbwput(queue_t *wq, mblk_t *mp) argument 568 sbioctl(queue_t *wq, mblk_t *mp) argument [all...] |
H A D | sundlpi.c | 43 queue_t *wq, 55 if ((mp = mexchange(wq, mp, size, M_PCPROTO, DL_BIND_ACK)) == NULL) 66 qreply(wq, mp); 71 queue_t *wq, 77 if ((mp = mexchange(wq, mp, sizeof (dl_ok_ack_t), M_PCPROTO, 82 qreply(wq, mp); 87 queue_t *wq, 95 if ((mp = mexchange(wq, mp, sizeof (dl_error_ack_t), M_PCPROTO, 102 qreply(wq, mp); 107 queue_t *wq, 42 dlbindack( queue_t *wq, mblk_t *mp, t_scalar_t sap, const void *addrp, t_uscalar_t addrlen, t_uscalar_t maxconind, t_uscalar_t xidtest) argument 70 dlokack( queue_t *wq, mblk_t *mp, t_uscalar_t correct_primitive) argument 86 dlerrorack( queue_t *wq, mblk_t *mp, t_uscalar_t error_primitive, t_uscalar_t error, t_uscalar_t unix_errno) argument 106 dluderrorind( queue_t *wq, mblk_t *mp, const void *addrp, t_uscalar_t addrlen, t_uscalar_t error, t_uscalar_t unix_errno) argument 132 dlphysaddrack( queue_t *wq, mblk_t *mp, const void *addrp, t_uscalar_t len) argument 175 dlnotifyack( queue_t *wq, mblk_t *mp, uint32_t notifications) argument [all...] |
H A D | tl.c | 1532 queue_t *wq = tep->te_wq; local 1535 ASSERT(wq == WR(rq)); 1628 rq->q_ptr = wq->q_ptr = NULL; 1723 tl_wput(queue_t *wq, mblk_t *mp) argument 1725 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; 1737 tl_merror(wq, mp, EPROTO); 1755 miocnak(wq, mp, 0, EINVAL); 1765 flushq(wq, FLUSHALL); 1769 flushq(RD(wq), FLUSHALL); 1770 qreply(wq, m 1993 tl_wsrv(queue_t *wq) argument 2026 queue_t *wq = tep->te_wq; local 2218 queue_t *wq = tep->te_wq; local 2281 tl_error_ack(queue_t *wq, mblk_t *mp, t_scalar_t tli_err, t_scalar_t unix_err, t_scalar_t type) argument 2313 tl_ok_ack(queue_t *wq, mblk_t *mp, t_scalar_t type) argument 2353 queue_t *wq = tep->te_wq; local 2660 queue_t *wq; local 2735 tl_optmgmt(queue_t *wq, mblk_t *mp) argument 2804 tl_conn_req(queue_t *wq, mblk_t *mp) argument 3047 queue_t *wq; local 3327 queue_t *wq; local 3859 queue_t *wq; local 4187 queue_t *wq; local 4414 queue_t *wq = tep->te_wq; local 4615 queue_t *wq = tep->te_wq; local 4779 queue_t *wq = tep->te_wq; local 4903 tl_uderr(queue_t *wq, mblk_t *mp, t_scalar_t err) argument 4976 queue_t *wq = tep->te_wq; local 4997 queue_t *wq = tep->te_wq; local 5980 tl_merror(queue_t *wq, mblk_t *mp, int error) argument 6071 tl_default_opt(queue_t *wq, int level, int name, uchar_t *ptr) argument 6079 tl_get_opt(queue_t *wq, int level, int name, uchar_t *ptr) argument 6126 tl_set_opt( queue_t *wq, uint_t mgmt_flags, int level, int name, uint_t inlen, uchar_t *invalp, uint_t *outlenp, uchar_t *outvalp, void *thisdg_attrs, cred_t *cr) argument 6205 queue_t *wq = arg; local 6223 queue_t *wq = arg; local 6240 tl_memrecover(queue_t *wq, mblk_t *mp, size_t size) argument [all...] |
H A D | strsun.c | 43 merror(queue_t *wq, mblk_t *mp, int error) argument 45 if ((mp = mexchange(wq, mp, 1, M_ERROR, -1)) == NULL) 49 qreply(wq, mp); 70 miocack(queue_t *wq, mblk_t *mp, int count, int rval) argument 78 qreply(wq, mp); 82 miocnak(queue_t *wq, mblk_t *mp, int count, int error) argument 89 qreply(wq, mp); 93 mexchange(queue_t *wq, mblk_t *mp, size_t size, uchar_t type, int32_t primtype) argument 98 if (wq != NULL) { 100 merror(wq, m [all...] |
H A D | pfmod.c | 90 static void pfioctl(queue_t *wq, mblk_t *mp); 212 pfwput(queue_t *wq, mblk_t *mp) argument 216 pfioctl(wq, mp); 220 putnext(wq, mp); 339 pfioctl(queue_t *wq, mblk_t *mp) argument 341 struct epacketfilt *pfp = (struct epacketfilt *)wq->q_ptr; 364 miocnak(wq, mp, 0, error); 369 miocnak(wq, mp, 0, EINVAL); 380 miocnak(wq, mp, 0, error); 386 miocnak(wq, m [all...] |
/illumos-gate/usr/src/uts/common/rpc/ |
H A D | svc_gen.c | 110 queue_t *wq; local 130 wq = fp->f_vnode->v_stream->sd_wrq; 131 while ((wq = wq->q_next) != NULL) { 132 if (strcmp(wq->q_qinfo->qi_minfo->mi_idname, "rpcmod") == 0) 135 if (!wq) { 191 xprt->xp_wq = wq; 225 vp = (void **)wq->q_ptr; 235 create_putlocks(wq, 1);
|
H A D | rpcmod.c | 1008 static void mir_svc_release(queue_t *wq, mblk_t *mp, bool_t); 1009 static void mir_svc_start(queue_t *wq); 1995 mir_svc_start_close(queue_t *wq, mir_t *mir) argument 1998 ASSERT((wq->q_flag & QREADR) == 0); 2013 qenable(RD(wq)); 2019 qenable(wq); 2027 mir_svc_release(queue_t *wq, mblk_t *mp, bool_t enable) argument 2029 mir_t *mir = (mir_t *)wq->q_ptr; 2032 ASSERT((wq->q_flag & QREADR) == 0); 2037 qenable(RD(wq)); 2090 mir_svc_start(queue_t *wq) argument 2108 mir_clnt_idle_stop(queue_t *wq, mir_t *mir) argument 2121 mir_clnt_idle_start(queue_t *wq, mir_t *mir) argument 2135 mir_clnt_idle_do_stop(queue_t *wq) argument 2152 queue_t *wq = (queue_t *)arg; local [all...] |
/illumos-gate/usr/src/uts/sun4u/starfire/io/ |
H A D | idn_dlpi.c | 709 idndl_proto(queue_t *wq, mblk_t *mp) argument 716 stp = (struct idnstr *)wq->q_ptr; 722 DLERRORACK(wq, mp, -1, DL_BADPRIM, 0); 729 "idndl_proto start: wq %p dlprim %X", wq, prim); 732 PR_DLPI("%s: stp = 0x%p, wq = 0x%p, dlprim = 0x%x(%s)\n", 733 proc, (void *)stp, (void *)wq, prim, dlprim2str(prim)); 740 idndl_udreq(wq, mp); 744 idndl_areq(wq, mp); 748 idndl_dreq(wq, m 815 idnioc_dlpi(queue_t *wq, mblk_t *mp, int *argsizep) argument 855 idndl_ioc_hdr_info(queue_t *wq, mblk_t *mp, int *argsizep) argument 934 idndl_areq(queue_t *wq, mblk_t *mp) argument 995 idndl_dreq(queue_t *wq, mblk_t *mp) argument 1078 idndl_breq(queue_t *wq, mblk_t *mp) argument 1151 idndl_ubreq(queue_t *wq, mblk_t *mp) argument 1195 idndl_ireq(queue_t *wq, mblk_t *mp) argument 1238 idndl_ponreq(queue_t *wq, mblk_t *mp) argument 1277 idndl_poffreq(queue_t *wq, mblk_t *mp) argument 1324 idndl_emreq(queue_t *wq, mblk_t *mp) argument 1390 idndl_dmreq(queue_t *wq, mblk_t *mp) argument 1441 idndl_pareq(queue_t *wq, mblk_t *mp) argument 1484 idndl_spareq(queue_t *wq, mblk_t *mp) argument 1543 idndl_udreq(queue_t *wq, mblk_t *mp) argument 1632 idndl_start(queue_t *wq, register mblk_t *mp, register struct idn *sip) argument 2250 queue_t *wq; local [all...] |
/illumos-gate/usr/src/uts/sun4u/starcat/io/ |
H A D | dman.c | 1561 * wq - upper write queue of mxx 1565 man_uwput(register queue_t *wq, register mblk_t *mp) argument 1570 msp = (manstr_t *)wq->q_ptr; 1572 MAN_DBG(MAN_UWPUT, ("man_uwput: wq(0x%p) mp(0x%p) db_type(0x%x)" 1574 (void *)wq, (void *)mp, DB_TYPE(mp), (void *)msp)); 1600 merror(wq, mp, EPROTO); 1604 if (wq->q_first) { 1605 (void) putq(wq, mp); 1606 qenable(wq); 1610 (void) man_start(wq, m 1689 man_start(register queue_t *wq, register mblk_t *mp, eaddr_t *eap) argument 1790 queue_t *wq = mdp->md_wq; local 1951 man_ioctl(register queue_t *wq, register mblk_t *mp) argument 2043 man_plink(queue_t *wq, mblk_t *mp) argument 2079 man_unplink(queue_t *wq, mblk_t *mp) argument 2106 queue_t *wq = NULL; local 2143 man_set_linkcheck_time(queue_t *wq, mblk_t *mp) argument 2179 man_setpath(queue_t *wq, mblk_t *mp) argument 2204 man_geteaddr(queue_t *wq, mblk_t *mp) argument 2224 man_set_sc_ipaddrs(queue_t *wq, mblk_t *mp) argument 2259 man_set_sc_ip6addrs(queue_t *wq, mblk_t *mp) argument 2294 man_dl_ioc_hdr_info(queue_t *wq, mblk_t *mp) argument 2389 man_uwsrv(queue_t *wq) argument 2481 man_proto(queue_t *wq, mblk_t *mp) argument 2555 man_udreq(queue_t *wq, mblk_t *mp) argument 2602 man_areq(queue_t *wq, mblk_t *mp) argument 3010 man_dreq(queue_t *wq, mblk_t *mp) argument 3195 man_breq(queue_t *wq, mblk_t *mp) argument 3250 man_ubreq(queue_t *wq, mblk_t *mp) argument 3280 man_ireq(queue_t *wq, mblk_t *mp) argument 3328 man_ponreq(queue_t *wq, mblk_t *mp) argument 3374 man_poffreq(queue_t *wq, mblk_t *mp) argument 3427 man_emreq(queue_t *wq, mblk_t *mp) argument 3473 man_dmreq(queue_t *wq, mblk_t *mp) argument 3517 man_pareq(queue_t *wq, mblk_t *mp) argument 3560 man_spareq(queue_t *wq, mblk_t *mp) argument 3633 man_lwsrv(queue_t *wq) argument 7145 man_nd_getset(queue_t *wq, mblk_t *mp) argument 7156 man_pathgroups_report(queue_t *wq, mblk_t *mp, caddr_t cp, cred_t *cr) argument 7265 man_set_active_path(queue_t *wq, mblk_t *mp, char *value, caddr_t cp, cred_t *cr) argument 7347 man_get_hostinfo(queue_t *wq, mblk_t *mp, caddr_t cp, cred_t *cr) argument [all...] |
/illumos-gate/usr/src/uts/common/io/hxge/ |
H A D | hxge_hw.c | 471 hxge_hw_ioctl(p_hxge_t hxgep, queue_t *wq, mblk_t *mp, struct iocblk *iocp) argument 478 miocnak(wq, mp, 0, EINVAL); 487 miocnak(wq, mp, 0, EINVAL); 492 miocack(wq, mp, 0, 0); 497 miocack(wq, mp, 0, 0); 501 hxge_rtrace_ioctl(hxgep, wq, mp, iocp); 510 hxge_loopback_ioctl(p_hxge_t hxgep, queue_t *wq, mblk_t *mp, argument 518 miocnak(wq, mp, 0, EINVAL); 527 miocack(wq, mp, sizeof (hxge_lb_t), 0); 529 miocnak(wq, m 586 hxge_set_lb(p_hxge_t hxgep, queue_t *wq, p_mblk_t mp) argument 710 hxge_rtrace_ioctl(p_hxge_t hxgep, queue_t *wq, mblk_t *mp, struct iocblk *iocp) argument [all...] |
/illumos-gate/usr/src/uts/common/sys/fibre-channel/fca/oce/ |
H A D | oce_buf.h | 126 struct oce_wq *wq; member in struct:_oce_wqe_desc_s 181 int oce_wqb_cache_create(struct oce_wq *wq, size_t buf_size); 182 void oce_wqb_cache_destroy(struct oce_wq *wq); 184 void oce_wqm_cache_destroy(struct oce_wq *wq); 185 int oce_wqm_cache_create(struct oce_wq *wq);
|
/illumos-gate/usr/src/uts/common/io/ib/adapters/hermon/ |
H A D | hermon_wr.c | 77 hermon_workq_hdr_t *wq; local 108 wq = qp->qp_sq_wqhdr; 109 qsize_msk = wq->wq_mask; 113 tail = wq->wq_tail; 114 head = wq->wq_head; 124 if (wq->wq_full != 0) { 131 wq->wq_full = 1; 363 wq->wq_wrid[tail] = wr->wr_id; 368 wq->wq_tail = tail; 430 hermon_workq_hdr_t *wq; local 783 hermon_workq_hdr_t *wq; local 1116 hermon_workq_hdr_t *wq; local 1226 hermon_workq_hdr_t *wq; local 2362 hermon_workq_hdr_t *wq; local [all...] |
/illumos-gate/usr/src/lib/udapl/udapl_tavor/tavor/ |
H A D | dapl_tavor_wr.c | 62 dapls_tavor_workq_hdr_t *wq; local 72 wq = dapli_tavor_wrid_wqhdr_find(cq, qpnum, send_or_recv); 74 dapl_os_assert(wq != NULL); 86 dapl_os_lock(&wq->wq_wrid_lock->wrl_lock); 87 wre_tmp = dapli_tavor_wrid_find_match(wq, cqe); 107 wre->wr_wqeaddrsz = dapli_tavor_wrid_get_wqeaddrsz(wq); 113 dapl_os_unlock(&wq->wq_wrid_lock->wrl_lock); 124 dapli_tavor_wrid_find_match(dapls_tavor_workq_hdr_t *wq, tavor_hw_cqe_t *cqe) argument 132 /* dapl_os_assert(MUTEX_HELD(&wq->wq_wrid_lock)); */ 148 container = wq 509 dapli_tavor_wrid_reaplist_add(ib_cq_handle_t cq, dapls_tavor_workq_hdr_t *wq) argument 567 dapli_tavor_wrid_get_wqeaddrsz(dapls_tavor_workq_hdr_t *wq) argument [all...] |
/illumos-gate/usr/src/uts/common/io/audio/impl/ |
H A D | audio_sun.c | 626 devaudio_ioc_getinfo(queue_t *wq, audio_client_t *c, mblk_t *mp) argument 633 miocnak(wq, mp, 0, ENOMEM); 645 qreply(wq, mp); 654 devaudio_ioc_setinfo(queue_t *wq, audio_client_t *c, mblk_t *mp) argument 681 qreply(wq, mp); 688 miocnak(wq, mp, 0, EINVAL); 934 qreply(wq, mp); 939 miocnak(wq, mp, 0, rv); 943 devaudio_ioc_getdev(queue_t *wq, audio_client_t *c, mblk_t *mp) argument 950 miocnak(wq, m 1130 queue_t *wq; local 1169 queue_t *wq = auclnt_get_wq(c); local 1216 queue_t *wq = auclnt_get_wq(c); local 1264 queue_t *wq = auclnt_get_wq(c); local 1360 queue_t *wq = auclnt_get_wq(c); local [all...] |
/illumos-gate/usr/src/uts/common/io/softmac/ |
H A D | softmac_dev.c | 391 softmac_mod_wput(queue_t *wq, mblk_t *mp) argument 396 ASSERT(wq->q_next != NULL); 404 softmac_lower_t *slp = wq->q_ptr; 408 miocnak(wq, mp, 0, EINVAL); 419 miocack(wq, mp, sizeof (*arg), 0); 423 miocnak(wq, mp, 0, EINVAL); 435 softmac_mod_wsrv(queue_t *wq) argument 437 softmac_lower_t *slp = wq->q_ptr; 442 ASSERT(wq->q_next != NULL); 611 softmac_drv_wput(queue_t *wq, mblk_ argument 646 softmac_drv_wsrv(queue_t *wq) argument [all...] |
H A D | softmac_pkt.c | 33 queue_t *wq = ((softmac_t *)arg)->smac_lower->sl_wq; local 39 if (!SOFTMAC_CANPUTNEXT(wq)) 43 putnext(wq, mp); 50 if (!SOFTMAC_CANPUTNEXT(wq)) 54 putnext(wq, mp);
|
/illumos-gate/usr/src/uts/sun4u/opl/io/ |
H A D | dm2s.c | 114 int dm2s_wput(queue_t *wq, mblk_t *mp); 116 int dm2s_wsrv(queue_t *wq); 121 void dm2s_start(queue_t *wq, dm2s_t *dm2sp); 123 int dm2s_transmit(queue_t *wq, mblk_t *mp, target_id_t target, mkey_t key); 533 dm2s_wsrv(queue_t *wq) argument 535 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr; 546 dm2s_start(wq, dm2sp); 560 dm2s_wput(queue_t *wq, mblk_t *mp) argument 562 dm2s_t *dm2sp = (dm2s_t *)wq->q_ptr; 587 (void) putq(wq, m 901 dm2s_start(queue_t *wq, dm2s_t *dm2sp) argument 1053 dm2s_transmit(queue_t *wq, mblk_t *mp, target_id_t target, mkey_t key) argument [all...] |
/illumos-gate/usr/src/uts/common/io/fibre-channel/ulp/ |
H A D | fcip.c | 145 static int fcip_open(queue_t *wq, dev_t *devp, int flag, 148 static int fcip_start(queue_t *wq, mblk_t *mp, struct fcip *fptr, 162 static void fcip_spareq(queue_t *wq, mblk_t *mp); 163 static void fcip_pareq(queue_t *wq, mblk_t *mp); 164 static void fcip_ubreq(queue_t *wq, mblk_t *mp); 165 static void fcip_breq(queue_t *wq, mblk_t *mp); 166 static void fcip_dreq(queue_t *wq, mblk_t *mp); 167 static void fcip_areq(queue_t *wq, mblk_t *mp); 168 static void fcip_udreq(queue_t *wq, mblk_t *mp); 169 static void fcip_ireq(queue_t *wq, mblk_ 3736 fcip_ioctl(queue_t *wq, mblk_t *mp) argument 3767 fcip_wput(queue_t *wq, mblk_t *mp) argument 3879 fcip_proto(queue_t *wq, mblk_t *mp) argument 4013 fcip_wsrv(queue_t *wq) argument 4072 fcip_start(queue_t *wq, mblk_t *mp, struct fcip *fptr, struct fcip_dest *fdestp, int flags) argument 5119 fcip_ireq(queue_t *wq, mblk_t *mp) argument 5184 fcip_udreq(queue_t *wq, mblk_t *mp) argument 5347 fcip_areq(queue_t *wq, mblk_t *mp) argument 5443 fcip_dreq(queue_t *wq, mblk_t *mp) argument 5469 fcip_breq(queue_t *wq, mblk_t *mp) argument 5530 fcip_ubreq(queue_t *wq, mblk_t *mp) argument 5559 fcip_pareq(queue_t *wq, mblk_t *mp) argument 5612 fcip_spareq(queue_t *wq, mblk_t *mp) argument 5725 fcip_dl_ioc_hdr_info(queue_t *wq, mblk_t *mp) argument [all...] |
/illumos-gate/usr/src/uts/common/io/nxge/ |
H A D | nxge_hw.c | 584 nxge_hw_ioctl(p_nxge_t nxgep, queue_t *wq, mblk_t *mp, struct iocblk *iocp) argument 591 miocnak(wq, mp, 0, EINVAL); 599 miocnak(wq, mp, 0, EINVAL); 604 miocack(wq, mp, sizeof (uint16_t), 0); 609 miocack(wq, mp, 0, 0); 614 miocack(wq, mp, sizeof (uint32_t), 0); 619 miocack(wq, mp, 0, 0); 624 miocack(wq, mp, 0, 0); 629 miocack(wq, mp, 0, 0); 634 miocack(wq, m 653 nxge_loopback_ioctl(p_nxge_t nxgep, queue_t *wq, mblk_t *mp, struct iocblk *iocp) argument 956 nxge_set_lb(p_nxge_t nxgep, queue_t *wq, p_mblk_t mp) argument 1244 nxge_rtrace_ioctl(p_nxge_t nxgep, queue_t *wq, mblk_t *mp, struct iocblk *iocp) argument [all...] |