Lines Matching refs:qp
144 putnext(queue_t *qp, mblk_t *mp) in putnext() argument
146 queue_t *fqp = qp; /* For strft tracing */ in putnext()
160 "putnext_start:(%p, %p)", qp, mp); in putnext()
164 stp = STREAM(qp); in putnext()
173 qp = qp->q_next; in putnext()
174 sq = qp->q_syncq; in putnext()
177 qi = qp->q_qinfo; in putnext()
195 queued = qp->q_sqflags & Q_SQQUEUED; in putnext()
223 qp, mp, sq); in putnext()
232 qfill_syncq(sq, qp, mp); in putnext()
245 queued = qp->q_sqflags & Q_SQQUEUED; in putnext()
274 (*putproc)(qp, mp); in putnext()
276 ASSERT(MUTEX_NOT_HELD(QLOCK(qp))); in putnext()
278 mutex_enter(QLOCK(qp)); in putnext()
283 if (qp->q_syncqmsgs == 0) { in putnext()
284 mutex_exit(QLOCK(qp)); in putnext()
287 (*putproc)(qp, mp); in putnext()
310 mp->b_queue = qp; in putnext()
313 SQPUT_MP(qp, mp); in putnext()
314 qdrain_syncq(sq, qp); in putnext()
315 ASSERT(MUTEX_NOT_HELD(QLOCK(qp))); in putnext()
364 "putnext_end:(%p, %p, %p) done", qp, mp, sq); in putnext()
374 putnext_tail(sq, qp, (flags & ~drain_mask)); in putnext()
411 "putnext_end:(%p, %p, %p) done", qp, mp, sq); in putnext()
426 put(queue_t *qp, mblk_t *mp) in put() argument
428 queue_t *fqp = qp; /* For strft tracing */ in put()
440 "put:(%X, %X)", qp, mp); in put()
444 sq = qp->q_syncq; in put()
446 qi = qp->q_qinfo; in put()
463 queued = qp->q_sqflags & Q_SQQUEUED; in put()
490 qp, mp, sq); in put()
499 qfill_syncq(sq, qp, mp); in put()
512 queued = qp->q_sqflags & Q_SQQUEUED; in put()
541 (*putproc)(qp, mp); in put()
543 ASSERT(MUTEX_NOT_HELD(QLOCK(qp))); in put()
545 mutex_enter(QLOCK(qp)); in put()
550 if (qp->q_syncqmsgs == 0) { in put()
551 mutex_exit(QLOCK(qp)); in put()
554 (*putproc)(qp, mp); in put()
577 mp->b_queue = qp; in put()
580 SQPUT_MP(qp, mp); in put()
581 qdrain_syncq(sq, qp); in put()
582 ASSERT(MUTEX_NOT_HELD(QLOCK(qp))); in put()
631 "putnext_end:(%p, %p, %p) done", qp, mp, sq); in put()
641 putnext_tail(sq, qp, (flags & ~drain_mask)); in put()
678 "putnext_end:(%p, %p, %p) done", qp, mp, sq); in put()