From: Rob Pike Date: Mon, 13 Oct 2014 17:27:51 +0000 (-0700) Subject: net/rpc: fix mutex comment X-Git-Tag: go1.4beta1~135 X-Git-Url: http://www.git.cypherpunks.su/?a=commitdiff_plain;h=968153d0632ad138440780d6041cc5a5b50a1fa3;p=gostls13.git net/rpc: fix mutex comment Fixes #8086. LGTM=bradfitz R=golang-codereviews, bradfitz CC=golang-codereviews https://golang.org/cl/153420044 --- diff --git a/src/net/rpc/client.go b/src/net/rpc/client.go index 21f79b0684..d0c4a69214 100644 --- a/src/net/rpc/client.go +++ b/src/net/rpc/client.go @@ -41,10 +41,10 @@ type Call struct { type Client struct { codec ClientCodec - sending sync.Mutex + reqMutex sync.Mutex // protects following + request Request mutex sync.Mutex // protects following - request Request seq uint64 pending map[uint64]*Call closing bool // user has called Close @@ -69,8 +69,8 @@ type ClientCodec interface { } func (client *Client) send(call *Call) { - client.sending.Lock() - defer client.sending.Unlock() + client.reqMutex.Lock() + defer client.reqMutex.Unlock() // Register this call. client.mutex.Lock() @@ -146,7 +146,7 @@ func (client *Client) input() { } } // Terminate pending calls. - client.sending.Lock() + client.reqMutex.Lock() client.mutex.Lock() client.shutdown = true closing := client.closing @@ -162,7 +162,7 @@ func (client *Client) input() { call.done() } client.mutex.Unlock() - client.sending.Unlock() + client.reqMutex.Unlock() if debugLog && err != io.EOF && !closing { log.Println("rpc: client protocol error:", err) }