| /kernel/linux/linux-5.10/net/sunrpc/ |
| H A D | svcsock.c | 123 struct svc_sock *svsk = in svc_tcp_release_rqst() local
127 skb_free_datagram_locked(svsk->sk_sk, skb); in svc_tcp_release_rqst()
155 struct svc_sock *svsk = in svc_set_cmsg_data() local
157 switch (svsk->sk_sk->sk_family) { in svc_set_cmsg_data()
193 static int svc_one_sock_name(struct svc_sock *svsk, char *buf, int remaining) in svc_one_sock_name() argument
195 const struct sock *sk = svsk->sk_sk; in svc_one_sock_name()
254 struct svc_sock *svsk = in svc_tcp_read_msg() local
264 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
279 len = sock_recvmsg(svsk->sk_sock, &msg, MSG_DONTWAIT); in svc_tcp_read_msg()
287 set_bit(XPT_DATA, &svsk in svc_tcp_read_msg()
295 svc_sock_setbufsize(struct svc_sock *svsk, unsigned int nreqs) svc_sock_setbufsize() argument
322 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; svc_data_ready() local
339 struct svc_sock *svsk = (struct svc_sock *)(sk->sk_user_data); svc_write_space() local
352 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_has_wspace() local
361 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_kill_temp_xprt() local
433 struct svc_sock *svsk = svc_udp_recvfrom() local
554 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_udp_sendto() local
600 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_udp_has_wspace() local
656 svc_udp_init(struct svc_sock *svsk, struct svc_serv *serv) svc_udp_init() argument
693 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; svc_tcp_listen_data_ready() local
723 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; svc_tcp_state_change() local
742 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_accept() local
810 svc_tcp_restore_pages(struct svc_sock *svsk, struct svc_rqst *rqstp) svc_tcp_restore_pages() argument
830 svc_tcp_save_pages(struct svc_sock *svsk, struct svc_rqst *rqstp) svc_tcp_save_pages() argument
844 svc_tcp_clear_pages(struct svc_sock *svsk) svc_tcp_clear_pages() argument
868 svc_tcp_read_marker(struct svc_sock *svsk, struct svc_rqst *rqstp) svc_tcp_read_marker() argument
908 receive_cb_reply(struct svc_sock *svsk, struct svc_rqst *rqstp) receive_cb_reply() argument
953 svc_tcp_fragment_received(struct svc_sock *svsk) svc_tcp_fragment_received() argument
980 struct svc_sock *svsk = svc_tcp_recvfrom() local
1163 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_sendto() local
1242 svc_tcp_init(struct svc_sock *svsk, struct svc_serv *serv) svc_tcp_init() argument
1284 struct svc_sock *svsk; svc_sock_update_bufs() local
1300 struct svc_sock *svsk; svc_setup_socket() local
1378 struct svc_sock *svsk = NULL; svc_addsock() local
1425 struct svc_sock *svsk; svc_create_socket() local
1499 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_sock_detach() local
1516 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_sock_detach() local
1531 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_sock_free() local
[all...] |
| /kernel/linux/linux-6.6/net/sunrpc/ |
| H A D | svcsock.c | 158 struct svc_sock *svsk = in svc_set_cmsg_data() local
160 switch (svsk->sk_sk->sk_family) { in svc_set_cmsg_data()
196 static int svc_one_sock_name(struct svc_sock *svsk, char *buf, int remaining) in svc_one_sock_name() argument
198 const struct sock *sk = svsk->sk_sk; in svc_one_sock_name()
260 svc_tcp_sock_recv_cmsg(struct svc_sock *svsk, struct msghdr *msg) in svc_tcp_sock_recv_cmsg() argument
266 struct socket *sock = svsk->sk_sock; in svc_tcp_sock_recv_cmsg()
304 struct svc_sock *svsk = in svc_tcp_read_msg() local
312 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
324 len = svc_tcp_sock_recv_cmsg(svsk, &msg); in svc_tcp_read_msg()
332 set_bit(XPT_DATA, &svsk in svc_tcp_read_msg()
340 svc_sock_setbufsize(struct svc_sock *svsk, unsigned int nreqs) svc_sock_setbufsize() argument
367 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; svc_data_ready() local
388 struct svc_sock *svsk = (struct svc_sock *)(sk->sk_user_data); svc_write_space() local
401 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_has_wspace() local
410 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_kill_temp_xprt() local
429 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_handshake_done() local
447 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_handshake() local
564 struct svc_sock *svsk = svc_udp_recvfrom() local
689 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_udp_sendto() local
741 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_udp_has_wspace() local
796 svc_udp_init(struct svc_sock *svsk, struct svc_serv *serv) svc_udp_init() argument
833 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; svc_tcp_listen_data_ready() local
865 struct svc_sock *svsk = (struct svc_sock *)sk->sk_user_data; svc_tcp_state_change() local
882 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_accept() local
948 svc_tcp_restore_pages(struct svc_sock *svsk, struct svc_rqst *rqstp) svc_tcp_restore_pages() argument
968 svc_tcp_save_pages(struct svc_sock *svsk, struct svc_rqst *rqstp) svc_tcp_save_pages() argument
982 svc_tcp_clear_pages(struct svc_sock *svsk) svc_tcp_clear_pages() argument
1006 svc_tcp_read_marker(struct svc_sock *svsk, struct svc_rqst *rqstp) svc_tcp_read_marker() argument
1046 receive_cb_reply(struct svc_sock *svsk, struct svc_rqst *rqstp) receive_cb_reply() argument
1091 svc_tcp_fragment_received(struct svc_sock *svsk) svc_tcp_fragment_received() argument
1121 struct svc_sock *svsk = svc_tcp_recvfrom() local
1229 svc_tcp_sendmsg(struct svc_sock *svsk, struct svc_rqst *rqstp, rpc_fraghdr marker, unsigned int *sentp) svc_tcp_sendmsg() argument
1275 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_sendto() local
1350 svc_tcp_init(struct svc_sock *svsk, struct svc_serv *serv) svc_tcp_init() argument
1392 struct svc_sock *svsk; svc_sock_update_bufs() local
1408 struct svc_sock *svsk; svc_setup_socket() local
1471 struct svc_sock *svsk = NULL; svc_addsock() local
1521 struct svc_sock *svsk; svc_create_socket() local
1595 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_sock_detach() local
1612 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_tcp_sock_detach() local
1629 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); svc_sock_free() local
[all...] |
| /kernel/linux/linux-6.6/include/linux/sunrpc/ |
| H A D | svcsock.h | 46 static inline u32 svc_sock_reclen(struct svc_sock *svsk) in svc_sock_reclen() argument
48 return be32_to_cpu(svsk->sk_marker) & RPC_FRAGMENT_SIZE_MASK; in svc_sock_reclen()
51 static inline u32 svc_sock_final_rec(struct svc_sock *svsk) in svc_sock_final_rec() argument
53 return be32_to_cpu(svsk->sk_marker) & RPC_LAST_STREAM_FRAGMENT; in svc_sock_final_rec()
|
| /kernel/linux/linux-5.10/include/linux/sunrpc/ |
| H A D | svcsock.h | 42 static inline u32 svc_sock_reclen(struct svc_sock *svsk) in svc_sock_reclen() argument
44 return be32_to_cpu(svsk->sk_marker) & RPC_FRAGMENT_SIZE_MASK; in svc_sock_reclen()
47 static inline u32 svc_sock_final_rec(struct svc_sock *svsk) in svc_sock_final_rec() argument
49 return be32_to_cpu(svsk->sk_marker) & RPC_LAST_STREAM_FRAGMENT; in svc_sock_final_rec()
|
| /kernel/linux/linux-6.6/include/trace/events/ |
| H A D | sunrpc.h | 2205 const void *svsk,
2208 TP_ARGS(svsk, socket),
2211 __field(const void *, svsk)
2221 __entry->svsk = svsk;
2227 TP_printk("svsk=%p type=%s family=%s%s",
2228 __entry->svsk, show_socket_type(__entry->type),
2236 const void *svsk, \
2239 TP_ARGS(svsk, socket))
|