Lines Matching refs:end_seq
350 if (TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq)
705 if (TCP_SKB_CB(skb)->end_seq -
1007 u32 end_seq, struct tcp_sacktag_state *state)
1011 if (!before(start_seq, end_seq))
1014 seq_len = end_seq - start_seq;
1020 else if (tp->tlp_high_seq && tp->tlp_high_seq == end_seq)
1198 * fact that though start_seq (s) is before end_seq (i.e., not reversed),
1200 * happens when start_seq resides between end_seq wrap (e_w) and snd_nxt
1212 * similar case (end_seq after snd_nxt wrap) as earlier reversed check in
1230 u32 start_seq, u32 end_seq)
1233 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq))
1250 if (after(end_seq, tp->snd_una))
1257 if (!after(end_seq, tp->undo_marker))
1261 * start_seq < undo_marker and end_seq >= undo_marker.
1263 return !before(start_seq, end_seq - tp->max_window);
1272 u32 end_seq_0 = get_unaligned_be32(&sp[0].end_seq);
1278 u32 end_seq_1 = get_unaligned_be32(&sp[1].end_seq);
1314 u32 start_seq, u32 end_seq)
1322 !before(end_seq, TCP_SKB_CB(skb)->end_seq);
1325 after(TCP_SKB_CB(skb)->end_seq, start_seq)) {
1334 pkt_len = end_seq - TCP_SKB_CB(skb)->seq;
1364 u32 start_seq, u32 end_seq,
1373 after(end_seq, tp->undo_marker))
1381 if (!after(end_seq, tp->snd_una))
1385 tcp_rack_advance(tp, sacked, end_seq, xmit_time);
1407 if (!after(end_seq, tp->high_seq))
1455 u32 end_seq = start_seq + shifted; /* end of newly-SACKed */
1466 start_seq, end_seq, dup_sack, pcount,
1473 TCP_SKB_CB(prev)->end_seq += shifted;
1513 TCP_SKB_CB(prev)->end_seq++;
1563 u32 start_seq, u32 end_seq,
1580 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una))
1595 !before(end_seq, TCP_SKB_CB(skb)->end_seq);
1608 if (!after(TCP_SKB_CB(skb)->end_seq, start_seq))
1620 * if (!after(TCP_SKB_CB(skb)->end_seq, end_seq)),
1633 len = end_seq - TCP_SKB_CB(skb)->seq;
1702 u32 start_seq, u32 end_seq,
1713 if (!before(TCP_SKB_CB(skb)->seq, end_seq))
1717 before(TCP_SKB_CB(skb)->seq, next_dup->end_seq)) {
1720 next_dup->end_seq);
1731 start_seq, end_seq, dup_sack);
1742 end_seq);
1755 TCP_SKB_CB(skb)->end_seq,
1783 if (!before(seq, TCP_SKB_CB(skb)->end_seq)) {
1813 next_dup->start_seq, next_dup->end_seq,
1867 sp[used_sacks].end_seq = get_unaligned_be32(&sp_wire[i].end_seq);
1871 sp[used_sacks].end_seq)) {
1882 !after(sp[used_sacks].end_seq, tp->snd_una))
1894 if (!after(sp[used_sacks].end_seq, prior_snd_una)) {
1927 !cache->end_seq)
1933 u32 end_seq = sp[i].end_seq;
1942 !before(start_seq, cache->end_seq))
1947 after(end_seq, cache->start_seq)) {
1960 if (!after(end_seq, cache->end_seq))
1965 cache->end_seq);
1968 if (tcp_highest_sack_seq(tp) == cache->end_seq) {
1977 skb = tcp_sacktag_skip(skb, sk, cache->end_seq);
1992 start_seq, end_seq, dup_sack);
2001 tp->recv_sack_cache[i].end_seq = 0;
2385 if (after(TCP_SKB_CB(skb)->end_seq, loss_high))
3219 BUG_ON(!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una));
3228 BUG_ON(!before(TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq));
3283 if (after(scb->end_seq, tp->snd_una)) {
3308 if (!after(scb->end_seq, tp->high_seq))
3317 tcp_rack_advance(tp, sacked, scb->end_seq,
3471 if (!after(TCP_SKB_CB(head)->end_seq, tcp_wnd_end(tp))) {
3643 if ((TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq) &&
3867 if (ack_seq != TCP_SKB_CB(skb)->end_seq)
4298 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) &&
4333 u32 seq, u32 end_seq)
4335 if (before(end_seq, tp->rcv_wup))
4461 u32 end_seq)
4463 if (!after(seq, sp->end_seq) && !after(sp->start_seq, end_seq)) {
4466 if (after(end_seq, sp->end_seq))
4467 sp->end_seq = end_seq;
4473 static void tcp_dsack_set(struct sock *sk, u32 seq, u32 end_seq)
4489 tp->duplicate_sack[0].end_seq = end_seq;
4493 static void tcp_dsack_extend(struct sock *sk, u32 seq, u32 end_seq)
4498 tcp_dsack_set(sk, seq, end_seq);
4500 tcp_sack_extend(tp->duplicate_sack, seq, end_seq);
4519 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq &&
4525 u32 end_seq = TCP_SKB_CB(skb)->end_seq;
4528 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt))
4529 end_seq = tp->rcv_nxt;
4530 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, end_seq);
4550 if (tcp_sack_extend(sp, swalk->start_seq, swalk->end_seq)) {
4593 static void tcp_sack_new_ofo_skb(struct sock *sk, u32 seq, u32 end_seq)
4604 if (tcp_sack_extend(sp, seq, end_seq)) {
4636 sp->end_seq = end_seq;
4660 WARN_ON(before(tp->rcv_nxt, sp->end_seq));
4697 if (TCP_SKB_CB(from)->seq != TCP_SKB_CB(to)->end_seq)
4714 TCP_SKB_CB(to)->end_seq = TCP_SKB_CB(from)->end_seq;
4770 if (before(TCP_SKB_CB(skb)->end_seq, dsack_high))
4771 dsack_high = TCP_SKB_CB(skb)->end_seq;
4777 if (unlikely(!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt))) {
4784 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq);
4826 u32 seq, end_seq;
4845 end_seq = TCP_SKB_CB(skb)->end_seq;
4853 tp->selective_acks[0].end_seq = end_seq;
4877 if (!before(seq, TCP_SKB_CB(tp->ooo_last_skb)->end_seq)) {
4892 if (before(seq, TCP_SKB_CB(skb1)->end_seq)) {
4893 if (!after(end_seq, TCP_SKB_CB(skb1)->end_seq)) {
4900 tcp_dsack_set(sk, seq, end_seq);
4905 tcp_dsack_set(sk, seq, TCP_SKB_CB(skb1)->end_seq);
4914 TCP_SKB_CB(skb1)->end_seq);
4935 if (!after(end_seq, TCP_SKB_CB(skb1)->seq))
4937 if (before(end_seq, TCP_SKB_CB(skb1)->end_seq)) {
4939 end_seq);
4944 TCP_SKB_CB(skb1)->end_seq);
4954 tcp_sack_new_ofo_skb(sk, seq, end_seq);
4976 tcp_rcv_nxt_update(tcp_sk(sk), TCP_SKB_CB(skb)->end_seq);
5020 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(skb)->seq + size;
5057 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) {
5123 if (!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) {
5128 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq);
5146 /* Partial packet, seq < rcv_next < end_seq */
5231 if (!before(start, TCP_SKB_CB(skb)->end_seq)) {
5251 TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(n)->seq) {
5257 start = TCP_SKB_CB(skb)->end_seq;
5277 TCP_SKB_CB(nskb)->seq = TCP_SKB_CB(nskb)->end_seq = start;
5288 int size = TCP_SKB_CB(skb)->end_seq - start;
5295 TCP_SKB_CB(nskb)->end_seq += size;
5299 if (!before(start, TCP_SKB_CB(skb)->end_seq)) {
5335 end = TCP_SKB_CB(skb)->end_seq;
5346 before(TCP_SKB_CB(skb)->end_seq, start)) {
5363 if (after(TCP_SKB_CB(skb)->end_seq, end))
5364 end = TCP_SKB_CB(skb)->end_seq;
5686 if (skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq)) {
5770 reason = tcp_sequence(tp, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq);
5808 int max_sack = sp[0].end_seq;
5813 max_sack = after(sp[this_sack].end_seq,
5815 sp[this_sack].end_seq : max_sack;
6657 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq &&
6658 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) {
6725 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq &&
6726 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) {