net/sunrpc/xprtsock.c
Source file repositories/reference/linux-study-clean/net/sunrpc/xprtsock.c
File Facts
- System
- Linux kernel
- Corpus path
net/sunrpc/xprtsock.c- Extension
.c- Size
- 100335 bytes
- Lines
- 3762
- Domain
- Networking Core
- Bucket
- Sockets, Protocols, Packet Path, And Network Policy
- Inferred role
- Networking Core: implementation source
- Status
- source implementation candidate
Why This File Exists
Networking stack implementation surface: socket APIs, protocol dispatch, packet flow, routing, filtering, and network namespaces.
- Networking stack implementation surface: socket APIs, protocol dispatch, packet flow, routing, filtering, and network namespaces.
- Uses kernel synchronization; read lock ordering, sleepability, and interrupt context assumptions before translating.
- Allocates kernel memory; connect allocation flags and lifetime to context constraints.
- Defines or uses C structs; map object ownership, embedded links, reference counts, and lock ownership.
Dependency Surface
linux/types.hlinux/string.hlinux/slab.hlinux/module.hlinux/capability.hlinux/pagemap.hlinux/errno.hlinux/socket.hlinux/in.hlinux/net.hlinux/mm.hlinux/un.hlinux/udp.hlinux/tcp.hlinux/sunrpc/clnt.hlinux/sunrpc/addr.hlinux/sunrpc/sched.hlinux/sunrpc/svcsock.hlinux/sunrpc/xprtsock.hlinux/file.hlinux/sunrpc/bc_xprt.hnet/sock.hnet/checksum.hnet/udp.hnet/tcp.hnet/tls_prot.hnet/handshake.hlinux/bvec.hlinux/highmem.hlinux/uio.hlinux/sched/mm.htrace/events/sock.h
Detected Declarations
function xs_pktdumpfunction xs_pktdumpfunction xs_format_common_peer_addressesfunction xs_format_common_peer_portsfunction xs_format_peer_addressesfunction xs_update_peer_portfunction xs_free_peer_addressesfunction xs_alloc_sparse_pagesfunction xs_sock_process_cmsgfunction xs_sock_recv_cmsgfunction xs_sock_recvmsgfunction xs_read_kvecfunction xs_read_bvecfunction xs_read_discardfunction xs_flush_bvecfunction xs_flush_bvecfunction xs_read_headerfunction xs_read_stream_request_donefunction xs_read_stream_check_eorfunction xs_read_stream_requestfunction xs_read_stream_headersizefunction xs_read_stream_headerfunction xs_read_stream_callfunction xs_read_stream_callfunction xs_read_stream_replyfunction xs_read_streamfunction xs_poll_socketfunction xs_poll_socket_readablefunction xs_poll_check_readablefunction xs_stream_data_receivefunction xs_stream_data_receive_workfnfunction xs_stream_reset_connectfunction xs_stream_start_connectfunction xs_nospacefunction xs_sock_nospacefunction xs_stream_nospacefunction xs_stream_prepare_requestfunction xs_stream_abort_send_requestfunction xs_send_request_was_abortedfunction xs_stream_record_markerfunction xs_local_send_requestfunction xs_udp_send_requestfunction xs_tcp_send_requestfunction xs_save_old_callbacksfunction xs_restore_old_callbacksfunction xs_sock_reset_state_flagsfunction xs_run_error_workerfunction xs_sock_reset_connection_flags
Annotated Snippet
if (!(j & 31)) {
if (j)
dprintk("\n");
dprintk("0x%04x ", j);
}
dprintk("%02x%02x%02x%02x ",
buf[j], buf[j+1], buf[j+2], buf[j+3]);
}
dprintk("\n");
}
#else
static inline void xs_pktdump(char *msg, u32 *packet, unsigned int count)
{
/* NOP */
}
#endif
static inline struct rpc_xprt *xprt_from_sock(struct sock *sk)
{
return (struct rpc_xprt *) sk->sk_user_data;
}
static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt)
{
return (struct sockaddr *) &xprt->addr;
}
static inline struct sockaddr_un *xs_addr_un(struct rpc_xprt *xprt)
{
return (struct sockaddr_un *) &xprt->addr;
}
static inline struct sockaddr_in *xs_addr_in(struct rpc_xprt *xprt)
{
return (struct sockaddr_in *) &xprt->addr;
}
static inline struct sockaddr_in6 *xs_addr_in6(struct rpc_xprt *xprt)
{
return (struct sockaddr_in6 *) &xprt->addr;
}
static void xs_format_common_peer_addresses(struct rpc_xprt *xprt)
{
struct sockaddr *sap = xs_addr(xprt);
struct sockaddr_in6 *sin6;
struct sockaddr_in *sin;
struct sockaddr_un *sun;
char buf[128];
switch (sap->sa_family) {
case AF_LOCAL:
sun = xs_addr_un(xprt);
if (sun->sun_path[0]) {
strscpy(buf, sun->sun_path, sizeof(buf));
} else {
buf[0] = '@';
strscpy(buf+1, sun->sun_path+1, sizeof(buf)-1);
}
xprt->address_strings[RPC_DISPLAY_ADDR] =
kstrdup(buf, GFP_KERNEL);
break;
case AF_INET:
(void)rpc_ntop(sap, buf, sizeof(buf));
xprt->address_strings[RPC_DISPLAY_ADDR] =
kstrdup(buf, GFP_KERNEL);
sin = xs_addr_in(xprt);
snprintf(buf, sizeof(buf), "%08x", ntohl(sin->sin_addr.s_addr));
break;
case AF_INET6:
(void)rpc_ntop(sap, buf, sizeof(buf));
xprt->address_strings[RPC_DISPLAY_ADDR] =
kstrdup(buf, GFP_KERNEL);
sin6 = xs_addr_in6(xprt);
snprintf(buf, sizeof(buf), "%pi6", &sin6->sin6_addr);
break;
default:
BUG();
}
xprt->address_strings[RPC_DISPLAY_HEX_ADDR] = kstrdup(buf, GFP_KERNEL);
}
static void xs_format_common_peer_ports(struct rpc_xprt *xprt)
{
struct sockaddr *sap = xs_addr(xprt);
char buf[128];
snprintf(buf, sizeof(buf), "%u", rpc_get_port(sap));
xprt->address_strings[RPC_DISPLAY_PORT] = kstrdup(buf, GFP_KERNEL);
Annotation
- Immediate include surface: `linux/types.h`, `linux/string.h`, `linux/slab.h`, `linux/module.h`, `linux/capability.h`, `linux/pagemap.h`, `linux/errno.h`, `linux/socket.h`.
- Detected declarations: `function xs_pktdump`, `function xs_pktdump`, `function xs_format_common_peer_addresses`, `function xs_format_common_peer_ports`, `function xs_format_peer_addresses`, `function xs_update_peer_port`, `function xs_free_peer_addresses`, `function xs_alloc_sparse_pages`, `function xs_sock_process_cmsg`, `function xs_sock_recv_cmsg`.
- Atlas domain: Networking Core / Sockets, Protocols, Packet Path, And Network Policy.
- Implementation status: source implementation candidate.
- Synchronization appears in or near this file; preserve lock ordering, sleepability, and interrupt-context constraints.
Implementation Notes
- This generated page is the file-by-file coverage layer; curated subsystem chapters should link here when they synthesize a multi-file control flow.
- Core OS pages should be promoted from atlas-only to deep-reviewed when they explain data structures, invariants, locking, lifecycle, and C implementation snippets.
- Driver-family pages are intentionally pattern-oriented unless they are part of the selected PCIe/NVMe representative device path.