fix rpc client call WARNING: DATA RACE

2018-09-20 10:08:00 +08:00 · 2018-09-20 10:08:00 +08:00 · ef8b5e28b0
commit ef8b5e28b0
parent 818f150b25
1 changed files with 1 additions and 1 deletions
--- a/client/rpc_client.go
+++ b/client/rpc_client.go
@ -89,7 +89,7 @@ func (r *rpcClient) call(ctx context.Context, address string, req Request, resp
 		r.pool.release(address, c, grr)
 	}()

-	seq := r.seq
+	seq := atomic.LoadUint64(&r.seq)
 	atomic.AddUint64(&r.seq, 1)

 	stream := &rpcStream{