Lines Matching refs:end_seq
342 if (TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq)
689 if (TCP_SKB_CB(skb)->end_seq -
997 u32 end_seq, struct tcp_sacktag_state *state)
1001 if (!before(start_seq, end_seq))
1004 seq_len = end_seq - start_seq;
1179 * fact that though start_seq (s) is before end_seq (i.e., not reversed),
1181 * happens when start_seq resides between end_seq wrap (e_w) and snd_nxt
1193 * similar case (end_seq after snd_nxt wrap) as earlier reversed check in
1211 u32 start_seq, u32 end_seq)
1214 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq))
1231 if (after(end_seq, tp->snd_una))
1238 if (!after(end_seq, tp->undo_marker))
1242 * start_seq < undo_marker and end_seq >= undo_marker.
1244 return !before(start_seq, end_seq - tp->max_window);
1253 u32 end_seq_0 = get_unaligned_be32(&sp[0].end_seq);
1259 u32 end_seq_1 = get_unaligned_be32(&sp[1].end_seq);
1295 u32 start_seq, u32 end_seq)
1303 !before(end_seq, TCP_SKB_CB(skb)->end_seq);
1306 after(TCP_SKB_CB(skb)->end_seq, start_seq)) {
1315 pkt_len = end_seq - TCP_SKB_CB(skb)->seq;
1345 u32 start_seq, u32 end_seq,
1354 after(end_seq, tp->undo_marker))
1362 if (!after(end_seq, tp->snd_una))
1366 tcp_rack_advance(tp, sacked, end_seq, xmit_time);
1388 if (!after(end_seq, tp->high_seq))
1436 u32 end_seq = start_seq + shifted; /* end of newly-SACKed */
1447 start_seq, end_seq, dup_sack, pcount,
1454 TCP_SKB_CB(prev)->end_seq += shifted;
1494 TCP_SKB_CB(prev)->end_seq++;
1544 u32 start_seq, u32 end_seq,
1561 if (!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una))
1576 !before(end_seq, TCP_SKB_CB(skb)->end_seq);
1589 if (!after(TCP_SKB_CB(skb)->end_seq, start_seq))
1601 * if (!after(TCP_SKB_CB(skb)->end_seq, end_seq)),
1614 len = end_seq - TCP_SKB_CB(skb)->seq;
1683 u32 start_seq, u32 end_seq,
1694 if (!before(TCP_SKB_CB(skb)->seq, end_seq))
1698 before(TCP_SKB_CB(skb)->seq, next_dup->end_seq)) {
1701 next_dup->end_seq);
1712 start_seq, end_seq, dup_sack);
1723 end_seq);
1736 TCP_SKB_CB(skb)->end_seq,
1764 if (!before(seq, TCP_SKB_CB(skb)->end_seq)) {
1794 next_dup->start_seq, next_dup->end_seq,
1848 sp[used_sacks].end_seq = get_unaligned_be32(&sp_wire[i].end_seq);
1852 sp[used_sacks].end_seq)) {
1863 !after(sp[used_sacks].end_seq, tp->snd_una))
1875 if (!after(sp[used_sacks].end_seq, prior_snd_una)) {
1908 !cache->end_seq)
1914 u32 end_seq = sp[i].end_seq;
1923 !before(start_seq, cache->end_seq))
1928 after(end_seq, cache->start_seq)) {
1941 if (!after(end_seq, cache->end_seq))
1946 cache->end_seq);
1949 if (tcp_highest_sack_seq(tp) == cache->end_seq) {
1958 skb = tcp_sacktag_skip(skb, sk, cache->end_seq);
1973 start_seq, end_seq, dup_sack);
1982 tp->recv_sack_cache[i].end_seq = 0;
2366 if (after(TCP_SKB_CB(skb)->end_seq, loss_high))
3186 BUG_ON(!after(TCP_SKB_CB(skb)->end_seq, tp->snd_una));
3195 BUG_ON(!before(TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq));
3251 if (after(scb->end_seq, tp->snd_una)) {
3277 if (!after(scb->end_seq, tp->high_seq))
3286 tcp_rack_advance(tp, sacked, scb->end_seq,
3439 if (!after(TCP_SKB_CB(head)->end_seq, tcp_wnd_end(tp))) {
3611 if ((TCP_SKB_CB(skb)->seq != TCP_SKB_CB(skb)->end_seq) &&
3833 if (ack_seq != TCP_SKB_CB(skb)->end_seq)
4264 (th->ack && seq == TCP_SKB_CB(skb)->end_seq && seq == tp->rcv_nxt) &&
4298 static inline bool tcp_sequence(const struct tcp_sock *tp, u32 seq, u32 end_seq)
4300 return !before(end_seq, tp->rcv_wup) &&
4416 u32 end_seq)
4418 if (!after(seq, sp->end_seq) && !after(sp->start_seq, end_seq)) {
4421 if (after(end_seq, sp->end_seq))
4422 sp->end_seq = end_seq;
4428 static void tcp_dsack_set(struct sock *sk, u32 seq, u32 end_seq)
4444 tp->duplicate_sack[0].end_seq = end_seq;
4448 static void tcp_dsack_extend(struct sock *sk, u32 seq, u32 end_seq)
4453 tcp_dsack_set(sk, seq, end_seq);
4455 tcp_sack_extend(tp->duplicate_sack, seq, end_seq);
4474 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq &&
4480 u32 end_seq = TCP_SKB_CB(skb)->end_seq;
4483 if (after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt))
4484 end_seq = tp->rcv_nxt;
4485 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, end_seq);
4505 if (tcp_sack_extend(sp, swalk->start_seq, swalk->end_seq)) {
4548 static void tcp_sack_new_ofo_skb(struct sock *sk, u32 seq, u32 end_seq)
4559 if (tcp_sack_extend(sp, seq, end_seq)) {
4591 sp->end_seq = end_seq;
4615 WARN_ON(before(tp->rcv_nxt, sp->end_seq));
4652 if (TCP_SKB_CB(from)->seq != TCP_SKB_CB(to)->end_seq)
4669 TCP_SKB_CB(to)->end_seq = TCP_SKB_CB(from)->end_seq;
4724 if (before(TCP_SKB_CB(skb)->end_seq, dsack_high))
4725 dsack_high = TCP_SKB_CB(skb)->end_seq;
4731 if (unlikely(!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt))) {
4738 tcp_rcv_nxt_update(tp, TCP_SKB_CB(skb)->end_seq);
4780 u32 seq, end_seq;
4799 end_seq = TCP_SKB_CB(skb)->end_seq;
4807 tp->selective_acks[0].end_seq = end_seq;
4831 if (!before(seq, TCP_SKB_CB(tp->ooo_last_skb)->end_seq)) {
4846 if (before(seq, TCP_SKB_CB(skb1)->end_seq)) {
4847 if (!after(end_seq, TCP_SKB_CB(skb1)->end_seq)) {
4853 tcp_dsack_set(sk, seq, end_seq);
4858 tcp_dsack_set(sk, seq, TCP_SKB_CB(skb1)->end_seq);
4867 TCP_SKB_CB(skb1)->end_seq);
4887 if (!after(end_seq, TCP_SKB_CB(skb1)->seq))
4889 if (before(end_seq, TCP_SKB_CB(skb1)->end_seq)) {
4891 end_seq);
4896 TCP_SKB_CB(skb1)->end_seq);
4906 tcp_sack_new_ofo_skb(sk, seq, end_seq);
4928 tcp_rcv_nxt_update(tcp_sk(sk), TCP_SKB_CB(skb)->end_seq);
4972 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(skb)->seq + size;
5010 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) {
5067 if (!after(TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt)) {
5071 tcp_dsack_set(sk, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq);
5086 /* Partial packet, seq < rcv_next < end_seq */
5170 if (!before(start, TCP_SKB_CB(skb)->end_seq)) {
5190 TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(n)->seq) {
5196 start = TCP_SKB_CB(skb)->end_seq;
5216 TCP_SKB_CB(nskb)->seq = TCP_SKB_CB(nskb)->end_seq = start;
5227 int size = TCP_SKB_CB(skb)->end_seq - start;
5234 TCP_SKB_CB(nskb)->end_seq += size;
5238 if (!before(start, TCP_SKB_CB(skb)->end_seq)) {
5274 end = TCP_SKB_CB(skb)->end_seq;
5285 before(TCP_SKB_CB(skb)->end_seq, start)) {
5302 if (after(TCP_SKB_CB(skb)->end_seq, end))
5303 end = TCP_SKB_CB(skb)->end_seq;
5608 if (skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq)) {
5689 if (!tcp_sequence(tp, TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq)) {
5725 int max_sack = sp[0].end_seq;
5730 max_sack = after(sp[this_sack].end_seq,
5732 sp[this_sack].end_seq : max_sack;
6554 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq &&
6555 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) {
6619 if (TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq &&
6620 after(TCP_SKB_CB(skb)->end_seq - th->fin, tp->rcv_nxt)) {