Skip to content

Commit

Permalink
test: cleanup balancer switching tests (#5271)
Browse files Browse the repository at this point in the history
  • Loading branch information
easwars committed Mar 30, 2022
1 parent b6873c0 commit 42cadc1
Show file tree
Hide file tree
Showing 13 changed files with 944 additions and 908 deletions.
569 changes: 0 additions & 569 deletions balancer_switching_test.go

This file was deleted.

211 changes: 0 additions & 211 deletions call_test.go

This file was deleted.

10 changes: 5 additions & 5 deletions clientconn.go
Expand Up @@ -672,14 +672,14 @@ func (cc *ClientConn) updateResolverState(s resolver.State, err error) error {
cc.mu.Unlock()
if cbn != grpclbName {
// Filter any grpclb addresses since we don't have the grpclb balancer.
for i := 0; i < len(s.Addresses); {
if s.Addresses[i].Type == resolver.GRPCLB {
copy(s.Addresses[i:], s.Addresses[i+1:])
s.Addresses = s.Addresses[:len(s.Addresses)-1]
var addrs []resolver.Address
for _, addr := range s.Addresses {
if addr.Type == resolver.GRPCLB {
continue
}
i++
addrs = append(addrs, addr)
}
s.Addresses = addrs
}
uccsErr := bw.updateClientConnState(&balancer.ClientConnState{ResolverState: s, BalancerConfig: balCfg})
if ret == nil {
Expand Down
5 changes: 4 additions & 1 deletion clientconn_state_transition_test.go
Expand Up @@ -35,7 +35,10 @@ import (
"google.golang.org/grpc/resolver/manual"
)

const stateRecordingBalancerName = "state_recoding_balancer"
const (
stateRecordingBalancerName = "state_recoding_balancer"
defaultTestTimeout = 10 * time.Second
)

var testBalancerBuilder = newStateRecordingBalancerBuilder()

Expand Down
9 changes: 9 additions & 0 deletions clientconn_test.go
Expand Up @@ -40,9 +40,18 @@ import (
"google.golang.org/grpc/keepalive"
"google.golang.org/grpc/resolver"
"google.golang.org/grpc/resolver/manual"
"google.golang.org/grpc/serviceconfig"
"google.golang.org/grpc/testdata"
)

func parseCfg(r *manual.Resolver, s string) *serviceconfig.ParseResult {
scpr := r.CC.ParseServiceConfig(s)
if scpr.Err != nil {
panic(fmt.Sprintf("Error parsing config %q: %v", s, scpr.Err))
}
return scpr
}

func (s) TestDialWithTimeout(t *testing.T) {
lis, err := net.Listen("tcp", "localhost:0")
if err != nil {
Expand Down

0 comments on commit 42cadc1

Please sign in to comment.