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