Lines Matching refs:mp1
739 mblk_t *mp1; in tcp_reass() local
761 mp1 = tcp->tcp_reass_tail; in tcp_reass()
762 if (mp1 == NULL || SEQ_GEQ(start, TCP_REASS_END(mp1))) { in tcp_reass()
763 if (mp1 != NULL) { in tcp_reass()
768 mp1->b_cont = mp; in tcp_reass()
779 mp1 = tcp->tcp_reass_head; in tcp_reass()
780 u1 = TCP_REASS_SEQ(mp1); in tcp_reass()
784 mp->b_cont = mp1; in tcp_reass()
793 for (; (mp2 = mp1->b_cont) != NULL; mp1 = mp2) { in tcp_reass()
800 mp1->b_cont = mp; in tcp_reass()
806 tcp_reass_elim_overlap(tcp, mp1); in tcp_reass()
809 mp1 = tcp->tcp_reass_head; in tcp_reass()
811 if (TCP_REASS_SEQ(mp1) != tcp->tcp_rnxt) in tcp_reass()
815 mp = mp1->b_cont; in tcp_reass()
816 end = TCP_REASS_END(mp1); in tcp_reass()
817 TCP_REASS_SET_SEQ(mp1, 0); in tcp_reass()
818 TCP_REASS_SET_END(mp1, 0); in tcp_reass()
824 mp1->b_cont = NULL; in tcp_reass()
827 mp1 = mp; in tcp_reass()
829 mp1 = tcp->tcp_reass_head; in tcp_reass()
831 return (mp1); in tcp_reass()
839 mblk_t *mp1; in tcp_reass_elim_overlap() local
844 while ((mp1 = mp->b_cont) != NULL) { in tcp_reass_elim_overlap()
845 u1 = TCP_REASS_SEQ(mp1); in tcp_reass_elim_overlap()
848 if (!SEQ_GEQ(end, TCP_REASS_END(mp1))) { in tcp_reass_elim_overlap()
856 mp->b_cont = mp1->b_cont; in tcp_reass_elim_overlap()
857 TCP_REASS_SET_SEQ(mp1, 0); in tcp_reass_elim_overlap()
858 TCP_REASS_SET_END(mp1, 0); in tcp_reass_elim_overlap()
859 freeb(mp1); in tcp_reass_elim_overlap()
863 if (!mp1) in tcp_reass_elim_overlap()
1446 mblk_t *mp1; in tcp_input_listener() local
1894 mp1 = tcp_xmit_mp(eager, eager->tcp_xmit_head, eager->tcp_mss, in tcp_input_listener()
1896 if (mp1 == NULL) { in tcp_input_listener()
1950 econnp->conn_ixa, __dtrace_tcp_void_ip_t *, mp1->b_rptr, in tcp_input_listener()
1952 &mp1->b_rptr[econnp->conn_ixa->ixa_ip_hdr_length]); in tcp_input_listener()
1953 (void) conn_ip_output(mp1, econnp->conn_ixa); in tcp_input_listener()
1956 SQUEUE_ENTER_ONE(econnp->conn_sqp, mp1, tcp_send_synack, in tcp_input_listener()
1961 freemsg(mp1); in tcp_input_listener()
1964 mp1 = &eager->tcp_closemp; in tcp_input_listener()
1965 SQUEUE_ENTER_ONE(econnp->conn_sqp, mp1, tcp_eager_kill, in tcp_input_listener()
2253 mblk_t *mp1; in tcp_ack_mp() local
2275 mp1 = allocb(total_hdr_len + tcps->tcps_wroff_xtra, BPRI_MED); in tcp_ack_mp()
2276 if (!mp1) in tcp_ack_mp()
2283 rptr = mp1->b_rptr + tcps->tcps_wroff_xtra; in tcp_ack_mp()
2284 mp1->b_rptr = rptr; in tcp_ack_mp()
2285 mp1->b_wptr = rptr + total_hdr_len; in tcp_ack_mp()
2360 return (mp1); in tcp_ack_mp()
2491 mblk_t *mp1; in tcp_input_data() local
2564 if ((mp1 = mp->b_cont) != NULL && mp1->b_datap->db_type == M_DATA) { in tcp_input_data()
2566 ASSERT((uintptr_t)(mp1->b_wptr - mp1->b_rptr) <= in tcp_input_data()
2568 seg_len += (int)(mp1->b_wptr - mp1->b_rptr); in tcp_input_data()
2569 } while ((mp1 = mp1->b_cont) != NULL && in tcp_input_data()
2570 mp1->b_datap->db_type == M_DATA); in tcp_input_data()
2747 mp1 = NULL; in tcp_input_data()
2757 tcp->tcp_loopback ? &mp1 : NULL, ira)) { in tcp_input_data()
2832 ASSERT(mp1 != NULL); in tcp_input_data()
2854 mblk_setcred(mp1, in tcp_input_data()
2858 putnext(connp->conn_rq, mp1); in tcp_input_data()
2865 freemsg(mp1); in tcp_input_data()
2882 mblk_setcred(mp1, ira->ira_cred, in tcp_input_data()
2885 putnext(connp->conn_rq, mp1); in tcp_input_data()
2891 freemsg(mp1); in tcp_input_data()
2918 mp1 = tcp_xmit_mp(tcp, tcp->tcp_xmit_head, tcp->tcp_mss, in tcp_input_data()
2920 if (mp1 != NULL) { in tcp_input_data()
2921 tcp_send_data(tcp, mp1); in tcp_input_data()
3315 mp1 = allocb(0, BPRI_MED); in tcp_input_data()
3316 if (mp1 == NULL) { in tcp_input_data()
3324 freemsg(mp1); in tcp_input_data()
3334 mp1->b_flag |= MSGMARKNEXT; in tcp_input_data()
3336 mp1->b_flag |= MSGNOTMARKNEXT; in tcp_input_data()
3338 tcp->tcp_urp_mark_mp = mp1; in tcp_input_data()
3368 if ((mp1 = mp2->b_cont) != NULL) { in tcp_input_data()
3370 freemsg(mp1); in tcp_input_data()
3607 mp1 = allocb(0, BPRI_MED); in tcp_input_data()
3608 if (mp1 == NULL) { in tcp_input_data()
3616 freemsg(mp1); in tcp_input_data()
3630 mp1->b_flag |= MSGNOTMARKNEXT; in tcp_input_data()
3632 tcp->tcp_urp_mark_mp = mp1; in tcp_input_data()
3675 mp1 = dupmsg(mp); in tcp_input_data()
3676 if (!mp1) { in tcp_input_data()
3687 (void) adjmsg(mp1, urp - seg_len); in tcp_input_data()
3690 tcp_input_data(connp, mp1, NULL, ira); in tcp_input_data()
3710 mp1 = dupmsg(mp); in tcp_input_data()
3711 if (!mp1) { in tcp_input_data()
3723 (void) adjmsg(mp1, urp + 1 - seg_len); in tcp_input_data()
3725 tcp_input_data(connp, mp1, NULL, ira); in tcp_input_data()
3761 mp1 = allocb(sizeof (struct T_exdata_ind), in tcp_input_data()
3763 if (!mp1) { in tcp_input_data()
3781 mp1->b_datap->db_type = M_PROTO; in tcp_input_data()
3782 tei = (struct T_exdata_ind *)mp1->b_rptr; in tcp_input_data()
3785 mp1->b_wptr = (uchar_t *)&tei[1]; in tcp_input_data()
3786 tcp->tcp_urp_mp = mp1; in tcp_input_data()
4092 mp1 = tcp->tcp_xmit_head; in tcp_input_data()
4106 if (mp1 && tcp->tcp_suna != tcp->tcp_snxt && in tcp_input_data()
4469 if (mp1 == NULL) { in tcp_input_data()
4508 if ((mp1->b_next != NULL) && in tcp_input_data()
4509 SEQ_GT(seg_ack, (uint32_t)(uintptr_t)(mp1->b_next))) { in tcp_input_data()
4511 (hrtime_t)(intptr_t)mp1->b_prev); in tcp_input_data()
4531 wptr = mp1->b_wptr; in tcp_input_data()
4532 ASSERT((uintptr_t)(wptr - mp1->b_rptr) <= (uintptr_t)INT_MAX); in tcp_input_data()
4533 bytes_acked -= (int)(wptr - mp1->b_rptr); in tcp_input_data()
4535 mp1->b_rptr = wptr + bytes_acked; in tcp_input_data()
4541 (uint32_t)(uintptr_t)(mp1->b_next))) { in tcp_input_data()
4542 mp1->b_prev = in tcp_input_data()
4544 mp1->b_next = NULL; in tcp_input_data()
4548 mp1->b_next = NULL; in tcp_input_data()
4549 mp1->b_prev = NULL; in tcp_input_data()
4550 mp2 = mp1; in tcp_input_data()
4551 mp1 = mp1->b_cont; in tcp_input_data()
4563 if (mp1 == NULL) { in tcp_input_data()
4580 tcp->tcp_xmit_tail = mp1; in tcp_input_data()
4581 ASSERT((uintptr_t)(mp1->b_wptr - mp1->b_rptr) <= in tcp_input_data()
4583 tcp->tcp_xmit_tail_unsent = (int)(mp1->b_wptr - in tcp_input_data()
4584 mp1->b_rptr); in tcp_input_data()
4587 if (mp1 == NULL) { in tcp_input_data()
4640 tcp->tcp_xmit_head = mp1; in tcp_input_data()
4804 mp1 = mp; in tcp_input_data()
4806 freeb(mp1); in tcp_input_data()
5017 mp1 = tcp_xmit_mp(tcp, tcp->tcp_xmit_head, snd_size, in tcp_input_data()
5021 if (mp1 != NULL) { in tcp_input_data()
5030 tcp_send_data(tcp, mp1); in tcp_input_data()
5082 mp1 = tcp->tcp_urp_mark_mp; in tcp_input_data()
5085 tcp_setcred_data(mp1, ira); in tcp_input_data()
5087 putnext(connp->conn_rq, mp1); in tcp_input_data()
5091 ((mp1->b_flag & MSGMARKNEXT) ? "MSGMARKNEXT" : in tcp_input_data()
5101 mp1 = tcp_ack_mp(tcp); in tcp_input_data()
5103 if (mp1 != NULL) { in tcp_input_data()
5104 tcp_send_data(tcp, mp1); in tcp_input_data()
5153 mp1 = tcp->tcp_ordrel_mp; in tcp_input_data()
5156 putnext(connp->conn_rq, mp1); in tcp_input_data()
5179 mblk_t *mp1; in tcp_input_add_ancillary() local
5274 mp1 = allocb(sizeof (struct T_optdata_ind) + optlen, BPRI_MED); in tcp_input_add_ancillary()
5275 if (mp1 == NULL) { in tcp_input_add_ancillary()
5282 mp1->b_cont = mp; in tcp_input_add_ancillary()
5283 mp = mp1; in tcp_input_add_ancillary()