Commit 7559c7a2 authored by Chuck Lever's avatar Chuck Lever Committed by Trond Myklebust

SUNRPC: Make address format buffers more generic

For now we will assume that all transports will use the address format
buffers in the rpc_xprt struct to store their addresses.  Change
rpc_peer2str() to be a generic routine to handle this, and get rid of the
print_address() op in the rpc_xprt_ops vector.
Signed-off-by: default avatarChuck Lever <chuck.lever@oracle.com>
Signed-off-by: default avatarTrond Myklebust <Trond.Myklebust@netapp.com>
parent 314dfd79
...@@ -106,7 +106,6 @@ struct rpc_rqst { ...@@ -106,7 +106,6 @@ struct rpc_rqst {
struct rpc_xprt_ops { struct rpc_xprt_ops {
void (*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize); void (*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize);
char * (*print_addr)(struct rpc_xprt *xprt, enum rpc_display_format_t format);
int (*reserve_xprt)(struct rpc_task *task); int (*reserve_xprt)(struct rpc_task *task);
void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task); void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
void (*rpcbind)(struct rpc_task *task); void (*rpcbind)(struct rpc_task *task);
......
...@@ -594,7 +594,11 @@ EXPORT_SYMBOL_GPL(rpc_peeraddr); ...@@ -594,7 +594,11 @@ EXPORT_SYMBOL_GPL(rpc_peeraddr);
char *rpc_peeraddr2str(struct rpc_clnt *clnt, enum rpc_display_format_t format) char *rpc_peeraddr2str(struct rpc_clnt *clnt, enum rpc_display_format_t format)
{ {
struct rpc_xprt *xprt = clnt->cl_xprt; struct rpc_xprt *xprt = clnt->cl_xprt;
return xprt->ops->print_addr(xprt, format);
if (xprt->address_strings[format] != NULL)
return xprt->address_strings[format];
else
return "unprintable";
} }
EXPORT_SYMBOL_GPL(rpc_peeraddr2str); EXPORT_SYMBOL_GPL(rpc_peeraddr2str);
......
...@@ -1060,19 +1060,6 @@ static unsigned short xs_get_random_port(void) ...@@ -1060,19 +1060,6 @@ static unsigned short xs_get_random_port(void)
return rand + xprt_min_resvport; return rand + xprt_min_resvport;
} }
/**
* xs_print_peer_address - format an IPv4 address for printing
* @xprt: generic transport
* @format: flags field indicating which parts of the address to render
*/
static char *xs_print_peer_address(struct rpc_xprt *xprt, enum rpc_display_format_t format)
{
if (xprt->address_strings[format] != NULL)
return xprt->address_strings[format];
else
return "unprintable";
}
/** /**
* xs_set_port - reset the port number in the remote endpoint address * xs_set_port - reset the port number in the remote endpoint address
* @xprt: generic transport * @xprt: generic transport
...@@ -1146,7 +1133,7 @@ static void xs_udp_connect_worker(void *args) ...@@ -1146,7 +1133,7 @@ static void xs_udp_connect_worker(void *args)
} }
dprintk("RPC: worker connecting xprt %p to address: %s\n", dprintk("RPC: worker connecting xprt %p to address: %s\n",
xprt, xs_print_peer_address(xprt, RPC_DISPLAY_ALL)); xprt, xprt->address_strings[RPC_DISPLAY_ALL]);
if (!transport->inet) { if (!transport->inet) {
struct sock *sk = sock->sk; struct sock *sk = sock->sk;
...@@ -1233,7 +1220,7 @@ static void xs_tcp_connect_worker(void *args) ...@@ -1233,7 +1220,7 @@ static void xs_tcp_connect_worker(void *args)
xs_tcp_reuse_connection(xprt); xs_tcp_reuse_connection(xprt);
dprintk("RPC: worker connecting xprt %p to address: %s\n", dprintk("RPC: worker connecting xprt %p to address: %s\n",
xprt, xs_print_peer_address(xprt, RPC_DISPLAY_ALL)); xprt, xprt->address_strings[RPC_DISPLAY_ALL]);
if (!transport->inet) { if (!transport->inet) {
struct sock *sk = sock->sk; struct sock *sk = sock->sk;
...@@ -1380,7 +1367,6 @@ static void xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) ...@@ -1380,7 +1367,6 @@ static void xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq)
static struct rpc_xprt_ops xs_udp_ops = { static struct rpc_xprt_ops xs_udp_ops = {
.set_buffer_size = xs_udp_set_buffer_size, .set_buffer_size = xs_udp_set_buffer_size,
.print_addr = xs_print_peer_address,
.reserve_xprt = xprt_reserve_xprt_cong, .reserve_xprt = xprt_reserve_xprt_cong,
.release_xprt = xprt_release_xprt_cong, .release_xprt = xprt_release_xprt_cong,
.rpcbind = rpc_getport, .rpcbind = rpc_getport,
...@@ -1398,7 +1384,6 @@ static struct rpc_xprt_ops xs_udp_ops = { ...@@ -1398,7 +1384,6 @@ static struct rpc_xprt_ops xs_udp_ops = {
}; };
static struct rpc_xprt_ops xs_tcp_ops = { static struct rpc_xprt_ops xs_tcp_ops = {
.print_addr = xs_print_peer_address,
.reserve_xprt = xprt_reserve_xprt, .reserve_xprt = xprt_reserve_xprt,
.release_xprt = xs_tcp_release_xprt, .release_xprt = xs_tcp_release_xprt,
.rpcbind = rpc_getport, .rpcbind = rpc_getport,
...@@ -1485,7 +1470,7 @@ struct rpc_xprt *xs_setup_udp(struct sockaddr *addr, size_t addrlen, struct rpc_ ...@@ -1485,7 +1470,7 @@ struct rpc_xprt *xs_setup_udp(struct sockaddr *addr, size_t addrlen, struct rpc_
xs_format_peer_addresses(xprt); xs_format_peer_addresses(xprt);
dprintk("RPC: set up transport to address %s\n", dprintk("RPC: set up transport to address %s\n",
xs_print_peer_address(xprt, RPC_DISPLAY_ALL)); xprt->address_strings[RPC_DISPLAY_ALL]);
return xprt; return xprt;
} }
...@@ -1529,7 +1514,7 @@ struct rpc_xprt *xs_setup_tcp(struct sockaddr *addr, size_t addrlen, struct rpc_ ...@@ -1529,7 +1514,7 @@ struct rpc_xprt *xs_setup_tcp(struct sockaddr *addr, size_t addrlen, struct rpc_
xs_format_peer_addresses(xprt); xs_format_peer_addresses(xprt);
dprintk("RPC: set up transport to address %s\n", dprintk("RPC: set up transport to address %s\n",
xs_print_peer_address(xprt, RPC_DISPLAY_ALL)); xprt->address_strings[RPC_DISPLAY_ALL]);
return xprt; return xprt;
} }
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment