Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 69199
b: refs/heads/master
c: 95392c5
h: refs/heads/master
i:
  69197: e5c5b6d
  69195: 7a49a39
  69191: 900d2d6
  69183: 211715b
v: v3
  • Loading branch information
Chuck Lever authored and Trond Myklebust committed Oct 9, 2007
1 parent 30337f2 commit e3e4458
Show file tree
Hide file tree
Showing 2 changed files with 21 additions and 7 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 8f9d5b1a2e717fb9e0c4d2c60a224ecce905bd23
refs/heads/master: 95392c593e13fa7546857425971f87e4ded6e0c1
26 changes: 20 additions & 6 deletions trunk/net/sunrpc/xprtsock.c
Original file line number Diff line number Diff line change
Expand Up @@ -263,9 +263,24 @@ struct sock_xprt {
#define TCP_RCV_COPY_XID (1UL << 2)
#define TCP_RCV_COPY_DATA (1UL << 3)

static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt)
{
return (struct sockaddr *) &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_ipv4_peer_addresses(struct rpc_xprt *xprt)
{
struct sockaddr_in *addr = (struct sockaddr_in *) &xprt->addr;
struct sockaddr_in *addr = xs_addr_in(xprt);
char *buf;

buf = kzalloc(20, GFP_KERNEL);
Expand Down Expand Up @@ -317,7 +332,7 @@ static void xs_format_ipv4_peer_addresses(struct rpc_xprt *xprt)

static void xs_format_ipv6_peer_addresses(struct rpc_xprt *xprt)
{
struct sockaddr_in6 *addr = (struct sockaddr_in6 *) &xprt->addr;
struct sockaddr_in6 *addr = xs_addr_in6(xprt);
char *buf;

buf = kzalloc(40, GFP_KERNEL);
Expand Down Expand Up @@ -537,7 +552,7 @@ static int xs_udp_send_request(struct rpc_task *task)

req->rq_xtime = jiffies;
status = xs_sendpages(transport->sock,
(struct sockaddr *) &xprt->addr,
xs_addr(xprt),
xprt->addrlen, xdr,
req->rq_bytes_sent);

Expand Down Expand Up @@ -1214,7 +1229,7 @@ static unsigned short xs_get_random_port(void)
*/
static void xs_set_port(struct rpc_xprt *xprt, unsigned short port)
{
struct sockaddr *addr = (struct sockaddr *) &xprt->addr;
struct sockaddr *addr = xs_addr(xprt);

dprintk("RPC: setting port for xprt %p to %u\n", xprt, port);

Expand Down Expand Up @@ -1497,8 +1512,7 @@ static int xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock)
/* Tell the socket layer to start connecting... */
xprt->stat.connect_count++;
xprt->stat.connect_start = jiffies;
return kernel_connect(sock, (struct sockaddr *) &xprt->addr,
xprt->addrlen, O_NONBLOCK);
return kernel_connect(sock, xs_addr(xprt), xprt->addrlen, O_NONBLOCK);
}

/**
Expand Down

0 comments on commit e3e4458

Please sign in to comment.