Home
last modified time | relevance | path

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

/linux/net/ipv4/
H A Dtcp_input.c885 if (TCP_SKB_CB(skb)->end_seq - in tcp_rcv_rtt_measure_ts()
927 rcvwin += TCP_SKB_CB(tp->ooo_last_skb)->end_seq - tp->rcv_nxt; in tcp_rcvbuf_grow()
1216 u32 end_seq, struct tcp_sacktag_state *state) in tcp_dsack_seen() argument
1220 if (!before(start_seq, end_seq)) in tcp_dsack_seen()
1223 seq_len = end_seq - start_seq; in tcp_dsack_seen()
1229 else if (tp->tlp_high_seq && tp->tlp_high_seq == end_seq) in tcp_dsack_seen()
1430 u32 start_seq, u32 end_seq) in tcp_is_sackblock_valid() argument
1433 if (after(end_seq, tp->snd_nxt) || !before(start_seq, end_seq)) in tcp_is_sackblock_valid()
1450 if (after(end_seq, tp->snd_una)) in tcp_is_sackblock_valid()
1457 if (!after(end_seq, tp->undo_marker)) in tcp_is_sackblock_valid()
[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_output.c76 WRITE_ONCE(tp->snd_nxt, TCP_SKB_CB(skb)->end_seq); in tcp_event_new_data_sent()
376 TCP_SKB_CB(skb)->end_seq = seq; in tcp_init_nondata_skb()
763 *ptr++ = htonl(sp[this_sack].end_seq); in tcp_options_write()
1613 if (after(tcb->end_seq, tp->snd_nxt) || tcb->seq == tcb->end_seq) in __tcp_transmit_skb()
1663 WRITE_ONCE(tp->write_seq, TCP_SKB_CB(skb)->end_seq); in tcp_queue_skb()
1807 TCP_SKB_CB(buff)->end_seq = TCP_SKB_CB(skb)->end_seq; in tcp_fragment()
1808 TCP_SKB_CB(skb)->end_seq = TCP_SKB_CB(buff)->seq; in tcp_fragment()
1834 if (!before(tp->snd_nxt, TCP_SKB_CB(buff)->end_seq)) { in tcp_fragment()
2141 tp->snd_sml = TCP_SKB_CB(skb)->end_seq; in tcp_minshall_update()
2302 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_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.c704 tcb->seq = tcb->end_seq = tp->write_seq; in tcp_skb_entail()
980 if (skb && TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) { in tcp_remove_empty_skb()
1338 TCP_SKB_CB(skb)->end_seq += copy; in tcp_sendmsg_locked()
1570 WARN(skb && !before(tp->copied_seq, TCP_SKB_CB(skb)->end_seq), in tcp_cleanup_rbuf()
1572 tp->copied_seq, TCP_SKB_CB(skb)->end_seq, tp->rcv_nxt); in tcp_cleanup_rbuf()
3146 u32 end_seq = TCP_SKB_CB(skb)->end_seq; in __tcp_close()
3149 end_seq--; in __tcp_close()
3150 if (after(end_seq, tcp_sk(sk)->copied_seq)) in __tcp_close()
3450 tp->duplicate_sack[0].end_seq in tcp_disconnect()
3145 u32 end_seq = TCP_SKB_CB(skb)->end_seq; __tcp_close() local
[all...]
/linux/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/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()
621 before(seq, info->end_seq - info->len)) { in tls_get_record()
644 last->end_seq)) in tls_get_record()
653 if (before(seq, info->end_seq)) { in tls_get_record()
655 after(info->end_seq, in tls_get_record()
656 context->retransmit_hint->end_seq)) { in tls_get_record()
1129 start_marker_record->end_seq = tcp_sk(sk)->write_seq; in tls_set_device_offload()
/linux/net/mptcp/
H A Dprotocol.c168 to->len, MPTCP_SKB_CB(from)->end_seq); in __mptcp_try_coalesce()
169 MPTCP_SKB_CB(to)->end_seq = MPTCP_SKB_CB(from)->end_seq; in __mptcp_try_coalesce()
196 if (MPTCP_SKB_CB(from)->map_seq != MPTCP_SKB_CB(to)->end_seq) in mptcp_ooo_try_coalesce()
228 rcvwin += MPTCP_SKB_CB(msk->ooo_last_skb)->end_seq - msk->ack_seq; in mptcp_rcvbuf_grow()
248 u64 seq, end_seq, max_seq; in mptcp_data_queue_ofo() local
252 end_seq = MPTCP_SKB_CB(skb)->end_seq; in mptcp_data_queue_ofo()
257 if (after64(end_seq, max_seq)) { in mptcp_data_queue_ofo()
261 (unsigned long long)end_seq in mptcp_data_queue_ofo()
783 u64 end_seq; __mptcp_ofo_queue() local
[all...]
H A Dfastopen.c46 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()
946 TCP_SKB_CB(skb)->end_seq == TCP_SKB_CB(skb)->seq && in check_fully_established()
1246 if (TCP_SKB_CB(skb)->seq == TCP_SKB_CB(skb)->end_seq) { in mptcp_incoming_options()
H A Dsubflow.c1136 TCP_SKB_CB(skb)->end_seq, in get_mapping_status()
1277 if (!before(tcp_sk(ssk)->copied_seq, TCP_SKB_CB(skb)->end_seq)) in mptcp_subflow_discard_data()
H A Dprotocol.h130 u64 end_seq; member
/linux/tools/testing/selftests/bpf/progs/
H A Dbpf_cubic.c90 __u32 end_seq; /* end_seq of the round */
168 ca->end_seq = tp->snd_nxt;
388 if (hystart && after(ack, ca->end_seq)) in BPF_PROG()
97 __u32 end_seq; /* end_seq of the round */ global() member
/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 wup + rcv_wnd
/linux/include/net/
H A Dtls.h148 u32 end_seq; member
346 return rec->end_seq - rec->len; in tls_record_start_seq()
H A Dtcp.h1037 __u32 end_seq; /* SEQ + FIN + SYN + datalen */ member
2516 extern void tcp_rack_advance(struct tcp_sock *tp, u8 sacked, u32 end_seq,
/linux/drivers/infiniband/hw/irdma/
H A Dpuda.c1136 u32 marker_seq, end_seq, blk_start; in irdma_ieq_get_fpdu_len() local
1160 end_seq = rcv_seq + total_len; in irdma_ieq_get_fpdu_len()
1161 while ((int)(marker_seq - end_seq) < 0) { in irdma_ieq_get_fpdu_len()
1163 end_seq += marker_len; in irdma_ieq_get_fpdu_len()
/linux/include/trace/events/
H A Dtcp.h247 TCP_SKB_CB(tp->ooo_last_skb)->end_seq -
/linux/net/ipv6/
H A Dtcp_ipv6.c1662 if (TCP_SKB_CB(opt_skb)->end_seq == tp->rcv_nxt &&
1699 TCP_SKB_CB(skb)->end_seq = (TCP_SKB_CB(skb)->seq + th->syn + th->fin +
/linux/net/sched/
H A Dsch_cake.c1071 u32 end_a = get_unaligned_be32(&sack_a->end_seq); in cake_tcph_sack_compare()
1083 u32 end_b = get_unaligned_be32(&sack_tmp->end_seq); in cake_tcph_sack_compare()