diff options
author | Trond Myklebust <trond.myklebust@primarydata.com> | 2014-07-25 05:59:33 +0200 |
---|---|---|
committer | J. Bruce Fields <bfields@redhat.com> | 2014-07-29 22:10:20 +0200 |
commit | 518776800c094a518ae6d303660b57f1400eb1eb (patch) | |
tree | 5b61d53a0ba2ff0a24cc47dc2a0cc5bac151b654 /net/sunrpc/svcsock.c | |
parent | SUNRPC: svc_tcp_write_space: don't clear SOCK_NOSPACE prematurely (diff) | |
download | linux-518776800c094a518ae6d303660b57f1400eb1eb.tar.xz linux-518776800c094a518ae6d303660b57f1400eb1eb.zip |
SUNRPC: Allow svc_reserve() to notify TCP socket that space has been freed
Signed-off-by: Trond Myklebust <trond.myklebust@primarydata.com>
Signed-off-by: J. Bruce Fields <bfields@redhat.com>
Diffstat (limited to 'net/sunrpc/svcsock.c')
-rw-r--r-- | net/sunrpc/svcsock.c | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/net/sunrpc/svcsock.c b/net/sunrpc/svcsock.c index 88db211d4264..c24a8ff33f8f 100644 --- a/net/sunrpc/svcsock.c +++ b/net/sunrpc/svcsock.c @@ -475,6 +475,14 @@ static void svc_tcp_write_space(struct sock *sk) svc_write_space(sk); } +static void svc_tcp_adjust_wspace(struct svc_xprt *xprt) +{ + struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); + + if (svc_tcp_has_wspace(xprt)) + clear_bit(SOCK_NOSPACE, &svsk->sk_sock->flags); +} + /* * See net/ipv6/ip_sockglue.c : ip_cmsg_recv_pktinfo */ @@ -1289,6 +1297,7 @@ static struct svc_xprt_ops svc_tcp_ops = { .xpo_has_wspace = svc_tcp_has_wspace, .xpo_accept = svc_tcp_accept, .xpo_secure_port = svc_sock_secure_port, + .xpo_adjust_wspace = svc_tcp_adjust_wspace, }; static struct svc_xprt_class svc_tcp_class = { |