inet/tcp/tcp_input.c

2043 tcp_rcv_enqueue(tcp_t *tcp, mblk_t *mp, uint_t seg_len, cred_t *cr)
2045 	ASSERT(seg_len == msgdsize(mp));
2074 	tcp->tcp_rcv_cnt += seg_len;
2075 	tcp->tcp_rwnd -= seg_len;
2258 	int		seg_len;
2322 	seg_len = (int)(mp->b_wptr - rptr) -
2328 			seg_len += (int)(mp1->b_wptr - mp1->b_rptr);
2339 		    seg_len, tcpha, ira);
2395 			seg_len = 0;
2656 			if (seg_len == 0 && !(flags & TH_URG)) {
2785 	    (seg_len > 0 && SEQ_GT(seg_seq + seg_len, tcp->tcp_rnxt))) {
2821 	rgap = tcp->tcp_rwnd - (gap + seg_len);
2830 		    (seg_len != 0)) {
2839 		    (seg_len > -gap ? -gap : seg_len));
2840 		/* Remove the old stuff from seg_len. */
2841 		seg_len += gap;
2847 		if (seg_len < 0 || (seg_len == 0 && !(flags & TH_FIN))) {
2864 			if (SEQ_GEQ(seg_seq + seg_len - gap, tcp->tcp_rack) &&
2875 			 * Adjust seg_len to the original value for tracing.
2877 			seg_len -= gap;
2882 				    "seg_len %d, rnxt %u, snxt %u, %s",
2884 				    seg_len, tcp->tcp_rnxt, tcp->tcp_snxt,
2915 			 * We clear seg_len and flag fields related to
2919 			seg_len = 0;
2962 		 * seg_len does not include the FIN, so if more than
2970 		/* Fix seg_len and make sure there is something left. */
2971 		seg_len += rgap;
2972 		if (seg_len <= 0) {
3049 			 * process the ACK part.  But we need to set seg_len
3055 				seg_len = 0;
3063 		rgap = seg_len;
3131 			tcp->tcp_ofo_fin_seq = seg_seq + seg_len;
3135 		if (seg_len > 0) {
3139 				    seg_seq, seg_seq + seg_len,
3153 				seg_len = mp->b_cont ? msgdsize(mp) :
3162 				    seg_seq + seg_len == tcp->tcp_ofo_fin_seq) {
3190 				 * seg_len == 0 to determine if it is a pure
3193 				seg_len = 0;
3204 	} else if (seg_len > 0) {
3206 		TCPS_UPDATE_MIB(tcps, tcpInDataInorderBytes, seg_len);
3213 		    seg_seq + seg_len == tcp->tcp_ofo_fin_seq) {
3359 		 * Note that seg_len is the number of bytes in the segment, and
3361 		 * urp < seg_len means that the urgent byte is in this segment.
3363 		if (urp < seg_len) {
3364 			if (seg_len != 1) {
3383 						    urp - seg_len);
3388 					(void) adjmsg(mp1, urp - seg_len);
3405 				if (urp != seg_len - 1) {
3419 						    urp + 1 - seg_len);
3424 					(void) adjmsg(mp1, urp + 1 - seg_len);
3451 				    (connp->conn_upper_handle, mp, seg_len,
3470 					seg_len = 0;
3511 		} else if (urp == seg_len) {
3530 				if (seg_len != 0) {
3546 			    seg_len, flags,
3555 			    urp - seg_len, tcp_display(tcp, NULL,
3798 		if (!ofo_seg && seg_len == 0 && new_swnd == tcp->tcp_swnd) {
4518 				if (seg_len) {
4532 	if (seg_len == 0) {
4566 		} else if (seg_len < mss) {
4588 	tcp->tcp_rnxt += seg_len;
4631 		    mp, seg_len, 0, &error, &push) <= 0) {
4638 				tcp->tcp_rwnd -= seg_len;
4654 		tcp_rcv_enqueue(tcp, mp, seg_len, ira->ira_cred);
4681 				tcp->tcp_rwnd -= seg_len;
4683 		    tcp->tcp_rcv_cnt + seg_len >= connp->conn_rcvbuf >> 3) {
4698 				tcp_rcv_enqueue(tcp, mp, seg_len,
4707 					tcp->tcp_rwnd -= seg_len;
4714 			tcp_rcv_enqueue(tcp, mp, seg_len, ira->ira_cred);