STREAM
queue_t *qnext = STREAM(q)->sd_wrq->q_next;
vn = STREAM(connp->conn_rq)->sd_pvnode;
stp = STREAM(q);
stp = STREAM(connp->conn_rq);
STREAM(rqp)->sd_flag |= STRXPG4TTY;
freezer = STREAM(q)->sd_freezer;
ASSERT((q->q_flag & QREADR) || MUTEX_NOT_HELD(&STREAM(q)->sd_lock));
freezer = STREAM(q)->sd_freezer;
if (curthread != STREAM(q)->sd_freezer && MUTEX_HELD(QLOCK(q))) {
freezer = STREAM(q)->sd_freezer;
ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(q->q_nfsrv));
freezer = STREAM(q)->sd_freezer;
freezer = STREAM(q)->sd_freezer;
freezer = STREAM(q)->sd_freezer;
freezer = STREAM(q)->sd_freezer;
wrq = STREAM(q)->sd_wrq;
if (STREAM(q)->sd_vnode->v_type == VFIFO)
STREAM(q)->sd_qn_maxpsz = val;
wrq = STREAM(q)->sd_wrq;
STREAM(q)->sd_qn_minpsz = (ssize_t)val;
freezer = STREAM(q)->sd_freezer;
stdata_t *stp = STREAM(q);
stdata_t *stp = STREAM(q);
stp = STREAM(qp);
stp = STREAM(qp);
return (STREAM(q)->sd_struiordq == q);
return (STREAM(q)->sd_struiowrq == q);
struct stdata *stp = STREAM(q);
vp = STREAM(q)->sd_vnode;
struct stdata *stp = STREAM(q);
ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(qofsq));
insertq(STREAM(q), q);
struct stdata *stp = STREAM(q);
struct stdata *stp = STREAM(q);
stp = STREAM(rq);
stp = STREAM(qp);
STREAM(qp) = STREAM(_WR(qp)) = stp;
if (!STRMATED(resstp) && STREAM(q) != resstp &&
if ((nextqp != NULL) && (STREAM(nextqp) != stp)) {
qp = _RD(STREAM(nextqp)->sd_wrq);
vp = STREAM(qp)->sd_vnode;
STREAM(wrq1)->sd_mate = STREAM(wrq2);
STREAM(wrq1)->sd_flag |= STRMATE;
STREAM(wrq2)->sd_mate = STREAM(wrq1);
STREAM(wrq2)->sd_flag |= STRMATE;
STREAM(rq) = STREAM(wrq) = STREAM(qp);
mutex_enter(&STREAM(qp)->sd_lock);
mutex_exit(&STREAM(qp)->sd_lock);
ASSERT(STREAM(qp)->sd_flag & (STRCLOSE|STWOPEN|STRPLUMB));
if (STREAM_NEEDSERVICE(STREAM(qp)))
stream_runservice(STREAM(qp));
ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(nq));
freezer = STREAM(q)->sd_freezer;
if (freezer != curthread || STREAM(q) != STREAM(nq)) {
if (freezer != curthread || STREAM(q) != STREAM(nq))
struct stdata *stp = STREAM(qp);
stp = STREAM(q);
stp = STREAM(q);
struct stdata *stp = STREAM(qp);
struct stdata *stp = STREAM(qp);
STREAM(passq) = STREAM(_WR(passq)) = stpdown;
insertq(STREAM(passq), passq);
stdata_t *stp = STREAM(q);