Home
last modified time | relevance | path

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

/linux/net/ipv4/
H A Dtcp_input.c902 if (TCP_SKB_CB(skb)->end_seq - in tcp_rcv_rtt_measure_ts()
944 rcvwin += TCP_SKB_CB(tp->ooo_last_skb)->end_seq - tp->rcv_nxt; in tcp_rcvbuf_grow()
1233 u32 end_seq, struct tcp_sacktag_state *state) in tcp_dsack_seen() argument
1237 if (!before(start_seq, end_seq)) in tcp_dsack_seen()
1240 seq_len = end_seq - start_seq; in tcp_dsack_seen()
1246 else if (tp->tlp_high_seq && tp->tlp_high_seq == end_seq) in tcp_dsack_seen()
1416 * fact that though start_seq (s) is before end_seq (i.e., not reversed),
1418 * happens when start_seq resides between end_seq wrap (e_w) and snd_nxt
1430 * similar case (end_seq after snd_nxt wrap) as earlier reversed check in
1448 u32 start_seq, u32 end_seq) in tcp_is_sackblock_valid() argument
1532 tcp_match_skb_to_sack(struct sock * sk,struct sk_buff * skb,u32 start_seq,u32 end_seq) tcp_match_skb_to_sack() argument
1584 tcp_rack_advance(struct tcp_sock * tp,u8 sacked,u32 end_seq,u64 xmit_time) tcp_rack_advance() argument
1614 tcp_sacktag_one(struct sock * sk,struct tcp_sacktag_state * state,u8 sacked,u32 start_seq,u32 end_seq,int dup_sack,int pcount,u32 plen,u64 xmit_time) tcp_sacktag_one() argument
1855 u32 end_seq = start_seq + shifted; /* end of newly-SACKed */ tcp_shifted_skb() local
1956 tcp_shift_skb_data(struct sock * sk,struct sk_buff * skb,struct tcp_sacktag_state * state,u32 start_seq,u32 end_seq,bool dup_sack) tcp_shift_skb_data() argument
2095 tcp_sacktag_walk(struct sk_buff * skb,struct sock * sk,struct tcp_sack_block * next_dup,struct tcp_sacktag_state * state,u32 start_seq,u32 end_seq,bool dup_sack_in) tcp_sacktag_walk() argument
2327 u32 end_seq = sp[i].end_seq; tcp_sacktag_write_queue() local
4841 tcp_sequence(const struct sock * sk,u32 seq,u32 end_seq,const struct tcphdr * th) tcp_sequence() argument
4995 tcp_sack_extend(struct tcp_sack_block * sp,u32 seq,u32 end_seq) tcp_sack_extend() argument
5007 tcp_dsack_set(struct sock * sk,u32 seq,u32 end_seq) tcp_dsack_set() argument
5027 tcp_dsack_extend(struct sock * sk,u32 seq,u32 end_seq) tcp_dsack_extend() argument
5082 u32 end_seq = TCP_SKB_CB(skb)->end_seq; tcp_send_dupack() local
5150 tcp_sack_new_ofo_skb(struct sock * sk,u32 seq,u32 end_seq) tcp_sack_new_ofo_skb() argument
5386 u32 seq, end_seq; tcp_data_queue_ofo() local
[all...]
H A Dtcp_minisocks.c29 static bool tcp_in_window(u32 seq, u32 end_seq, u32 s_win, u32 e_win) in tcp_in_window() argument
33 if (after(end_seq, s_win) && before(seq, e_win)) in tcp_in_window()
35 return seq == e_win && seq == end_seq; in tcp_in_window()
140 !tcp_in_window(TCP_SKB_CB(skb)->seq, TCP_SKB_CB(skb)->end_seq, in tcp_timewait_state_process()
154 !after(TCP_SKB_CB(skb)->end_seq, rcv_nxt) || in tcp_timewait_state_process()
155 TCP_SKB_CB(skb)->end_seq == TCP_SKB_CB(skb)->seq) { in tcp_timewait_state_process()
164 TCP_SKB_CB(skb)->end_seq != rcv_nxt + 1) in tcp_timewait_state_process()
169 twsk_rcv_nxt_update(tcptw, TCP_SKB_CB(skb)->end_seq, in tcp_timewait_state_process()
205 (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq || th->rst))) { in tcp_timewait_state_process()
845 TCP_SKB_CB(skb)->end_seq, in tcp_check_req()
[all …]
H A Dtcp_output.c89 WRITE_ONCE(tp->snd_nxt, TCP_SKB_CB(skb)->end_seq); in tcp_event_new_data_sent()
393 TCP_SKB_CB(skb)->end_seq = seq; in tcp_init_nondata_skb()
788 *ptr++ = htonl(sp[this_sack].end_seq); in tcp_options_write()
1698 if (after(tcb->end_seq, tp->snd_nxt) || tcb->seq == tcb->end_seq) in __tcp_transmit_skb()
1748 WRITE_ONCE(tp->write_seq, TCP_SKB_CB(skb)->end_seq); in tcp_queue_skb()
1892 TCP_SKB_CB(buff)->end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_fragment()
1893 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(buff)->seq; in tcp_fragment()
1919 if (!before(tp->snd_nxt, TCP_SKB_CB(buff)->end_seq)) { in tcp_fragment()
2224 tp->snd_sml = TCP_SKB_CB(skb)->end_seq; in tcp_minshall_update()
2385 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_snd_wnd_test() local
[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_fastopen.c261 if (TCP_SKB_CB(skb)->end_seq == tp->rcv_nxt) in tcp_fastopen_add_skb()
284 tp->rcv_nxt = TCP_SKB_CB(skb)->end_seq; in tcp_fastopen_add_skb()
443 bool syn_data = TCP_SKB_CB(skb)->end_seq != TCP_SKB_CB(skb)->seq + 1; in tcp_try_fastopen()
H A Dtcp.c701 tcb->seq = tcb->end_seq = tp->write_seq; in tcp_skb_entail()
1001 if (skb && TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) { in tcp_remove_empty_skb()
1377 TCP_SKB_CB(skb)->end_seq += copy; in tcp_sendmsg_locked()
1608 WARN(skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq), in tcp_cleanup_rbuf()
1610 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); in tcp_cleanup_rbuf()
3158 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in __tcp_close() local
3161 end_seq--; in __tcp_close()
3162 if (after(end_seq, tcp_sk(sk)->copied_seq)) in __tcp_close()
3462 tp->duplicate_sack[0].end_seq = 0; in tcp_disconnect()
H A Dtcp_ipv4.c1946 if (TCP_SKB_CB(tail)->end_seq != TCP_SKB_CB(skb)->seq ||
1973 TCP_SKB_CB(tail)->end_seq = TCP_SKB_CB(skb)->end_seq;
2056 TCP_SKB_CB(skb)->end_seq = (TCP_SKB_CB(skb)->seq + th->syn + th->fin +
/linux/include/net/psp/
H A Dfunctions.h73 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in psp_is_allowed_nondata() local
77 pure_fin = fin && end_seq - seq == 1; in psp_is_allowed_nondata()
79 return seq == end_seq || (pure_fin && seq == pas->upgrade_seq); in psp_is_allowed_nondata()
/linux/net/tls/
H A Dtls_device.c177 if (info && !before(acked_seq, info->end_seq)) in tls_tcp_clean_acked()
181 if (before(acked_seq, info->end_seq)) in tls_tcp_clean_acked()
290 record->end_seq = tp->write_seq + record->len; in tls_push_record()
624 before(seq, info->end_seq - info->len)) { in tls_get_record()
647 last->end_seq)) in tls_get_record()
656 if (before(seq, info->end_seq)) { in tls_get_record()
658 after(info->end_seq, in tls_get_record()
659 context->retransmit_hint->end_seq)) { in tls_get_record()
1132 start_marker_record->end_seq = tcp_sk(sk)->write_seq; in tls_set_device_offload()
/linux/net/mptcp/
H A Dprotocol.c177 to->len, MPTCP_SKB_CB(from)->end_seq); in __mptcp_try_coalesce()
178 MPTCP_SKB_CB(to)->end_seq = MPTCP_SKB_CB(from)->end_seq; in __mptcp_try_coalesce()
205 if (MPTCP_SKB_CB(from)->map_seq != MPTCP_SKB_CB(to)->end_seq) in mptcp_ooo_try_coalesce()
313 u64 seq, end_seq, max_seq; in mptcp_data_queue_ofo() local
317 end_seq = MPTCP_SKB_CB(skb)->end_seq; in mptcp_data_queue_ofo()
322 if (after64(end_seq, max_seq)) { in mptcp_data_queue_ofo()
326 (unsigned long long)end_seq - (unsigned long)max_seq, in mptcp_data_queue_ofo()
357 if (!before64(seq, MPTCP_SKB_CB(msk->ooo_last_skb)->end_seq)) { in mptcp_data_queue_ofo()
373 if (before64(seq, MPTCP_SKB_CB(skb1)->end_seq)) { in mptcp_data_queue_ofo()
374 if (!after64(end_seq, MPTCP_SKB_CB(skb1)->end_seq)) { in mptcp_data_queue_ofo()
[all …]
H A Dfastopen.c49 MPTCP_SKB_CB(skb)->end_seq = 0; in mptcp_fastopen_subflow_synack_set_params()
H A Doptions.c473 subflow->snd_isn = TCP_SKB_CB(skb)->end_seq; in mptcp_syn_options()
991 TCP_SKB_CB(skb)->end_seq == TCP_SKB_CB(skb)->seq && in check_fully_established()
1206 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq || in mptcp_over_limit()
1208 !after(TCP_SKB_CB(skb)->end_seq, tcp_sk(ssk)->rcv_nxt)) in mptcp_over_limit()
1317 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) { in mptcp_incoming_options()
H A Dsubflow.c1144 TCP_SKB_CB(skb)->end_seq, in get_mapping_status()
1285 if (!before(tcp_sk(ssk)->copied_seq, TCP_SKB_CB(skb)->end_seq)) in mptcp_subflow_discard_data()
H A Dprotocol.h132 u64 end_seq; member
/linux/tools/testing/selftests/bpf/progs/
H A Dbpf_cubic.c91 __u32 end_seq; /* end_seq of the round */ member
169 ca->end_seq = tp->snd_nxt; in bictcp_hystart_reset()
399 if (hystart && after(ack, ca->end_seq)) in BPF_PROG()
/linux/tools/testing/selftests/net/packetdrill/
H A Dtcp_rcv_big_endseq.pkt39 // If queue is empty, accept a packet even if its end_seq is above rcv_mwnd_seq
/linux/include/linux/
H A Dtcp.h99 __be32 end_seq; member
104 u32 end_seq; member
385 u32 end_seq; /* Ending TCP sequence of the skb */ member
/linux/include/trace/events/
H A Dmptcp.h226 MPTCP_SKB_CB(msk->ooo_last_skb)->end_seq -
/linux/drivers/net/ethernet/chelsio/inline_crypto/ch_ktls/
H A Dchcr_ktls.c1741 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/kernel/bpf/
H A Ddiagnostics.c406 u64 end_seq; in bpf_diag_event_log_restore() local
412 end_seq = log_end(log); in bpf_diag_event_log_restore()
413 if (WARN_ON_ONCE(log_pos > end_seq)) in bpf_diag_event_log_restore()
414 log_pos = end_seq; in bpf_diag_event_log_restore()
/linux/net/ipv6/
H A Dtcp_ipv6.c1684 if (TCP_SKB_CB(opt_skb)->end_seq == tp->rcv_nxt &&
1721 TCP_SKB_CB(skb)->end_seq = (TCP_SKB_CB(skb)->seq + th->syn + th->fin +
/linux/net/sched/
H A Dsch_cake.c1090 u32 end_a = get_unaligned_be32(&sack_a->end_seq); in cake_tcph_sack_compare()
1102 u32 end_b = get_unaligned_be32(&sack_tmp->end_seq); in cake_tcph_sack_compare()
/linux/include/net/
H A Dtcp.h1109 __u32 end_seq; /* SEQ + FIN + SYN + datalen */ member