Home
last modified time | relevance | path

Searched refs:ack_seq (Results 1 - 25 of 93) sorted by relevance

1234

/kernel/linux/linux-6.6/net/mptcp/
H A Dfastopen.c72 MPTCP_SKB_CB(skb)->map_seq, MPTCP_SKB_CB(skb)->map_seq + msk->ack_seq, in __mptcp_fastopen_gen_msk_ackseq()
73 MPTCP_SKB_CB(skb)->end_seq, MPTCP_SKB_CB(skb)->end_seq + msk->ack_seq); in __mptcp_fastopen_gen_msk_ackseq()
74 MPTCP_SKB_CB(skb)->map_seq += msk->ack_seq; in __mptcp_fastopen_gen_msk_ackseq()
75 MPTCP_SKB_CB(skb)->end_seq += msk->ack_seq; in __mptcp_fastopen_gen_msk_ackseq()
78 pr_debug("msk=%p ack_seq=%llx", msk, msk->ack_seq); in __mptcp_fastopen_gen_msk_ackseq()
H A Doptions.c567 u64 ack_seq; in mptcp_established_options_dss() local
598 ack_seq = READ_ONCE(msk->ack_seq); in mptcp_established_options_dss()
601 opts->ext_copy.data_ack = ack_seq; in mptcp_established_options_dss()
605 opts->ext_copy.data_ack32 = (uint32_t)ack_seq; in mptcp_established_options_dss()
1089 mptcp_expand_seq(READ_ONCE(msk->ack_seq), data_fin_seq, use_64bit)); in mptcp_update_rcv_data_fin()
1196 /* we can't wait for recvmsg() to update the ack_seq, otherwise in mptcp_incoming_options()
1254 u64 ack_seq, rcv_wnd_old, rcv_wnd_new; in mptcp_set_rwin() local
1262 ack_seq = READ_ONCE(msk->ack_seq); in mptcp_set_rwin()
[all...]
H A Dsubflow.c460 WRITE_ONCE(msk->ack_seq, subflow->iasn); in subflow_set_remote_key()
1129 map_seq = mptcp_expand_seq(READ_ONCE(msk->ack_seq), mpext->data_seq, mpext->dsn64); in get_mapping_status()
1271 u64 ack_seq; in subflow_check_data_avail() local
1290 old_ack = READ_ONCE(msk->ack_seq); in subflow_check_data_avail()
1291 ack_seq = mptcp_subflow_get_mapped_dsn(subflow); in subflow_check_data_avail()
1292 pr_debug("msk ack_seq=%llx subflow ack_seq=%llx", old_ack, in subflow_check_data_avail()
1293 ack_seq); in subflow_check_data_avail()
1294 if (unlikely(before64(ack_seq, old_ack))) { in subflow_check_data_avail()
1295 mptcp_subflow_discard_data(ssk, skb, old_ack - ack_seq); in subflow_check_data_avail()
[all...]
H A Dprotocol.c383 if (MPTCP_SKB_CB(skb)->map_seq == msk->ack_seq) { in __mptcp_move_skb()
386 WRITE_ONCE(msk->ack_seq, msk->ack_seq + copy_len); in __mptcp_move_skb()
394 } else if (after64(MPTCP_SKB_CB(skb)->map_seq, msk->ack_seq)) { in __mptcp_move_skb()
469 if (msk->ack_seq == rcv_data_fin_seq) { in mptcp_pending_data_fin()
605 WRITE_ONCE(msk->ack_seq, msk->ack_seq + 1); in mptcp_check_data_fin()
740 if (after64(MPTCP_SKB_CB(skb)->map_seq, msk->ack_seq)) in __mptcp_ofo_queue()
747 msk->ack_seq))) { in __mptcp_ofo_queue()
756 int delta = msk->ack_seq in __mptcp_ofo_queue()
[all...]
/kernel/linux/linux-5.10/net/netfilter/
H A Dnf_synproxy_core.c496 nth->ack_seq = htonl(ntohl(th->seq) + 1); in synproxy_send_client_synack()
539 /* ack_seq is used to relay our ISN to the synproxy hook to initialize in synproxy_send_server_syn()
542 nth->ack_seq = htonl(ntohl(th->ack_seq) - 1); in synproxy_send_server_syn()
583 nth->seq = htonl(ntohl(th->ack_seq)); in synproxy_send_server_ack()
584 nth->ack_seq = htonl(ntohl(th->seq) + 1); in synproxy_send_server_ack()
622 nth->ack_seq = th->ack_seq; in synproxy_send_client_ack()
643 mss = __cookie_v4_check(ip_hdr(skb), th, ntohl(th->ack_seq) - 1); in synproxy_recv_client_ack()
733 synproxy->isn = ntohl(th->ack_seq); in ipv4_synproxy_hook()
[all...]
H A Dnf_conntrack_seqadj.c198 if (after(ntohl(tcph->ack_seq) - other_way->offset_before, in nf_ct_seq_adjust()
204 newack = htonl(ntohl(tcph->ack_seq) - ackoff); in nf_ct_seq_adjust()
205 inet_proto_csum_replace4(&tcph->check, skb, tcph->ack_seq, newack, in nf_ct_seq_adjust()
208 ntohl(tcph->seq), ntohl(newseq), ntohl(tcph->ack_seq), in nf_ct_seq_adjust()
210 tcph->ack_seq = newack; in nf_ct_seq_adjust()
/kernel/linux/linux-6.6/net/netfilter/
H A Dnf_synproxy_core.c473 nth->ack_seq = htonl(ntohl(th->seq) + 1); in synproxy_send_client_synack()
516 /* ack_seq is used to relay our ISN to the synproxy hook to initialize in synproxy_send_server_syn()
519 nth->ack_seq = htonl(ntohl(th->ack_seq) - 1); in synproxy_send_server_syn()
560 nth->seq = htonl(ntohl(th->ack_seq)); in synproxy_send_server_ack()
561 nth->ack_seq = htonl(ntohl(th->seq) + 1); in synproxy_send_server_ack()
599 nth->ack_seq = th->ack_seq; in synproxy_send_client_ack()
620 mss = __cookie_v4_check(ip_hdr(skb), th, ntohl(th->ack_seq) - 1); in synproxy_recv_client_ack()
710 synproxy->isn = ntohl(th->ack_seq); in ipv4_synproxy_hook()
[all...]
H A Dnf_conntrack_seqadj.c198 if (after(ntohl(tcph->ack_seq) - other_way->offset_before, in nf_ct_seq_adjust()
204 newack = htonl(ntohl(tcph->ack_seq) - ackoff); in nf_ct_seq_adjust()
205 inet_proto_csum_replace4(&tcph->check, skb, tcph->ack_seq, newack, in nf_ct_seq_adjust()
208 ntohl(tcph->seq), ntohl(newseq), ntohl(tcph->ack_seq), in nf_ct_seq_adjust()
210 tcph->ack_seq = newack; in nf_ct_seq_adjust()
/kernel/linux/linux-5.10/net/netfilter/ipvs/
H A Dip_vs_app.c312 * Fixes th->ack_seq based on ip_vs_seq info.
317 __u32 ack_seq = ntohl(th->ack_seq); in vs_fix_ack_seq() local
320 * Adjust ack_seq with delta-offset for in vs_fix_ack_seq()
325 /* since ack_seq is the number of octet that is expected in vs_fix_ack_seq()
327 if(after(ack_seq, vseq->init_seq+vseq->delta)) { in vs_fix_ack_seq()
328 th->ack_seq = htonl(ack_seq - vseq->delta); in vs_fix_ack_seq()
330 "(%d) from ack_seq\n", __func__, vseq->delta); in vs_fix_ack_seq()
333 th->ack_seq in vs_fix_ack_seq()
[all...]
/kernel/linux/linux-6.6/net/netfilter/ipvs/
H A Dip_vs_app.c312 * Fixes th->ack_seq based on ip_vs_seq info.
317 __u32 ack_seq = ntohl(th->ack_seq); in vs_fix_ack_seq() local
320 * Adjust ack_seq with delta-offset for in vs_fix_ack_seq()
325 /* since ack_seq is the number of octet that is expected in vs_fix_ack_seq()
327 if(after(ack_seq, vseq->init_seq+vseq->delta)) { in vs_fix_ack_seq()
328 th->ack_seq = htonl(ack_seq - vseq->delta); in vs_fix_ack_seq()
330 "(%d) from ack_seq\n", __func__, vseq->delta); in vs_fix_ack_seq()
333 th->ack_seq in vs_fix_ack_seq()
[all...]
/kernel/linux/linux-5.10/net/mptcp/
H A Dprotocol.c165 max_seq = space > 0 ? space + msk->ack_seq : msk->ack_seq; in mptcp_data_queue_ofo()
296 if (MPTCP_SKB_CB(skb)->map_seq == msk->ack_seq) { in __mptcp_move_skb()
298 WRITE_ONCE(msk->ack_seq, msk->ack_seq + copy_len); in __mptcp_move_skb()
306 } else if (after64(MPTCP_SKB_CB(skb)->map_seq, msk->ack_seq)) { in __mptcp_move_skb()
372 if (msk->ack_seq == rcv_data_fin_seq) { in mptcp_pending_data_fin()
417 WRITE_ONCE(msk->ack_seq, msk->ack_seq + 1); in mptcp_check_data_fin()
558 if (after64(MPTCP_SKB_CB(skb)->map_seq, msk->ack_seq)) in mptcp_ofo_queue()
2064 u64 ack_seq; mptcp_sk_clone() local
2421 u64 ack_seq; mptcp_finish_connect() local
[all...]
H A Dsubflow.c895 u64 ack_seq; in subflow_check_data_avail() local
908 subflow->map_seq = READ_ONCE(msk->ack_seq); in subflow_check_data_avail()
932 WRITE_ONCE(msk->ack_seq, subflow->map_seq); in subflow_check_data_avail()
936 old_ack = READ_ONCE(msk->ack_seq); in subflow_check_data_avail()
937 ack_seq = mptcp_subflow_get_mapped_dsn(subflow); in subflow_check_data_avail()
938 pr_debug("msk ack_seq=%llx subflow ack_seq=%llx", old_ack, in subflow_check_data_avail()
939 ack_seq); in subflow_check_data_avail()
940 if (ack_seq == old_ack) { in subflow_check_data_avail()
943 } else if (after64(ack_seq, old_ac in subflow_check_data_avail()
[all...]
/kernel/linux/linux-5.10/drivers/net/slip/
H A Dslhc.c384 if((deltaA = ntohl(th->ack_seq) - ntohl(oth->ack_seq)) != 0L){ in slhc_compress()
554 thp->ack_seq = htonl( ntohl(thp->ack_seq) + i); in slhc_uncompress()
583 thp->ack_seq = htonl( ntohl(thp->ack_seq) + x); in slhc_uncompress()
/kernel/linux/linux-6.6/drivers/net/slip/
H A Dslhc.c384 if((deltaA = ntohl(th->ack_seq) - ntohl(oth->ack_seq)) != 0L){ in slhc_compress()
554 thp->ack_seq = htonl( ntohl(thp->ack_seq) + i); in slhc_uncompress()
583 thp->ack_seq = htonl( ntohl(thp->ack_seq) + x); in slhc_uncompress()
/kernel/linux/common_modules/newip/third_party/linux-5.10/net/newip/
H A Dtcp_nip_input.c273 TCP_SKB_CB(to)->ack_seq = TCP_SKB_CB(from)->ack_seq; in tcp_nip_try_coalesce()
1255 const u32 ack, const u32 ack_seq, in tcp_nip_may_update_window()
1259 after(ack_seq, tp->snd_wl1) || in tcp_nip_may_update_window()
1260 (ack_seq == tp->snd_wl1 && nwin > tp->snd_wnd); in tcp_nip_may_update_window()
1264 u32 ack_seq) in tcp_nip_ack_update_window()
1272 if (tcp_nip_may_update_window(tp, ack, ack_seq, nwin)) { in tcp_nip_ack_update_window()
1273 tcp_update_wl(tp, ack_seq); in tcp_nip_ack_update_window()
1627 u32 ack_seq = TCP_SKB_CB(skb)->seq; in tcp_nip_ack() local
1628 u32 ack = TCP_SKB_CB(skb)->ack_seq; in tcp_nip_ack()
1254 tcp_nip_may_update_window(const struct tcp_sock *tp, const u32 ack, const u32 ack_seq, const u32 nwin) tcp_nip_may_update_window() argument
1263 tcp_nip_ack_update_window(struct sock *sk, const struct sk_buff *skb, u32 ack, u32 ack_seq) tcp_nip_ack_update_window() argument
[all...]
H A Dnip_output.c450 u32 ack_seq, u32 win, int rst, u32 priority) in tcp_nip_actual_send_reset()
488 t1->ack_seq = htonl(ack_seq); in tcp_nip_actual_send_reset()
495 nip_dbg("host seq=%u, net seq=0x%x, host ack_seq=%u, net ack_seq=0x%x", in tcp_nip_actual_send_reset()
496 seq, t1->seq, ack_seq, t1->ack_seq); in tcp_nip_actual_send_reset()
449 tcp_nip_actual_send_reset(struct sock *sk, struct sk_buff *skb, u32 seq, u32 ack_seq, u32 win, int rst, u32 priority) tcp_nip_actual_send_reset() argument
/kernel/linux/linux-5.10/net/ipv6/netfilter/
H A Dnf_reject_ipv6.c103 tcph->seq = oth->ack_seq; in nf_reject_ip6_tcphdr_put()
104 tcph->ack_seq = 0; in nf_reject_ip6_tcphdr_put()
107 tcph->ack_seq = htonl(ntohl(oth->seq) + oth->syn + oth->fin + in nf_reject_ip6_tcphdr_put()
/kernel/linux/linux-5.10/net/ipv4/netfilter/
H A Dnf_reject_ipv4.c82 tcph->seq = oth->ack_seq; in nf_reject_ip_tcphdr_put()
84 tcph->ack_seq = htonl(ntohl(oth->seq) + oth->syn + oth->fin + in nf_reject_ip_tcphdr_put()
/kernel/linux/linux-6.6/net/ipv6/netfilter/
H A Dnf_reject_ipv6.c237 tcph->seq = oth->ack_seq; in nf_reject_ip6_tcphdr_put()
238 tcph->ack_seq = 0; in nf_reject_ip6_tcphdr_put()
241 tcph->ack_seq = htonl(ntohl(oth->seq) + oth->syn + oth->fin + in nf_reject_ip6_tcphdr_put()
/kernel/linux/linux-5.10/net/ipv4/
H A Dtcp_offload.c242 flush |= (__force int)(th->ack_seq ^ th2->ack_seq); in tcp_gro_receive()
/kernel/linux/linux-6.6/net/ipv4/netfilter/
H A Dnf_reject_ipv4.c206 tcph->seq = oth->ack_seq; in nf_reject_ip_tcphdr_put()
208 tcph->ack_seq = htonl(ntohl(oth->seq) + oth->syn + oth->fin + in nf_reject_ip_tcphdr_put()
/kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/
H A Dtest_btf_skc_cls_ingress.c64 recv_cookie = bpf_ntohl(th->ack_seq) - 1; in test_syncookie_helper()
/kernel/linux/linux-6.6/tools/testing/selftests/bpf/progs/
H A Dtest_btf_skc_cls_ingress.c64 recv_cookie = bpf_ntohl(th->ack_seq) - 1; in test_syncookie_helper()
/kernel/linux/linux-5.10/net/rds/
H A Dib_cm.c104 __be64 ack_seq = 0; in rds_ib_cm_connect_complete() local
122 ack_seq = get_unaligned(&dp->ricp_v6.dp_ack_seq); in rds_ib_cm_connect_complete()
129 ack_seq = get_unaligned(&dp->ricp_v4.dp_ack_seq); in rds_ib_cm_connect_complete()
188 if (ack_seq) in rds_ib_cm_connect_complete()
189 rds_send_drop_acked(conn, be64_to_cpu(ack_seq), in rds_ib_cm_connect_complete()
/kernel/linux/linux-6.6/net/rds/
H A Dib_cm.c78 __be64 ack_seq = 0; in rds_ib_cm_connect_complete() local
96 ack_seq = get_unaligned(&dp->ricp_v6.dp_ack_seq); in rds_ib_cm_connect_complete()
103 ack_seq = get_unaligned(&dp->ricp_v4.dp_ack_seq); in rds_ib_cm_connect_complete()
154 if (ack_seq) in rds_ib_cm_connect_complete()
155 rds_send_drop_acked(conn, be64_to_cpu(ack_seq), in rds_ib_cm_connect_complete()

Completed in 43 milliseconds

1234