Lines Matching refs:q
151 queue_t *q, /* pointer to the read side queue */ in ptemopen() argument
166 if (q->q_ptr != NULL) { in ptemopen()
210 ntp->q_ptr = q; in ptemopen()
211 q->q_ptr = ntp; in ptemopen()
212 WR(q)->q_ptr = ntp; in ptemopen()
240 qprocson(q); in ptemopen()
241 putnext(q, mop); in ptemopen()
253 ptemclose(queue_t *q, int flag, cred_t *credp) in ptemclose() argument
257 qprocsoff(q); in ptemclose()
258 ntp = (struct ptem *)q->q_ptr; in ptemclose()
261 q->q_ptr = WR(q)->q_ptr = NULL; in ptemclose()
272 ptemrput(queue_t *q, mblk_t *mp) in ptemrput() argument
298 miocnak(q, mp, 0, error); in ptemrput()
302 if (!putnextctl(q, M_BREAK)) { in ptemrput()
306 miocnak(q, mp, 0, EAGAIN); in ptemrput()
314 qreply(q, mp); in ptemrput()
320 ptioc(q, mp, RDSIDE); in ptemrput()
346 qreply(q, mp); in ptemrput()
350 ptioc(q, mp, RDSIDE); in ptemrput()
355 ptioc(q, mp, RDSIDE); in ptemrput()
358 qreply(q, mp); in ptemrput()
363 putnext(q, mp); in ptemrput()
386 ptioc(q, mp, RDSIDE); in ptemrput()
393 qreply(q, mp); in ptemrput()
418 struct ptem *ntp = (struct ptem *)q->q_ptr; in ptemrput()
421 qenable(WR(q)); in ptemrput()
425 putnext(q, mp); in ptemrput()
441 ptemwput(queue_t *q, mblk_t *mp) in ptemwput() argument
443 struct ptem *ntp = (struct ptem *)q->q_ptr; in ptemwput()
467 ptioc(q, mp, WRSIDE); in ptemwput()
473 qreply(q, mp); in ptemwput()
485 flushband(q, *(mp->b_rptr + 1), FLUSHDATA); in ptemwput()
487 flushq(q, FLUSHDATA); in ptemwput()
489 putnext(q, mp); in ptemwput()
501 putnext(q, mp); in ptemwput()
509 putnext(q, mp); in ptemwput()
510 qenable(q); in ptemwput()
513 putnext(q, mp); in ptemwput()
522 if (q->q_first != NULL || !bcanputnext(q, mp->b_band)) { in ptemwput()
547 (void) ptemwmsg(q, mp); in ptemwput()
570 (void) putq(q, mp); in ptemwput()
576 if (!ptemwmsg(q, mp)) in ptemwput()
577 (void) putq(q, mp); in ptemwput()
584 ptemwsrv(queue_t *q) in ptemwsrv() argument
588 while ((mp = getq(q)) != NULL) { in ptemwsrv()
589 if (!bcanputnext(q, mp->b_band) || !ptemwmsg(q, mp)) { in ptemwsrv()
590 (void) putbq(q, mp); in ptemwsrv()
605 ptemwmsg(queue_t *q, mblk_t *mp) in ptemwmsg() argument
607 struct ptem *ntp = (struct ptem *)q->q_ptr; in ptemwmsg()
636 if (putnextctl1(q, M_FLUSH, FLUSHR) == 0) { in ptemwmsg()
637 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
653 miocnak(q, mp, 0, error); in ptemwmsg()
667 miocnak(q, mp, 0, error); in ptemwmsg()
688 putnext(q, dack_ptr); in ptemwmsg()
696 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
699 putnext(q, pckt_msgp); in ptemwmsg()
705 qreply(q, mp); in ptemwmsg()
712 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
718 qreply(q, mp); in ptemwmsg()
724 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
730 qreply(q, mp); in ptemwmsg()
736 miocnak(q, mp, 0, error); in ptemwmsg()
745 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
751 putnext(q, pckt_msgp); in ptemwmsg()
758 (void) putnextctl(q, M_BREAK); in ptemwmsg()
763 qreply(q, mp); in ptemwmsg()
769 ptioc(q, mp, WRSIDE); in ptemwmsg()
787 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
796 miocnak(q, mp, 0, error); in ptemwmsg()
808 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
815 if (!bcanputnext(RD(q), mp->b_band)) { in ptemwmsg()
818 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
822 qreply(q, bp); in ptemwmsg()
825 putnext(q, pckt_msgp); in ptemwmsg()
827 qreply(q, mp); in ptemwmsg()
832 miocnak(q, mp, 0, EEXIST); in ptemwmsg()
836 qreply(q, mp); in ptemwmsg()
845 miocnak(q, mp, 0, EINVAL); in ptemwmsg()
871 putnext(q, mp); in ptemwmsg()
883 ptioc(queue_t *q, mblk_t *mp, int qside) in ptioc() argument
894 tp = (struct ptem *)q->q_ptr; in ptioc()
905 miocnak(q, mp, 0, EINVAL); in ptioc()
911 miocnak(q, mp, 0, EAGAIN); in ptioc()
926 qreply(q, mp); in ptioc()
935 miocnak(q, mp, 0, EINVAL); in ptioc()
941 miocnak(q, mp, 0, EAGAIN); in ptioc()
953 qreply(q, mp); in ptioc()
959 miocnak(q, mp, 0, error); in ptioc()
976 (void) putnextctl1(RD(q), M_SIG, SIGWINCH); in ptioc()
978 (void) putnextctl1(q, M_SIG, SIGWINCH); in ptioc()
991 miocnak(q, mp, 0, EAGAIN); in ptioc()
994 putnext(q, pckt_msgp); in ptioc()
1003 qreply(q, mp); in ptioc()
1016 miocnak(q, mp, 0, error); in ptioc()
1027 miocnak(q, mp, 0, EINVAL); in ptioc()
1036 if (putnextctl1(q, M_PCSIG, sig) == 0) { in ptioc()
1037 miocnak(q, mp, 0, EAGAIN); in ptioc()
1042 qreply(q, mp); in ptioc()
1053 miocnak(q, mp, 0, error); in ptioc()
1065 miocnak(q, mp, 0, EAGAIN); in ptioc()
1069 putnext(q, mctlp); in ptioc()
1075 qreply(q, mp); in ptioc()
1088 putnext(q, mp); in ptioc()