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