Lines Matching refs:q
279 logdmuxopen(queue_t *q, dev_t *devp, int flag, int sflag, cred_t *crp) in logdmuxopen() argument
315 tmxp->rdq = q; in logdmuxopen()
322 q->q_ptr = tmxp; in logdmuxopen()
323 WR(q)->q_ptr = tmxp; in logdmuxopen()
325 qprocson(q); in logdmuxopen()
334 logdmuxclose(queue_t *q, int flag, cred_t *crp) in logdmuxclose() argument
336 struct tmx *tmxp = q->q_ptr; in logdmuxclose()
342 qprocsoff(q); in logdmuxclose()
344 qunbufcall(q, tmxp->wbufcid); in logdmuxclose()
348 qunbufcall(q, tmxp->rbufcid); in logdmuxclose()
352 (void) quntimeout(q, tmxp->rtimoutid); in logdmuxclose()
356 (void) quntimeout(q, tmxp->wtimoutid); in logdmuxclose()
360 (void) quntimeout(q, tmxp->utimoutid); in logdmuxclose()
374 q->q_ptr = NULL; in logdmuxclose()
375 WR(q)->q_ptr = NULL; in logdmuxclose()
384 logdmuxursrv(queue_t *q) in logdmuxursrv() argument
386 struct tmx *tmxp = q->q_ptr; in logdmuxursrv()
398 logdmuxuwput(queue_t *q, mblk_t *mp) in logdmuxuwput() argument
408 tmxp = q->q_ptr; in logdmuxuwput()
425 miocnak(q, mp, 0, error); in logdmuxuwput()
447 miocnak(q, mp, 0, EINVAL); in logdmuxuwput()
469 miocnak(q, mp, 0, EINVAL); in logdmuxuwput()
487 miocnak(q, mp, 0, error); in logdmuxuwput()
495 miocack(q, mp, 0, 0); in logdmuxuwput()
500 logdmuxlink(q, mp); in logdmuxuwput()
505 logdmuxunlink(q, mp); in logdmuxuwput()
510 miocnak(q, mp, 0, EINVAL); in logdmuxuwput()
522 recover(q, mp, sizeof (char)); in logdmuxuwput()
536 merror(q, mp, EINVAL); in logdmuxuwput()
541 if (q->q_first != NULL || !canputnext(qp)) { in logdmuxuwput()
542 (void) putq(q, mp); in logdmuxuwput()
551 flushq(q, FLUSHALL); in logdmuxuwput()
560 qreply(q, mp); in logdmuxuwput()
577 logdmuxuwsrv(queue_t *q) in logdmuxuwsrv() argument
581 struct tmx *tmxp = q->q_ptr; in logdmuxuwsrv()
583 while ((mp = getq(q)) != NULL) { in logdmuxuwsrv()
589 recover(q, mp, sizeof (char)); in logdmuxuwsrv()
602 merror(q, mp, EIO); in logdmuxuwsrv()
607 (void) putbq(q, mp); in logdmuxuwsrv()
630 logdmuxlrput(queue_t *q, mblk_t *mp) in logdmuxlrput() argument
635 struct tmx *tmxp = q->q_ptr; in logdmuxlrput()
650 if ((q->q_first != NULL) && (queclass(mp) < QPCTL) && in logdmuxlrput()
652 (void) putq(q, mp); in logdmuxlrput()
679 miocnak(q, mp, 0, 0); in logdmuxlrput()
738 if (q->q_first != NULL || !canputnext(qp)) { in logdmuxlrput()
739 (void) putq(q, mp); in logdmuxlrput()
782 flushq_dataonly(q); in logdmuxlrput()
822 if (q->q_first != NULL || !canputnext(qp)) { in logdmuxlrput()
823 (void) putq(q, mp); in logdmuxlrput()
835 logdmuxlrsrv(queue_t *q) in logdmuxlrsrv() argument
840 struct tmx *tmxp = q->q_ptr; in logdmuxlrsrv()
842 while ((mp = getq(q)) != NULL) { in logdmuxlrsrv()
873 miocnak(q, mp, 0, 0); in logdmuxlrsrv()
886 (void) putbq(q, mp); in logdmuxlrsrv()
911 (void) putbq(q, mp); in logdmuxlrsrv()
925 logdmuxlwsrv(queue_t *q) in logdmuxlwsrv() argument
927 struct tmx *tmxp = q->q_ptr; in logdmuxlwsrv()
949 logdmuxlink(queue_t *q, mblk_t *mp) in logdmuxlink() argument
951 struct tmx *tmxp = q->q_ptr; in logdmuxlink()
958 miocnak(q, mp, 0, EINVAL); in logdmuxlink()
966 miocack(q, mp, 0, 0); in logdmuxlink()
978 logdmuxunlink(queue_t *q, mblk_t *mp) in logdmuxunlink() argument
980 struct tmx *tmxp = q->q_ptr; in logdmuxunlink()
998 miocack(q, mp, 0, 0); in logdmuxunlink()
1043 tmxp->utimoutid = qtimeout(q, logdmux_unlink_timer, q, in logdmuxunlink()
1055 logdmux_finish_unlink(q, mp); in logdmuxunlink()
1071 logdmux_finish_unlink(queue_t *q, mblk_t *unlink_mp) in logdmux_finish_unlink() argument
1073 struct tmx *tmxp = q->q_ptr; in logdmux_finish_unlink()
1079 while ((mp = getq(WR(q))) != NULL) in logdmux_finish_unlink()
1092 miocack(q, unlink_mp, 0, 0); in logdmux_finish_unlink()
1103 queue_t *q = arg; in logdmux_unlink_timer() local
1104 struct tmx *tmxp = q->q_ptr; in logdmux_unlink_timer()
1117 tmxp->utimoutid = qtimeout(q, logdmux_unlink_timer, q, in logdmux_unlink_timer()
1128 logdmux_finish_unlink(q, tmxp->unlink_mp); in logdmux_unlink_timer()
1135 queue_t *q = arg; in logdmux_timer() local
1136 struct tmx *tmxp = q->q_ptr; in logdmux_timer()
1140 if (q->q_flag & QREADR) { in logdmux_timer()
1147 enableok(q); in logdmux_timer()
1148 qenable(q); in logdmux_timer()
1154 queue_t *q = arg; in logdmux_buffer() local
1155 struct tmx *tmxp = q->q_ptr; in logdmux_buffer()
1159 if (q->q_flag & QREADR) { in logdmux_buffer()
1166 enableok(q); in logdmux_buffer()
1167 qenable(q); in logdmux_buffer()
1171 recover(queue_t *q, mblk_t *mp, size_t size) in recover() argument
1175 struct tmx *tmxp = q->q_ptr; in recover()
1181 ASSERT(WR(q)->q_next == NULL); /* Called from upper queue only */ in recover()
1182 noenable(q); in recover()
1183 (void) putbq(q, mp); in recover()
1188 if (q->q_flag & QREADR) { in recover()
1195 if (!(bid = qbufcall(RD(q), size, BPRI_MED, logdmux_buffer, q))) { in recover()
1196 tid = qtimeout(RD(q), logdmux_timer, q, drv_usectohz(SIMWAIT)); in recover()
1197 if (q->q_flag & QREADR) in recover()
1202 if (q->q_flag & QREADR) in recover()
1210 flushq_dataonly(queue_t *q) in flushq_dataonly() argument
1219 mp = q->q_first; in flushq_dataonly()
1223 rmvq(q, mp); in flushq_dataonly()