|
|
|
@ -759,8 +759,10 @@ void Subchannel::OnRetryTimer() { |
|
|
|
|
|
|
|
|
|
void Subchannel::OnRetryTimerLocked() { |
|
|
|
|
if (shutdown_) return; |
|
|
|
|
LOG(INFO) << "subchannel " << this << " " << key_.ToString() |
|
|
|
|
<< ": backoff delay elapsed, reporting IDLE"; |
|
|
|
|
if (GRPC_TRACE_FLAG_ENABLED(subchannel)) { |
|
|
|
|
LOG(INFO) << "subchannel " << this << " " << key_.ToString() |
|
|
|
|
<< ": backoff delay elapsed, reporting IDLE"; |
|
|
|
|
} |
|
|
|
|
SetConnectivityStateLocked(GRPC_CHANNEL_IDLE, absl::OkStatus()); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
@ -804,10 +806,12 @@ void Subchannel::OnConnectingFinishedLocked(grpc_error_handle error) { |
|
|
|
|
if (connecting_result_.transport == nullptr || !PublishTransportLocked()) { |
|
|
|
|
const Duration time_until_next_attempt = |
|
|
|
|
next_attempt_time_ - Timestamp::Now(); |
|
|
|
|
LOG(INFO) << "subchannel " << this << " " << key_.ToString() |
|
|
|
|
<< ": connect failed (" << StatusToString(error) |
|
|
|
|
<< "), backing off for " << time_until_next_attempt.millis() |
|
|
|
|
<< " ms"; |
|
|
|
|
if (GRPC_TRACE_FLAG_ENABLED(subchannel)) { |
|
|
|
|
LOG(INFO) << "subchannel " << this << " " << key_.ToString() |
|
|
|
|
<< ": connect failed (" << StatusToString(error) |
|
|
|
|
<< "), backing off for " << time_until_next_attempt.millis() |
|
|
|
|
<< " ms"; |
|
|
|
|
} |
|
|
|
|
SetConnectivityStateLocked(GRPC_CHANNEL_TRANSIENT_FAILURE, |
|
|
|
|
grpc_error_to_absl_status(error)); |
|
|
|
|
retry_timer_handle_ = event_engine_->RunAfter( |
|
|
|
|