Lines Matching refs:end_seq
543 (TCP_SKB_CB(skb)->end_seq - in tcp_rcv_rtt_measure_ts()
875 after(TCP_SKB_CB(skb)->end_seq, tp->retransmit_high)) in tcp_verify_retransmit_hint()
876 tp->retransmit_high = TCP_SKB_CB(skb)->end_seq; in tcp_verify_retransmit_hint()
995 u32 start_seq, u32 end_seq) in tcp_is_sackblock_valid() argument
998 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq)) in tcp_is_sackblock_valid()
1015 if (after(end_seq, tp->snd_una)) in tcp_is_sackblock_valid()
1022 if (!after(end_seq, tp->undo_marker)) in tcp_is_sackblock_valid()
1028 return !before(start_seq, end_seq - tp->max_window); in tcp_is_sackblock_valid()
1061 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)) in tcp_mark_lost_retrans()
1101 u32 end_seq_0 = get_unaligned_be32(&sp[0].end_seq); in tcp_check_dsack()
1109 u32 end_seq_1 = get_unaligned_be32(&sp[1].end_seq); in tcp_check_dsack()
1146 u32 start_seq, u32 end_seq) in tcp_match_skb_to_sack() argument
1154 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_match_skb_to_sack()
1157 after(TCP_SKB_CB(skb)->end_seq, start_seq)) { in tcp_match_skb_to_sack()
1166 pkt_len = end_seq - TCP_SKB_CB(skb)->seq; in tcp_match_skb_to_sack()
1194 u32 start_seq, u32 end_seq, in tcp_sacktag_one() argument
1204 after(end_seq, tp->undo_marker)) in tcp_sacktag_one()
1211 if (!after(end_seq, tp->snd_una)) in tcp_sacktag_one()
1234 if (!after(end_seq, tp->high_seq)) in tcp_sacktag_one()
1290 u32 end_seq = start_seq + shifted; /* end of newly-SACKed */ in tcp_shifted_skb() local
1301 start_seq, end_seq, dup_sack, pcount, in tcp_shifted_skb()
1307 TCP_SKB_CB(prev)->end_seq += shifted; in tcp_shifted_skb()
1350 TCP_SKB_CB(prev)->end_seq++; in tcp_shifted_skb()
1382 u32 start_seq, u32 end_seq, in tcp_shift_skb_data() argument
1402 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)) in tcp_shift_skb_data()
1414 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_shift_skb_data()
1427 if (!after(TCP_SKB_CB(skb)->end_seq, start_seq)) in tcp_shift_skb_data()
1452 len = end_seq - TCP_SKB_CB(skb)->seq; in tcp_shift_skb_data()
1521 u32 start_seq, u32 end_seq, in tcp_sacktag_walk() argument
1535 if (!before(TCP_SKB_CB(skb)->seq, end_seq)) in tcp_sacktag_walk()
1539 before(TCP_SKB_CB(skb)->seq, next_dup->end_seq)) { in tcp_sacktag_walk()
1542 next_dup->end_seq); in tcp_sacktag_walk()
1553 start_seq, end_seq, dup_sack); in tcp_sacktag_walk()
1564 end_seq); in tcp_sacktag_walk()
1577 TCP_SKB_CB(skb)->end_seq, in tcp_sacktag_walk()
1603 if (after(TCP_SKB_CB(skb)->end_seq, skip_to_seq)) in tcp_sacktag_skip()
1623 next_dup->start_seq, next_dup->end_seq, in tcp_maybe_skipping_dsack()
1684 sp[used_sacks].end_seq = get_unaligned_be32(&sp_wire[i].end_seq); in tcp_sacktag_write_queue()
1688 sp[used_sacks].end_seq)) { in tcp_sacktag_write_queue()
1699 !after(sp[used_sacks].end_seq, tp->snd_una)) in tcp_sacktag_write_queue()
1711 if (!after(sp[used_sacks].end_seq, prior_snd_una)) in tcp_sacktag_write_queue()
1741 !cache->end_seq) in tcp_sacktag_write_queue()
1747 u32 end_seq = sp[i].end_seq; in tcp_sacktag_write_queue() local
1756 !before(start_seq, cache->end_seq)) in tcp_sacktag_write_queue()
1761 after(end_seq, cache->start_seq)) { in tcp_sacktag_write_queue()
1775 if (!after(end_seq, cache->end_seq)) in tcp_sacktag_write_queue()
1780 cache->end_seq); in tcp_sacktag_write_queue()
1783 if (tcp_highest_sack_seq(tp) == cache->end_seq) { in tcp_sacktag_write_queue()
1793 skb = tcp_sacktag_skip(skb, sk, &state, cache->end_seq); in tcp_sacktag_write_queue()
1809 start_seq, end_seq, dup_sack); in tcp_sacktag_write_queue()
1818 tp->recv_sack_cache[i].end_seq = 0; in tcp_sacktag_write_queue()
1968 tp->retransmit_high = TCP_SKB_CB(skb)->end_seq; in tcp_enter_loss()
2244 if (after(TCP_SKB_CB(skb)->end_seq, loss_high)) in tcp_mark_head_lost()
3023 BUG_ON(!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)); in tcp_tso_acked()
3032 BUG_ON(!before(TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq)); in tcp_tso_acked()
3083 if (after(scb->end_seq, tp->snd_una)) { in tcp_clean_rtx_queue()
3110 if (!after(scb->end_seq, tp->high_seq)) in tcp_clean_rtx_queue()
3234 if (!after(TCP_SKB_CB(tcp_send_head(sk))->end_seq, tcp_wnd_end(tp))) { in tcp_ack_probe()
3357 if ((TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq) && in tcp_oow_rate_limited()
3532 if (ack_seq != TCP_SKB_CB(skb)->end_seq) in tcp_ack()
3872 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) && in tcp_disordered_ack()
3906 static inline bool tcp_sequence(const struct tcp_sock *tp, u32 seq, u32 end_seq) in tcp_sequence() argument
3908 return !before(end_seq, tp->rcv_wup) && in tcp_sequence()
4024 u32 end_seq) in tcp_sack_extend() argument
4026 if (!after(seq, sp->end_seq) && !after(sp->start_seq, end_seq)) { in tcp_sack_extend()
4029 if (after(end_seq, sp->end_seq)) in tcp_sack_extend()
4030 sp->end_seq = end_seq; in tcp_sack_extend()
4036 static void tcp_dsack_set(struct sock *sk, u32 seq, u32 end_seq) in tcp_dsack_set() argument
4052 tp->duplicate_sack[0].end_seq = end_seq; in tcp_dsack_set()
4056 static void tcp_dsack_extend(struct sock *sk, u32 seq, u32 end_seq) in tcp_dsack_extend() argument
4061 tcp_dsack_set(sk, seq, end_seq); in tcp_dsack_extend()
4063 tcp_sack_extend(tp->duplicate_sack, seq, end_seq); in tcp_dsack_extend()
4070 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_send_dupack()
4076 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_send_dupack() local
4078 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) in tcp_send_dupack()
4079 end_seq = tp->rcv_nxt; in tcp_send_dupack()
4080 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, end_seq); in tcp_send_dupack()
4100 if (tcp_sack_extend(sp, swalk->start_seq, swalk->end_seq)) { in tcp_sack_maybe_coalesce()
4115 static void tcp_sack_new_ofo_skb(struct sock *sk, u32 seq, u32 end_seq) in tcp_sack_new_ofo_skb() argument
4126 if (tcp_sack_extend(sp, seq, end_seq)) { in tcp_sack_new_ofo_skb()
4153 sp->end_seq = end_seq; in tcp_sack_new_ofo_skb()
4177 WARN_ON(before(tp->rcv_nxt, sp->end_seq)); in tcp_sack_remove()
4214 if (TCP_SKB_CB(from)->seq != TCP_SKB_CB(to)->end_seq) in tcp_try_coalesce()
4223 TCP_SKB_CB(to)->end_seq = TCP_SKB_CB(from)->end_seq; in tcp_try_coalesce()
4245 if (before(TCP_SKB_CB(skb)->end_seq, dsack_high)) in tcp_ofo_queue()
4246 dsack_high = TCP_SKB_CB(skb)->end_seq; in tcp_ofo_queue()
4251 if (!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) { in tcp_ofo_queue()
4258 TCP_SKB_CB(skb)->end_seq); in tcp_ofo_queue()
4262 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq); in tcp_ofo_queue()
4299 u32 seq, end_seq; in tcp_data_queue_ofo() local
4315 tp->rcv_nxt, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq); in tcp_data_queue_ofo()
4323 tp->selective_acks[0].end_seq = in tcp_data_queue_ofo()
4324 TCP_SKB_CB(skb)->end_seq; in tcp_data_queue_ofo()
4331 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_data_queue_ofo()
4333 if (seq == TCP_SKB_CB(skb1)->end_seq) { in tcp_data_queue_ofo()
4345 tp->selective_acks[0].end_seq != seq) in tcp_data_queue_ofo()
4349 tp->selective_acks[0].end_seq = end_seq; in tcp_data_queue_ofo()
4365 if (skb1 && before(seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4366 if (!after(end_seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4371 tcp_dsack_set(sk, seq, end_seq); in tcp_data_queue_ofo()
4377 TCP_SKB_CB(skb1)->end_seq); in tcp_data_queue_ofo()
4397 if (!after(end_seq, TCP_SKB_CB(skb1)->seq)) in tcp_data_queue_ofo()
4399 if (before(end_seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4401 end_seq); in tcp_data_queue_ofo()
4406 TCP_SKB_CB(skb1)->end_seq); in tcp_data_queue_ofo()
4413 tcp_sack_new_ofo_skb(sk, seq, end_seq); in tcp_data_queue_ofo()
4430 tcp_rcv_nxt_update(tcp_sk(sk), TCP_SKB_CB(skb)->end_seq); in tcp_queue_rcv()
4472 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(skb)->seq + size; in tcp_send_rcvq()
4494 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) in tcp_data_queue()
4539 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq); in tcp_data_queue()
4567 if (!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) { in tcp_data_queue()
4570 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq); in tcp_data_queue()
4590 TCP_SKB_CB(skb)->end_seq); in tcp_data_queue()
4645 if (!before(start, TCP_SKB_CB(skb)->end_seq)) { in tcp_collapse()
4667 TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(next)->seq) { in tcp_collapse()
4674 start = TCP_SKB_CB(skb)->end_seq; in tcp_collapse()
4689 TCP_SKB_CB(nskb)->seq = TCP_SKB_CB(nskb)->end_seq = start; in tcp_collapse()
4696 int size = TCP_SKB_CB(skb)->end_seq - start; in tcp_collapse()
4703 TCP_SKB_CB(nskb)->end_seq += size; in tcp_collapse()
4707 if (!before(start, TCP_SKB_CB(skb)->end_seq)) { in tcp_collapse()
4732 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
4746 before(TCP_SKB_CB(skb)->end_seq, start)) { in tcp_collapse_ofo_queue()
4754 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
4758 if (after(TCP_SKB_CB(skb)->end_seq, end)) in tcp_collapse_ofo_queue()
4759 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
4997 if (skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq)) { in tcp_check_urg()
5103 if (!tcp_sequence(tp, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq)) { in tcp_validate_incoming()
5287 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq); in tcp_rcv_established()
5881 (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_rcv_state_process()
5882 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt))) { in tcp_rcv_state_process()
5939 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_rcv_state_process()
5940 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) { in tcp_rcv_state_process()