Lines Matching refs:end_seq
357 if (TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq) in tcp_ecn_accept_cwr()
738 if (TCP_SKB_CB(skb)->end_seq - in tcp_rcv_rtt_measure_ts()
761 rcvwin += TCP_SKB_CB(tp->ooo_last_skb)->end_seq - tp->rcv_nxt; in tcp_rcvbuf_grow()
1045 u32 end_seq, struct tcp_sacktag_state *state) in tcp_dsack_seen() argument
1049 if (!before(start_seq, end_seq)) in tcp_dsack_seen()
1052 seq_len = end_seq - start_seq; in tcp_dsack_seen()
1058 else if (tp->tlp_high_seq && tp->tlp_high_seq == end_seq) in tcp_dsack_seen()
1259 u32 start_seq, u32 end_seq) in tcp_is_sackblock_valid() argument
1262 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq)) in tcp_is_sackblock_valid()
1279 if (after(end_seq, tp->snd_una)) in tcp_is_sackblock_valid()
1286 if (!after(end_seq, tp->undo_marker)) in tcp_is_sackblock_valid()
1292 return !before(start_seq, end_seq - tp->max_window); in tcp_is_sackblock_valid()
1301 u32 end_seq_0 = get_unaligned_be32(&sp[0].end_seq); in tcp_check_dsack()
1307 u32 end_seq_1 = get_unaligned_be32(&sp[1].end_seq); in tcp_check_dsack()
1343 u32 start_seq, u32 end_seq) in tcp_match_skb_to_sack() argument
1351 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_match_skb_to_sack()
1354 after(TCP_SKB_CB(skb)->end_seq, start_seq)) { in tcp_match_skb_to_sack()
1363 pkt_len = end_seq - TCP_SKB_CB(skb)->seq; in tcp_match_skb_to_sack()
1393 u32 start_seq, u32 end_seq, in tcp_sacktag_one() argument
1402 after(end_seq, tp->undo_marker)) in tcp_sacktag_one()
1410 if (!after(end_seq, tp->snd_una)) in tcp_sacktag_one()
1414 tcp_rack_advance(tp, sacked, end_seq, xmit_time); in tcp_sacktag_one()
1436 if (!after(end_seq, tp->high_seq)) in tcp_sacktag_one()
1479 u32 end_seq = start_seq + shifted; /* end of newly-SACKed */ in tcp_shifted_skb() local
1490 start_seq, end_seq, dup_sack, pcount, in tcp_shifted_skb()
1494 TCP_SKB_CB(prev)->end_seq += shifted; in tcp_shifted_skb()
1530 TCP_SKB_CB(prev)->end_seq++; in tcp_shifted_skb()
1580 u32 start_seq, u32 end_seq, in tcp_shift_skb_data() argument
1597 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)) in tcp_shift_skb_data()
1612 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_shift_skb_data()
1625 if (!after(TCP_SKB_CB(skb)->end_seq, start_seq)) in tcp_shift_skb_data()
1650 len = end_seq - TCP_SKB_CB(skb)->seq; in tcp_shift_skb_data()
1719 u32 start_seq, u32 end_seq, in tcp_sacktag_walk() argument
1730 if (!before(TCP_SKB_CB(skb)->seq, end_seq)) in tcp_sacktag_walk()
1734 before(TCP_SKB_CB(skb)->seq, next_dup->end_seq)) { in tcp_sacktag_walk()
1737 next_dup->end_seq); in tcp_sacktag_walk()
1748 start_seq, end_seq, dup_sack); in tcp_sacktag_walk()
1759 end_seq); in tcp_sacktag_walk()
1772 TCP_SKB_CB(skb)->end_seq, in tcp_sacktag_walk()
1800 if (!before(seq, TCP_SKB_CB(skb)->end_seq)) { in tcp_sacktag_bsearch()
1830 next_dup->start_seq, next_dup->end_seq, in tcp_maybe_skipping_dsack()
1884 sp[used_sacks].end_seq = get_unaligned_be32(&sp_wire[i].end_seq); in tcp_sacktag_write_queue()
1888 sp[used_sacks].end_seq)) { in tcp_sacktag_write_queue()
1899 !after(sp[used_sacks].end_seq, tp->snd_una)) in tcp_sacktag_write_queue()
1911 if (!after(sp[used_sacks].end_seq, prior_snd_una)) { in tcp_sacktag_write_queue()
1944 !cache->end_seq) in tcp_sacktag_write_queue()
1950 u32 end_seq = sp[i].end_seq; in tcp_sacktag_write_queue() local
1959 !before(start_seq, cache->end_seq)) in tcp_sacktag_write_queue()
1964 after(end_seq, cache->start_seq)) { in tcp_sacktag_write_queue()
1977 if (!after(end_seq, cache->end_seq)) in tcp_sacktag_write_queue()
1982 cache->end_seq); in tcp_sacktag_write_queue()
1985 if (tcp_highest_sack_seq(tp) == cache->end_seq) { in tcp_sacktag_write_queue()
1994 skb = tcp_sacktag_skip(skb, sk, cache->end_seq); in tcp_sacktag_write_queue()
2009 start_seq, end_seq, dup_sack); in tcp_sacktag_write_queue()
2018 tp->recv_sack_cache[i].end_seq = 0; in tcp_sacktag_write_queue()
3188 BUG_ON(!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)); in tcp_tso_acked()
3197 BUG_ON(!before(TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq)); in tcp_tso_acked()
3252 if (after(scb->end_seq, tp->snd_una)) { in tcp_clean_rtx_queue()
3277 if (!after(scb->end_seq, tp->high_seq)) in tcp_clean_rtx_queue()
3286 tcp_rack_advance(tp, sacked, scb->end_seq, in tcp_clean_rtx_queue()
3433 if (!after(TCP_SKB_CB(head)->end_seq, tcp_wnd_end(tp))) { in tcp_ack_probe()
3641 if ((TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq) && in tcp_oow_rate_limited()
3884 if (ack_seq != TCP_SKB_CB(skb)->end_seq) in tcp_ack()
4355 if (!th->ack || seq != TCP_SKB_CB(skb)->end_seq) in tcp_disordered_ack_check()
4395 u32 seq, u32 end_seq) in tcp_sequence() argument
4399 if (before(end_seq, tp->rcv_wup)) in tcp_sequence()
4402 if (after(end_seq, tp->rcv_nxt + tcp_receive_window(tp))) { in tcp_sequence()
4541 u32 end_seq) in tcp_sack_extend() argument
4543 if (!after(seq, sp->end_seq) && !after(sp->start_seq, end_seq)) { in tcp_sack_extend()
4546 if (after(end_seq, sp->end_seq)) in tcp_sack_extend()
4547 sp->end_seq = end_seq; in tcp_sack_extend()
4553 static void tcp_dsack_set(struct sock *sk, u32 seq, u32 end_seq) in tcp_dsack_set() argument
4569 tp->duplicate_sack[0].end_seq = end_seq; in tcp_dsack_set()
4573 static void tcp_dsack_extend(struct sock *sk, u32 seq, u32 end_seq) in tcp_dsack_extend() argument
4578 tcp_dsack_set(sk, seq, end_seq); in tcp_dsack_extend()
4580 tcp_sack_extend(tp->duplicate_sack, seq, end_seq); in tcp_dsack_extend()
4610 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_send_dupack()
4616 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_send_dupack() local
4619 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) in tcp_send_dupack()
4620 end_seq = tp->rcv_nxt; in tcp_send_dupack()
4621 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, end_seq); in tcp_send_dupack()
4641 if (tcp_sack_extend(sp, swalk->start_seq, swalk->end_seq)) { in tcp_sack_maybe_coalesce()
4684 static void tcp_sack_new_ofo_skb(struct sock *sk, u32 seq, u32 end_seq) in tcp_sack_new_ofo_skb() argument
4695 if (tcp_sack_extend(sp, seq, end_seq)) { in tcp_sack_new_ofo_skb()
4727 sp->end_seq = end_seq; in tcp_sack_new_ofo_skb()
4751 WARN_ON(before(tp->rcv_nxt, sp->end_seq)); in tcp_sack_remove()
4788 if (TCP_SKB_CB(from)->seq != TCP_SKB_CB(to)->end_seq) in tcp_try_coalesce()
4800 TCP_SKB_CB(to)->end_seq = TCP_SKB_CB(from)->end_seq; in tcp_try_coalesce()
4857 if (before(TCP_SKB_CB(skb)->end_seq, dsack_high)) in tcp_ofo_queue()
4858 dsack = TCP_SKB_CB(skb)->end_seq; in tcp_ofo_queue()
4864 if (unlikely(!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt))) { in tcp_ofo_queue()
4871 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq); in tcp_ofo_queue()
4923 u32 seq, end_seq; in tcp_data_queue_ofo() local
4944 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_data_queue_ofo()
4952 tp->selective_acks[0].end_seq = end_seq; in tcp_data_queue_ofo()
4976 if (!before(seq, TCP_SKB_CB(tp->ooo_last_skb)->end_seq)) { in tcp_data_queue_ofo()
4991 if (before(seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4992 if (!after(end_seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4999 tcp_dsack_set(sk, seq, end_seq); in tcp_data_queue_ofo()
5004 tcp_dsack_set(sk, seq, TCP_SKB_CB(skb1)->end_seq); in tcp_data_queue_ofo()
5013 TCP_SKB_CB(skb1)->end_seq); in tcp_data_queue_ofo()
5034 if (!after(end_seq, TCP_SKB_CB(skb1)->seq)) in tcp_data_queue_ofo()
5036 if (before(end_seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
5038 end_seq); in tcp_data_queue_ofo()
5043 TCP_SKB_CB(skb1)->end_seq); in tcp_data_queue_ofo()
5053 tcp_sack_new_ofo_skb(sk, seq, end_seq); in tcp_data_queue_ofo()
5078 tcp_rcv_nxt_update(tcp_sk(sk), TCP_SKB_CB(skb)->end_seq); in tcp_queue_rcv()
5122 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(skb)->seq + size; in tcp_send_rcvq()
5159 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) { in tcp_data_queue()
5235 if (!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) { in tcp_data_queue()
5240 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq); in tcp_data_queue()
5346 if (!before(start, TCP_SKB_CB(skb)->end_seq)) { in tcp_collapse()
5367 TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(n)->seq) { in tcp_collapse()
5374 start = TCP_SKB_CB(skb)->end_seq; in tcp_collapse()
5393 TCP_SKB_CB(nskb)->seq = TCP_SKB_CB(nskb)->end_seq = start; in tcp_collapse()
5404 int size = TCP_SKB_CB(skb)->end_seq - start; in tcp_collapse()
5411 TCP_SKB_CB(nskb)->end_seq += size; in tcp_collapse()
5415 if (!before(start, TCP_SKB_CB(skb)->end_seq)) { in tcp_collapse()
5448 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
5459 before(TCP_SKB_CB(skb)->end_seq, start)) { in tcp_collapse_ofo_queue()
5476 if (after(TCP_SKB_CB(skb)->end_seq, end)) in tcp_collapse_ofo_queue()
5477 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
5811 if (skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq)) { in tcp_check_urg()
5907 reason = tcp_sequence(sk, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq); in tcp_validate_incoming()
5950 int max_sack = sp[0].end_seq; in tcp_validate_incoming()
5955 max_sack = after(sp[this_sack].end_seq, in tcp_validate_incoming()
5957 sp[this_sack].end_seq : max_sack; in tcp_validate_incoming()
5983 TCP_SKB_CB(skb)->seq + 1 == TCP_SKB_CB(skb)->end_seq && in tcp_validate_incoming()
6141 if (after(TCP_SKB_CB(skb)->end_seq, in tcp_rcv_established()
6845 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_rcv_state_process()
6846 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) { in tcp_rcv_state_process()
6913 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_rcv_state_process()
6914 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) { in tcp_rcv_state_process()