Lines Matching refs:end_seq
547 (TCP_SKB_CB(skb)->end_seq - in tcp_rcv_rtt_measure_ts()
896 after(TCP_SKB_CB(skb)->end_seq, tp->retransmit_high)) in tcp_verify_retransmit_hint()
897 tp->retransmit_high = TCP_SKB_CB(skb)->end_seq; in tcp_verify_retransmit_hint()
1015 u32 start_seq, u32 end_seq) in tcp_is_sackblock_valid() argument
1018 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq)) in tcp_is_sackblock_valid()
1035 if (after(end_seq, tp->snd_una)) in tcp_is_sackblock_valid()
1042 if (!after(end_seq, tp->undo_marker)) in tcp_is_sackblock_valid()
1048 return !before(start_seq, end_seq - tp->max_window); in tcp_is_sackblock_valid()
1057 u32 end_seq_0 = get_unaligned_be32(&sp[0].end_seq); in tcp_check_dsack()
1065 u32 end_seq_1 = get_unaligned_be32(&sp[1].end_seq); in tcp_check_dsack()
1107 u32 start_seq, u32 end_seq) in tcp_match_skb_to_sack() argument
1115 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_match_skb_to_sack()
1118 after(TCP_SKB_CB(skb)->end_seq, start_seq)) { in tcp_match_skb_to_sack()
1127 pkt_len = end_seq - TCP_SKB_CB(skb)->seq; in tcp_match_skb_to_sack()
1155 u32 start_seq, u32 end_seq, in tcp_sacktag_one() argument
1165 after(end_seq, tp->undo_marker)) in tcp_sacktag_one()
1172 if (!after(end_seq, tp->snd_una)) in tcp_sacktag_one()
1197 if (!after(end_seq, tp->high_seq)) in tcp_sacktag_one()
1248 u32 end_seq = start_seq + shifted; /* end of newly-SACKed */ in tcp_shifted_skb() local
1259 start_seq, end_seq, dup_sack, pcount, in tcp_shifted_skb()
1265 TCP_SKB_CB(prev)->end_seq += shifted; in tcp_shifted_skb()
1304 TCP_SKB_CB(prev)->end_seq++; in tcp_shifted_skb()
1336 u32 start_seq, u32 end_seq, in tcp_shift_skb_data() argument
1356 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)) in tcp_shift_skb_data()
1368 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_shift_skb_data()
1381 if (!after(TCP_SKB_CB(skb)->end_seq, start_seq)) in tcp_shift_skb_data()
1406 len = end_seq - TCP_SKB_CB(skb)->seq; in tcp_shift_skb_data()
1475 u32 start_seq, u32 end_seq, in tcp_sacktag_walk() argument
1489 if (!before(TCP_SKB_CB(skb)->seq, end_seq)) in tcp_sacktag_walk()
1493 before(TCP_SKB_CB(skb)->seq, next_dup->end_seq)) { in tcp_sacktag_walk()
1496 next_dup->end_seq); in tcp_sacktag_walk()
1507 start_seq, end_seq, dup_sack); in tcp_sacktag_walk()
1518 end_seq); in tcp_sacktag_walk()
1531 TCP_SKB_CB(skb)->end_seq, in tcp_sacktag_walk()
1557 if (after(TCP_SKB_CB(skb)->end_seq, skip_to_seq)) in tcp_sacktag_skip()
1577 next_dup->start_seq, next_dup->end_seq, in tcp_maybe_skipping_dsack()
1636 sp[used_sacks].end_seq = get_unaligned_be32(&sp_wire[i].end_seq); in tcp_sacktag_write_queue()
1640 sp[used_sacks].end_seq)) { in tcp_sacktag_write_queue()
1651 !after(sp[used_sacks].end_seq, tp->snd_una)) in tcp_sacktag_write_queue()
1663 if (!after(sp[used_sacks].end_seq, prior_snd_una)) in tcp_sacktag_write_queue()
1693 !cache->end_seq) in tcp_sacktag_write_queue()
1699 u32 end_seq = sp[i].end_seq; in tcp_sacktag_write_queue() local
1708 !before(start_seq, cache->end_seq)) in tcp_sacktag_write_queue()
1713 after(end_seq, cache->start_seq)) { in tcp_sacktag_write_queue()
1727 if (!after(end_seq, cache->end_seq)) in tcp_sacktag_write_queue()
1732 cache->end_seq); in tcp_sacktag_write_queue()
1735 if (tcp_highest_sack_seq(tp) == cache->end_seq) { in tcp_sacktag_write_queue()
1745 skb = tcp_sacktag_skip(skb, sk, state, cache->end_seq); in tcp_sacktag_write_queue()
1761 start_seq, end_seq, dup_sack); in tcp_sacktag_write_queue()
1770 tp->recv_sack_cache[i].end_seq = 0; in tcp_sacktag_write_queue()
1917 tp->retransmit_high = TCP_SKB_CB(skb)->end_seq; in tcp_enter_loss()
2193 if (after(TCP_SKB_CB(skb)->end_seq, loss_high)) in tcp_mark_head_lost()
3063 BUG_ON(!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una)); in tcp_tso_acked()
3072 BUG_ON(!before(TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq)); in tcp_tso_acked()
3125 if (after(scb->end_seq, tp->snd_una)) { in tcp_clean_rtx_queue()
3152 if (!after(scb->end_seq, tp->high_seq)) in tcp_clean_rtx_queue()
3278 if (!after(TCP_SKB_CB(tcp_send_head(sk))->end_seq, tcp_wnd_end(tp))) { in tcp_ack_probe()
3404 if ((TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq) && in tcp_oow_rate_limited()
3581 if (ack_seq != TCP_SKB_CB(skb)->end_seq) in tcp_ack()
3921 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) && in tcp_disordered_ack()
3955 static inline bool tcp_sequence(const struct tcp_sock *tp, u32 seq, u32 end_seq) in tcp_sequence() argument
3957 return !before(end_seq, tp->rcv_wup) && in tcp_sequence()
4070 u32 end_seq) in tcp_sack_extend() argument
4072 if (!after(seq, sp->end_seq) && !after(sp->start_seq, end_seq)) { in tcp_sack_extend()
4075 if (after(end_seq, sp->end_seq)) in tcp_sack_extend()
4076 sp->end_seq = end_seq; in tcp_sack_extend()
4082 static void tcp_dsack_set(struct sock *sk, u32 seq, u32 end_seq) in tcp_dsack_set() argument
4098 tp->duplicate_sack[0].end_seq = end_seq; in tcp_dsack_set()
4102 static void tcp_dsack_extend(struct sock *sk, u32 seq, u32 end_seq) in tcp_dsack_extend() argument
4107 tcp_dsack_set(sk, seq, end_seq); in tcp_dsack_extend()
4109 tcp_sack_extend(tp->duplicate_sack, seq, end_seq); in tcp_dsack_extend()
4116 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_send_dupack()
4122 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_send_dupack() local
4124 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) in tcp_send_dupack()
4125 end_seq = tp->rcv_nxt; in tcp_send_dupack()
4126 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, end_seq); in tcp_send_dupack()
4146 if (tcp_sack_extend(sp, swalk->start_seq, swalk->end_seq)) { in tcp_sack_maybe_coalesce()
4161 static void tcp_sack_new_ofo_skb(struct sock *sk, u32 seq, u32 end_seq) in tcp_sack_new_ofo_skb() argument
4172 if (tcp_sack_extend(sp, seq, end_seq)) { in tcp_sack_new_ofo_skb()
4199 sp->end_seq = end_seq; in tcp_sack_new_ofo_skb()
4223 WARN_ON(before(tp->rcv_nxt, sp->end_seq)); in tcp_sack_remove()
4260 if (TCP_SKB_CB(from)->seq != TCP_SKB_CB(to)->end_seq) in tcp_try_coalesce()
4269 TCP_SKB_CB(to)->end_seq = TCP_SKB_CB(from)->end_seq; in tcp_try_coalesce()
4291 if (before(TCP_SKB_CB(skb)->end_seq, dsack_high)) in tcp_ofo_queue()
4292 dsack_high = TCP_SKB_CB(skb)->end_seq; in tcp_ofo_queue()
4297 if (!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) { in tcp_ofo_queue()
4304 TCP_SKB_CB(skb)->end_seq); in tcp_ofo_queue()
4308 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq); in tcp_ofo_queue()
4345 u32 seq, end_seq; in tcp_data_queue_ofo() local
4361 tp->rcv_nxt, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq); in tcp_data_queue_ofo()
4369 tp->selective_acks[0].end_seq = in tcp_data_queue_ofo()
4370 TCP_SKB_CB(skb)->end_seq; in tcp_data_queue_ofo()
4377 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_data_queue_ofo()
4379 if (seq == TCP_SKB_CB(skb1)->end_seq) { in tcp_data_queue_ofo()
4391 tp->selective_acks[0].end_seq != seq) in tcp_data_queue_ofo()
4395 tp->selective_acks[0].end_seq = end_seq; in tcp_data_queue_ofo()
4411 if (skb1 && before(seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4412 if (!after(end_seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4417 tcp_dsack_set(sk, seq, end_seq); in tcp_data_queue_ofo()
4423 TCP_SKB_CB(skb1)->end_seq); in tcp_data_queue_ofo()
4443 if (!after(end_seq, TCP_SKB_CB(skb1)->seq)) in tcp_data_queue_ofo()
4445 if (before(end_seq, TCP_SKB_CB(skb1)->end_seq)) { in tcp_data_queue_ofo()
4447 end_seq); in tcp_data_queue_ofo()
4452 TCP_SKB_CB(skb1)->end_seq); in tcp_data_queue_ofo()
4459 tcp_sack_new_ofo_skb(sk, seq, end_seq); in tcp_data_queue_ofo()
4476 tcp_rcv_nxt_update(tcp_sk(sk), TCP_SKB_CB(skb)->end_seq); in tcp_queue_rcv()
4518 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(skb)->seq + size; in tcp_send_rcvq()
4540 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) in tcp_data_queue()
4587 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq); in tcp_data_queue()
4615 if (!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) { in tcp_data_queue()
4618 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq); in tcp_data_queue()
4638 TCP_SKB_CB(skb)->end_seq); in tcp_data_queue()
4693 if (!before(start, TCP_SKB_CB(skb)->end_seq)) { in tcp_collapse()
4715 TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(next)->seq) { in tcp_collapse()
4722 start = TCP_SKB_CB(skb)->end_seq; in tcp_collapse()
4737 TCP_SKB_CB(nskb)->seq = TCP_SKB_CB(nskb)->end_seq = start; in tcp_collapse()
4744 int size = TCP_SKB_CB(skb)->end_seq - start; in tcp_collapse()
4751 TCP_SKB_CB(nskb)->end_seq += size; in tcp_collapse()
4755 if (!before(start, TCP_SKB_CB(skb)->end_seq)) { in tcp_collapse()
4780 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
4794 before(TCP_SKB_CB(skb)->end_seq, start)) { in tcp_collapse_ofo_queue()
4802 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
4806 if (after(TCP_SKB_CB(skb)->end_seq, end)) in tcp_collapse_ofo_queue()
4807 end = TCP_SKB_CB(skb)->end_seq; in tcp_collapse_ofo_queue()
5045 if (skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq)) { in tcp_check_urg()
5151 if (!tcp_sequence(tp, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq)) { in tcp_validate_incoming()
5335 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq); in tcp_rcv_established()
5928 (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_rcv_state_process()
5929 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt))) { in tcp_rcv_state_process()
5986 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq && in tcp_rcv_state_process()
5987 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) { in tcp_rcv_state_process()