unistack-org/micro
4
0
Fork 3
Code Issues 15 Pull Requests 2 Actions Packages Projects Releases 246 Wiki Activity

fix bug: loop variable i captured by func literal

Browse Source
This commit is contained in:
fireyang 2018-09-19 21:58:20 +08:00
parent 240052246f
commit 446d3fc72e
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
client/rpc_client.go
View File

@ -7,6 +7,8 @@ import (
"sync" "sync"
"time" "time"
"sync/atomic"
"github.com/micro/go-micro/broker" "github.com/micro/go-micro/broker"
"github.com/micro/go-micro/codec" "github.com/micro/go-micro/codec"
"github.com/micro/go-micro/errors" "github.com/micro/go-micro/errors"
@ -14,7 +16,6 @@ import (
"github.com/micro/go-micro/registry" "github.com/micro/go-micro/registry"
"github.com/micro/go-micro/selector" "github.com/micro/go-micro/selector"
"github.com/micro/go-micro/transport" "github.com/micro/go-micro/transport"
"sync/atomic"
) )
type rpcClient struct { type rpcClient struct {
@ -322,9 +323,9 @@ func (r *rpcClient) Call(ctx context.Context, request Request, response interfac
var gerr error var gerr error
for i := 0; i <= callOpts.Retries; i++ { for i := 0; i <= callOpts.Retries; i++ {
go func() { go func(i int) {
ch <- call(i) ch <- call(i)
}() }(i)
select { select {
case <-ctx.Done(): case <-ctx.Done():