projects
/
GitHub
/
moto-9609
/
android_kernel_motorola_exynos9610.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
nfsd41: sunrpc: Added rpc server-side backchannel handling
[GitHub/moto-9609/android_kernel_motorola_exynos9610.git]
/
net
/
sunrpc
/
svc_xprt.c
diff --git
a/net/sunrpc/svc_xprt.c
b/net/sunrpc/svc_xprt.c
index 912dea558cccaaa712e4b9b02a3bb91d4917c13e..df124f78ee489762f4a9028af3b95f38a90f34d3 100644
(file)
--- a/
net/sunrpc/svc_xprt.c
+++ b/
net/sunrpc/svc_xprt.c
@@
-160,6
+160,7
@@
void svc_xprt_init(struct svc_xprt_class *xcl, struct svc_xprt *xprt,
mutex_init(&xprt->xpt_mutex);
spin_lock_init(&xprt->xpt_lock);
set_bit(XPT_BUSY, &xprt->xpt_flags);
mutex_init(&xprt->xpt_mutex);
spin_lock_init(&xprt->xpt_lock);
set_bit(XPT_BUSY, &xprt->xpt_flags);
+ rpc_init_wait_queue(&xprt->xpt_bc_pending, "xpt_bc_pending");
}
EXPORT_SYMBOL_GPL(svc_xprt_init);
}
EXPORT_SYMBOL_GPL(svc_xprt_init);
@@
-810,6
+811,7
@@
int svc_send(struct svc_rqst *rqstp)
else
len = xprt->xpt_ops->xpo_sendto(rqstp);
mutex_unlock(&xprt->xpt_mutex);
else
len = xprt->xpt_ops->xpo_sendto(rqstp);
mutex_unlock(&xprt->xpt_mutex);
+ rpc_wake_up(&xprt->xpt_bc_pending);
svc_xprt_release(rqstp);
if (len == -ECONNREFUSED || len == -ENOTCONN || len == -EAGAIN)
svc_xprt_release(rqstp);
if (len == -ECONNREFUSED || len == -ENOTCONN || len == -EAGAIN)