Change error returned for transport not found
This commit is contained in:
@ -501,7 +501,7 @@ func (cc *ClientConn) getTransport(ctx context.Context, opts BalancerGetOptions)
|
|||||||
if put != nil {
|
if put != nil {
|
||||||
put()
|
put()
|
||||||
}
|
}
|
||||||
return nil, nil, Errorf(codes.Internal, "grpc: failed to find the transport to send the rpc")
|
return nil, nil, errConnClosing
|
||||||
}
|
}
|
||||||
t, err := ac.wait(ctx, !opts.BlockingWait)
|
t, err := ac.wait(ctx, !opts.BlockingWait)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Reference in New Issue
Block a user