Skip to content

Commit

Permalink
Update internal/net/grpc/pool/pool.go
Browse files Browse the repository at this point in the history
Signed-off-by: kpango <[email protected]>
  • Loading branch information
kpango committed Feb 1, 2024
1 parent a596c5f commit 87bda2f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions internal/net/grpc/pool/pool.go
Original file line number Diff line number Diff line change
Expand Up @@ -797,14 +797,14 @@ func isHealthy(ctx context.Context, conn *ClientConn) bool {
log.Debugf("gRPC target %s's connection status will be Ready soon\tstatus: %s", conn.Target(), state.String())
return true
case connectivity.Idle:
log.Debug("gRPC target %s's connection status is waiting for target\tstatus: %s", conn.Target(), state.String())
log.Debugf("gRPC target %s's connection status is waiting for target\tstatus: %s", conn.Target(), state.String())
conn.Connect()
if conn.WaitForStateChange(ctx, state) {
state = conn.GetState()
if state == connectivity.Ready || state == connectivity.Connecting {
log.Debug("gRPC target %s's connection status enabled for target\tstatus: %s", conn.Target(), state.String())
log.Debugf("gRPC target %s's connection status enabled for target\tstatus: %s", conn.Target(), state.String())
return true
}

Check warning on line 807 in internal/net/grpc/pool/pool.go

View check run for this annotation

Codecov / codecov/patch

internal/net/grpc/pool/pool.go#L800-L807

Added lines #L800 - L807 were not covered by tests
return true
}
return false
case connectivity.Shutdown, connectivity.TransientFailure:
Expand Down

0 comments on commit 87bda2f

Please sign in to comment.