diff --git a/pkg/logger/logger.go b/pkg/logger/logger.go index d1dbfdc4f..f0b31ac94 100644 --- a/pkg/logger/logger.go +++ b/pkg/logger/logger.go @@ -19,6 +19,7 @@ var ( "discard message from", "Failed to discover mDNS candidate", "Failed to read from candidate tcp", + "remote mDNS candidate added, but mDNS is disabled", }, "pc": { "Failed to accept RTCP stream is already closed", diff --git a/pkg/rtc/subscriptionmanager.go b/pkg/rtc/subscriptionmanager.go index b07a67cb3..c45f64c0f 100644 --- a/pkg/rtc/subscriptionmanager.go +++ b/pkg/rtc/subscriptionmanager.go @@ -301,12 +301,17 @@ func (m *SubscriptionManager) reconcileSubscription(s *trackSubscription) { } default: // all other errors - s.logger.Warnw("failed to subscribe", err, - "attempt", s.numAttempts.Load(), - ) if s.durationSinceStart() > subscriptionTimeout { + s.logger.Errorw("failed to subscribe, triggering error handler", err, + "attempt", s.numAttempts.Load(), + ) s.maybeRecordError(m.params.Telemetry, m.params.Participant.ID(), err, false) m.params.OnSubcriptionError(s.trackID) + } else { + s.logger.Debugw("failed to subscribe, retrying", + "error", err, + "attempt", s.numAttempts.Load(), + ) } } } else {