diff options
author | Tom Tucker <tom@opengridcomputing.com> | 2007-12-30 22:08:14 -0500 |
---|---|---|
committer | J. Bruce Fields <bfields@citi.umich.edu> | 2008-02-01 16:42:12 -0500 |
commit | eab996d4aca7a9d8621d2b98c00ce420df85eaed (patch) | |
tree | beee1815aebbb5e31628d939cd08330cf3417c3f /net/sunrpc | |
parent | 9dbc240f199c16c3c0859c255ad52a663d8ee51d (diff) |
svc: Make svc_sock_release svc_xprt_release
The svc_sock_release function only touches transport independent fields.
Change the function to manipulate svc_xprt directly instead of the transport
dependent svc_sock structure.
Signed-off-by: Tom Tucker <tom@opengridcomputing.com>
Acked-by: Neil Brown <neilb@suse.de>
Reviewed-by: Chuck Lever <chuck.lever@oracle.com>
Reviewed-by: Greg Banks <gnb@sgi.com>
Signed-off-by: J. Bruce Fields <bfields@citi.umich.edu>
Diffstat (limited to 'net/sunrpc')
-rw-r--r-- | net/sunrpc/svcsock.c | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/net/sunrpc/svcsock.c b/net/sunrpc/svcsock.c index 9564d2e9520e..355ab8da54fe 100644 --- a/net/sunrpc/svcsock.c +++ b/net/sunrpc/svcsock.c | |||
@@ -368,10 +368,9 @@ void svc_reserve(struct svc_rqst *rqstp, int space) | |||
368 | } | 368 | } |
369 | } | 369 | } |
370 | 370 | ||
371 | static void | 371 | static void svc_xprt_release(struct svc_rqst *rqstp) |
372 | svc_sock_release(struct svc_rqst *rqstp) | ||
373 | { | 372 | { |
374 | struct svc_sock *svsk = rqstp->rq_sock; | 373 | struct svc_xprt *xprt = rqstp->rq_xprt; |
375 | 374 | ||
376 | rqstp->rq_xprt->xpt_ops->xpo_release_rqst(rqstp); | 375 | rqstp->rq_xprt->xpt_ops->xpo_release_rqst(rqstp); |
377 | 376 | ||
@@ -379,7 +378,6 @@ svc_sock_release(struct svc_rqst *rqstp) | |||
379 | rqstp->rq_res.page_len = 0; | 378 | rqstp->rq_res.page_len = 0; |
380 | rqstp->rq_res.page_base = 0; | 379 | rqstp->rq_res.page_base = 0; |
381 | 380 | ||
382 | |||
383 | /* Reset response buffer and release | 381 | /* Reset response buffer and release |
384 | * the reservation. | 382 | * the reservation. |
385 | * But first, check that enough space was reserved | 383 | * But first, check that enough space was reserved |
@@ -392,9 +390,9 @@ svc_sock_release(struct svc_rqst *rqstp) | |||
392 | 390 | ||
393 | rqstp->rq_res.head[0].iov_len = 0; | 391 | rqstp->rq_res.head[0].iov_len = 0; |
394 | svc_reserve(rqstp, 0); | 392 | svc_reserve(rqstp, 0); |
395 | rqstp->rq_sock = NULL; | 393 | rqstp->rq_xprt = NULL; |
396 | 394 | ||
397 | svc_xprt_put(&svsk->sk_xprt); | 395 | svc_xprt_put(xprt); |
398 | } | 396 | } |
399 | 397 | ||
400 | /* | 398 | /* |
@@ -1593,7 +1591,7 @@ svc_recv(struct svc_rqst *rqstp, long timeout) | |||
1593 | /* No data, incomplete (TCP) read, or accept() */ | 1591 | /* No data, incomplete (TCP) read, or accept() */ |
1594 | if (len == 0 || len == -EAGAIN) { | 1592 | if (len == 0 || len == -EAGAIN) { |
1595 | rqstp->rq_res.len = 0; | 1593 | rqstp->rq_res.len = 0; |
1596 | svc_sock_release(rqstp); | 1594 | svc_xprt_release(rqstp); |
1597 | return -EAGAIN; | 1595 | return -EAGAIN; |
1598 | } | 1596 | } |
1599 | clear_bit(XPT_OLD, &svsk->sk_xprt.xpt_flags); | 1597 | clear_bit(XPT_OLD, &svsk->sk_xprt.xpt_flags); |
@@ -1613,7 +1611,7 @@ void | |||
1613 | svc_drop(struct svc_rqst *rqstp) | 1611 | svc_drop(struct svc_rqst *rqstp) |
1614 | { | 1612 | { |
1615 | dprintk("svc: socket %p dropped request\n", rqstp->rq_sock); | 1613 | dprintk("svc: socket %p dropped request\n", rqstp->rq_sock); |
1616 | svc_sock_release(rqstp); | 1614 | svc_xprt_release(rqstp); |
1617 | } | 1615 | } |
1618 | 1616 | ||
1619 | /* | 1617 | /* |
@@ -1646,7 +1644,7 @@ svc_send(struct svc_rqst *rqstp) | |||
1646 | else | 1644 | else |
1647 | len = xprt->xpt_ops->xpo_sendto(rqstp); | 1645 | len = xprt->xpt_ops->xpo_sendto(rqstp); |
1648 | mutex_unlock(&xprt->xpt_mutex); | 1646 | mutex_unlock(&xprt->xpt_mutex); |
1649 | svc_sock_release(rqstp); | 1647 | svc_xprt_release(rqstp); |
1650 | 1648 | ||
1651 | if (len == -ECONNREFUSED || len == -ENOTCONN || len == -EAGAIN) | 1649 | if (len == -ECONNREFUSED || len == -ENOTCONN || len == -EAGAIN) |
1652 | return 0; | 1650 | return 0; |