Home
last modified time | relevance | path

Searched refs:sd_wrq (Results 1 – 17 of 17) sorted by relevance

/illumos-gate/usr/src/uts/common/os/
H A Dstreamio.c393 claimstr(stp->sd_wrq); in stropen()
394 qp = stp->sd_wrq; in stropen()
400 releasestr(stp->sd_wrq); in stropen()
623 mutex_enter(QLOCK(stp->sd_wrq->q_next)); in stropen()
624 rmin = stp->sd_wrq->q_next->q_minpsz; in stropen()
625 rmax = stp->sd_wrq->q_next->q_maxpsz; in stropen()
626 mutex_exit(QLOCK(stp->sd_wrq->q_next)); in stropen()
636 mutex_enter(QLOCK(stp->sd_wrq)); in stropen()
639 mutex_exit(QLOCK(stp->sd_wrq)); in stropen()
679 qp = stp->sd_wrq; in strclose()
[all …]
H A Dstrsubr.c662 stp->sd_wrq = NULL; in stream_head_constructor()
1637 qup = getendq(stp->sd_wrq); in findlinks()
1805 rq = getendq(stp->sd_wrq); in mlink_file()
1809 linkp = alloclink(rq, stpdown->sd_wrq, fpdown); in mlink_file()
1861 rq = _RD(stpdown->sd_wrq); in mlink_file()
2096 wrq = stpdown->sd_wrq; in munlink()
3036 sleepon = &_RD(stp->sd_wrq)->q_wait; in strwaitq()
3040 sleepon = &stp->sd_wrq->q_wait; in strwaitq()
3090 putnext(stp->sd_wrq, mp); in strwaitq()
3098 if (_RD(stp->sd_wrq)->q_first != NULL) { in strwaitq()
[all …]
H A Dddi.c639 for (q = stp->sd_wrq; q != NULL; q = SAMESTR(q) ? q->q_next : NULL) { in freezestr()
656 for (q1 = stp->sd_wrq; q1 != NULL; in unfreezestr()
H A Ddriver_lyr.c1299 ret = ldi_ident_from_stream(getendq(stp->sd_wrq), &li); in ldi_mlink_fp()
1414 ret = ldi_ident_from_stream(getendq(stp->sd_wrq), &li); in ldi_munlink_fp()
/illumos-gate/usr/src/uts/common/inet/
H A Dproto_set.c122 claimstr(stp->sd_wrq); in proto_set_maxpsz()
123 wq = stp->sd_wrq->q_next; in proto_set_maxpsz()
126 releasestr(stp->sd_wrq); in proto_set_maxpsz()
/illumos-gate/usr/src/uts/common/rpc/
H A Dsvc_gen.c130 wq = fp->f_vnode->v_stream->sd_wrq; in svc_tli_kcreate()
H A Dclnt_clts.c1646 new->e_wq = tiptr->fp->f_vnode->v_stream->sd_wrq->q_next; in endpnt_get()
H A Dclnt_cots.c2171 wq = tiptr->fp->f_vnode->v_stream->sd_wrq->q_next; in connmgr_get()
/illumos-gate/usr/src/uts/common/fs/fifofs/
H A Dfifovnops.c446 queue_t *sd_wrq; in fifo_close() local
465 sd_wrq = strvp2wq(vp); in fifo_close()
511 (void) putnextctl_wait(sd_wrq, M_HANGUP); in fifo_close()
563 (void) putnextctl_wait(sd_wrq, M_HANGUP); in fifo_close()
H A Dfifosubr.c1079 ASSERT(FTOV(fnp)->v_stream->sd_wrq != NULL); in fifo_fastturnoff()
1080 ASSERT(RD(FTOV(fnp)->v_stream->sd_wrq) != NULL); in fifo_fastturnoff()
/illumos-gate/usr/src/cmd/mdb/common/modules/genunix/
H A Dstreams.c707 addr, sd.sd_wrq, sd.sd_flag, sd.sd_vnode, in stdata()
838 mdb_printf("%p\n", sd->sd_wrq); in sdprint_wrq()
967 wsp->walk_addr = (uintptr_t)s.sd_wrq; in str_walk_init()
/illumos-gate/usr/src/uts/common/fs/sockfs/
H A Dsocktpi.c455 ASSERT(stp->sd_wrq != NULL); in sotpi_init()
456 sti->sti_provinfo = tpi_findprov(stp->sd_wrq); in sotpi_init()
470 queue_t *tq = stp->sd_wrq->q_next; in sotpi_init()
4359 canputnext(SOTOV(so)->v_stream->sd_wrq)) { in sotpi_sendmsg()
4427 wqp = stp->sd_wrq; in kstrwritemp()
4592 udp_wq = stp->sd_wrq->q_next; in sodgram_direct()
4639 queue_t *tcp_wq = stp->sd_wrq->q_next; in sostream_direct()
6388 q = stp->sd_wrq->q_next; in sotpi_convert_sonode()
H A Dsockstr.c1627 cv_broadcast(&stp->sd_wrq->q_wait); in strsock_discon_ind()
2053 qp = _RD(stp->sd_wrq); in strsock_proto()
/illumos-gate/usr/src/uts/common/io/
H A Dstream.c3330 wrq = STREAM(q)->sd_wrq; in strqset()
3373 wrq = STREAM(q)->sd_wrq; in strqset()
3555 cv_broadcast(&stp->sd_wrq->q_wait); in strwakeq()
3569 cv_broadcast(&_RD(stp->sd_wrq)->q_wait); in strwakeq()
3587 cv_broadcast(&stp->sd_wrq->q_wait); in strwakeq()
3768 if (nqp != stp->sd_wrq) in rwnext()
/illumos-gate/usr/src/uts/common/sys/
H A Dstrsubr.h183 struct queue *sd_wrq; /* write queue */ member
/illumos-gate/usr/src/uts/common/fs/specfs/
H A Dspecvnops.c520 for (dq = stp->sd_wrq; dq; dq = dq->q_next) { in spec_clone()
/illumos-gate/usr/src/uts/common/inet/ip/
H A Dip_arp.c2116 queue_t *qnext = STREAM(q)->sd_wrq->q_next; in arp_over_driver()