Lines Matching refs:q
150 queue_t *q, /* pointer to the read side queue */ in ptemopen() argument
165 if (q->q_ptr != NULL) { in ptemopen()
209 ntp->q_ptr = q; in ptemopen()
210 q->q_ptr = ntp; in ptemopen()
211 WR(q)->q_ptr = ntp; in ptemopen()
239 qprocson(q); in ptemopen()
240 putnext(q, mop); in ptemopen()
252 ptemclose(queue_t *q, int flag, cred_t *credp) in ptemclose() argument
256 qprocsoff(q); in ptemclose()
257 ntp = (struct ptem *)q->q_ptr; in ptemclose()
260 q->q_ptr = WR(q)->q_ptr = NULL; in ptemclose()
271 ptemrput(queue_t *q, mblk_t *mp) in ptemrput() argument
297 miocnak(q, mp, 0, error); in ptemrput()
301 if (!putnextctl(q, M_BREAK)) { in ptemrput()
305 miocnak(q, mp, 0, EAGAIN); in ptemrput()
313 qreply(q, mp); in ptemrput()
319 ptioc(q, mp, RDSIDE); in ptemrput()
345 qreply(q, mp); in ptemrput()
349 ptioc(q, mp, RDSIDE); in ptemrput()
354 ptioc(q, mp, RDSIDE); in ptemrput()
357 qreply(q, mp); in ptemrput()
362 putnext(q, mp); in ptemrput()
385 ptioc(q, mp, RDSIDE); in ptemrput()
392 qreply(q, mp); in ptemrput()
417 struct ptem *ntp = (struct ptem *)q->q_ptr; in ptemrput()
420 qenable(WR(q)); in ptemrput()
425 putnext(q, mp); in ptemrput()
442 ptemwput(queue_t *q, mblk_t *mp) in ptemwput() argument
444 struct ptem *ntp = (struct ptem *)q->q_ptr; in ptemwput()
468 ptioc(q, mp, WRSIDE); in ptemwput()
474 qreply(q, mp); in ptemwput()
486 flushband(q, *(mp->b_rptr + 1), in ptemwput()
489 flushq(q, FLUSHDATA); in ptemwput()
491 putnext(q, mp); in ptemwput()
503 putnext(q, mp); in ptemwput()
511 putnext(q, mp); in ptemwput()
512 qenable(q); in ptemwput()
515 putnext(q, mp); in ptemwput()
524 if (q->q_first != NULL || !bcanputnext(q, mp->b_band)) { in ptemwput()
549 (void) ptemwmsg(q, mp); in ptemwput()
572 (void) putq(q, mp); in ptemwput()
578 if (!ptemwmsg(q, mp)) in ptemwput()
579 (void) putq(q, mp); in ptemwput()
587 ptemwsrv(queue_t *q) in ptemwsrv() argument
591 while ((mp = getq(q)) != NULL) { in ptemwsrv()
592 if (!bcanputnext(q, mp->b_band) || !ptemwmsg(q, mp)) { in ptemwsrv()
593 (void) putbq(q, mp); in ptemwsrv()
609 ptemwmsg(queue_t *q, mblk_t *mp) in ptemwmsg() argument
611 struct ptem *ntp = (struct ptem *)q->q_ptr; in ptemwmsg()
640 if (putnextctl1(q, M_FLUSH, FLUSHR) == 0) { in ptemwmsg()
641 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
657 miocnak(q, mp, 0, error); in ptemwmsg()
671 miocnak(q, mp, 0, error); in ptemwmsg()
692 putnext(q, dack_ptr); in ptemwmsg()
700 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
703 putnext(q, pckt_msgp); in ptemwmsg()
709 qreply(q, mp); in ptemwmsg()
716 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
722 qreply(q, mp); in ptemwmsg()
728 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
734 qreply(q, mp); in ptemwmsg()
740 miocnak(q, mp, 0, error); in ptemwmsg()
749 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
755 putnext(q, pckt_msgp); in ptemwmsg()
762 (void) putnextctl(q, M_BREAK); in ptemwmsg()
767 qreply(q, mp); in ptemwmsg()
773 ptioc(q, mp, WRSIDE); in ptemwmsg()
791 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
800 miocnak(q, mp, 0, error); in ptemwmsg()
812 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
819 if (!bcanputnext(RD(q), mp->b_band)) { in ptemwmsg()
822 miocnak(q, mp, 0, EAGAIN); in ptemwmsg()
826 qreply(q, bp); in ptemwmsg()
829 putnext(q, pckt_msgp); in ptemwmsg()
831 qreply(q, mp); in ptemwmsg()
836 miocnak(q, mp, 0, EEXIST); in ptemwmsg()
840 qreply(q, mp); in ptemwmsg()
850 miocnak(q, mp, 0, EINVAL); in ptemwmsg()
877 putnext(q, mp); in ptemwmsg()
889 ptioc(queue_t *q, mblk_t *mp, int qside) in ptioc() argument
900 tp = (struct ptem *)q->q_ptr; in ptioc()
911 miocnak(q, mp, 0, EINVAL); in ptioc()
917 miocnak(q, mp, 0, EAGAIN); in ptioc()
932 qreply(q, mp); in ptioc()
941 miocnak(q, mp, 0, EINVAL); in ptioc()
947 miocnak(q, mp, 0, EAGAIN); in ptioc()
959 qreply(q, mp); in ptioc()
965 miocnak(q, mp, 0, error); in ptioc()
982 (void) putnextctl1(RD(q), M_SIG, SIGWINCH); in ptioc()
984 (void) putnextctl1(q, M_SIG, SIGWINCH); in ptioc()
997 miocnak(q, mp, 0, EAGAIN); in ptioc()
1000 putnext(q, pckt_msgp); in ptioc()
1009 qreply(q, mp); in ptioc()
1022 miocnak(q, mp, 0, error); in ptioc()
1033 miocnak(q, mp, 0, EINVAL); in ptioc()
1042 if (putnextctl1(q, M_PCSIG, sig) == 0) { in ptioc()
1043 miocnak(q, mp, 0, EAGAIN); in ptioc()
1048 qreply(q, mp); in ptioc()
1059 miocnak(q, mp, 0, error); in ptioc()
1071 miocnak(q, mp, 0, EAGAIN); in ptioc()
1075 putnext(q, mctlp); in ptioc()
1081 qreply(q, mp); in ptioc()
1094 putnext(q, mp); in ptioc()