| /kernel/linux/linux-5.10/fs/hmdfs/comm/ |
| H A D | crypto.c | 12 #include <linux/tcp.h>
22 struct tcp_handle *tcp = conn_impl->connect_handle; in tls_crypto_set_key() local
30 lock_sock(tcp->sock->sk); in tls_crypto_set_key()
31 ctx = tls_get_ctx(tcp->sock->sk); in tls_crypto_set_key()
53 release_sock(tcp->sock->sk); in tls_crypto_set_key()
60 struct tcp_handle *tcp = in tls_crypto_info_init() local
62 if (!tcp) in tls_crypto_info_init()
66 ret = tcp->sock->ops->setsockopt(tcp->sock, SOL_TCP, TCP_ULP, in tls_crypto_info_init()
70 tcp in tls_crypto_info_init()
117 tls_set_tx(struct tcp_handle *tcp) tls_set_tx() argument
148 tls_set_rx(struct tcp_handle *tcp) tls_set_rx() argument
181 struct tcp_handle *tcp = set_crypto_info() local
[all...] |
| H A D | transport.c | 15 #include <linux/tcp.h>
83 struct tcp_handle *tcp = NULL; in hmdfs_tcpi_rtt() local
88 tcp = (struct tcp_handle *)(conn_impl->connect_handle); in hmdfs_tcpi_rtt()
89 if (tcp->sock) in hmdfs_tcpi_rtt()
90 rtt_us = tcp_sk(tcp->sock->sk)->srtt_us >> 3; in hmdfs_tcpi_rtt()
117 hmdfs_err("tcp recv error %d", rc); in tcp_read_head_from_socket()
153 hmdfs_err("tcp recv error %d", rc); in tcp_read_buffer_from_socket()
219 struct tcp_handle *tcp = NULL; in tcp_recvpage_tls() local
226 hmdfs_err("tcp connect == NULL"); in tcp_recvpage_tls()
230 tcp in tcp_recvpage_tls()
397 struct tcp_handle *tcp = NULL; tcp_recvbuffer_cipher() local
456 struct tcp_handle *tcp = NULL; tcp_recvbuffer_tls() local
493 tcp_receive_from_sock(struct tcp_handle *tcp) tcp_receive_from_sock() argument
553 tcp_handle_is_available(struct tcp_handle *tcp) tcp_handle_is_available() argument
596 struct tcp_handle *tcp = (struct tcp_handle *)arg; tcp_recv_thread() local
646 tcp_send_message_sock_cipher(struct tcp_handle *tcp, struct hmdfs_send_data *msg) tcp_send_message_sock_cipher() argument
703 tcp_send_message_sock_tls(struct tcp_handle *tcp, struct hmdfs_send_data *msg) tcp_send_message_sock_tls() argument
756 struct tcp_handle *tcp = connect->connect_handle; tcp_send_rekey_request() local
803 struct tcp_handle *tcp = NULL; tcp_send_message() local
846 tcp_close_socket(struct tcp_handle *tcp) tcp_close_socket() argument
890 is_tcp_socket(struct tcp_handle *tcp) is_tcp_socket() argument
919 tcp_update_socket(struct tcp_handle *tcp, int fd, uint8_t *master_key, struct socket *socket) tcp_update_socket() argument
1011 struct tcp_handle *tcp = kzalloc(sizeof(*tcp), GFP_KERNEL); tcp_alloc_handle() local
1047 struct tcp_handle *tcp = NULL; connection_notify_to_close() local
1061 struct tcp_handle *tcp = NULL; hmdfs_reget_connection() local
1119 struct tcp_handle *tcp = NULL; lookup_conn_by_socketfd_unsafe() local
1200 struct tcp_handle *tcp = NULL; hmdfs_get_conn_tcp() local
[all...] |
| H A D | connection.c | 16 #include <linux/tcp.h>
558 struct tcp_handle *tcp = NULL; in connection_send_handshake() local
564 tcp = conn_impl->connect_handle; in connection_send_handshake()
565 hmdfs_err("Failed to send handshake: err = %d, fd = %d", err, tcp->fd); in connection_send_handshake()
596 struct tcp_handle *tcp = NULL; in connection_to_working() local
604 tcp = conn_impl->connect_handle; in connection_to_working()
605 hmdfs_info("fd %d to working", tcp->fd); in connection_to_working()
631 "Recved handshake request: device_id = %llu, head->len = %d, tcp->fd = %d", in connection_handshake_recv_handler()
641 "Recved handshake response: device_id = %llu, cmd->status = %hhu, tcp->fd = %d", in connection_handshake_recv_handler()
689 hmdfs_err("protocol negotiation failed, remote device_id = %llu, tcp in connection_handshake_recv_handler()
724 struct tcp_handle *tcp = conn->connect_handle; cmd_update_tls_crypto_key() local
746 struct tcp_handle *tcp = NULL; connection_release() local
826 struct tcp_handle *tcp = NULL; hmdfs_dump_deleting_list() local
856 struct tcp_handle *tcp = NULL; hmdfs_disconnect_node() local
972 struct tcp_handle *tcp = NULL; set_conn_sock_quickack() local
[all...] |
| /kernel/linux/linux-6.6/fs/hmdfs/comm/ |
| H A D | crypto.c | 12 #include <linux/tcp.h>
22 struct tcp_handle *tcp = conn_impl->connect_handle; in tls_crypto_set_key() local
30 lock_sock(tcp->sock->sk); in tls_crypto_set_key()
31 ctx = tls_get_ctx(tcp->sock->sk); in tls_crypto_set_key()
53 release_sock(tcp->sock->sk); in tls_crypto_set_key()
60 struct tcp_handle *tcp = in tls_crypto_info_init() local
62 if (!tcp) in tls_crypto_info_init()
66 ret = tcp->sock->ops->setsockopt(tcp->sock, SOL_TCP, TCP_ULP, in tls_crypto_info_init()
70 tcp in tls_crypto_info_init()
117 tls_set_tx(struct tcp_handle *tcp) tls_set_tx() argument
148 tls_set_rx(struct tcp_handle *tcp) tls_set_rx() argument
181 struct tcp_handle *tcp = set_crypto_info() local
[all...] |
| H A D | transport.c | 15 #include <linux/tcp.h>
83 struct tcp_handle *tcp = NULL; in hmdfs_tcpi_rtt() local
88 tcp = (struct tcp_handle *)(conn_impl->connect_handle); in hmdfs_tcpi_rtt()
89 if (tcp->sock) in hmdfs_tcpi_rtt()
90 rtt_us = tcp_sk(tcp->sock->sk)->srtt_us >> 3; in hmdfs_tcpi_rtt()
117 hmdfs_err("tcp recv error %d", rc); in tcp_read_head_from_socket()
153 hmdfs_err("tcp recv error %d", rc); in tcp_read_buffer_from_socket()
219 struct tcp_handle *tcp = NULL; in tcp_recvpage_tls() local
226 hmdfs_err("tcp connect == NULL"); in tcp_recvpage_tls()
230 tcp in tcp_recvpage_tls()
397 struct tcp_handle *tcp = NULL; tcp_recvbuffer_cipher() local
456 struct tcp_handle *tcp = NULL; tcp_recvbuffer_tls() local
493 tcp_receive_from_sock(struct tcp_handle *tcp) tcp_receive_from_sock() argument
553 tcp_handle_is_available(struct tcp_handle *tcp) tcp_handle_is_available() argument
596 struct tcp_handle *tcp = (struct tcp_handle *)arg; tcp_recv_thread() local
646 tcp_send_message_sock_cipher(struct tcp_handle *tcp, struct hmdfs_send_data *msg) tcp_send_message_sock_cipher() argument
703 tcp_send_message_sock_tls(struct tcp_handle *tcp, struct hmdfs_send_data *msg) tcp_send_message_sock_tls() argument
756 struct tcp_handle *tcp = connect->connect_handle; tcp_send_rekey_request() local
803 struct tcp_handle *tcp = NULL; tcp_send_message() local
846 tcp_close_socket(struct tcp_handle *tcp) tcp_close_socket() argument
890 is_tcp_socket(struct tcp_handle *tcp) is_tcp_socket() argument
919 tcp_update_socket(struct tcp_handle *tcp, int fd, uint8_t *master_key, struct socket *socket) tcp_update_socket() argument
1011 struct tcp_handle *tcp = kzalloc(sizeof(*tcp), GFP_KERNEL); tcp_alloc_handle() local
1047 struct tcp_handle *tcp = NULL; connection_notify_to_close() local
1061 struct tcp_handle *tcp = NULL; hmdfs_reget_connection() local
1119 struct tcp_handle *tcp = NULL; lookup_conn_by_socketfd_unsafe() local
1200 struct tcp_handle *tcp = NULL; hmdfs_get_conn_tcp() local
[all...] |
| /kernel/linux/linux-5.10/net/netfilter/ |
| H A D | nf_conntrack_proto_tcp.c | 12 #include <linux/tcp.h>
19 #include <net/tcp.h>
279 seq_printf(s, "%s ", tcp_conntrack_names[ct->proto.tcp.state]); in tcp_print_conntrack()
758 tcp_error_log(skb, state, "invalid tcp flag combination"); in tcp_error()
772 const struct ip_ct_tcp_state *sender = &ct->proto.tcp.seen[0]; in tcp_new()
773 const struct ip_ct_tcp_state *receiver = &ct->proto.tcp.seen[1]; in tcp_new()
785 memset(&ct->proto.tcp, 0, sizeof(ct->proto.tcp)); in tcp_new()
787 ct->proto.tcp.seen[0].td_end = in tcp_new()
790 ct->proto.tcp in tcp_new()
[all...] |
| H A D | nft_synproxy.c | 4 #include <net/tcp.h>
24 const struct tcphdr *tcp, in nft_synproxy_tcp_options()
30 if (tcp->ece && tcp->cwr) in nft_synproxy_tcp_options()
47 const struct tcphdr *tcp, in nft_synproxy_eval_v4()
56 if (tcp->syn) { in nft_synproxy_eval_v4()
58 nft_synproxy_tcp_options(opts, tcp, snet, &info, priv); in nft_synproxy_eval_v4()
59 synproxy_send_client_synack(net, skb, tcp, opts); in nft_synproxy_eval_v4()
62 } else if (tcp->ack) { in nft_synproxy_eval_v4()
64 if (synproxy_recv_client_ack(net, skb, tcp, opt in nft_synproxy_eval_v4()
23 nft_synproxy_tcp_options(struct synproxy_options *opts, const struct tcphdr *tcp, struct synproxy_net *snet, struct nf_synproxy_info *info, const struct nft_synproxy *priv) nft_synproxy_tcp_options() argument
44 nft_synproxy_eval_v4(const struct nft_synproxy *priv, struct nft_regs *regs, const struct nft_pktinfo *pkt, const struct tcphdr *tcp, struct tcphdr *_tcph, struct synproxy_options *opts) nft_synproxy_eval_v4() argument
75 nft_synproxy_eval_v6(const struct nft_synproxy *priv, struct nft_regs *regs, const struct nft_pktinfo *pkt, const struct tcphdr *tcp, struct tcphdr *_tcph, struct synproxy_options *opts) nft_synproxy_eval_v6() argument
113 const struct tcphdr *tcp; nft_synproxy_do_eval() local
[all...] |
| H A D | nfnetlink_osf.c | 14 #include <linux/tcp.h>
17 #include <net/tcp.h>
171 const struct tcphdr *tcp; in nf_osf_hdr_ctx_init() local
173 tcp = skb_header_pointer(skb, ip_hdrlen(skb), sizeof(struct tcphdr), _tcph); in nf_osf_hdr_ctx_init()
174 if (!tcp) in nf_osf_hdr_ctx_init()
177 if (!tcp->syn) in nf_osf_hdr_ctx_init()
182 ctx->window = ntohs(tcp->window); in nf_osf_hdr_ctx_init()
184 if (tcp->doff * 4 > sizeof(struct tcphdr)) { in nf_osf_hdr_ctx_init()
185 ctx->optsize = tcp->doff * 4 - sizeof(struct tcphdr); in nf_osf_hdr_ctx_init()
193 return tcp; in nf_osf_hdr_ctx_init()
209 const struct tcphdr *tcp; nf_osf_match() local
270 const struct tcphdr *tcp; nf_osf_find() local
[all...] |
| /kernel/linux/linux-6.6/tools/testing/selftests/bpf/prog_tests/ |
| H A D | flow_dissector.c | 47 struct tcphdr tcp; member
54 struct tcphdr tcp; member
62 struct tcphdr tcp; member
68 struct tcphdr tcp; member
80 struct tcphdr tcp; member
90 struct tcphdr tcp; member
119 .tcp.doff = 5,
120 .tcp.source = 80,
121 .tcp.dest = 8080,
140 .tcp
[all...] |
| /kernel/linux/linux-6.6/net/netfilter/ |
| H A D | nf_conntrack_proto_tcp.c | 12 #include <linux/tcp.h>
19 #include <net/tcp.h>
271 seq_printf(s, "%s ", tcp_conntrack_names[ct->proto.tcp.state]); in tcp_print_conntrack()
515 struct ip_ct_tcp *state = &ct->proto.tcp; in tcp_in_window()
586 * syn(-ack) reply, it might differ in seq, ack or tcp options. in tcp_in_window()
753 if (ct->proto.tcp.last_dir != dir && in nf_tcp_handle_invalid()
754 (ct->proto.tcp.last_index == TCP_FIN_SET || in nf_tcp_handle_invalid()
755 ct->proto.tcp.last_index == TCP_RST_SET)) { in nf_tcp_handle_invalid()
769 index, dir, ct->proto.tcp.last_index, timeout); in nf_tcp_handle_invalid()
774 ct->proto.tcp in nf_tcp_handle_invalid()
[all...] |
| H A D | nft_synproxy.c | 4 #include <net/tcp.h>
24 const struct tcphdr *tcp, in nft_synproxy_tcp_options()
30 if (tcp->ece && tcp->cwr) in nft_synproxy_tcp_options()
47 const struct tcphdr *tcp, in nft_synproxy_eval_v4()
56 if (tcp->syn) { in nft_synproxy_eval_v4()
58 nft_synproxy_tcp_options(opts, tcp, snet, &info, priv); in nft_synproxy_eval_v4()
59 synproxy_send_client_synack(net, skb, tcp, opts); in nft_synproxy_eval_v4()
62 } else if (tcp->ack) { in nft_synproxy_eval_v4()
64 if (synproxy_recv_client_ack(net, skb, tcp, opt in nft_synproxy_eval_v4()
23 nft_synproxy_tcp_options(struct synproxy_options *opts, const struct tcphdr *tcp, struct synproxy_net *snet, struct nf_synproxy_info *info, const struct nft_synproxy *priv) nft_synproxy_tcp_options() argument
44 nft_synproxy_eval_v4(const struct nft_synproxy *priv, struct nft_regs *regs, const struct nft_pktinfo *pkt, const struct tcphdr *tcp, struct tcphdr *_tcph, struct synproxy_options *opts) nft_synproxy_eval_v4() argument
75 nft_synproxy_eval_v6(const struct nft_synproxy *priv, struct nft_regs *regs, const struct nft_pktinfo *pkt, const struct tcphdr *tcp, struct tcphdr *_tcph, struct synproxy_options *opts) nft_synproxy_eval_v6() argument
113 const struct tcphdr *tcp; nft_synproxy_do_eval() local
[all...] |
| H A D | nfnetlink_osf.c | 14 #include <linux/tcp.h>
17 #include <net/tcp.h>
171 const struct tcphdr *tcp; in nf_osf_hdr_ctx_init() local
173 tcp = skb_header_pointer(skb, ip_hdrlen(skb), sizeof(struct tcphdr), _tcph); in nf_osf_hdr_ctx_init()
174 if (!tcp) in nf_osf_hdr_ctx_init()
177 if (!tcp->syn) in nf_osf_hdr_ctx_init()
182 ctx->window = ntohs(tcp->window); in nf_osf_hdr_ctx_init()
184 if (tcp->doff * 4 > sizeof(struct tcphdr)) { in nf_osf_hdr_ctx_init()
185 ctx->optsize = tcp->doff * 4 - sizeof(struct tcphdr); in nf_osf_hdr_ctx_init()
193 return tcp; in nf_osf_hdr_ctx_init()
209 const struct tcphdr *tcp; nf_osf_match() local
270 const struct tcphdr *tcp; nf_osf_find() local
[all...] |
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/prog_tests/ |
| H A D | flow_dissector.c | 44 struct tcphdr tcp; member
51 struct tcphdr tcp; member
59 struct tcphdr tcp; member
65 struct tcphdr tcp; member
77 struct tcphdr tcp; member
87 struct tcphdr tcp; member
115 .tcp.doff = 5,
116 .tcp.source = 80,
117 .tcp.dest = 8080,
135 .tcp
[all...] |
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/progs/ |
| H A D | test_pkt_access.c | 12 #include <linux/tcp.h>
87 struct tcphdr *tcp = NULL; in test_pkt_write_access_subprog() local
92 tcp = data + off; in test_pkt_write_access_subprog()
93 if (tcp + 1 > data_end) in test_pkt_write_access_subprog()
96 tcp->check++; in test_pkt_write_access_subprog()
106 struct tcphdr *tcp = NULL; in test_pkt_access() local
120 tcp = (struct tcphdr *)((void *)(iph) + ihl_len); in test_pkt_access()
128 tcp = (struct tcphdr *)((void *)(ip6h) + ihl_len); in test_pkt_access()
137 if (tcp) { in test_pkt_access()
138 if (test_pkt_write_access_subprog(skb, (void *)tcp in test_pkt_access()
[all...] |
| /kernel/linux/linux-6.6/tools/testing/selftests/bpf/progs/ |
| H A D | test_pkt_access.c | 12 #include <linux/tcp.h>
89 struct tcphdr *tcp = NULL; in test_pkt_write_access_subprog() local
94 tcp = data + off; in test_pkt_write_access_subprog()
95 if (tcp + 1 > data_end) in test_pkt_write_access_subprog()
98 tcp->check++; in test_pkt_write_access_subprog()
108 struct tcphdr *tcp = NULL; in test_pkt_access() local
122 tcp = (struct tcphdr *)((void *)(iph) + ihl_len); in test_pkt_access()
130 tcp = (struct tcphdr *)((void *)(ip6h) + ihl_len); in test_pkt_access()
139 if (tcp) { in test_pkt_access()
140 if (test_pkt_write_access_subprog(skb, (void *)tcp in test_pkt_access()
[all...] |
| H A D | xdp_synproxy_kern.c | 369 struct tcphdr *tcp; member
395 hdr->tcp = (void *)hdr->ipv4 + hdr->ipv4->ihl * 4; in tcp_dissect()
412 hdr->tcp = (void *)hdr->ipv6 + sizeof(*hdr->ipv6); in tcp_dissect()
419 if (hdr->tcp + 1 > data_end) in tcp_dissect()
421 hdr->tcp_len = hdr->tcp->doff * 4; in tcp_dissect()
422 if (hdr->tcp_len < sizeof(*hdr->tcp)) in tcp_dissect()
447 tup.ipv4.sport = hdr->tcp->source; in tcp_lookup()
448 tup.ipv4.dport = hdr->tcp->dest; in tcp_lookup()
453 tup.ipv6.sport = hdr->tcp->source; in tcp_lookup()
454 tup.ipv6.dport = hdr->tcp in tcp_lookup()
[all...] |
| H A D | test_migrate_reuseport.c | 19 #include <linux/tcp.h>
50 struct tcphdr *tcp = NULL; in drop_ack() local
65 tcp = (struct tcphdr *)((void *)ip + ip->ihl * 4); in drop_ack()
77 tcp = (struct tcphdr *)(ipv6 + 1); in drop_ack()
84 if (tcp + 1 > data_end) in drop_ack()
87 if (tcp->dest != server_port) in drop_ack()
90 if (!tcp->syn && tcp->ack) in drop_ack()
|
| H A D | skb_pkt_end.c | 32 struct tcphdr *tcp; in main_prog() local
43 tcp = (void*)(ip + 1); in main_prog()
44 if (tcp->dest != 0) in main_prog()
46 if (!tcp) in main_prog()
49 return tcp->urg_ptr; in main_prog()
|
| H A D | test_assign_reuse.c | 9 #include <linux/tcp.h>
20 struct tcphdr tcp; member
39 if (ctx->data + sizeof(headers.tcp) > ctx->data_end) in reuse_accept()
42 if (__builtin_memcmp(&headers.tcp, ctx->data, sizeof(headers.tcp)) != 0) in reuse_accept()
89 __builtin_memcpy(&headers.tcp, th, sizeof(headers.tcp)); in maybe_assign_tcp()
|
| H A D | xdpwall.c | 11 #include <linux/tcp.h>
173 static __always_inline bool tcphdr_only_contains_flag(struct tcphdr *tcp, in tcphdr_only_contains_flag() argument
176 return (tcp_flag_word(tcp) & in tcphdr_only_contains_flag()
181 struct tcphdr *tcp) { in set_tcp_flags()
182 if (tcphdr_only_contains_flag(tcp, TCP_FLAG_SYN)) in set_tcp_flags()
184 else if (tcphdr_only_contains_flag(tcp, TCP_FLAG_ACK)) in set_tcp_flags()
186 else if (tcphdr_only_contains_flag(tcp, TCP_FLAG_RST)) in set_tcp_flags()
193 struct tcphdr *tcp = transport_hdr; in parse_tcp() local
195 if (tcp + 1 > data_end) in parse_tcp()
198 info->sport = bpf_ntohs(tcp in parse_tcp()
180 set_tcp_flags(struct pkt_info *info, struct tcphdr *tcp) set_tcp_flags() argument
[all...] |
| /kernel/linux/linux-5.10/net/ipv4/netfilter/ |
| H A D | nf_nat_h323.c | 13 #include <linux/tcp.h>
14 #include <net/tcp.h>
290 exp->saved_proto.tcp.port = exp->tuple.dst.u.tcp.port; in nat_t120()
298 exp->tuple.dst.u.tcp.port = htons(nated_port); in nat_t120()
323 ntohs(exp->tuple.src.u.tcp.port), in nat_t120()
325 ntohs(exp->tuple.dst.u.tcp.port)); in nat_t120()
342 exp->saved_proto.tcp.port = exp->tuple.dst.u.tcp.port; in nat_h245()
354 exp->tuple.dst.u.tcp in nat_h245()
[all...] |
| /kernel/linux/linux-5.10/drivers/net/ethernet/chelsio/libcxgb/ |
| H A D | libcxgb_cm.c | 33 #include <linux/tcp.h>
54 struct tcphdr *tcp = (struct tcphdr *) in cxgb_get_4tuple() local
60 ntohs(tcp->source), ntohs(tcp->dest)); in cxgb_get_4tuple()
67 ntohs(tcp->source), ntohs(tcp->dest)); in cxgb_get_4tuple()
72 *peer_port = tcp->source; in cxgb_get_4tuple()
73 *local_port = tcp->dest; in cxgb_get_4tuple()
|
| /kernel/linux/linux-5.10/samples/bpf/ |
| H A D | parse_varlen.c | 13 #include <linux/tcp.h>
22 static int tcp(void *data, uint64_t tp_off, void *data_end) in tcp() function
24 struct tcphdr *tcp = data + tp_off; in tcp() local
26 if (tcp + 1 > data_end) in tcp()
28 if (tcp->dest == htons(80) || tcp->source == htons(80)) in tcp()
72 return tcp(data, nh_off + ihl_len, data_end); in parse_ipv4()
106 return tcp(data, nh_off + ihl_len, data_end); in parse_ipv6()
|
| /kernel/linux/linux-6.6/drivers/net/ethernet/chelsio/libcxgb/ |
| H A D | libcxgb_cm.c | 33 #include <linux/tcp.h>
54 struct tcphdr *tcp = (struct tcphdr *) in cxgb_get_4tuple() local
60 ntohs(tcp->source), ntohs(tcp->dest)); in cxgb_get_4tuple()
67 ntohs(tcp->source), ntohs(tcp->dest)); in cxgb_get_4tuple()
72 *peer_port = tcp->source; in cxgb_get_4tuple()
73 *local_port = tcp->dest; in cxgb_get_4tuple()
|
| /kernel/linux/linux-6.6/samples/bpf/ |
| H A D | parse_varlen.c | 13 #include <linux/tcp.h>
22 static int tcp(void *data, uint64_t tp_off, void *data_end) in tcp() function
24 struct tcphdr *tcp = data + tp_off; in tcp() local
26 if (tcp + 1 > data_end) in tcp()
28 if (tcp->dest == htons(80) || tcp->source == htons(80)) in tcp()
72 return tcp(data, nh_off + ihl_len, data_end); in parse_ipv4()
106 return tcp(data, nh_off + ihl_len, data_end); in parse_ipv6()
|