diff options
Diffstat (limited to 'net/sunrpc')
| -rw-r--r-- | net/sunrpc/svc_xprt.c | 1 | ||||
| -rw-r--r-- | net/sunrpc/svcsock.c | 19 |
2 files changed, 9 insertions, 11 deletions
diff --git a/net/sunrpc/svc_xprt.c b/net/sunrpc/svc_xprt.c index 95186b548099..3e6a1c81d4ce 100644 --- a/net/sunrpc/svc_xprt.c +++ b/net/sunrpc/svc_xprt.c | |||
| @@ -99,6 +99,7 @@ void svc_xprt_init(struct svc_xprt_class *xcl, struct svc_xprt *xprt, | |||
| 99 | xprt->xpt_server = serv; | 99 | xprt->xpt_server = serv; |
| 100 | INIT_LIST_HEAD(&xprt->xpt_list); | 100 | INIT_LIST_HEAD(&xprt->xpt_list); |
| 101 | INIT_LIST_HEAD(&xprt->xpt_ready); | 101 | INIT_LIST_HEAD(&xprt->xpt_ready); |
| 102 | mutex_init(&xprt->xpt_mutex); | ||
| 102 | } | 103 | } |
| 103 | EXPORT_SYMBOL_GPL(svc_xprt_init); | 104 | EXPORT_SYMBOL_GPL(svc_xprt_init); |
| 104 | 105 | ||
diff --git a/net/sunrpc/svcsock.c b/net/sunrpc/svcsock.c index d95a0c894d4f..2016d9c63f88 100644 --- a/net/sunrpc/svcsock.c +++ b/net/sunrpc/svcsock.c | |||
| @@ -1632,15 +1632,13 @@ svc_drop(struct svc_rqst *rqstp) | |||
| 1632 | int | 1632 | int |
| 1633 | svc_send(struct svc_rqst *rqstp) | 1633 | svc_send(struct svc_rqst *rqstp) |
| 1634 | { | 1634 | { |
| 1635 | struct svc_sock *svsk; | 1635 | struct svc_xprt *xprt; |
| 1636 | int len; | 1636 | int len; |
| 1637 | struct xdr_buf *xb; | 1637 | struct xdr_buf *xb; |
| 1638 | 1638 | ||
| 1639 | if ((svsk = rqstp->rq_sock) == NULL) { | 1639 | xprt = rqstp->rq_xprt; |
| 1640 | printk(KERN_WARNING "NULL socket pointer in %s:%d\n", | 1640 | if (!xprt) |
| 1641 | __FILE__, __LINE__); | ||
| 1642 | return -EFAULT; | 1641 | return -EFAULT; |
| 1643 | } | ||
| 1644 | 1642 | ||
| 1645 | /* release the receive skb before sending the reply */ | 1643 | /* release the receive skb before sending the reply */ |
| 1646 | rqstp->rq_xprt->xpt_ops->xpo_release_rqst(rqstp); | 1644 | rqstp->rq_xprt->xpt_ops->xpo_release_rqst(rqstp); |
| @@ -1651,13 +1649,13 @@ svc_send(struct svc_rqst *rqstp) | |||
| 1651 | xb->page_len + | 1649 | xb->page_len + |
| 1652 | xb->tail[0].iov_len; | 1650 | xb->tail[0].iov_len; |
| 1653 | 1651 | ||
| 1654 | /* Grab svsk->sk_mutex to serialize outgoing data. */ | 1652 | /* Grab mutex to serialize outgoing data. */ |
| 1655 | mutex_lock(&svsk->sk_mutex); | 1653 | mutex_lock(&xprt->xpt_mutex); |
| 1656 | if (test_bit(XPT_DEAD, &svsk->sk_xprt.xpt_flags)) | 1654 | if (test_bit(XPT_DEAD, &xprt->xpt_flags)) |
| 1657 | len = -ENOTCONN; | 1655 | len = -ENOTCONN; |
| 1658 | else | 1656 | else |
| 1659 | len = svsk->sk_xprt.xpt_ops->xpo_sendto(rqstp); | 1657 | len = xprt->xpt_ops->xpo_sendto(rqstp); |
| 1660 | mutex_unlock(&svsk->sk_mutex); | 1658 | mutex_unlock(&xprt->xpt_mutex); |
| 1661 | svc_sock_release(rqstp); | 1659 | svc_sock_release(rqstp); |
| 1662 | 1660 | ||
| 1663 | if (len == -ECONNREFUSED || len == -ENOTCONN || len == -EAGAIN) | 1661 | if (len == -ECONNREFUSED || len == -ENOTCONN || len == -EAGAIN) |
| @@ -1759,7 +1757,6 @@ static struct svc_sock *svc_setup_socket(struct svc_serv *serv, | |||
| 1759 | svsk->sk_lastrecv = get_seconds(); | 1757 | svsk->sk_lastrecv = get_seconds(); |
| 1760 | spin_lock_init(&svsk->sk_lock); | 1758 | spin_lock_init(&svsk->sk_lock); |
| 1761 | INIT_LIST_HEAD(&svsk->sk_deferred); | 1759 | INIT_LIST_HEAD(&svsk->sk_deferred); |
| 1762 | mutex_init(&svsk->sk_mutex); | ||
| 1763 | 1760 | ||
| 1764 | /* Initialize the socket */ | 1761 | /* Initialize the socket */ |
| 1765 | if (sock->type == SOCK_DGRAM) | 1762 | if (sock->type == SOCK_DGRAM) |
