aboutsummaryrefslogtreecommitdiffstats
path: root/net/sunrpc/xprt.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/sunrpc/xprt.c')
-rw-r--r--net/sunrpc/xprt.c3
1 files changed, 2 insertions, 1 deletions
diff --git a/net/sunrpc/xprt.c b/net/sunrpc/xprt.c
index 940dba965bb9..4dd5b3cfe754 100644
--- a/net/sunrpc/xprt.c
+++ b/net/sunrpc/xprt.c
@@ -651,6 +651,8 @@ void xprt_complete_rqst(struct rpc_task *task, int copied)
651 task->tk_rtt = (long)jiffies - req->rq_xtime; 651 task->tk_rtt = (long)jiffies - req->rq_xtime;
652 652
653 list_del_init(&req->rq_list); 653 list_del_init(&req->rq_list);
654 /* Ensure all writes are done before we update req->rq_received */
655 smp_wmb();
654 req->rq_received = req->rq_private_buf.len = copied; 656 req->rq_received = req->rq_private_buf.len = copied;
655 rpc_wake_up_task(task); 657 rpc_wake_up_task(task);
656} 658}
@@ -727,7 +729,6 @@ void xprt_transmit(struct rpc_task *task)
727 729
728 dprintk("RPC: %4d xprt_transmit(%u)\n", task->tk_pid, req->rq_slen); 730 dprintk("RPC: %4d xprt_transmit(%u)\n", task->tk_pid, req->rq_slen);
729 731
730 smp_rmb();
731 if (!req->rq_received) { 732 if (!req->rq_received) {
732 if (list_empty(&req->rq_list)) { 733 if (list_empty(&req->rq_list)) {
733 spin_lock_bh(&xprt->transport_lock); 734 spin_lock_bh(&xprt->transport_lock);