diff --git a/pkg/sfu/interceptor/rtx.go b/pkg/sfu/interceptor/rtx.go index 47bf5989d..fc2f0cf33 100644 --- a/pkg/sfu/interceptor/rtx.go +++ b/pkg/sfu/interceptor/rtx.go @@ -92,7 +92,7 @@ func (f *RTXInfoExtractorFactory) SetStreamInfo(ssrc uint32, mid, rid, rsid stri if info.mid == mid && info.rsid == rid { repairSsrc = repair baseSsrc = ssrc - repairSid = info.rid + repairSid = rid delete(f.streams, repair) break } @@ -115,6 +115,8 @@ func (f *RTXInfoExtractorFactory) SetStreamInfo(ssrc uint32, mid, rid, rsid stri } } +// ------------------------------------------ + type RTXInfoExtractor struct { interceptor.NoOp @@ -143,6 +145,8 @@ func (u *RTXInfoExtractor) BindRemoteStream(info *interceptor.StreamInfo, reader } } +// ------------------------------------------ + type rtxInfoReader struct { tryTimes int reader interceptor.RTPReader