Searched refs:STREAM (Results 1 – 14 of 14) sorted by relevance
495 struct stdata *stp = STREAM(q); in canputnext()513 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(qofsq)); in canputnext()575 insertq(STREAM(q), q); in qprocson()628 struct stdata *stp = STREAM(q); in freezestr()653 struct stdata *stp = STREAM(q); in unfreezestr()1188 vp = STREAM(q)->sd_vnode; in qassociate()
1136 STREAM(rq) = STREAM(wrq) = STREAM(qp); in qattach()1237 mutex_enter(&STREAM(qp)->sd_lock); in qreopen()1239 mutex_exit(&STREAM(qp)->sd_lock); in qreopen()1262 ASSERT(STREAM(qp)->sd_flag & (STRCLOSE|STWOPEN|STRPLUMB)); in qdetach()1264 if (STREAM_NEEDSERVICE(STREAM(qp))) in qdetach()1265 stream_runservice(STREAM(qp)); in qdetach()4248 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(nq)); in backenable()4261 freezer = STREAM(q)->sd_freezer; in backenable()4262 if (freezer != curthread || STREAM(q) != STREAM(nq)) { in backenable()4274 if (freezer != curthread || STREAM(q) != STREAM(nq)) in backenable()[all …]
445 STREAM(qp) = STREAM(_WR(qp)) = stp; in stropen()5289 if (!STRMATED(resstp) && STREAM(q) != resstp && in strioctl()5900 if ((nextqp != NULL) && (STREAM(nextqp) != stp)) { in do_sendfp()5913 qp = _RD(STREAM(nextqp)->sd_wrq); in do_sendfp()8622 vp = STREAM(qp)->sd_vnode; in strq2vp()8681 STREAM(wrq1)->sd_mate = STREAM(wrq2); in strmate()8682 STREAM(wrq1)->sd_flag |= STRMATE; in strmate()8683 STREAM(wrq2)->sd_mate = STREAM(wrq1); in strmate()8684 STREAM(wrq2)->sd_flag |= STRMATE; in strmate()
164 stp = STREAM(qp); in putnext()
7196 stp = STREAM(rq); in ddi_assoc_queue_with_devi()
1 SED - STREAM EDITOR
1922 freezer = STREAM(q)->sd_freezer; in getq_noenab()2102 ASSERT((q->q_flag & QREADR) || MUTEX_NOT_HELD(&STREAM(q)->sd_lock)); in qbackenable()2116 freezer = STREAM(q)->sd_freezer; in qbackenable()2185 if (curthread != STREAM(q)->sd_freezer && MUTEX_HELD(QLOCK(q))) { in rmvq()2210 freezer = STREAM(q)->sd_freezer; in rmvq_noenab()2498 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(q->q_nfsrv)); in canput()2599 freezer = STREAM(q)->sd_freezer; in putq()2790 freezer = STREAM(q)->sd_freezer; in putbq()2979 freezer = STREAM(q)->sd_freezer; in insq()3267 freezer = STREAM(q)->sd_freezer; in strqset()[all …]
391 STREAM(rqp)->sd_flag |= STRXPG4TTY; in ptsopen()
113 stp = STREAM(q); in proto_set_maxpsz()
819 #define STREAM(q) ((q)->q_stream) macro
109 member is consulted. If the flag has been set to zero, then the STREAM
2116 queue_t *qnext = STREAM(q)->sd_wrq->q_next; in arp_over_driver()
2786 vn = STREAM(connp->conn_rq)->sd_pvnode; in conn_get_socket_info()
3330 stp = STREAM(connp->conn_rq); in tcp_zcopy_notify()