Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 23949
b: refs/heads/master
c: 43ac3f2
h: refs/heads/master
i:
  23947: 33fe979
v: v3
  • Loading branch information
Trond Myklebust authored and Trond Myklebust committed Mar 20, 2006
1 parent 22a58f8 commit 7531233
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 2 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: c42de9dd67250fe984e0e31c9b542d721af6454b
refs/heads/master: 43ac3f2961b8616da26114ec6dc76ac2a61f76ad
5 changes: 5 additions & 0 deletions trunk/net/sunrpc/clnt.c
Original file line number Diff line number Diff line change
Expand Up @@ -1069,6 +1069,11 @@ call_decode(struct rpc_task *task)
return;
}

/*
* Ensure that we see all writes made by xprt_complete_rqst()
* before it changed req->rq_received.
*/
smp_rmb();
req->rq_rcv_buf.len = req->rq_private_buf.len;

/* Check that the softirq receive buffer is valid */
Expand Down
3 changes: 2 additions & 1 deletion trunk/net/sunrpc/xprt.c
Original file line number Diff line number Diff line change
Expand Up @@ -651,6 +651,8 @@ void xprt_complete_rqst(struct rpc_task *task, int copied)
task->tk_rtt = (long)jiffies - req->rq_xtime;

list_del_init(&req->rq_list);
/* Ensure all writes are done before we update req->rq_received */
smp_wmb();
req->rq_received = req->rq_private_buf.len = copied;
rpc_wake_up_task(task);
}
Expand Down Expand Up @@ -727,7 +729,6 @@ void xprt_transmit(struct rpc_task *task)

dprintk("RPC: %4d xprt_transmit(%u)\n", task->tk_pid, req->rq_slen);

smp_rmb();
if (!req->rq_received) {
if (list_empty(&req->rq_list)) {
spin_lock_bh(&xprt->transport_lock);
Expand Down

0 comments on commit 7531233

Please sign in to comment.