On Fri, 19 Jun 2015 19:25:59 -0400
Trond Myklebust <trond.mykleb...@primarydata.com> wrote:
> 8<--------------------------------------------------------------
> >From 4876cc779ff525b9c2376d8076edf47815e71f2c Mon Sep 17 00:00:00 2001
> From: Trond Myklebust <trond.mykleb...@primarydata.com>
> Date: Fri, 19 Jun 2015 16:17:57 -0400
> Subject: [PATCH v2] SUNRPC: Ensure we release the TCP socket once it has been
> closed
>
> This fixes a regression introduced by commit caf4ccd4e88cf2 ("SUNRPC:
> Make xs_tcp_close() do a socket shutdown rather than a sock_release").
> Prior to that commit, the autoclose feature would ensure that an
> idle connection would result in the socket being both disconnected and
> released, whereas now only gets disconnected.
>
> While the current behaviour is harmless, it does leave the port bound
> until either RPC traffic resumes or the RPC client is shut down.
Is there a way to test RPC traffic resuming? I'd like to try that before
declaring this bug harmless.
>
> Reported-by: Steven Rostedt <rost...@goodmis.org>
The problem appears to go away with this patch.
Tested-by: Steven Rostedt <rost...@goodmis.org>
Thanks a lot!
-- Steve
> Signed-off-by: Trond Myklebust <trond.mykleb...@primarydata.com>
> ---
> net/sunrpc/xprt.c | 2 +-
> net/sunrpc/xprtsock.c | 40 ++++++++++++++++++++++------------------
> 2 files changed, 23 insertions(+), 19 deletions(-)
>
> diff --git a/net/sunrpc/xprt.c b/net/sunrpc/xprt.c
> index 3ca31f20b97c..ab5dd621ae0c 100644
> --- a/net/sunrpc/xprt.c
> +++ b/net/sunrpc/xprt.c
> @@ -611,8 +611,8 @@ static void xprt_autoclose(struct work_struct *work)
> struct rpc_xprt *xprt =
> container_of(work, struct rpc_xprt, task_cleanup);
>
> - xprt->ops->close(xprt);
> clear_bit(XPRT_CLOSE_WAIT, &xprt->state);
> + xprt->ops->close(xprt);
> xprt_release_write(xprt, NULL);
> }
>
> diff --git a/net/sunrpc/xprtsock.c b/net/sunrpc/xprtsock.c
> index fda8ec8c74c0..ee0715dfc3c7 100644
> --- a/net/sunrpc/xprtsock.c
> +++ b/net/sunrpc/xprtsock.c
> @@ -623,24 +623,6 @@ process_status:
> }
>
> /**
> - * xs_tcp_shutdown - gracefully shut down a TCP socket
> - * @xprt: transport
> - *
> - * Initiates a graceful shutdown of the TCP socket by calling the
> - * equivalent of shutdown(SHUT_RDWR);
> - */
> -static void xs_tcp_shutdown(struct rpc_xprt *xprt)
> -{
> - struct sock_xprt *transport = container_of(xprt, struct sock_xprt,
> xprt);
> - struct socket *sock = transport->sock;
> -
> - if (sock != NULL) {
> - kernel_sock_shutdown(sock, SHUT_RDWR);
> - trace_rpc_socket_shutdown(xprt, sock);
> - }
> -}
> -
> -/**
> * xs_tcp_send_request - write an RPC request to a TCP socket
> * @task: address of RPC task that manages the state of an RPC request
> *
> @@ -786,6 +768,7 @@ static void xs_sock_mark_closed(struct rpc_xprt *xprt)
> xs_sock_reset_connection_flags(xprt);
> /* Mark transport as closed and wake up all pending tasks */
> xprt_disconnect_done(xprt);
> + xprt_force_disconnect(xprt);
> }
>
> /**
> @@ -2103,6 +2086,27 @@ out:
> xprt_wake_pending_tasks(xprt, status);
> }
>
> +/**
> + * xs_tcp_shutdown - gracefully shut down a TCP socket
> + * @xprt: transport
> + *
> + * Initiates a graceful shutdown of the TCP socket by calling the
> + * equivalent of shutdown(SHUT_RDWR);
> + */
> +static void xs_tcp_shutdown(struct rpc_xprt *xprt)
> +{
> + struct sock_xprt *transport = container_of(xprt, struct sock_xprt,
> xprt);
> + struct socket *sock = transport->sock;
> +
> + if (sock == NULL)
> + return;
> + if (xprt_connected(xprt)) {
> + kernel_sock_shutdown(sock, SHUT_RDWR);
> + trace_rpc_socket_shutdown(xprt, sock);
> + } else
> + xs_reset_transport(transport);
> +}
> +
> static int xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket
> *sock)
> {
> struct sock_xprt *transport = container_of(xprt, struct sock_xprt,
> xprt);
--
To unsubscribe from this list: send the line "unsubscribe netdev" in
