Skip to content

Commit

Permalink
shed bikes
Browse files Browse the repository at this point in the history
  • Loading branch information
dfawley committed Aug 21, 2019
1 parent ef03f65 commit 7c9d789
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions clientconn.go
Expand Up @@ -544,13 +544,13 @@ func init() {

func (cc *ClientConn) maybeApplyDefaultServiceConfig(addrs []resolver.Address) {
if cc.sc != nil {
cc.applyServiceConfig(cc.sc, addrs)
cc.applyServiceConfigAndBalancer(cc.sc, addrs)
return
}
if cc.dopts.defaultServiceConfig != nil {
cc.applyServiceConfig(cc.dopts.defaultServiceConfig, addrs)
cc.applyServiceConfigAndBalancer(cc.dopts.defaultServiceConfig, addrs)
} else {
cc.applyServiceConfig(emptyServiceConfig, addrs)
cc.applyServiceConfigAndBalancer(emptyServiceConfig, addrs)
}
}

Expand Down Expand Up @@ -587,7 +587,7 @@ func (cc *ClientConn) updateResolverState(s resolver.State, err error) error {
} else {
scg, err := s.ServiceConfigGetter.Get()
if sc, ok := scg.(*ServiceConfig); err == nil && ok {
cc.applyServiceConfig(sc, s.Addresses)
cc.applyServiceConfigAndBalancer(sc, s.Addresses)
} else {
ret = balancer.ErrBadResolverState
}
Expand Down Expand Up @@ -865,7 +865,7 @@ func (cc *ClientConn) getTransport(ctx context.Context, failfast bool, method st
return t, done, nil
}

func (cc *ClientConn) applyServiceConfig(sc *ServiceConfig, addrs []resolver.Address) {
func (cc *ClientConn) applyServiceConfigAndBalancer(sc *ServiceConfig, addrs []resolver.Address) {
if sc == nil {
// should never reach here.
return
Expand Down

0 comments on commit 7c9d789

Please sign in to comment.