SUNRPC: Clean up xprt_release()

Reviewed-by: Chuck Lever <chuck.lever@oracle.com>
Signed-off-by: Trond Myklebust <Trond.Myklebust@netapp.com>
This commit is contained in:
Trond Myklebust 2010-04-16 16:37:01 -04:00
Родитель fd86dfd263
Коммит ee5ebe851e
1 изменённых файлов: 16 добавлений и 16 удалений

Просмотреть файл

@ -62,7 +62,6 @@
* Local functions * Local functions
*/ */
static void xprt_request_init(struct rpc_task *, struct rpc_xprt *); static void xprt_request_init(struct rpc_task *, struct rpc_xprt *);
static inline void do_xprt_reserve(struct rpc_task *);
static void xprt_connect_status(struct rpc_task *task); static void xprt_connect_status(struct rpc_task *task);
static int __xprt_get_cong(struct rpc_xprt *, struct rpc_task *); static int __xprt_get_cong(struct rpc_xprt *, struct rpc_task *);
@ -935,7 +934,7 @@ void xprt_transmit(struct rpc_task *task)
spin_unlock_bh(&xprt->transport_lock); spin_unlock_bh(&xprt->transport_lock);
} }
static inline void do_xprt_reserve(struct rpc_task *task) static void xprt_alloc_slot(struct rpc_task *task)
{ {
struct rpc_xprt *xprt = task->tk_xprt; struct rpc_xprt *xprt = task->tk_xprt;
@ -955,6 +954,16 @@ static inline void do_xprt_reserve(struct rpc_task *task)
rpc_sleep_on(&xprt->backlog, task, NULL); rpc_sleep_on(&xprt->backlog, task, NULL);
} }
static void xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req)
{
memset(req, 0, sizeof(*req)); /* mark unused */
spin_lock(&xprt->reserve_lock);
list_add(&req->rq_list, &xprt->free);
rpc_wake_up_next(&xprt->backlog);
spin_unlock(&xprt->reserve_lock);
}
/** /**
* xprt_reserve - allocate an RPC request slot * xprt_reserve - allocate an RPC request slot
* @task: RPC task requesting a slot allocation * @task: RPC task requesting a slot allocation
@ -968,7 +977,7 @@ void xprt_reserve(struct rpc_task *task)
task->tk_status = -EIO; task->tk_status = -EIO;
spin_lock(&xprt->reserve_lock); spin_lock(&xprt->reserve_lock);
do_xprt_reserve(task); xprt_alloc_slot(task);
spin_unlock(&xprt->reserve_lock); spin_unlock(&xprt->reserve_lock);
} }
@ -1006,14 +1015,10 @@ void xprt_release(struct rpc_task *task)
{ {
struct rpc_xprt *xprt; struct rpc_xprt *xprt;
struct rpc_rqst *req; struct rpc_rqst *req;
int is_bc_request;
if (!(req = task->tk_rqstp)) if (!(req = task->tk_rqstp))
return; return;
/* Preallocated backchannel request? */
is_bc_request = bc_prealloc(req);
xprt = req->rq_xprt; xprt = req->rq_xprt;
rpc_count_iostats(task); rpc_count_iostats(task);
spin_lock_bh(&xprt->transport_lock); spin_lock_bh(&xprt->transport_lock);
@ -1027,21 +1032,16 @@ void xprt_release(struct rpc_task *task)
mod_timer(&xprt->timer, mod_timer(&xprt->timer,
xprt->last_used + xprt->idle_timeout); xprt->last_used + xprt->idle_timeout);
spin_unlock_bh(&xprt->transport_lock); spin_unlock_bh(&xprt->transport_lock);
if (!bc_prealloc(req)) if (req->rq_buffer)
xprt->ops->buf_free(req->rq_buffer); xprt->ops->buf_free(req->rq_buffer);
task->tk_rqstp = NULL; task->tk_rqstp = NULL;
if (req->rq_release_snd_buf) if (req->rq_release_snd_buf)
req->rq_release_snd_buf(req); req->rq_release_snd_buf(req);
dprintk("RPC: %5u release request %p\n", task->tk_pid, req); dprintk("RPC: %5u release request %p\n", task->tk_pid, req);
if (likely(!is_bc_request)) { if (likely(!bc_prealloc(req)))
memset(req, 0, sizeof(*req)); /* mark unused */ xprt_free_slot(xprt, req);
else
spin_lock(&xprt->reserve_lock);
list_add(&req->rq_list, &xprt->free);
rpc_wake_up_next(&xprt->backlog);
spin_unlock(&xprt->reserve_lock);
} else
xprt_free_bc_request(req); xprt_free_bc_request(req);
} }