Lines Matching refs:mp
313 mblk_t *mp; in rlmodclose() local
321 while (mp = getq(WR(q))) in rlmodclose()
322 putnext(WR(q), mp); in rlmodclose()
365 rlmodrput(queue_t *q, mblk_t *mp) in rlmodrput() argument
371 "q %p, mp %p", q, mp); in rlmodrput()
375 if ((mp->b_datap->db_type < QPCTL) && in rlmodrput()
380 (mp->b_datap->db_type == M_DATA)))) { in rlmodrput()
382 (void) putq(q, mp); in rlmodrput()
384 "rlmodrput end: q %p, mp %p, %s", q, mp, "flow"); in rlmodrput()
388 switch (mp->b_datap->db_type) { in rlmodrput()
392 tip = (union T_primitives *)mp->b_rptr; in rlmodrput()
398 mp->b_datap->db_type = M_HANGUP; in rlmodrput()
399 mp->b_wptr = mp->b_rptr; in rlmodrput()
400 if (mp->b_cont) { in rlmodrput()
401 freemsg(mp->b_cont); in rlmodrput()
402 mp->b_cont = NULL; in rlmodrput()
411 putnext(q, mp); in rlmodrput()
415 putnext(q, mp); in rlmodrput()
425 freemsg(mp); in rlmodrput()
432 freemsg(mp); in rlmodrput()
438 (void) rlmodrmsg(q, mp); in rlmodrput()
440 (void) putq(q, mp); in rlmodrput()
450 mp->b_flag |= MSGMARK; in rlmodrput()
451 if (*mp->b_rptr & FLUSHR) in rlmodrput()
454 putnext(q, mp); in rlmodrput()
462 if (mp->b_datap->db_type <= QPCTL && !canputnext(q)) in rlmodrput()
463 (void) putq(q, mp); in rlmodrput()
465 putnext(q, mp); in rlmodrput()
471 mp->b_datap->db_type); in rlmodrput()
473 freemsg(mp); in rlmodrput()
476 "mp %p, %s", q, mp, "done"); in rlmodrput()
486 mblk_t *mp; in rlmodrsrv() local
492 while ((mp = getq(q)) != NULL) { in rlmodrsrv()
494 switch (mp->b_datap->db_type) { in rlmodrsrv()
497 (void) putbq(q, mp); in rlmodrsrv()
499 "rlmodrsrv end: q %p, mp %p, %s", q, mp, in rlmodrsrv()
504 (void) putbq(q, mp); in rlmodrsrv()
507 q, mp, "!canputnext"); in rlmodrsrv()
510 if (!rlmodrmsg(q, mp)) { in rlmodrsrv()
513 q, mp, "!rlmodrmsg"); in rlmodrsrv()
519 tip = (union T_primitives *)mp->b_rptr; in rlmodrsrv()
525 mp->b_datap->db_type = M_HANGUP; in rlmodrsrv()
526 mp->b_wptr = mp->b_rptr; in rlmodrsrv()
527 if (mp->b_cont) { in rlmodrsrv()
528 freemsg(mp->b_cont); in rlmodrsrv()
529 mp->b_cont = NULL; in rlmodrsrv()
538 putnext(q, mp); in rlmodrsrv()
542 putnext(q, mp); in rlmodrsrv()
552 freemsg(mp); in rlmodrsrv()
559 freemsg(mp); in rlmodrsrv()
565 (void) putbq(q, mp); in rlmodrsrv()
568 q, mp, "!canputnext M_SETOPTS"); in rlmodrsrv()
571 putnext(q, mp); in rlmodrsrv()
578 mp->b_datap->db_type); in rlmodrsrv()
580 freemsg(mp); in rlmodrsrv()
585 "mp %p, %s", q, mp, "empty"); in rlmodrsrv()
595 rlmodwput(queue_t *q, mblk_t *mp) in rlmodwput() argument
603 "q %p, mp %p", q, mp); in rlmodwput()
613 (void) putq(q, mp); in rlmodwput()
616 q, mp, "expdata && !canputnext"); in rlmodwput()
627 if ((q->q_first || rmip->rl_expdat) && mp->b_datap->db_type < QPCTL) { in rlmodwput()
628 (void) putq(q, mp); in rlmodwput()
630 "q %p, mp %p, %s", q, mp, "queued data"); in rlmodwput()
633 switch (mp->b_datap->db_type) { in rlmodwput()
637 (void) putq(q, mp); in rlmodwput()
639 putnext(q, mp); in rlmodwput()
647 rw = *mp->b_rptr; in rlmodwput()
648 *mp->b_rptr &= ~FLUSHW; in rlmodwput()
649 qreply(q, mp); in rlmodwput()
676 q, mp, "flushw && !canputnext"); in rlmodwput()
679 if ((mp = make_expmblk(cntl)) == NULL) { in rlmodwput()
684 q, mp, "!make_expmblk"); in rlmodwput()
687 putnext(q, mp); in rlmodwput()
692 if (!rlmodwioctl(q, mp)) in rlmodwput()
693 (void) putq(q, mp); in rlmodwput()
697 switch (((union T_primitives *)mp->b_rptr)->type) { in rlmodwput()
701 putnext(q, mp); in rlmodwput()
708 ((union T_primitives *)mp->b_rptr)->type); in rlmodwput()
710 freemsg(mp); in rlmodwput()
715 if (((struct T_exdata_req *)mp->b_rptr)->PRIM_type == in rlmodwput()
717 putnext(q, mp); in rlmodwput()
720 freemsg(mp); in rlmodwput()
728 mp->b_datap->db_type); in rlmodwput()
730 freemsg(mp); in rlmodwput()
734 "q %p, mp %p, %s", q, mp, "done"); in rlmodwput()
744 mblk_t *mp, *tmpmp; in rlmodwsrv() local
773 while ((mp = getq(q)) != NULL) { in rlmodwsrv()
776 (void) putbq(q, mp); in rlmodwsrv()
779 q, mp, "!canputnext || expdat"); in rlmodwsrv()
782 if (mp->b_datap->db_type == M_IOCTL) { in rlmodwsrv()
783 if (!rlmodwioctl(q, mp)) { in rlmodwsrv()
786 q, mp, "!rlmodwioctl"); in rlmodwsrv()
787 (void) putbq(q, mp); in rlmodwsrv()
792 putnext(q, mp); in rlmodwsrv()
795 "mp %p, %s", q, mp, "done"); in rlmodwsrv()
806 mblk_t *mp; in make_expmblk() local
813 if ((mp = allocb(sizeof (char), BPRI_MED)) == NULL) { in make_expmblk()
827 mp->b_datap->db_type = M_DATA; in make_expmblk()
828 mp->b_wptr = mp->b_rptr + 1; in make_expmblk()
829 (*(char *)(mp->b_rptr)) = cntl; in make_expmblk()
830 bp->b_cont = mp; in make_expmblk()
840 rlmodrmsg(queue_t *q, mblk_t *mp) in rlmodrmsg() argument
852 if (msgdsize(mp) == 0) { in rlmodrmsg()
862 linkb(rmip->wndw_sz_hd_mp, mp); in rlmodrmsg()
863 mp = rmip->wndw_sz_hd_mp; in rlmodrmsg()
866 newmp = mp; in rlmodrmsg()
868 while (mp) { in rlmodrmsg()
869 tmp = mp->b_rptr; in rlmodrmsg()
873 while (tmp < mp->b_wptr) { in rlmodrmsg()
881 count = newcount + tmp - mp->b_rptr; in rlmodrmsg()
896 mp = newmp; in rlmodrmsg()
904 tmp = mp->b_rptr + count; in rlmodrmsg()
915 if (tmp1 > mp->b_wptr) { in rlmodrmsg()
923 rmip->wndw_sz_hd_mp = mp; in rlmodrmsg()
942 if (rlwinsetup(q, mp, tmp) == NULL) { in rlmodrmsg()
943 sz = msgdsize(mp); in rlmodrmsg()
944 recover(q, mp, sz); in rlmodrmsg()
964 newcount += (mp->b_wptr - mp->b_rptr); in rlmodrmsg()
965 mp = mp->b_cont; in rlmodrmsg()
993 rlwinctl(queue_t *q, mblk_t *mp) in rlwinctl() argument
1000 "mp %p", q, mp); in rlwinctl()
1006 "q %p, mp %p, allocb failed", q, mp); in rlwinctl()
1013 rl_msgp->b_cont = mp; in rlwinctl()
1015 iocbp->ioc_count = msgdsize(mp); in rlwinctl()
1019 "q %p, mp %p, done", q, mp); in rlwinctl()
1030 rlwinsetup(queue_t *q, mblk_t *mp, unsigned char *blk) in rlwinsetup() argument
1042 left = mp->b_wptr - jmpmp; in rlwinsetup()
1066 mp->b_wptr = blk + left; in rlwinsetup()
1068 mp->b_wptr = blk; in rlwinsetup()
1069 return (mp); in rlwinsetup()
1083 tty_flow(queue_t *q, struct rlmod_info *rmip, mblk_t *mp) in tty_flow() argument
1093 ioc = (struct iocblk *)mp->b_rptr; in tty_flow()
1104 error = miocpullup(mp, sizeof (struct termios)); in tty_flow()
1106 miocnak(q, mp, 0, error); in tty_flow()
1109 tp = (struct termios *)(mp->b_cont->b_rptr); in tty_flow()
1118 error = miocpullup(mp, sizeof (struct termio)); in tty_flow()
1120 miocnak(q, mp, 0, error); in tty_flow()
1123 ti = (struct termio *)(mp->b_cont->b_rptr); in tty_flow()
1136 miocnak(q, mp, 0, EINVAL); in tty_flow()
1149 recover(q, mp, sizeof (mblk_t)); in tty_flow()
1163 recover(q, mp, sizeof (mblk_t)); in tty_flow()
1175 miocack(q, mp, 0, 0); in tty_flow()
1182 rlmodwioctl(queue_t *q, mblk_t *mp) in rlmodwioctl() argument
1188 ioc = (struct iocblk *)mp->b_rptr; in rlmodwioctl()
1202 miocnak(q, mp, 0, EINVAL); in rlmodwioctl()
1205 if (mp->b_cont) { in rlmodwioctl()
1206 (void) putbq(RD(q), mp->b_cont); in rlmodwioctl()
1207 mp->b_cont = NULL; in rlmodwioctl()
1213 miocack(q, mp, 0, 0); in rlmodwioctl()
1216 q, mp, "IOCACK enable"); in rlmodwioctl()
1230 return (tty_flow(q, rmip, mp)); in rlmodwioctl()
1236 miocnak(q, mp, 0, EINVAL); in rlmodwioctl()
1240 error = miocpullup(mp, sizeof (uchar_t)); in rlmodwioctl()
1242 miocnak(q, mp, 0, error); in rlmodwioctl()
1245 if (*(mp->b_cont->b_rptr) == 0x01) in rlmodwioctl()
1250 miocack(q, mp, 0, 0); in rlmodwioctl()
1255 putnext(q, mp); in rlmodwioctl()
1262 miocnak(q, mp, 0, EINVAL); in rlmodwioctl()
1305 recover(queue_t *q, mblk_t *mp, size_t size) in recover() argument
1310 ASSERT(mp->b_datap->db_type < QPCTL); in recover()
1313 (void) putbq(q, mp); in recover()