mirror of
https://github.com/livekit/livekit.git
synced 2026-04-26 13:07:39 +00:00
add code lost during refactor (#326)
Co-authored-by: cnderrauber <zengjie9004@gmail.com>
This commit is contained in:
@@ -12,6 +12,7 @@ import (
|
||||
|
||||
"github.com/livekit/livekit-server/pkg/config"
|
||||
"github.com/livekit/livekit-server/pkg/rtc/types"
|
||||
"github.com/livekit/livekit-server/pkg/sfu"
|
||||
"github.com/livekit/livekit-server/pkg/sfu/twcc"
|
||||
"github.com/livekit/livekit-server/pkg/telemetry"
|
||||
)
|
||||
@@ -29,6 +30,7 @@ type LocalParticipantParams struct {
|
||||
Telemetry telemetry.TelemetryService
|
||||
ThrottleConfig config.PLIThrottleConfig
|
||||
Logger logger.Logger
|
||||
SimTracks map[uint32]SimulcastTrackInfo
|
||||
}
|
||||
|
||||
type LocalParticipant struct {
|
||||
@@ -227,6 +229,12 @@ func (l *LocalParticipant) MediaTrackReceived(track *webrtc.TrackRemote, rtpRece
|
||||
SubscriberConfig: l.params.Config.Subscriber,
|
||||
})
|
||||
|
||||
for ssrc,info :=range l.params.SimTracks {
|
||||
if info.Mid == mid {
|
||||
mt.TrySetSimulcastSSRC(uint8(sfu.RidToLayer(info.Rid)), ssrc)
|
||||
}
|
||||
}
|
||||
|
||||
// add to published and clean up pending
|
||||
l.UptrackManager.AddPublishedTrack(mt)
|
||||
delete(l.pendingTracks, signalCid)
|
||||
|
||||
@@ -817,6 +817,7 @@ func (p *ParticipantImpl) setupLocalParticipant() {
|
||||
Telemetry: p.params.Telemetry,
|
||||
ThrottleConfig: p.params.ThrottleConfig,
|
||||
Logger: p.params.Logger,
|
||||
SimTracks: p.params.SimTracks,
|
||||
})
|
||||
|
||||
p.LocalParticipant.OnTrackPublished(func(track types.PublishedTrack) {
|
||||
|
||||
Reference in New Issue
Block a user