Lines Matching refs:mp1
563 mblk_t *mp1;
584 mp1 = tcp->tcp_reass_tail;
585 if (!mp1) {
594 if (SEQ_GEQ(start, TCP_REASS_END(mp1))) {
596 mp1->b_cont = mp;
603 mp1 = tcp->tcp_reass_head;
604 u1 = TCP_REASS_SEQ(mp1);
608 mp->b_cont = mp1;
615 * We find our slot, where mp1 precedes us and mp2 trails.
617 for (; (mp2 = mp1->b_cont) != NULL; mp1 = mp2) {
624 mp1->b_cont = mp;
630 tcp_reass_elim_overlap(tcp, mp1);
633 mp1 = tcp->tcp_reass_head;
635 if (TCP_REASS_SEQ(mp1) != tcp->tcp_rnxt)
639 mp = mp1->b_cont;
640 end = TCP_REASS_END(mp1);
641 TCP_REASS_SET_SEQ(mp1, 0);
642 TCP_REASS_SET_END(mp1, 0);
648 mp1->b_cont = NULL;
651 mp1 = mp;
653 mp1 = tcp->tcp_reass_head;
655 return (mp1);
663 mblk_t *mp1;
668 while ((mp1 = mp->b_cont) != NULL) {
669 u1 = TCP_REASS_SEQ(mp1);
672 if (!SEQ_GEQ(end, TCP_REASS_END(mp1))) {
680 mp->b_cont = mp1->b_cont;
681 TCP_REASS_SET_SEQ(mp1, 0);
682 TCP_REASS_SET_END(mp1, 0);
683 freeb(mp1);
687 if (!mp1)
1270 mblk_t *mp1;
1715 mp1 = tcp_xmit_mp(eager, eager->tcp_xmit_head, eager->tcp_mss,
1717 if (mp1 == NULL) {
1771 econnp->conn_ixa, __dtrace_tcp_void_ip_t *, mp1->b_rptr,
1773 &mp1->b_rptr[econnp->conn_ixa->ixa_ip_hdr_length]);
1774 (void) conn_ip_output(mp1, econnp->conn_ixa);
1777 SQUEUE_ENTER_ONE(econnp->conn_sqp, mp1, tcp_send_synack,
1782 freemsg(mp1);
1785 mp1 = &eager->tcp_closemp;
1786 SQUEUE_ENTER_ONE(econnp->conn_sqp, mp1, tcp_eager_kill,
2073 mblk_t *mp1;
2095 mp1 = allocb(total_hdr_len + tcps->tcps_wroff_xtra, BPRI_MED);
2096 if (!mp1)
2103 rptr = mp1->b_rptr + tcps->tcps_wroff_xtra;
2104 mp1->b_rptr = rptr;
2105 mp1->b_wptr = rptr + total_hdr_len;
2180 return (mp1);
2311 mblk_t *mp1;
2385 if ((mp1 = mp->b_cont) != NULL && mp1->b_datap->db_type == M_DATA) {
2387 ASSERT((uintptr_t)(mp1->b_wptr - mp1->b_rptr) <=
2389 seg_len += (int)(mp1->b_wptr - mp1->b_rptr);
2390 } while ((mp1 = mp1->b_cont) != NULL &&
2391 mp1->b_datap->db_type == M_DATA);
2564 mp1 = NULL;
2574 tcp->tcp_loopback ? &mp1 : NULL, ira)) {
2646 ASSERT(mp1 != NULL);
2668 mblk_setcred(mp1,
2672 putnext(connp->conn_rq, mp1);
2679 freemsg(mp1);
2696 mblk_setcred(mp1, ira->ira_cred,
2699 putnext(connp->conn_rq, mp1);
2705 freemsg(mp1);
2732 mp1 = tcp_xmit_mp(tcp, tcp->tcp_xmit_head, tcp->tcp_mss,
2734 if (mp1 != NULL) {
2735 tcp_send_data(tcp, mp1);
3104 mp1 = allocb(0, BPRI_MED);
3105 if (mp1 == NULL) {
3113 freemsg(mp1);
3123 mp1->b_flag |= MSGMARKNEXT;
3125 mp1->b_flag |= MSGNOTMARKNEXT;
3127 tcp->tcp_urp_mark_mp = mp1;
3157 if ((mp1 = mp2->b_cont) != NULL) {
3159 freemsg(mp1);
3393 mp1 = allocb(0, BPRI_MED);
3394 if (mp1 == NULL) {
3402 freemsg(mp1);
3416 mp1->b_flag |= MSGNOTMARKNEXT;
3418 tcp->tcp_urp_mark_mp = mp1;
3461 mp1 = dupmsg(mp);
3462 if (!mp1) {
3473 (void) adjmsg(mp1, urp - seg_len);
3476 tcp_input_data(connp, mp1, NULL, ira);
3496 mp1 = dupmsg(mp);
3497 if (!mp1) {
3509 (void) adjmsg(mp1, urp + 1 - seg_len);
3511 tcp_input_data(connp, mp1, NULL, ira);
3547 mp1 = allocb(sizeof (struct T_exdata_ind),
3549 if (!mp1) {
3567 mp1->b_datap->db_type = M_PROTO;
3568 tei = (struct T_exdata_ind *)mp1->b_rptr;
3571 mp1->b_wptr = (uchar_t *)&tei[1];
3572 tcp->tcp_urp_mp = mp1;
3886 mp1 = tcp->tcp_xmit_head;
3900 if (mp1 && tcp->tcp_suna != tcp->tcp_snxt &&
4258 if (mp1 == NULL) {
4323 if ((mp1->b_next != NULL) &&
4324 SEQ_GT(seg_ack, (uint32_t)(uintptr_t)(mp1->b_next)))
4326 (int32_t)(intptr_t)mp1->b_prev);
4345 wptr = mp1->b_wptr;
4346 ASSERT((uintptr_t)(wptr - mp1->b_rptr) <= (uintptr_t)INT_MAX);
4347 bytes_acked -= (int)(wptr - mp1->b_rptr);
4349 mp1->b_rptr = wptr + bytes_acked;
4355 (uint32_t)(uintptr_t)(mp1->b_next))) {
4356 mp1->b_prev =
4358 mp1->b_next = NULL;
4362 mp1->b_next = NULL;
4363 mp1->b_prev = NULL;
4364 mp2 = mp1;
4365 mp1 = mp1->b_cont;
4377 if (mp1 == NULL) {
4394 tcp->tcp_xmit_tail = mp1;
4395 ASSERT((uintptr_t)(mp1->b_wptr - mp1->b_rptr) <=
4397 tcp->tcp_xmit_tail_unsent = (int)(mp1->b_wptr -
4398 mp1->b_rptr);
4401 if (mp1 == NULL) {
4454 tcp->tcp_xmit_head = mp1;
4618 mp1 = mp;
4620 freeb(mp1);
4828 mp1 = tcp_xmit_mp(tcp, tcp->tcp_xmit_head, snd_size,
4832 if (mp1 != NULL) {
4839 tcp_send_data(tcp, mp1);
4890 mp1 = tcp->tcp_urp_mark_mp;
4893 tcp_setcred_data(mp1, ira);
4895 putnext(connp->conn_rq, mp1);
4899 ((mp1->b_flag & MSGMARKNEXT) ? "MSGMARKNEXT" :
4909 mp1 = tcp_ack_mp(tcp);
4911 if (mp1 != NULL) {
4912 tcp_send_data(tcp, mp1);
4961 mp1 = tcp->tcp_ordrel_mp;
4964 putnext(connp->conn_rq, mp1);
4987 mblk_t *mp1;
5072 mp1 = allocb(sizeof (struct T_optdata_ind) + optlen, BPRI_MED);
5073 if (mp1 == NULL) {
5080 mp1->b_cont = mp;
5081 mp = mp1;