/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);
|
/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/uts/common/io/softmac/ |
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);
|
H A D | softmac_ctl.c | 203 softmac_m_ioctl(void *arg, queue_t *wq, mblk_t *mp) argument 210 qreply(wq, ackmp);
|
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...] |
/illumos-gate/usr/src/uts/common/inet/ |
H A D | proto_set.c | 112 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 D | unm_ndd.c | 428 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 D | rge_ndd.c | 407 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 D | mac_ndd.c | 157 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 D | audio_ddi.c | 424 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 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/io/ |
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...] |
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 | 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 | 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...] |
/illumos-gate/usr/src/uts/common/io/fibre-channel/fca/oce/ |
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...] |
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_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...] |
/illumos-gate/usr/src/uts/common/disp/ |
H A D | cpucaps.c | 500 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 D | qlge_gld.c | 544 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 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/sfxge/ |
H A D | sfxge.c | 611 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 D | sfxge_gld_v3.c | 412 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 D | mpt_sas.c | 460 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 D | auto_subr.c | 294 * 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';
|