Merge pull request #309 from fireyang/master

fix rpc client call WARNING: DATA RACE
2018-09-20 07:39:45 +01:00
parent 818f150b25 ef8b5e28b0
commit ab0956fa48
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{