Squelch error logs while waiting for track resolve. (#2376)

This commit is contained in:
Raja Subramanian authored and GitHub committed 2024-01-12 12:16:19 +05:30
1 parent dc1b09c757
commit 3687396d84
2 files changed
+4 -3

No files matched your search

+3 -2
View File
@@ -18,6 +18,7 @@ package rtc
import (
"context"
"errors"
"sync"
"time"
@@ -503,8 +504,8 @@ func (m *SubscriptionManager) subscribe(s *trackSubscription) error {
}
subTrack, err := track.AddSubscriber(m.params.Participant)
if err != nil && err != errAlreadySubscribed {
// ignore already subscribed error
if err != nil && !errors.Is(err, errAlreadySubscribed) && !errors.Is(err, ErrTrackNotAttached) && !errors.Is(err, ErrNoReceiver) {
// ignore errors: already subscribed OR waiting for track resolve
m.params.Logger.Warnw("add subscriber failed", err, "trackID", trackID)
return err
}
+1 -1
View File
@@ -305,7 +305,7 @@ func (t *TransportManager) RemoveSubscribedTrack(subTrack types.SubscribedTrack)
}
func (t *TransportManager) OnDataMessage(f func(kind livekit.DataPacket_Kind, data []byte)) {
// upstream data is always comes in via publisher peer connection irrespective of which is primary
// upstream data always comes in via publisher peer connection irrespective of which is primary
t.publisher.OnDataPacket(f)
}