Function doneChannelzWrapper

picker_wrapper.go:76–90

doneChannelzWrapper performs the following: - increments the calls started channelz counter - wraps the done function in the passed in result to increment the calls failed or calls succeeded channelz counter before invoking the actual done function.

(acbw *acBalancerWrapper, result *balancer.PickResult)

//     failed or calls succeeded channelz counter before invoking the actual
//     done function.
func doneChannelzWrapper(acbw *acBalancerWrapper, result *balancer.PickResult) {
	ac := acbw.ac
	ac.incrCallsStarted()
	done := result.Done
	result.Done = func(b balancer.DoneInfo) {
		if b.Err != nil && b.Err != io.EOF {
			ac.incrCallsFailed()
		} else {
			ac.incrCallsSucceeded()
		}
		if done != nil {
			done(b)
		}
	}
}

type pick struct {
	transport transport.ClientTransport // the selected transport