Searched defs:wq (Results 1 - 25 of 115) sorted by relevance

12345

/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);
/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/uts/common/io/softmac/
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);
H A Dsoftmac_ctl.c203 softmac_m_ioctl(void *arg, queue_t *wq, mblk_t *mp) argument
210 qreply(wq, ackmp);
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...]
/illumos-gate/usr/src/uts/common/inet/
H A Dproto_set.c112 queue_t *wq; local
123 wq = stp->sd_wrq->q_next;
124 ASSERT(wq != NULL);
125 (void) strqset(wq, QMAXPSZ, 0, size);
/illumos-gate/usr/src/uts/common/io/ntxn/
H A Dunm_ndd.c428 unm_nd_ioctl(unm_adapter *adapter, queue_t *wq, mblk_t *mp, struct iocblk *iocp) argument
434 (void *)adapter, (void *)wq, (void *)mp, (void *)iocp));
453 ok = nd_getset(wq, adapter->nd_data_p, mp);
468 ok = nd_getset(wq, adapter->nd_data_p, mp);
/illumos-gate/usr/src/uts/common/io/rge/
H A Drge_ndd.c407 rge_nd_ioctl(rge_t *rgep, queue_t *wq, mblk_t *mp, struct iocblk *iocp) argument
415 (void *)rgep, (void *)wq, (void *)mp, (void *)iocp));
436 ok = nd_getset(wq, rgep->nd_data_p, mp);
458 ok = nd_getset(wq, rgep->nd_data_p, mp);
/illumos-gate/usr/src/uts/common/io/mac/
H A Dmac_ndd.c157 mac_ndd_ioctl(mac_impl_t *mip, queue_t *wq, mblk_t *mp) argument
177 miocack(wq, mp, msgdsize(mp->b_cont), rval);
179 miocnak(wq, mp, 0, err);
/illumos-gate/usr/src/uts/common/io/audio/impl/
H A Daudio_ddi.c424 audio_wput(queue_t *wq, mblk_t *mp) argument
428 c = wq->q_ptr;
438 audio_wsrv(queue_t *wq) argument
442 c = wq->q_ptr;
446 flushq(wq, FLUSHALL);
/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/io/
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...]
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 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 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...]
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/oce/
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...]
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_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...]
/illumos-gate/usr/src/uts/common/disp/
H A Dcpucaps.c500 waitq_t *wq = &cap->cap_waitq; local
504 if (!waitq_isempty(wq))
505 waitq_runone(wq);
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/qlge/
H A Dqlge_gld.c544 ql_m_ioctl(void *arg, queue_t *wq, mblk_t *mp) argument
562 miocnak(wq, mp, 0, EINVAL);
568 miocnak(wq, mp, 0, EINVAL);
610 miocnak(wq, mp, 0, err);
642 status = ql_chip_ioctl(qlge, wq, mp);
648 status = ql_loop_ioctl(qlge, wq, mp, iocp);
664 miocnak(wq, mp, 0, iocp->ioc_error == 0 ?
678 miocack(wq, mp, 0, 0);
687 qreply(wq, mp);
/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/sfxge/
H A Dsfxge.c611 sfxge_ioctl(sfxge_t *sp, queue_t *wq, mblk_t *mp) argument
719 miocack(wq, mp, iocp->ioc_count, 0);
735 miocnak(wq, mp, 0, rc);
H A Dsfxge_gld_v3.c412 sfxge_gld_ioctl(void *arg, queue_t *wq, mblk_t *mp) argument
416 sfxge_ioctl(sp, wq, mp);
/illumos-gate/usr/src/cmd/mdb/common/modules/mpt_sas/
H A Dmpt_sas.c460 int wq, dq; local
499 for (q = mp->m_waitq, wq = 0; q; q = c.cmd_linkp, wq++)
526 " targ throttle m_t_ncmds targ_tot wq dq");
535 mdb_printf("%3d %2d %2d\n", tcmds, wq, dq);
/illumos-gate/usr/src/cmd/fs.d/autofs/
H A Dauto_subr.c294 * Gets the next token from the string "p" and copies it into "w". The "wq" is
297 * means "whitespace". The call to getword must provide buffers w and wq of size
303 getword(char *w, char *wq, char **p, char **pq, char delim, int wordsz) argument
306 char *tmpq = wq;
330 *wq++ = *(*pq)++;
333 *wq = '\0';

Completed in 140 milliseconds

12345