HomeSort by relevance Sort by last modified time
    Searched refs:balancerWrapper (Results 1 - 2 of 2) sorted by null

  /external/syzkaller/vendor/google.golang.org/grpc/
balancer_v1_wrapper.go 50 bw := &balancerWrapper{
76 type balancerWrapper struct {
99 func (bw *balancerWrapper) lbWatcher() {
125 grpclog.Infof("balancerWrapper: got update addr from Notify: %v\n", addrs)
232 func (bw *balancerWrapper) HandleSubConnStateChange(sc balancer.SubConn, s connectivity.State) {
262 func (bw *balancerWrapper) HandleResolvedAddrs([]resolver.Address, error) {
274 func (bw *balancerWrapper) Close() {
285 // The picker is the balancerWrapper itself.
288 func (bw *balancerWrapper) Pick(ctx context.Context, opts balancer.PickOptions) (balancer.SubConn, func(balancer.DoneInfo), error) {
clientconn.go 701 balancerWrapper *ccBalancerWrapper
797 } else if cc.balancerWrapper == nil {
800 cc.balancerWrapper = newCCBalancerWrapper(cc, cc.dopts.balancerBuilder, cc.balancerBuildOpts)
803 cc.balancerWrapper.handleResolvedAddrs(addrs, nil)
830 if cc.balancerWrapper != nil {
831 cc.balancerWrapper.close()
843 cc.balancerWrapper = newCCBalancerWrapper(cc, builder, cc.balancerBuildOpts)
854 cc.balancerWrapper.handleSubConnStateChange(sc, s)
    [all...]

Completed in 272 milliseconds