/linux-6.12.1/tools/testing/selftests/bpf/progs/ |
D | cgroup_tcp_skb.c | 25 int needed_tcp_pkt(struct __sk_buff *skb, struct tcphdr *tcph) in needed_tcp_pkt() argument 37 if (bpf_skb_load_bytes(skb, sizeof(ip6h), tcph, sizeof(*tcph))) in needed_tcp_pkt() 40 if (tcph->source != bpf_htons(g_sock_port) && in needed_tcp_pkt() 41 tcph->dest != bpf_htons(g_sock_port)) in needed_tcp_pkt() 48 static int egress_accept(struct tcphdr *tcph) in egress_accept() argument 51 if (tcph->fin || !tcph->syn || !tcph->ack) in egress_accept() 61 static int ingress_accept(struct tcphdr *tcph) in ingress_accept() argument 65 if (!tcph->syn || tcph->fin || tcph->ack) in ingress_accept() 71 if (tcph->fin || tcph->syn || !tcph->ack) in ingress_accept() 84 static int egress_connect(struct tcphdr *tcph) in egress_connect() argument [all …]
|
D | test_tcp_check_syncookie_kern.c | 28 struct tcphdr *tcph) in gen_syncookie() argument 30 __u32 thlen = tcph->doff * 4; in gen_syncookie() 32 if (tcph->syn && !tcph->ack) { in gen_syncookie() 37 if ((void *)tcph + thlen > data_end) in gen_syncookie() 40 return bpf_tcp_gen_syncookie(sk, iph, ip_size, tcph, thlen); in gen_syncookie() 53 struct tcphdr *tcph; in check_syncookie() local 73 tcph = data + sizeof(struct ethhdr) + sizeof(struct iphdr); in check_syncookie() 74 if (tcph + 1 > data_end) in check_syncookie() 79 tup.ipv4.sport = tcph->source; in check_syncookie() 80 tup.ipv4.dport = tcph->dest; in check_syncookie() [all …]
|
D | cgroup_skb_sk_lookup_kern.c | 31 const struct tcphdr *tcph) in set_tuple() argument 35 tuple->ipv6.sport = tcph->dest; in set_tuple() 36 tuple->ipv6.dport = tcph->source; in set_tuple() 41 const struct tcphdr *tcph) in is_allowed_peer_cg() argument 48 set_tuple(&tuple, ip6h, tcph); in is_allowed_peer_cg() 70 struct tcphdr tcph; in ingress_lookup() local 85 if (bpf_skb_load_bytes(skb, sizeof(ip6h), &tcph, sizeof(tcph))) in ingress_lookup() 91 if (tcph.dest != g_serv_port) in ingress_lookup() 94 return is_allowed_peer_cg(skb, &ip6h, &tcph); in ingress_lookup()
|
D | test_tc_tunnel.c | 100 struct tcphdr tcph; in __encap_ipv4() local 149 &tcph, sizeof(tcph)) < 0) in __encap_ipv4() 152 if (tcph.dest != __bpf_constant_htons(cfg_port)) in __encap_ipv4() 268 struct tcphdr tcph; in __encap_ipv6() local 280 &tcph, sizeof(tcph)) < 0) in __encap_ipv6() 283 if (tcph.dest != __bpf_constant_htons(cfg_port)) in __encap_ipv6() 377 struct tcphdr tcph; in encap_ipv6_ipip6() local 388 &tcph, sizeof(tcph)) < 0) in encap_ipv6_ipip6() 391 if (tcph.dest != __bpf_constant_htons(cfg_port)) in encap_ipv6_ipip6()
|
D | xdp_flowtable.c | 49 struct tcphdr *tcph = ports; in xdp_flowtable_offload_check_tcp_state() local 51 if (tcph + 1 > data_end) in xdp_flowtable_offload_check_tcp_state() 54 if (tcph->fin || tcph->rst) in xdp_flowtable_offload_check_tcp_state()
|
/linux-6.12.1/net/netfilter/ |
D | nf_conntrack_seqadj.c | 76 struct tcphdr *tcph, in nf_ct_sack_block_adjust() argument 106 inet_proto_csum_replace4(&tcph->check, skb, in nf_ct_sack_block_adjust() 108 inet_proto_csum_replace4(&tcph->check, skb, in nf_ct_sack_block_adjust() 122 struct tcphdr *tcph = (void *)skb->data + protoff; in nf_ct_sack_adjust() local 127 optend = protoff + tcph->doff * 4; in nf_ct_sack_adjust() 132 tcph = (void *)skb->data + protoff; in nf_ct_sack_adjust() 154 nf_ct_sack_block_adjust(skb, tcph, optoff + 2, in nf_ct_sack_adjust() 169 struct tcphdr *tcph; in nf_ct_seq_adjust() local 179 if (skb_ensure_writable(skb, protoff + sizeof(*tcph))) in nf_ct_seq_adjust() 182 tcph = (void *)skb->data + protoff; in nf_ct_seq_adjust() [all …]
|
D | xt_TCPMSS.c | 78 struct tcphdr *tcph; in tcpmss_mangle_packet() local 96 tcph = (struct tcphdr *)(skb_network_header(skb) + tcphoff); in tcpmss_mangle_packet() 97 tcp_hdrlen = tcph->doff * 4; in tcpmss_mangle_packet() 116 opt = (u_int8_t *)tcph; in tcpmss_mangle_packet() 133 inet_proto_csum_replace2(&tcph->check, skb, in tcpmss_mangle_packet() 159 tcph = (struct tcphdr *)(skb_network_header(skb) + tcphoff); in tcpmss_mangle_packet() 176 opt = (u_int8_t *)tcph + sizeof(struct tcphdr); in tcpmss_mangle_packet() 179 inet_proto_csum_replace2(&tcph->check, skb, in tcpmss_mangle_packet() 186 inet_proto_csum_replace4(&tcph->check, skb, 0, *((__be32 *)opt), false); in tcpmss_mangle_packet() 188 oldval = ((__be16 *)tcph)[6]; in tcpmss_mangle_packet() [all …]
|
D | xt_TCPOPTSTRIP.c | 34 struct tcphdr *tcph, _th; in tcpoptstrip_mangle_packet() local 44 tcph = skb_header_pointer(skb, tcphoff, sizeof(_th), &_th); in tcpoptstrip_mangle_packet() 45 if (!tcph) in tcpoptstrip_mangle_packet() 48 tcp_hdrlen = tcph->doff * 4; in tcpoptstrip_mangle_packet() 56 tcph = (struct tcphdr *)(skb_network_header(skb) + tcphoff); in tcpoptstrip_mangle_packet() 57 opt = (u8 *)tcph; in tcpoptstrip_mangle_packet() 79 inet_proto_csum_replace2(&tcph->check, skb, htons(o), in tcpoptstrip_mangle_packet()
|
D | nft_exthdr.c | 174 struct tcphdr *tcph; in nft_tcp_header_pointer() local 179 tcph = skb_header_pointer(pkt->skb, nft_thoff(pkt), sizeof(*tcph), buffer); in nft_tcp_header_pointer() 180 if (!tcph) in nft_tcp_header_pointer() 183 *tcphdr_len = __tcp_hdrlen(tcph); in nft_tcp_header_pointer() 184 if (*tcphdr_len < sizeof(*tcph) || *tcphdr_len > len) in nft_tcp_header_pointer() 198 struct tcphdr *tcph; in nft_exthdr_tcp_eval() local 201 tcph = nft_tcp_header_pointer(pkt, sizeof(buff), buff, &tcphdr_len); in nft_exthdr_tcp_eval() 202 if (!tcph) in nft_exthdr_tcp_eval() 205 opt = (u8 *)tcph; in nft_exthdr_tcp_eval() 206 for (i = sizeof(*tcph); i < tcphdr_len - 1; i += optl) { in nft_exthdr_tcp_eval() [all …]
|
D | nf_conntrack_proto_tcp.c | 275 static unsigned int get_conntrack_index(const struct tcphdr *tcph) in get_conntrack_index() argument 277 if (tcph->rst) return TCP_RST_SET; in get_conntrack_index() 278 else if (tcph->syn) return (tcph->ack ? TCP_SYNACK_SET : TCP_SYN_SET); in get_conntrack_index() 279 else if (tcph->fin) return TCP_FIN_SET; in get_conntrack_index() 280 else if (tcph->ack) return TCP_ACK_SET; in get_conntrack_index() 316 const struct tcphdr *tcph) in segment_seq_plus_len() argument 320 return (seq + len - dataoff - tcph->doff*4 in segment_seq_plus_len() 321 + (tcph->syn ? 1 : 0) + (tcph->fin ? 1 : 0)); in segment_seq_plus_len() 335 const struct tcphdr *tcph, in tcp_options() argument 340 int length = (tcph->doff*4) - sizeof(struct tcphdr); in tcp_options() [all …]
|
D | nf_nat_helper.c | 95 struct tcphdr *tcph; in __nf_nat_mangle_tcp_packet() local 106 tcph = (void *)skb->data + protoff; in __nf_nat_mangle_tcp_packet() 109 mangle_contents(skb, protoff + tcph->doff*4, in __nf_nat_mangle_tcp_packet() 115 tcph, &tcph->check, datalen, oldlen); in __nf_nat_mangle_tcp_packet() 118 nf_ct_seqadj_set(ct, ctinfo, tcph->seq, in __nf_nat_mangle_tcp_packet()
|
D | nf_flow_table_ip.c | 25 struct tcphdr *tcph; in nf_flow_state_check() local 30 tcph = (void *)(skb_network_header(skb) + thoff); in nf_flow_state_check() 31 if (unlikely(tcph->fin || tcph->rst)) { in nf_flow_state_check() 42 struct tcphdr *tcph; in nf_flow_nat_ip_tcp() local 44 tcph = (void *)(skb_network_header(skb) + thoff); in nf_flow_nat_ip_tcp() 45 inet_proto_csum_replace4(&tcph->check, skb, addr, new_addr, true); in nf_flow_nat_ip_tcp() 480 struct tcphdr *tcph; in nf_flow_nat_ipv6_tcp() local 482 tcph = (void *)(skb_network_header(skb) + thoff); in nf_flow_nat_ipv6_tcp() 483 inet_proto_csum_replace16(&tcph->check, skb, addr->s6_addr32, in nf_flow_nat_ipv6_tcp()
|
D | nft_flow_offload.c | 298 struct tcphdr _tcph, *tcph = NULL; in nft_flow_offload_eval() local 315 tcph = skb_header_pointer(pkt->skb, nft_thoff(pkt), in nft_flow_offload_eval() 317 if (unlikely(!tcph || tcph->fin || tcph->rst || in nft_flow_offload_eval() 360 if (tcph) { in nft_flow_offload_eval()
|
/linux-6.12.1/net/ipv4/netfilter/ |
D | ipt_ECN.c | 47 struct tcphdr _tcph, *tcph; in set_ect_tcp() local 51 tcph = skb_header_pointer(skb, ip_hdrlen(skb), sizeof(_tcph), &_tcph); in set_ect_tcp() 52 if (!tcph) in set_ect_tcp() 56 tcph->ece == einfo->proto.tcp.ece) && in set_ect_tcp() 58 tcph->cwr == einfo->proto.tcp.cwr)) in set_ect_tcp() 61 if (skb_ensure_writable(skb, ip_hdrlen(skb) + sizeof(*tcph))) in set_ect_tcp() 63 tcph = (void *)ip_hdr(skb) + ip_hdrlen(skb); in set_ect_tcp() 65 oldval = ((__be16 *)tcph)[6]; in set_ect_tcp() 67 tcph->ece = einfo->proto.tcp.ece; in set_ect_tcp() 69 tcph->cwr = einfo->proto.tcp.cwr; in set_ect_tcp() [all …]
|
D | nf_reject_ipv4.c | 197 struct tcphdr *tcph; in nf_reject_ip_tcphdr_put() local 200 tcph = skb_put_zero(nskb, sizeof(struct tcphdr)); in nf_reject_ip_tcphdr_put() 201 tcph->source = oth->dest; in nf_reject_ip_tcphdr_put() 202 tcph->dest = oth->source; in nf_reject_ip_tcphdr_put() 203 tcph->doff = sizeof(struct tcphdr) / 4; in nf_reject_ip_tcphdr_put() 206 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() 211 tcph->ack = 1; in nf_reject_ip_tcphdr_put() 214 tcph->rst = 1; in nf_reject_ip_tcphdr_put() 215 tcph->check = ~tcp_v4_check(sizeof(struct tcphdr), niph->saddr, in nf_reject_ip_tcphdr_put() [all …]
|
/linux-6.12.1/net/netfilter/ipvs/ |
D | ip_vs_proto_tcp.c | 105 tcp_fast_csum_update(int af, struct tcphdr *tcph, in tcp_fast_csum_update() argument 112 tcph->check = in tcp_fast_csum_update() 115 ~csum_unfold(tcph->check)))); in tcp_fast_csum_update() 118 tcph->check = in tcp_fast_csum_update() 121 ~csum_unfold(tcph->check)))); in tcp_fast_csum_update() 126 tcp_partial_csum_update(int af, struct tcphdr *tcph, in tcp_partial_csum_update() argument 133 tcph->check = in tcp_partial_csum_update() 136 csum_unfold(tcph->check)))); in tcp_partial_csum_update() 139 tcph->check = in tcp_partial_csum_update() 142 csum_unfold(tcph->check)))); in tcp_partial_csum_update() [all …]
|
/linux-6.12.1/tools/testing/selftests/net/ |
D | gro.c | 284 struct tcphdr *tcph = buf; in fill_transportlayer() local 286 memset(tcph, 0, sizeof(*tcph)); in fill_transportlayer() 288 tcph->source = htons(SPORT); in fill_transportlayer() 289 tcph->dest = htons(DPORT); in fill_transportlayer() 290 tcph->seq = ntohl(START_SEQ + seq_offset); in fill_transportlayer() 291 tcph->ack_seq = ntohl(START_ACK + ack_offset); in fill_transportlayer() 292 tcph->ack = 1; in fill_transportlayer() 293 tcph->fin = fin; in fill_transportlayer() 294 tcph->doff = 5; in fill_transportlayer() 295 tcph->window = htons(TCP_MAXWIN); in fill_transportlayer() [all …]
|
/linux-6.12.1/drivers/infiniband/hw/irdma/ |
D | cm.c | 310 struct tcphdr *tcph; in irdma_form_ah_cm_frame() local 338 pktsize = sizeof(*tcph) + opts_len + hdr_len + pd_len; in irdma_form_ah_cm_frame() 340 memset(buf, 0, sizeof(*tcph)); in irdma_form_ah_cm_frame() 343 sqbuf->tcphlen = sizeof(*tcph) + opts_len; in irdma_form_ah_cm_frame() 346 tcph = (struct tcphdr *)buf; in irdma_form_ah_cm_frame() 347 buf += sizeof(*tcph); in irdma_form_ah_cm_frame() 349 tcph->source = htons(cm_node->loc_port); in irdma_form_ah_cm_frame() 350 tcph->dest = htons(cm_node->rem_port); in irdma_form_ah_cm_frame() 351 tcph->seq = htonl(cm_node->tcp_cntxt.loc_seq_num); in irdma_form_ah_cm_frame() 355 tcph->ack_seq = htonl(cm_node->tcp_cntxt.loc_ack_num); in irdma_form_ah_cm_frame() [all …]
|
D | utils.c | 1420 struct tcphdr *tcph = (struct tcphdr *)buf->tcph; in irdma_ieq_get_qp() local 1430 loc_port = ntohs(tcph->dest); in irdma_ieq_get_qp() 1431 rem_port = ntohs(tcph->source); in irdma_ieq_get_qp() 1451 struct tcphdr *tcph = (struct tcphdr *)buf->tcph; in irdma_send_ieq_ack() local 1454 cm_node->tcp_cntxt.loc_seq_num = ntohl(tcph->ack_seq); in irdma_send_ieq_ack() 1513 struct tcphdr *tcph; in irdma_gen1_ieq_update_tcpip_info() local 1521 tcph = (struct tcphdr *)(addr + buf->maclen + iphlen); in irdma_gen1_ieq_update_tcpip_info() 1524 tcph->seq = htonl(seqnum); in irdma_gen1_ieq_update_tcpip_info() 1536 struct tcphdr *tcph; in irdma_ieq_update_tcpip_info() local 1543 tcph = (struct tcphdr *)addr; in irdma_ieq_update_tcpip_info() [all …]
|
/linux-6.12.1/net/core/ |
D | tso.c | 28 struct tcphdr *tcph = (struct tcphdr *)hdr; in tso_build_hdr() local 30 put_unaligned_be32(tso->tcp_seq, &tcph->seq); in tso_build_hdr() 34 tcph->psh = 0; in tso_build_hdr() 35 tcph->fin = 0; in tso_build_hdr() 36 tcph->rst = 0; in tso_build_hdr()
|
/linux-6.12.1/net/ipv6/netfilter/ |
D | nf_reject_ipv6.c | 225 struct tcphdr *tcph; in nf_reject_ip6_tcphdr_put() local 228 tcph = skb_put_zero(nskb, sizeof(struct tcphdr)); in nf_reject_ip6_tcphdr_put() 230 tcph->doff = sizeof(struct tcphdr)/4; in nf_reject_ip6_tcphdr_put() 231 tcph->source = oth->dest; in nf_reject_ip6_tcphdr_put() 232 tcph->dest = oth->source; in nf_reject_ip6_tcphdr_put() 235 tcph->seq = oth->ack_seq; in nf_reject_ip6_tcphdr_put() 237 tcph->ack_seq = htonl(ntohl(oth->seq) + oth->syn + oth->fin + in nf_reject_ip6_tcphdr_put() 239 tcph->ack = 1; in nf_reject_ip6_tcphdr_put() 242 tcph->rst = 1; in nf_reject_ip6_tcphdr_put() 245 tcph->check = csum_ipv6_magic(&ipv6_hdr(nskb)->saddr, in nf_reject_ip6_tcphdr_put() [all …]
|
/linux-6.12.1/net/sched/ |
D | act_csum.c | 208 struct tcphdr *tcph; in tcf_csum_ipv4_tcp() local 214 tcph = tcf_csum_skb_nextlayer(skb, ihl, ipl, sizeof(*tcph)); in tcf_csum_ipv4_tcp() 215 if (tcph == NULL) in tcf_csum_ipv4_tcp() 219 tcph->check = 0; in tcf_csum_ipv4_tcp() 220 skb->csum = csum_partial(tcph, ipl - ihl, 0); in tcf_csum_ipv4_tcp() 221 tcph->check = tcp_v4_check(ipl - ihl, in tcf_csum_ipv4_tcp() 232 struct tcphdr *tcph; in tcf_csum_ipv6_tcp() local 238 tcph = tcf_csum_skb_nextlayer(skb, ihl, ipl, sizeof(*tcph)); in tcf_csum_ipv6_tcp() 239 if (tcph == NULL) in tcf_csum_ipv6_tcp() 243 tcph->check = 0; in tcf_csum_ipv6_tcp() [all …]
|
D | act_nat.c | 181 struct tcphdr *tcph; in tcf_nat_act() local 183 if (!pskb_may_pull(skb, ihl + sizeof(*tcph) + noff) || in tcf_nat_act() 184 skb_try_make_writable(skb, ihl + sizeof(*tcph) + noff)) in tcf_nat_act() 187 tcph = (void *)(skb_network_header(skb) + ihl); in tcf_nat_act() 188 inet_proto_csum_replace4(&tcph->check, skb, addr, new_addr, in tcf_nat_act()
|
/linux-6.12.1/tools/testing/selftests/net/tcp_ao/ |
D | icmps-accept.c | 191 } tcph; in icmp_interfere4() member 209 packet_len = sizeof(packet.iphe) + sizeof(packet.tcph); in icmp_interfere4() 212 packet.tcph.sport = dst->sin_port; in icmp_interfere4() 213 packet.tcph.dport = src->sin_port; in icmp_interfere4() 214 packet.tcph.seq = htonl(rcv_nxt); in icmp_interfere4() 306 } tcph; in icmp6_interfere() member 321 packet_len = sizeof(packet.iphe) + sizeof(packet.tcph); in icmp6_interfere() 324 packet.tcph.sport = dst->sin6_port; in icmp6_interfere() 325 packet.tcph.dport = src->sin6_port; in icmp6_interfere() 326 packet.tcph.seq = htonl(rcv_nxt); in icmp6_interfere()
|
D | icmps-discard.c | 191 } tcph; in icmp_interfere4() member 209 packet_len = sizeof(packet.iphe) + sizeof(packet.tcph); in icmp_interfere4() 212 packet.tcph.sport = dst->sin_port; in icmp_interfere4() 213 packet.tcph.dport = src->sin_port; in icmp_interfere4() 214 packet.tcph.seq = htonl(rcv_nxt); in icmp_interfere4() 306 } tcph; in icmp6_interfere() member 321 packet_len = sizeof(packet.iphe) + sizeof(packet.tcph); in icmp6_interfere() 324 packet.tcph.sport = dst->sin6_port; in icmp6_interfere() 325 packet.tcph.dport = src->sin6_port; in icmp6_interfere() 326 packet.tcph.seq = htonl(rcv_nxt); in icmp6_interfere()
|