qxnw/hydra: rpc/rpc.sync.go; 16 LoC

[githubvet]

Found a possible issue in qxnw/hydra at rpc/rpc.sync.go

The below snippet of Go code triggered static analysis which searches for goroutines and/or defer statements
which capture loop variables.

Click here to see the code in its original context.

Click here to show the 17 line(s) of Go which triggered the analyzer.

	for _, v := range rs {
		go func(r rpc.IRPCResponse) {
			select {
			case <-closeCh:
				return
			case <-time.After(timeout):
				errChan <- &Result{Err: fmt.Errorf("%s请求超时(%v)", v.GetService(), timeout)}
				results = append(results, &Result{Status: 504, Err: fmt.Errorf("%s请求超时(%v)", v.GetService(), timeout)})
			case value := <-r.GetResult():
				if value.GetErr() != nil {
					errChan <- value
				}
				results = append(results, value)
			}
			atomic.AddInt32(&counter, 1)
		}(v)
	}

commit ID: 2762222302066275ff6860b210d01a7ed9a42f61