Home
last modified time | relevance | path

Searched refs:end_seq (Results 1 – 25 of 26) sorted by relevance

12

/linux-6.15/net/ipv4/
H A Dtcp_input.c1356 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_match_skb_to_sack()
1629 !before(end_seq, TCP_SKB_CB(skb)->end_seq); in tcp_shift_skb_data()
1967 u32 end_seq = sp[i].end_seq; in tcp_sacktag_write_queue() local
1994 if (!after(end_seq, cache->end_seq)) in tcp_sacktag_write_queue()
4670 if (after(end_seq, sp->end_seq)) in tcp_sack_extend()
4671 sp->end_seq = end_seq; in tcp_sack_extend()
4693 tp->duplicate_sack[0].end_seq = end_seq; in tcp_dsack_set()
4740 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_send_dupack() local
4851 sp->end_seq = end_seq; in tcp_sack_new_ofo_skb()
5056 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_data_queue_ofo()
[all …]
H A Dtcp_recovery.c78 tp->rack.end_seq, scb->end_seq)) in tcp_rack_detect_loss()
118 void tcp_rack_advance(struct tcp_sock *tp, u8 sacked, u32 end_seq, in tcp_rack_advance() argument
140 end_seq, tp->rack.end_seq)) { in tcp_rack_advance()
142 tp->rack.end_seq = end_seq; in tcp_rack_advance()
H A Dtcp_minisocks.c27 static bool tcp_in_window(u32 seq, u32 end_seq, u32 s_win, u32 e_win) in tcp_in_window() argument
31 if (after(end_seq, s_win) && before(seq, e_win)) in tcp_in_window()
33 return seq == e_win && seq == end_seq; in tcp_in_window()
127 !tcp_in_window(TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq, in tcp_timewait_state_process()
141 !after(TCP_SKB_CB(skb)->end_seq, rcv_nxt) || in tcp_timewait_state_process()
142 TCP_SKB_CB(skb)->end_seq == TCP_SKB_CB(skb)->seq) { in tcp_timewait_state_process()
151 TCP_SKB_CB(skb)->end_seq != rcv_nxt + 1) in tcp_timewait_state_process()
156 twsk_rcv_nxt_update(tcptw, TCP_SKB_CB(skb)->end_seq, in tcp_timewait_state_process()
192 (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq || th->rst))) { in tcp_timewait_state_process()
804 TCP_SKB_CB(skb)->end_seq, in tcp_check_req()
[all …]
H A Dtcp_output.c417 TCP_SKB_CB(skb)->end_seq = seq; in tcp_init_nondata_skb()
732 *ptr++ = htonl(sp[this_sack].end_seq); in tcp_options_write()
1461 if (after(tcb->end_seq, tp->snd_nxt) || tcb->seq == tcb->end_seq) in __tcp_transmit_skb()
1659 TCP_SKB_CB(buff)->end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_fragment()
2154 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_snd_wnd_test() local
2192 TCP_SKB_CB(buff)->end_seq = TCP_SKB_CB(skb)->end_seq; in tso_fragment()
2721 TCP_SKB_CB(skb)->end_seq += nlen; in tcp_grow_skb()
2726 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(next_skb)->end_seq; in tcp_grow_skb()
3244 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(next_skb)->end_seq; in tcp_collapse_retrans()
3600 TCP_SKB_CB(tskb)->end_seq++; in tcp_send_fin()
[all …]
H A Dtcp_illinois.c49 u32 end_seq; /* right edge of current RTT */ member
62 ca->end_seq = tp->snd_nxt; in rtt_reset()
265 if (after(ack, ca->end_seq)) in tcp_illinois_cong_avoid()
H A Dtcp_rate.c93 scb->end_seq, rs->last_end_seq)) { in tcp_rate_skb_delivered()
99 rs->last_end_seq = scb->end_seq; in tcp_rate_skb_delivered()
H A Dtcp_cubic.c102 u32 end_seq; /* end_seq of the round */ member
124 ca->end_seq = tp->snd_nxt; in bictcp_hystart_reset()
392 if (after(tp->snd_una, ca->end_seq)) in hystart_update()
H A Dtcp_fastopen.c174 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb()
197 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb()
353 bool syn_data = TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq + 1; in tcp_try_fastopen()
H A Dtcp.c689 tcb->seq = tcb->end_seq = tp->write_seq; in tcp_skb_entail()
963 if (skb && TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) { in tcp_remove_empty_skb()
1297 TCP_SKB_CB(skb)->end_seq += copy; in tcp_sendmsg_locked()
1522 WARN(skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq), in tcp_cleanup_rbuf()
1524 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); in tcp_cleanup_rbuf()
3095 u32 len = TCP_SKB_CB(skb)->end_seq - TCP_SKB_CB(skb)->seq; in __tcp_close()
3392 tp->duplicate_sack[0].end_seq = 0; in tcp_disconnect()
H A Dtcp_ipv4.c2060 if (TCP_SKB_CB(tail)->end_seq != TCP_SKB_CB(skb)->seq ||
2085 TCP_SKB_CB(tail)->end_seq = TCP_SKB_CB(skb)->end_seq;
2173 TCP_SKB_CB(skb)->end_seq = (TCP_SKB_CB(skb)->seq + th->syn + th->fin +
/linux-6.15/net/netfilter/
H A Dnf_conntrack_seqadj.c94 if (after(ntohl(sack->end_seq) - seq->offset_before, in nf_ct_sack_block_adjust()
96 new_end_seq = htonl(ntohl(sack->end_seq) - in nf_ct_sack_block_adjust()
99 new_end_seq = htonl(ntohl(sack->end_seq) - in nf_ct_sack_block_adjust()
104 ntohl(sack->end_seq), ntohl(new_end_seq)); in nf_ct_sack_block_adjust()
109 sack->end_seq, new_end_seq, false); in nf_ct_sack_block_adjust()
111 sack->end_seq = new_end_seq; in nf_ct_sack_block_adjust()
/linux-6.15/net/tls/
H A Dtls_device.c175 if (info && !before(acked_seq, info->end_seq)) in tls_tcp_clean_acked()
179 if (before(acked_seq, info->end_seq)) in tls_tcp_clean_acked()
288 record->end_seq = tp->write_seq + record->len; in tls_push_record()
618 before(seq, info->end_seq - info->len)) { in tls_get_record()
641 last->end_seq)) in tls_get_record()
650 if (before(seq, info->end_seq)) { in tls_get_record()
652 after(info->end_seq, in tls_get_record()
653 context->retransmit_hint->end_seq)) { in tls_get_record()
1124 start_marker_record->end_seq = tcp_sk(sk)->write_seq; in tls_set_device_offload()
/linux-6.15/net/mptcp/
H A Dprotocol.c135 to->len, MPTCP_SKB_CB(from)->end_seq); in mptcp_try_coalesce()
136 MPTCP_SKB_CB(to)->end_seq = MPTCP_SKB_CB(from)->end_seq; in mptcp_try_coalesce()
166 u64 seq, end_seq, max_seq; in mptcp_data_queue_ofo() local
170 end_seq = MPTCP_SKB_CB(skb)->end_seq; in mptcp_data_queue_ofo()
175 if (after64(end_seq, max_seq)) { in mptcp_data_queue_ofo()
221 if (!after64(end_seq, MPTCP_SKB_CB(skb1)->end_seq)) { in mptcp_data_queue_ofo()
258 if (before64(end_seq, MPTCP_SKB_CB(skb1)->end_seq)) in mptcp_data_queue_ofo()
648 u64 end_seq; in __mptcp_ofo_queue() local
667 end_seq = MPTCP_SKB_CB(skb)->end_seq; in __mptcp_ofo_queue()
681 WRITE_ONCE(msk->ack_seq, end_seq); in __mptcp_ofo_queue()
[all …]
H A Dfastopen.c45 MPTCP_SKB_CB(skb)->end_seq = 0; in mptcp_fastopen_subflow_synack_set_params()
H A Doptions.c409 subflow->snd_isn = TCP_SKB_CB(skb)->end_seq; in mptcp_syn_options()
943 TCP_SKB_CB(skb)->end_seq == TCP_SKB_CB(skb)->seq && in check_fully_established()
1213 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) { in mptcp_incoming_options()
H A Dsubflow.c1128 TCP_SKB_CB(skb)->end_seq, in get_mapping_status()
1269 if (!before(tcp_sk(ssk)->copied_seq, TCP_SKB_CB(skb)->end_seq)) in mptcp_subflow_discard_data()
H A Dprotocol.h131 u64 end_seq; member
/linux-6.15/tools/testing/selftests/bpf/progs/
H A Dbpf_cubic.c97 __u32 end_seq; /* end_seq of the round */ member
175 ca->end_seq = tp->snd_nxt; in bictcp_hystart_reset()
395 if (hystart && after(ack, ca->end_seq)) in BPF_PROG()
/linux-6.15/include/linux/
H A Dtcp.h99 __be32 end_seq; member
104 u32 end_seq; member
365 u32 end_seq; /* Ending TCP sequence of the skb */ member
/linux-6.15/include/net/
H A Dtls.h146 u32 end_seq; member
343 return rec->end_seq - rec->len; in tls_record_start_seq()
H A Dtcp.h1014 __u32 end_seq; /* SEQ + FIN + SYN + datalen */ member
2472 extern void tcp_rack_advance(struct tcp_sock *tp, u8 sacked, u32 end_seq,
/linux-6.15/drivers/net/ethernet/chelsio/inline_crypto/ch_ktls/
H A Dchcr_ktls.c1740 tx_info->prev_seq = record->end_seq; in chcr_end_part_handler()
1995 tls_end_offset = record->end_seq - tcp_seq; in chcr_ktls_xmit()
1998 tcp_seq, record->end_seq, tx_info->prev_seq, data_len); in chcr_ktls_xmit()
2005 tx_max = record->end_seq - in chcr_ktls_xmit()
2050 tcp_seq = record->end_seq; in chcr_ktls_xmit()
/linux-6.15/drivers/infiniband/hw/irdma/
H A Dpuda.c1152 u32 marker_seq, end_seq, blk_start; in irdma_ieq_get_fpdu_len() local
1176 end_seq = rcv_seq + total_len; in irdma_ieq_get_fpdu_len()
1177 while ((int)(marker_seq - end_seq) < 0) { in irdma_ieq_get_fpdu_len()
1179 end_seq += marker_len; in irdma_ieq_get_fpdu_len()
/linux-6.15/fs/bcachefs/
H A Drecovery.c315 u64 end_seq = c->journal_replay_seq_start; in bch2_journal_replay() local
322 keys->nr, start_seq, end_seq); in bch2_journal_replay()
/linux-6.15/net/ipv6/
H A Dtcp_ipv6.c1701 if (TCP_SKB_CB(opt_skb)->end_seq == tp->rcv_nxt &&
1738 TCP_SKB_CB(skb)->end_seq = (TCP_SKB_CB(skb)->seq + th->syn + th->fin +

12