Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 2d6f0964 authored by Meena Shanmugam's avatar Meena Shanmugam Committed by Greg Kroah-Hartman
Browse files

SUNRPC: Clean up scheduling of autoclose 



From: Trond Myklebust <trond.myklebust@hammerspace.com>

commit e26d9972720e2484f44cdd94ca4e31cc372ed2ed upstream.

Consolidate duplicated code in xprt_force_disconnect() and
xprt_conditional_disconnect().

Signed-off-by: default avatarTrond Myklebust <trond.myklebust@hammerspace.com>
Signed-off-by: default avatarAnna Schumaker <Anna.Schumaker@Netapp.com>
Signed-off-by: default avatarMeena Shanmugam <meenashanmugam@google.com>
Signed-off-by: default avatarGreg Kroah-Hartman <gregkh@linuxfoundation.org>
parent f3fe8d13

net/sunrpc/xprt.c

+15 −11
Original line number Diff line number Diff line
@@ -717,21 +717,29 @@ void xprt_disconnect_done(struct rpc_xprt *xprt) 
EXPORT_SYMBOL_GPL(xprt_disconnect_done);



/**

 * xprt_force_disconnect - force a transport to disconnect

 * xprt_schedule_autoclose_locked - Try to schedule an autoclose RPC call

 * @xprt: transport to disconnect

 *

 */

void xprt_force_disconnect(struct rpc_xprt *xprt)

static void xprt_schedule_autoclose_locked(struct rpc_xprt *xprt)

{

	/* Don't race with the test_bit() in xprt_clear_locked() */

	spin_lock(&xprt->transport_lock);

	set_bit(XPRT_CLOSE_WAIT, &xprt->state);

	/* Try to schedule an autoclose RPC call */

	if (test_and_set_bit(XPRT_LOCKED, &xprt->state) == 0)

		queue_work(xprtiod_workqueue, &xprt->task_cleanup);

	else if (xprt->snd_task && !test_bit(XPRT_SND_IS_COOKIE, &xprt->state))

		rpc_wake_up_queued_task_set_status(&xprt->pending,

						   xprt->snd_task, -ENOTCONN);

}



/**

 * xprt_force_disconnect - force a transport to disconnect

 * @xprt: transport to disconnect

 *

 */

void xprt_force_disconnect(struct rpc_xprt *xprt)

{

	/* Don't race with the test_bit() in xprt_clear_locked() */

	spin_lock(&xprt->transport_lock);

	xprt_schedule_autoclose_locked(xprt);

	spin_unlock(&xprt->transport_lock);

}

EXPORT_SYMBOL_GPL(xprt_force_disconnect);
@@ -771,11 +779,7 @@ void xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie) 
		goto out;

	if (test_bit(XPRT_CLOSING, &xprt->state))

		goto out;

	set_bit(XPRT_CLOSE_WAIT, &xprt->state);

	/* Try to schedule an autoclose RPC call */

	if (test_and_set_bit(XPRT_LOCKED, &xprt->state) == 0)

		queue_work(xprtiod_workqueue, &xprt->task_cleanup);

	xprt_wake_pending_tasks(xprt, -EAGAIN);

	xprt_schedule_autoclose_locked(xprt);

out:

	spin_unlock(&xprt->transport_lock);

}