SUNRPC: Fix TCP rebinding logic
Currently the TCP rebinding logic assumes that if we're not using a reserved port, then we don't need to reconnect on the same port if a disconnection event occurs. This breaks most RPC duplicate reply cache implementations. Also take into account the fact that xprt_min_resvport and xprt_max_resvport may change while we're reconnecting, since the user may change them at any time via the sysctls. Ensure that we check the port boundaries every time we loop in xs_bind4/xs_bind6. Also ensure that if the boundaries change, we only scan the ports a maximum of 2 times. Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
This commit is contained in:
parent
66af1e5585
commit
67a391d72c
|
@ -1276,34 +1276,53 @@ static void xs_set_port(struct rpc_xprt *xprt, unsigned short port)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
static unsigned short xs_get_srcport(struct sock_xprt *transport, struct socket *sock)
|
||||||
|
{
|
||||||
|
unsigned short port = transport->port;
|
||||||
|
|
||||||
|
if (port == 0 && transport->xprt.resvport)
|
||||||
|
port = xs_get_random_port();
|
||||||
|
return port;
|
||||||
|
}
|
||||||
|
|
||||||
|
static unsigned short xs_next_srcport(struct sock_xprt *transport, struct socket *sock, unsigned short port)
|
||||||
|
{
|
||||||
|
if (transport->port != 0)
|
||||||
|
transport->port = 0;
|
||||||
|
if (!transport->xprt.resvport)
|
||||||
|
return 0;
|
||||||
|
if (port <= xprt_min_resvport || port > xprt_max_resvport)
|
||||||
|
return xprt_max_resvport;
|
||||||
|
return --port;
|
||||||
|
}
|
||||||
|
|
||||||
static int xs_bind4(struct sock_xprt *transport, struct socket *sock)
|
static int xs_bind4(struct sock_xprt *transport, struct socket *sock)
|
||||||
{
|
{
|
||||||
struct sockaddr_in myaddr = {
|
struct sockaddr_in myaddr = {
|
||||||
.sin_family = AF_INET,
|
.sin_family = AF_INET,
|
||||||
};
|
};
|
||||||
struct sockaddr_in *sa;
|
struct sockaddr_in *sa;
|
||||||
int err;
|
int err, nloop = 0;
|
||||||
unsigned short port = transport->port;
|
unsigned short port = xs_get_srcport(transport, sock);
|
||||||
|
unsigned short last;
|
||||||
|
|
||||||
if (!transport->xprt.resvport)
|
|
||||||
port = 0;
|
|
||||||
sa = (struct sockaddr_in *)&transport->addr;
|
sa = (struct sockaddr_in *)&transport->addr;
|
||||||
myaddr.sin_addr = sa->sin_addr;
|
myaddr.sin_addr = sa->sin_addr;
|
||||||
do {
|
do {
|
||||||
myaddr.sin_port = htons(port);
|
myaddr.sin_port = htons(port);
|
||||||
err = kernel_bind(sock, (struct sockaddr *) &myaddr,
|
err = kernel_bind(sock, (struct sockaddr *) &myaddr,
|
||||||
sizeof(myaddr));
|
sizeof(myaddr));
|
||||||
if (!transport->xprt.resvport)
|
if (port == 0)
|
||||||
break;
|
break;
|
||||||
if (err == 0) {
|
if (err == 0) {
|
||||||
transport->port = port;
|
transport->port = port;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
if (port <= xprt_min_resvport)
|
last = port;
|
||||||
port = xprt_max_resvport;
|
port = xs_next_srcport(transport, sock, port);
|
||||||
else
|
if (port > last)
|
||||||
port--;
|
nloop++;
|
||||||
} while (err == -EADDRINUSE && port != transport->port);
|
} while (err == -EADDRINUSE && nloop != 2);
|
||||||
dprintk("RPC: %s "NIPQUAD_FMT":%u: %s (%d)\n",
|
dprintk("RPC: %s "NIPQUAD_FMT":%u: %s (%d)\n",
|
||||||
__FUNCTION__, NIPQUAD(myaddr.sin_addr),
|
__FUNCTION__, NIPQUAD(myaddr.sin_addr),
|
||||||
port, err ? "failed" : "ok", err);
|
port, err ? "failed" : "ok", err);
|
||||||
|
@ -1316,28 +1335,27 @@ static int xs_bind6(struct sock_xprt *transport, struct socket *sock)
|
||||||
.sin6_family = AF_INET6,
|
.sin6_family = AF_INET6,
|
||||||
};
|
};
|
||||||
struct sockaddr_in6 *sa;
|
struct sockaddr_in6 *sa;
|
||||||
int err;
|
int err, nloop = 0;
|
||||||
unsigned short port = transport->port;
|
unsigned short port = xs_get_srcport(transport, sock);
|
||||||
|
unsigned short last;
|
||||||
|
|
||||||
if (!transport->xprt.resvport)
|
|
||||||
port = 0;
|
|
||||||
sa = (struct sockaddr_in6 *)&transport->addr;
|
sa = (struct sockaddr_in6 *)&transport->addr;
|
||||||
myaddr.sin6_addr = sa->sin6_addr;
|
myaddr.sin6_addr = sa->sin6_addr;
|
||||||
do {
|
do {
|
||||||
myaddr.sin6_port = htons(port);
|
myaddr.sin6_port = htons(port);
|
||||||
err = kernel_bind(sock, (struct sockaddr *) &myaddr,
|
err = kernel_bind(sock, (struct sockaddr *) &myaddr,
|
||||||
sizeof(myaddr));
|
sizeof(myaddr));
|
||||||
if (!transport->xprt.resvport)
|
if (port == 0)
|
||||||
break;
|
break;
|
||||||
if (err == 0) {
|
if (err == 0) {
|
||||||
transport->port = port;
|
transport->port = port;
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
if (port <= xprt_min_resvport)
|
last = port;
|
||||||
port = xprt_max_resvport;
|
port = xs_next_srcport(transport, sock, port);
|
||||||
else
|
if (port > last)
|
||||||
port--;
|
nloop++;
|
||||||
} while (err == -EADDRINUSE && port != transport->port);
|
} while (err == -EADDRINUSE && nloop != 2);
|
||||||
dprintk("RPC: xs_bind6 "NIP6_FMT":%u: %s (%d)\n",
|
dprintk("RPC: xs_bind6 "NIP6_FMT":%u: %s (%d)\n",
|
||||||
NIP6(myaddr.sin6_addr), port, err ? "failed" : "ok", err);
|
NIP6(myaddr.sin6_addr), port, err ? "failed" : "ok", err);
|
||||||
return err;
|
return err;
|
||||||
|
@ -1819,7 +1837,6 @@ static struct rpc_xprt *xs_setup_xprt(struct xprt_create *args,
|
||||||
xprt->addrlen = args->addrlen;
|
xprt->addrlen = args->addrlen;
|
||||||
if (args->srcaddr)
|
if (args->srcaddr)
|
||||||
memcpy(&new->addr, args->srcaddr, args->addrlen);
|
memcpy(&new->addr, args->srcaddr, args->addrlen);
|
||||||
new->port = xs_get_random_port();
|
|
||||||
|
|
||||||
return xprt;
|
return xprt;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue