Home
last modified time | relevance | path

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

/titanic_44/usr/src/uts/common/os/
H A Dstreamio.c345 claimstr(stp->sd_wrq); in stropen()
346 qp = stp->sd_wrq; in stropen()
352 releasestr(stp->sd_wrq); in stropen()
569 mutex_enter(QLOCK(stp->sd_wrq->q_next)); in stropen()
570 rmin = stp->sd_wrq->q_next->q_minpsz; in stropen()
571 rmax = stp->sd_wrq->q_next->q_maxpsz; in stropen()
572 mutex_exit(QLOCK(stp->sd_wrq->q_next)); in stropen()
582 mutex_enter(QLOCK(stp->sd_wrq)); in stropen()
585 mutex_exit(QLOCK(stp->sd_wrq)); in stropen()
625 qp = stp->sd_wrq; in strclose()
[all …]
H A Dstrsubr.c659 stp->sd_wrq = NULL; in stream_head_constructor()
1634 qup = getendq(stp->sd_wrq); in findlinks()
1802 rq = getendq(stp->sd_wrq); in mlink_file()
1806 linkp = alloclink(rq, stpdown->sd_wrq, fpdown); in mlink_file()
1858 rq = _RD(stpdown->sd_wrq); in mlink_file()
2083 wrq = stpdown->sd_wrq; in munlink()
3012 sleepon = &_RD(stp->sd_wrq)->q_wait; in strwaitq()
3016 sleepon = &stp->sd_wrq->q_wait; in strwaitq()
3066 putnext(stp->sd_wrq, mp); in strwaitq()
3074 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.c1349 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()
/titanic_44/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()
/titanic_44/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.c1621 new->e_wq = tiptr->fp->f_vnode->v_stream->sd_wrq->q_next; in endpnt_get()
H A Dclnt_cots.c2161 wq = tiptr->fp->f_vnode->v_stream->sd_wrq->q_next; in connmgr_get()
/titanic_44/usr/src/uts/common/fs/fifofs/
H A Dfifovnops.c442 queue_t *sd_wrq; in fifo_close() local
461 sd_wrq = strvp2wq(vp); in fifo_close()
507 (void) putnextctl_wait(sd_wrq, M_HANGUP); in fifo_close()
559 (void) putnextctl_wait(sd_wrq, M_HANGUP); in fifo_close()
H A Dfifosubr.c1095 ASSERT(FTOV(fnp)->v_stream->sd_wrq != NULL); in fifo_fastturnoff()
1096 ASSERT(RD(FTOV(fnp)->v_stream->sd_wrq) != NULL); in fifo_fastturnoff()
/titanic_44/usr/src/cmd/mdb/common/modules/genunix/
H A Dstreams.c703 addr, sd.sd_wrq, sd.sd_flag, sd.sd_vnode, in stdata()
834 mdb_printf("%p\n", sd->sd_wrq); in sdprint_wrq()
963 wsp->walk_addr = (uintptr_t)s.sd_wrq; in str_walk_init()
/titanic_44/usr/src/uts/common/io/
H A Dstream.c3343 wrq = STREAM(q)->sd_wrq; in strqset()
3386 wrq = STREAM(q)->sd_wrq; in strqset()
3568 cv_broadcast(&stp->sd_wrq->q_wait); in strwakeq()
3582 cv_broadcast(&_RD(stp->sd_wrq)->q_wait); in strwakeq()
3600 cv_broadcast(&stp->sd_wrq->q_wait); in strwakeq()
3781 if (nqp != stp->sd_wrq) in rwnext()
/titanic_44/usr/src/uts/common/fs/sockfs/
H A Dsocktpi.c459 ASSERT(stp->sd_wrq != NULL); in sotpi_init()
460 sti->sti_provinfo = tpi_findprov(stp->sd_wrq); in sotpi_init()
474 queue_t *tq = stp->sd_wrq->q_next; in sotpi_init()
4432 canputnext(SOTOV(so)->v_stream->sd_wrq)) { in sotpi_sendmsg()
4500 wqp = stp->sd_wrq; in kstrwritemp()
4658 udp_wq = stp->sd_wrq->q_next; in sodgram_direct()
4705 queue_t *tcp_wq = stp->sd_wrq->q_next; in sostream_direct()
6453 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()
H A Dnl7curi.c1695 putnext(stp->sd_wrq, mp); in kstrwritempnoqwait()
/titanic_44/usr/src/uts/common/sys/
H A Dstrsubr.h176 struct queue *sd_wrq; /* write queue */ member
/titanic_44/usr/src/uts/common/inet/ip/
H A Dip_arp.c2115 queue_t *qnext = STREAM(q)->sd_wrq->q_next; in arp_over_driver()
/titanic_44/usr/src/uts/common/fs/specfs/
H A Dspecvnops.c518 for (dq = stp->sd_wrq; dq; dq = dq->q_next) { in spec_clone()