/opensolaris-onvv-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...] |
/opensolaris-onvv-gate/usr/src/tools/ctf/cvt/ |
H A D | ctfmerge.c | 278 finalize_phase_one(workqueue_t *wq) argument 294 for (startslot = -1, i = 0; i < wq->wq_nwipslots; i++) { 295 if (wq->wq_wip[i].wip_batchid == wq->wq_lastdonebatch + 1) { 303 for (i = startslot; i < startslot + wq->wq_nwipslots; i++) { 304 int slotnum = i % wq->wq_nwipslots; 305 wip_t *wipslot = &wq->wq_wip[slotnum]; 314 fifo_add(wq->wq_donequeue, wipslot->wip_td); 315 wq->wq_wip[slotnum].wip_td = NULL; 319 wq 326 init_phase_two(workqueue_t *wq) argument 354 wip_save_work(workqueue_t *wq, wip_t *slot, int slotnum) argument 392 worker_runphase1(workqueue_t *wq) argument 439 worker_runphase2(workqueue_t *wq) argument 510 worker_thread(workqueue_t *wq) argument 544 workqueue_t *wq = arg; local 623 wq_init(workqueue_t *wq, int nfiles) argument 684 start_threads(workqueue_t *wq) argument 707 join_threads(workqueue_t *wq) argument 732 static workqueue_t wq; variable [all...] |
/opensolaris-onvv-gate/usr/src/uts/common/io/fibre-channel/fca/oce/ |
H A D | oce_tx.c | 34 static void oce_free_wqed(struct oce_wq *wq, oce_wqe_desc_t *wqed); 35 static int oce_map_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, 37 static int oce_bcopy_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, mblk_t *mp, 39 static void oce_wqb_dtor(struct oce_wq *wq, oce_wq_bdesc_t *wqbd); 40 static int oce_wqb_ctor(oce_wq_bdesc_t *wqbd, struct oce_wq *wq, 42 static inline oce_wq_bdesc_t *oce_wqb_alloc(struct oce_wq *wq); 43 static void oce_wqb_free(struct oce_wq *wq, oce_wq_bdesc_t *wqbd); 45 static void oce_wqmd_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd); 46 static void oce_wqm_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd); 47 static oce_wq_mdesc_t *oce_wqm_alloc(struct oce_wq *wq); 97 oce_wqm_dtor(struct oce_wq *wq, oce_wq_mdesc_t *wqmd) argument 115 oce_wqm_ctor(oce_wq_mdesc_t *wqmd, struct oce_wq *wq) argument 136 oce_wqm_cache_create(struct oce_wq *wq) argument 175 oce_wqm_cache_destroy(struct oce_wq *wq) argument 198 oce_wqb_cache_create(struct oce_wq *wq, size_t buf_size) argument 238 oce_wqb_cache_destroy(struct oce_wq *wq) argument 260 oce_wqb_ctor(oce_wq_bdesc_t *wqbd, struct oce_wq *wq, size_t size, int flags) argument 284 oce_wqb_dtor(struct oce_wq *wq, oce_wq_bdesc_t *wqbd) argument 297 oce_wqb_alloc(struct oce_wq *wq) argument 311 oce_wqb_free(struct oce_wq *wq, oce_wq_bdesc_t *wqbd) argument 324 oce_wqm_alloc(struct oce_wq *wq) argument 338 oce_wqm_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd) argument 352 oce_wqmd_free(struct oce_wq *wq, oce_wq_mdesc_t *wqmd) argument 404 struct oce_wq *wq; local 428 oce_fill_ring_descs(struct oce_wq *wq, oce_wqe_desc_t *wqed) argument 454 oce_bcopy_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, mblk_t *mp, uint32_t pkt_len) argument 510 oce_map_wqe(struct oce_wq *wq, oce_wqe_desc_t *wqed, mblk_t *mp, uint32_t pkt_len) argument 559 oce_process_tx_compl(struct oce_wq *wq, boolean_t rearm) argument 617 struct oce_wq *wq; local 679 oce_send_packet(struct oce_wq *wq, mblk_t *mp) argument 902 oce_free_wqed(struct oce_wq *wq, oce_wqe_desc_t *wqed) argument 930 oce_start_wq(struct oce_wq *wq) argument 944 oce_clean_wq(struct oce_wq *wq) argument [all...] |
H A D | oce_queue.c | 55 static void oce_wq_fini(struct oce_dev *dev, struct oce_wq *wq); 56 static int oce_wq_create(struct oce_wq *wq, struct oce_eq *eq); 57 static void oce_wq_del(struct oce_dev *dev, struct oce_wq *wq); 462 struct oce_wq *wq; local 476 /* allocate wq */ 477 wq = kmem_zalloc(sizeof (struct oce_wq), KM_NOSLEEP); 478 if (wq == NULL) { 484 /* Set the wq config */ 485 wq->cfg.q_len = q_len; 486 wq 563 oce_wq_fini(struct oce_dev *dev, struct oce_wq *wq) argument 583 oce_wq_create(struct oce_wq *wq, struct oce_eq *eq) argument 665 oce_wq_del(struct oce_dev *dev, struct oce_wq *wq) argument [all...] |
H A D | oce_gld.c | 121 (void) oce_start_wq(dev->wq[qidx]); 163 mutex_enter(&dev->wq[qidx]->tx_lock); 168 oce_clean_wq(dev->wq[qidx]); 172 mutex_exit(&dev->wq[qidx]->tx_lock); 296 struct oce_wq *wq; local 306 * Hash to pick a wq 308 wq = oce_get_wq(dev, mp); 314 /* Hardcode wq since we have only one */ 315 rmp = oce_send_packet(wq, mp); 318 wq 582 oce_m_ioctl(void *arg, queue_t *wq, mblk_t *mp) argument [all...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-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 | 1526 queue_t *wq = tep->te_wq; local 1529 ASSERT(wq == WR(rq)); 1622 rq->q_ptr = wq->q_ptr = NULL; 1717 tl_wput(queue_t *wq, mblk_t *mp) argument 1719 tl_endpt_t *tep = (tl_endpt_t *)wq->q_ptr; 1731 tl_merror(wq, mp, EPROTO); 1749 miocnak(wq, mp, 0, EINVAL); 1759 flushq(wq, FLUSHALL); 1763 flushq(RD(wq), FLUSHALL); 1764 qreply(wq, m 1983 tl_wsrv(queue_t *wq) argument 2016 queue_t *wq = tep->te_wq; local 2208 queue_t *wq = tep->te_wq; local 2271 tl_error_ack(queue_t *wq, mblk_t *mp, t_scalar_t tli_err, t_scalar_t unix_err, t_scalar_t type) argument 2303 tl_ok_ack(queue_t *wq, mblk_t *mp, t_scalar_t type) argument 2343 queue_t *wq = tep->te_wq; local 2650 queue_t *wq; local 2725 tl_optmgmt(queue_t *wq, mblk_t *mp) argument 2794 tl_conn_req(queue_t *wq, mblk_t *mp) argument 3037 queue_t *wq; local 3317 queue_t *wq; local 3849 queue_t *wq; local 4166 queue_t *wq; local 4389 queue_t *wq = tep->te_wq; local 4590 queue_t *wq = tep->te_wq; local 4754 queue_t *wq = tep->te_wq; local 4878 tl_uderr(queue_t *wq, mblk_t *mp, t_scalar_t err) argument 4951 queue_t *wq = tep->te_wq; local 4972 queue_t *wq = tep->te_wq; local 5905 tl_merror(queue_t *wq, mblk_t *mp, int error) argument 5996 tl_default_opt(queue_t *wq, int level, int name, uchar_t *ptr) argument 6004 tl_get_opt(queue_t *wq, int level, int name, uchar_t *ptr) argument 6051 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 6130 queue_t *wq = arg; local 6148 queue_t *wq = arg; local 6165 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...] |
/opensolaris-onvv-gate/usr/src/uts/common/rpc/ |
H A D | svc_gen.c | 109 queue_t *wq; local 129 wq = fp->f_vnode->v_stream->sd_wrq; 130 while ((wq = wq->q_next) != NULL) { 131 if (strcmp(wq->q_qinfo->qi_minfo->mi_idname, "rpcmod") == 0) 134 if (!wq) { 186 xprt->xp_wq = wq; 220 vp = (void **)wq->q_ptr; 230 create_putlocks(wq, 1);
|
H A D | rpcmod.c | 1082 static void mir_svc_release(queue_t *wq, mblk_t *mp); 1083 static void mir_svc_start(queue_t *wq); 2103 mir_svc_start_close(queue_t *wq, mir_t *mir) argument 2106 ASSERT((wq->q_flag & QREADR) == 0); 2122 qenable(RD(wq)); 2128 qenable(wq); 2136 mir_svc_release(queue_t *wq, mblk_t *mp) argument 2138 mir_t *mir = (mir_t *)wq->q_ptr; 2141 ASSERT((wq->q_flag & QREADR) == 0); 2158 (void *)RD(wq)); 2196 mir_svc_start(queue_t *wq) argument 2214 mir_clnt_idle_stop(queue_t *wq, mir_t *mir) argument 2227 mir_clnt_idle_start(queue_t *wq, mir_t *mir) argument 2241 mir_clnt_idle_do_stop(queue_t *wq) argument 2258 queue_t *wq = (queue_t *)arg; local [all...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-gate/usr/src/uts/common/sys/fibre-channel/fca/oce/ |
H A D | oce_buf.h | 129 struct oce_wq *wq; member in struct:_oce_wqe_desc_s 184 int oce_wqb_cache_create(struct oce_wq *wq, size_t buf_size); 185 void oce_wqb_cache_destroy(struct oce_wq *wq); 187 void oce_wqm_cache_destroy(struct oce_wq *wq); 188 int oce_wqm_cache_create(struct oce_wq *wq);
|
/opensolaris-onvv-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...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-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);
|
/opensolaris-onvv-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...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-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...] |