Searched refs:wq (Results 1 - 25 of 135) sorted by relevance

123456

/illumos-gate/usr/src/uts/common/os/
H A Dwaitq.c44 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 Dctfmerge.c276 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 Doce_tx.c31 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 Doce_queue.c53 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 Doce_gld.c99 (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 Drdsv3_impl.c522 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 Dbufmod.c281 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 Dsundlpi.c43 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 Dtl.c1532 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 Dstrsun.c43 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 Dpfmod.c90 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 Dsvc_gen.c110 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 Drpcmod.c1008 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 Didn_dlpi.c709 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 Ddman.c1561 * 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 Dhxge_hw.c471 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 Doce_buf.h126 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 Dhermon_wr.c77 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 Ddapl_tavor_wr.c62 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 Daudio_sun.c626 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 Dsoftmac_dev.c391 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 Dsoftmac_pkt.c33 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 Ddm2s.c114 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 Dfcip.c145 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 Dnxge_hw.c584 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...]

Completed in 176 milliseconds

123456