Searched refs:STREAM (Results 1 – 13 of 13) 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()
1133 STREAM(rq) = STREAM(wrq) = STREAM(qp); in qattach()1234 mutex_enter(&STREAM(qp)->sd_lock); in qreopen()1236 mutex_exit(&STREAM(qp)->sd_lock); in qreopen()1259 ASSERT(STREAM(qp)->sd_flag & (STRCLOSE|STWOPEN|STRPLUMB)); in qdetach()1261 if (STREAM_NEEDSERVICE(STREAM(qp))) in qdetach()1262 stream_runservice(STREAM(qp)); in qdetach()4224 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(nq)); in backenable()4237 freezer = STREAM(q)->sd_freezer; in backenable()4238 if (freezer != curthread || STREAM(q) != STREAM(nq)) { in backenable()4250 if (freezer != curthread || STREAM(q) != STREAM(nq)) in backenable()[all …]
164 stp = STREAM(qp); in putnext()
396 STREAM(qp) = STREAM(_WR(qp)) = stp; in stropen()5163 if (!STRMATED(resstp) && STREAM(q) != resstp && in strioctl()5774 if ((nextqp != NULL) && (STREAM(nextqp) != stp)) { in do_sendfp()5787 qp = _RD(STREAM(nextqp)->sd_wrq); in do_sendfp()8487 vp = STREAM(qp)->sd_vnode; in strq2vp()8546 STREAM(wrq1)->sd_mate = STREAM(wrq2); in strmate()8547 STREAM(wrq1)->sd_flag |= STRMATE; in strmate()8548 STREAM(wrq2)->sd_mate = STREAM(wrq1); in strmate()8549 STREAM(wrq2)->sd_flag |= STRMATE; in strmate()
7041 stp = STREAM(rq); in ddi_assoc_queue_with_devi()
1 SED - STREAM EDITOR
1935 freezer = STREAM(q)->sd_freezer; in getq_noenab()2115 ASSERT((q->q_flag & QREADR) || MUTEX_NOT_HELD(&STREAM(q)->sd_lock)); in qbackenable()2129 freezer = STREAM(q)->sd_freezer; in qbackenable()2198 if (curthread != STREAM(q)->sd_freezer && MUTEX_HELD(QLOCK(q))) { in rmvq()2223 freezer = STREAM(q)->sd_freezer; in rmvq_noenab()2511 ASSERT(STRMATED(q->q_stream) || STREAM(q) == STREAM(q->q_nfsrv)); in canput()2612 freezer = STREAM(q)->sd_freezer; in putq()2803 freezer = STREAM(q)->sd_freezer; in putbq()2992 freezer = STREAM(q)->sd_freezer; in insq()3280 freezer = STREAM(q)->sd_freezer; in strqset()[all …]
53 int readfd; /* STREAM fd to read from */54 int writefd; /* STREAM fd to write to */
113 stp = STREAM(q); in proto_set_maxpsz()
801 #define STREAM(q) ((q)->q_stream) macro
185 lqi->sm_dev = q && STREAM(q) ? STREAM(q)->sd_vnode->v_rdev : NODEV; in sm_setdip()
2115 queue_t *qnext = STREAM(q)->sd_wrq->q_next; in arp_over_driver()
3294 stp = STREAM(connp->conn_rq); in tcp_zcopy_notify()