Lines Matching refs:mp

314 	mblk_t  *mp;  in rlmodclose()  local
322 while (mp = getq(WR(q))) in rlmodclose()
323 putnext(WR(q), mp); in rlmodclose()
366 rlmodrput(queue_t *q, mblk_t *mp) in rlmodrput() argument
372 "q %p, mp %p", q, mp); in rlmodrput()
376 if ((mp->b_datap->db_type < QPCTL) && in rlmodrput()
381 (mp->b_datap->db_type == M_DATA)))) { in rlmodrput()
383 (void) putq(q, mp); in rlmodrput()
385 "rlmodrput end: q %p, mp %p, %s", q, mp, "flow"); in rlmodrput()
389 switch (mp->b_datap->db_type) { in rlmodrput()
393 tip = (union T_primitives *)mp->b_rptr; in rlmodrput()
399 mp->b_datap->db_type = M_HANGUP; in rlmodrput()
400 mp->b_wptr = mp->b_rptr; in rlmodrput()
401 if (mp->b_cont) { in rlmodrput()
402 freemsg(mp->b_cont); in rlmodrput()
403 mp->b_cont = NULL; in rlmodrput()
412 putnext(q, mp); in rlmodrput()
416 putnext(q, mp); in rlmodrput()
426 freemsg(mp); in rlmodrput()
433 freemsg(mp); in rlmodrput()
439 (void) rlmodrmsg(q, mp); in rlmodrput()
441 (void) putq(q, mp); in rlmodrput()
451 mp->b_flag |= MSGMARK; in rlmodrput()
452 if (*mp->b_rptr & FLUSHR) in rlmodrput()
455 putnext(q, mp); in rlmodrput()
463 if (mp->b_datap->db_type <= QPCTL && !canputnext(q)) in rlmodrput()
464 (void) putq(q, mp); in rlmodrput()
466 putnext(q, mp); in rlmodrput()
472 mp->b_datap->db_type); in rlmodrput()
474 freemsg(mp); in rlmodrput()
477 "mp %p, %s", q, mp, "done"); in rlmodrput()
487 mblk_t *mp; in rlmodrsrv() local
493 while ((mp = getq(q)) != NULL) { in rlmodrsrv()
495 switch (mp->b_datap->db_type) { in rlmodrsrv()
498 (void) putbq(q, mp); in rlmodrsrv()
500 "rlmodrsrv end: q %p, mp %p, %s", q, mp, in rlmodrsrv()
505 (void) putbq(q, mp); in rlmodrsrv()
508 q, mp, "!canputnext"); in rlmodrsrv()
511 if (!rlmodrmsg(q, mp)) { in rlmodrsrv()
514 q, mp, "!rlmodrmsg"); in rlmodrsrv()
520 tip = (union T_primitives *)mp->b_rptr; in rlmodrsrv()
526 mp->b_datap->db_type = M_HANGUP; in rlmodrsrv()
527 mp->b_wptr = mp->b_rptr; in rlmodrsrv()
528 if (mp->b_cont) { in rlmodrsrv()
529 freemsg(mp->b_cont); in rlmodrsrv()
530 mp->b_cont = NULL; in rlmodrsrv()
539 putnext(q, mp); in rlmodrsrv()
543 putnext(q, mp); in rlmodrsrv()
553 freemsg(mp); in rlmodrsrv()
560 freemsg(mp); in rlmodrsrv()
566 (void) putbq(q, mp); in rlmodrsrv()
569 q, mp, "!canputnext M_SETOPTS"); in rlmodrsrv()
572 putnext(q, mp); in rlmodrsrv()
579 mp->b_datap->db_type); in rlmodrsrv()
581 freemsg(mp); in rlmodrsrv()
586 "mp %p, %s", q, mp, "empty"); in rlmodrsrv()
596 rlmodwput(queue_t *q, mblk_t *mp) in rlmodwput() argument
604 "q %p, mp %p", q, mp); in rlmodwput()
614 (void) putq(q, mp); in rlmodwput()
617 q, mp, "expdata && !canputnext"); in rlmodwput()
628 if ((q->q_first || rmip->rl_expdat) && mp->b_datap->db_type < QPCTL) { in rlmodwput()
629 (void) putq(q, mp); in rlmodwput()
631 "q %p, mp %p, %s", q, mp, "queued data"); in rlmodwput()
634 switch (mp->b_datap->db_type) { in rlmodwput()
638 (void) putq(q, mp); in rlmodwput()
640 putnext(q, mp); in rlmodwput()
648 rw = *mp->b_rptr; in rlmodwput()
649 *mp->b_rptr &= ~FLUSHW; in rlmodwput()
650 qreply(q, mp); in rlmodwput()
677 q, mp, "flushw && !canputnext"); in rlmodwput()
680 if ((mp = make_expmblk(cntl)) == NULL) { in rlmodwput()
685 q, mp, "!make_expmblk"); in rlmodwput()
688 putnext(q, mp); in rlmodwput()
693 if (!rlmodwioctl(q, mp)) in rlmodwput()
694 (void) putq(q, mp); in rlmodwput()
698 switch (((union T_primitives *)mp->b_rptr)->type) { in rlmodwput()
702 putnext(q, mp); in rlmodwput()
709 ((union T_primitives *)mp->b_rptr)->type); in rlmodwput()
711 freemsg(mp); in rlmodwput()
716 if (((struct T_exdata_req *)mp->b_rptr)->PRIM_type == in rlmodwput()
718 putnext(q, mp); in rlmodwput()
721 freemsg(mp); in rlmodwput()
729 mp->b_datap->db_type); in rlmodwput()
731 freemsg(mp); in rlmodwput()
735 "q %p, mp %p, %s", q, mp, "done"); in rlmodwput()
745 mblk_t *mp, *tmpmp; in rlmodwsrv() local
774 while ((mp = getq(q)) != NULL) { in rlmodwsrv()
777 (void) putbq(q, mp); in rlmodwsrv()
780 q, mp, "!canputnext || expdat"); in rlmodwsrv()
783 if (mp->b_datap->db_type == M_IOCTL) { in rlmodwsrv()
784 if (!rlmodwioctl(q, mp)) { in rlmodwsrv()
787 q, mp, "!rlmodwioctl"); in rlmodwsrv()
788 (void) putbq(q, mp); in rlmodwsrv()
793 putnext(q, mp); in rlmodwsrv()
796 "mp %p, %s", q, mp, "done"); in rlmodwsrv()
807 mblk_t *mp; in make_expmblk() local
814 if ((mp = allocb(sizeof (char), BPRI_MED)) == NULL) { in make_expmblk()
828 mp->b_datap->db_type = M_DATA; in make_expmblk()
829 mp->b_wptr = mp->b_rptr + 1; in make_expmblk()
830 (*(char *)(mp->b_rptr)) = cntl; in make_expmblk()
831 bp->b_cont = mp; in make_expmblk()
841 rlmodrmsg(queue_t *q, mblk_t *mp) in rlmodrmsg() argument
853 if (msgdsize(mp) == 0) { in rlmodrmsg()
863 linkb(rmip->wndw_sz_hd_mp, mp); in rlmodrmsg()
864 mp = rmip->wndw_sz_hd_mp; in rlmodrmsg()
867 newmp = mp; in rlmodrmsg()
869 while (mp) { in rlmodrmsg()
870 tmp = mp->b_rptr; in rlmodrmsg()
874 while (tmp < mp->b_wptr) { in rlmodrmsg()
882 count = newcount + tmp - mp->b_rptr; in rlmodrmsg()
897 mp = newmp; in rlmodrmsg()
905 tmp = mp->b_rptr + count; in rlmodrmsg()
916 if (tmp1 > mp->b_wptr) { in rlmodrmsg()
924 rmip->wndw_sz_hd_mp = mp; in rlmodrmsg()
943 if (rlwinsetup(q, mp, tmp) == NULL) { in rlmodrmsg()
944 sz = msgdsize(mp); in rlmodrmsg()
945 recover(q, mp, sz); in rlmodrmsg()
965 newcount += (mp->b_wptr - mp->b_rptr); in rlmodrmsg()
966 mp = mp->b_cont; in rlmodrmsg()
994 rlwinctl(queue_t *q, mblk_t *mp) in rlwinctl() argument
1001 "mp %p", q, mp); in rlwinctl()
1007 "q %p, mp %p, allocb failed", q, mp); in rlwinctl()
1014 rl_msgp->b_cont = mp; in rlwinctl()
1016 iocbp->ioc_count = msgdsize(mp); in rlwinctl()
1020 "q %p, mp %p, done", q, mp); in rlwinctl()
1031 rlwinsetup(queue_t *q, mblk_t *mp, unsigned char *blk) in rlwinsetup() argument
1043 left = mp->b_wptr - jmpmp; in rlwinsetup()
1067 mp->b_wptr = blk + left; in rlwinsetup()
1069 mp->b_wptr = blk; in rlwinsetup()
1070 return (mp); in rlwinsetup()
1084 tty_flow(queue_t *q, struct rlmod_info *rmip, mblk_t *mp) in tty_flow() argument
1094 ioc = (struct iocblk *)mp->b_rptr; in tty_flow()
1105 error = miocpullup(mp, sizeof (struct termios)); in tty_flow()
1107 miocnak(q, mp, 0, error); in tty_flow()
1110 tp = (struct termios *)(mp->b_cont->b_rptr); in tty_flow()
1119 error = miocpullup(mp, sizeof (struct termio)); in tty_flow()
1121 miocnak(q, mp, 0, error); in tty_flow()
1124 ti = (struct termio *)(mp->b_cont->b_rptr); in tty_flow()
1137 miocnak(q, mp, 0, EINVAL); in tty_flow()
1150 recover(q, mp, sizeof (mblk_t)); in tty_flow()
1164 recover(q, mp, sizeof (mblk_t)); in tty_flow()
1176 miocack(q, mp, 0, 0); in tty_flow()
1183 rlmodwioctl(queue_t *q, mblk_t *mp) in rlmodwioctl() argument
1189 ioc = (struct iocblk *)mp->b_rptr; in rlmodwioctl()
1203 miocnak(q, mp, 0, EINVAL); in rlmodwioctl()
1206 if (mp->b_cont) { in rlmodwioctl()
1207 (void) putbq(RD(q), mp->b_cont); in rlmodwioctl()
1208 mp->b_cont = NULL; in rlmodwioctl()
1214 miocack(q, mp, 0, 0); in rlmodwioctl()
1217 q, mp, "IOCACK enable"); in rlmodwioctl()
1231 return (tty_flow(q, rmip, mp)); in rlmodwioctl()
1237 miocnak(q, mp, 0, EINVAL); in rlmodwioctl()
1241 error = miocpullup(mp, sizeof (uchar_t)); in rlmodwioctl()
1243 miocnak(q, mp, 0, error); in rlmodwioctl()
1246 if (*(mp->b_cont->b_rptr) == 0x01) in rlmodwioctl()
1251 miocack(q, mp, NULL, 0); in rlmodwioctl()
1256 putnext(q, mp); in rlmodwioctl()
1263 miocnak(q, mp, 0, EINVAL); in rlmodwioctl()
1306 recover(queue_t *q, mblk_t *mp, size_t size) in recover() argument
1311 ASSERT(mp->b_datap->db_type < QPCTL); in recover()
1314 (void) putbq(q, mp); in recover()