Lines Matching refs:end

166 	if (SEQ_LEQ(tp->sackblks[0].end, tp->rcv_nxt))  in tcp_dsack_block_exists()
180 tcp_seq start, end; in tcp_update_dsack_list() local
189 (tp->sackblks[0].end == tp->rcv_nxt))) { in tcp_update_dsack_list()
191 saved_blks[0].end = rcv_end; in tcp_update_dsack_list()
193 saved_blks[0].start = saved_blks[0].end = 0; in tcp_update_dsack_list()
196 head_blk.start = head_blk.end = 0; in tcp_update_dsack_list()
198 mid_blk.end = rcv_end; in tcp_update_dsack_list()
203 end = tp->sackblks[i].end; in tcp_update_dsack_list()
208 if (SEQ_GT(rcv_start, end)) { in tcp_update_dsack_list()
212 if (SEQ_GT(tp->rcv_nxt, end)) { in tcp_update_dsack_list()
213 if ((SEQ_MAX(rcv_start, start) != SEQ_MIN(rcv_end, end)) && in tcp_update_dsack_list()
215 (head_blk.start == head_blk.end))) { in tcp_update_dsack_list()
217 head_blk.end = SEQ_MIN(rcv_end, end); in tcp_update_dsack_list()
221 if (((head_blk.start == head_blk.end) || in tcp_update_dsack_list()
223 (SEQ_GT(end, rcv_start) && in tcp_update_dsack_list()
226 head_blk.end = end; in tcp_update_dsack_list()
229 mid_blk.end = SEQ_MAX(mid_blk.end, end); in tcp_update_dsack_list()
231 (mid_blk.end == end)) in tcp_update_dsack_list()
234 if (SEQ_LT(head_blk.start, head_blk.end)) { in tcp_update_dsack_list()
237 saved_blks[0].end = SEQ_MIN(rcv_end, head_blk.end); in tcp_update_dsack_list()
244 if ((SEQ_LT(tp->rcv_nxt, mid_blk.end) && in tcp_update_dsack_list()
246 (mid_blk.end == saved_blks[0].end))) || in tcp_update_dsack_list()
249 saved_blks[n++].end = mid_blk.end; in tcp_update_dsack_list()
252 if (((SEQ_LT(tp->sackblks[j].end, mid_blk.start) || in tcp_update_dsack_list()
253 SEQ_GT(tp->sackblks[j].start, mid_blk.end)) && in tcp_update_dsack_list()
260 if (SEQ_LT(saved_blks[i].start, saved_blks[i].end)) { in tcp_update_dsack_list()
290 (rcv_end == tp->sackblks[0].end)) { in tcp_update_sack_list()
296 head_blk.end = rcv_end; in tcp_update_sack_list()
307 tcp_seq end = tp->sackblks[i].end; in tcp_update_sack_list() local
308 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_update_sack_list()
312 } else if (SEQ_LEQ(head_blk.start, end) && in tcp_update_sack_list()
313 SEQ_GEQ(head_blk.end, start)) { in tcp_update_sack_list()
331 if (head_blk.start == end) in tcp_update_sack_list()
333 else if (head_blk.end == start) in tcp_update_sack_list()
334 head_blk.end = end; in tcp_update_sack_list()
341 if (SEQ_GT(head_blk.end, end)) { in tcp_update_sack_list()
342 tcp_seq temp = end; in tcp_update_sack_list()
343 end = head_blk.end; in tcp_update_sack_list()
344 head_blk.end = temp; in tcp_update_sack_list()
347 (head_blk.end != end)) { in tcp_update_sack_list()
350 SEQ_LEQ(saved_blks[num_saved-1].end, end)) in tcp_update_sack_list()
353 saved_blks[num_saved].end = end; in tcp_update_sack_list()
363 SEQ_LEQ(saved_blks[num_saved-1].end, end)) in tcp_update_sack_list()
369 saved_blks[num_saved].end = end; in tcp_update_sack_list()
393 (rcv_start == tp->sackblks[0].end)) { in tcp_update_sack_list()
423 tcp_seq end = tp->sackblks[i].end; in tcp_clean_dsack_blocks() local
424 if (SEQ_GEQ(start, end) || SEQ_LEQ(start, tp->rcv_nxt)) { in tcp_clean_dsack_blocks()
434 saved_blks[num_saved].end = end; in tcp_clean_dsack_blocks()
458 tp->sackblks[i].start = tp->sackblks[i].end=0; in tcp_clean_sackreport()
465 tcp_sackhole_alloc(struct tcpcb *tp, tcp_seq start, tcp_seq end) in tcp_sackhole_alloc() argument
480 hole->end = end; in tcp_sackhole_alloc()
509 tcp_sackhole_insert(struct tcpcb *tp, tcp_seq start, tcp_seq end, in tcp_sackhole_insert() argument
515 hole = tcp_sackhole_alloc(tp, start, end); in tcp_sackhole_insert()
587 sack_blocks[num_sack_blks++].end = th_ack; in tcp_sack_doack()
607 sack.end = ntohl(sack.end); in tcp_sack_doack()
608 if (SEQ_GT(sack.end, sack.start) && in tcp_sack_doack()
612 SEQ_GT(sack.end, tp->snd_una) && in tcp_sack_doack()
613 SEQ_LEQ(sack.end, tp->snd_max) && in tcp_sack_doack()
614 ((sack.end - sack.start) >= maxseg || in tcp_sack_doack()
615 SEQ_GEQ(sack.end, tp->snd_max))) { in tcp_sack_doack()
618 SEQ_LEQ(sack.end, th_ack)) { in tcp_sack_doack()
622 tcp_record_dsack(tp, sack.start, sack.end, 0); in tcp_sack_doack()
640 if (SEQ_GT(sack_blocks[i].end, sack_blocks[j].end)) { in tcp_sack_doack()
670 tp->sackhint.last_sack_ack = sblkp->end; in tcp_sack_doack()
679 SEQ_LEQ(tp->snd_fack,temp->end)) { in tcp_sack_doack()
680 tp->sackhint.hole_bytes -= temp->end - temp->start; in tcp_sack_doack()
682 temp->end = sblkp->start; in tcp_sack_doack()
684 delivered_data += sblkp->end - sblkp->start; in tcp_sack_doack()
685 tp->sackhint.hole_bytes += temp->end - temp->start; in tcp_sack_doack()
688 tp->snd_fack = sblkp->end; in tcp_sack_doack()
700 delivered_data += sblkp->end - sblkp->start; in tcp_sack_doack()
701 tp->sackhint.hole_bytes += temp->end - temp->start; in tcp_sack_doack()
702 tp->snd_fack = sblkp->end; in tcp_sack_doack()
719 SEQ_LT(tp->snd_fack, sblkp->end)) { in tcp_sack_doack()
720 delivered_data += sblkp->end - tp->snd_fack; in tcp_sack_doack()
721 tp->snd_fack = sblkp->end; in tcp_sack_doack()
731 } else if (SEQ_LT(tp->snd_fack, sblkp->end)) { in tcp_sack_doack()
733 delivered_data += sblkp->end - tp->snd_fack; in tcp_sack_doack()
734 tp->snd_fack = sblkp->end; in tcp_sack_doack()
749 loss_thresh += loss_hiack - cur->end; in tcp_sack_doack()
754 notlost_bytes += cur->end - cur->start; in tcp_sack_doack()
761 if (SEQ_GEQ(sblkp->start, cur->end)) { in tcp_sack_doack()
769 if (SEQ_LEQ(sblkp->end, cur->start)) { in tcp_sack_doack()
774 loss_thresh += loss_hiack - cur->end; in tcp_sack_doack()
779 notlost_bytes += cur->end - cur->start; in tcp_sack_doack()
784 (SEQ_MIN(cur->rxmit, cur->end) - cur->start); in tcp_sack_doack()
790 if (SEQ_GEQ(sblkp->end, cur->end)) { in tcp_sack_doack()
792 delivered_data += (cur->end - cur->start); in tcp_sack_doack()
795 tp->sackhint.hole_bytes -= temp->end - temp->start; in tcp_sack_doack()
805 delivered_data += (sblkp->end - cur->start); in tcp_sack_doack()
806 tp->sackhint.hole_bytes -= sblkp->end - cur->start; in tcp_sack_doack()
807 cur->start = sblkp->end; in tcp_sack_doack()
812 if (SEQ_GEQ(sblkp->end, cur->end)) { in tcp_sack_doack()
814 delivered_data += (cur->end - sblkp->start); in tcp_sack_doack()
815 tp->sackhint.hole_bytes -= cur->end - sblkp->start; in tcp_sack_doack()
816 cur->end = sblkp->start; in tcp_sack_doack()
817 cur->rxmit = SEQ_MIN(cur->rxmit, cur->end); in tcp_sack_doack()
818 if ((tp->t_flags & TF_LRD) && SEQ_GEQ(cur->rxmit, cur->end)) in tcp_sack_doack()
825 temp = tcp_sackhole_insert(tp, sblkp->end, in tcp_sack_doack()
826 cur->end, cur); in tcp_sack_doack()
833 temp->end) - temp->start); in tcp_sack_doack()
835 tp->sackhint.hole_bytes -= sblkp->end - sblkp->start; in tcp_sack_doack()
836 loss_thresh += loss_hiack - temp->end; in tcp_sack_doack()
841 notlost_bytes += temp->end - temp->start; in tcp_sack_doack()
842 cur->end = sblkp->start; in tcp_sack_doack()
844 cur->end); in tcp_sack_doack()
845 if ((tp->t_flags & TF_LRD) && SEQ_GEQ(cur->rxmit, cur->end)) in tcp_sack_doack()
847 delivered_data += (sblkp->end - sblkp->start); in tcp_sack_doack()
852 (SEQ_MIN(cur->rxmit, cur->end) - cur->start); in tcp_sack_doack()
859 loss_thresh += loss_hiack - cur->end; in tcp_sack_doack()
864 notlost_bytes += cur->end - cur->start; in tcp_sack_doack()
1019 temp->end - temp->start; in tcp_sack_partialack()
1053 if (SEQ_GEQ(hole->rxmit, hole->end)) { in tcp_sack_output()
1058 if (SEQ_LT(hole->rxmit, hole->end)) { in tcp_sack_output()
1064 KASSERT(SEQ_LT(hole->start, hole->end), ("%s: hole.start >= hole.end", __func__)); in tcp_sack_output()
1067 KASSERT(SEQ_LT(hole->end, tp->snd_fack), ("%s: hole.end >= snd.fack", __func__)); in tcp_sack_output()
1069 if (SEQ_GEQ(hole->start, hole->end) || in tcp_sack_output()
1071 SEQ_GEQ(hole->end, tp->snd_fack) || in tcp_sack_output()
1074 hole->start, hole->end, hole->rxmit, tp->snd_fack); in tcp_sack_output()
1110 if (SEQ_LT(tp->snd_nxt, cur->end)) { in tcp_sack_adjust()
1113 sacked += p->start - cur->end; in tcp_sack_adjust()
1121 if (SEQ_LT(tp->snd_nxt, cur->end)) { in tcp_sack_adjust()
1142 SEQ_GEQ(temp->rxmit, temp->end) && in tcp_sack_lost_retransmission()
1153 SEQ_GEQ(temp->rxmit, temp->end)) in tcp_sack_lost_retransmission()