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