Function startBackends

balancer/grpclb/grpclb_test.go:305–334

(t *testing.T, sn string, fallback bool, lis ...net.Listener)

const testmdkey = "testmd"

func startBackends(t *testing.T, sn string, fallback bool, lis ...net.Listener) (servers []*grpc.Server) {
	for _, l := range lis {
		creds := &serverNameCheckCreds{
			sn: sn,
		}
		ss := &stubserver.StubServer{
			Listener: l,
			EmptyCallF: func(ctx context.Context, _ *testpb.Empty) (*testpb.Empty, error) {
				md, ok := metadata.FromIncomingContext(ctx)
				if !ok {
					return nil, status.Error(codes.Internal, "failed to receive metadata")
				}
				if !fallback && (md == nil || len(md["lb-token"]) == 0 || md["lb-token"][0] != lbToken) {
					return nil, status.Errorf(codes.Internal, "received unexpected metadata: %v", md)
				}
				grpc.SetTrailer(ctx, metadata.Pairs(testmdkey, l.Addr().String()))
				return &testpb.Empty{}, nil
			},
			FullDuplexCallF: func(testgrpc.TestService_FullDuplexCallServer) error {
				return nil
			},
		}
		if err := ss.StartServer(grpc.Creds(creds)); err != nil {
			t.Fatalf("Failed to start backend: %v", err)
		}
		servers = append(servers, ss.S.(*grpc.Server))
		t.Logf("Started backend server listening on %s", l.Addr().String())
	}
	return
}

func stopBackends(servers []*grpc.Server) {
	for _, s := range servers {