diff --git a/go.mod b/go.mod index 0e33bf2c4..736b24f0f 100644 --- a/go.mod +++ b/go.mod @@ -43,4 +43,4 @@ require ( gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b ) -replace github.com/pion/ion-sfu => github.com/livekit/ion-sfu v1.20.4 +replace github.com/pion/ion-sfu => github.com/livekit/ion-sfu v1.20.5 diff --git a/go.sum b/go.sum index e8d1b72d9..b63b6526d 100644 --- a/go.sum +++ b/go.sum @@ -235,8 +235,8 @@ github.com/lightstep/lightstep-tracer-common/golang/gogo v0.0.0-20190605223551-b github.com/lightstep/lightstep-tracer-go v0.18.1/go.mod h1:jlF1pusYV4pidLvZ+XD0UBX0ZE6WURAspgAczcDHrL4= github.com/lithammer/shortuuid/v3 v3.0.6 h1:pr15YQyvhiSX/qPxncFtqk+v4xLEpOZObbsY/mKrcvA= github.com/lithammer/shortuuid/v3 v3.0.6/go.mod h1:vMk8ke37EmiewwolSO1NLW8vP4ZaKlRuDIi8tWWmAts= -github.com/livekit/ion-sfu v1.20.4 h1:Rh+9pxXoqAE7zn19/pPhw/LR28Ns4YD9qp8ESes1AQs= -github.com/livekit/ion-sfu v1.20.4/go.mod h1:dEdOG4KSqIftr5HxxqciNKBIdu0v3OD0ZYL7A3J09KA= +github.com/livekit/ion-sfu v1.20.5 h1:2PltjaVWd4y3gUcBssHwa/V3jIp92z5vC0+6CzB7rz8= +github.com/livekit/ion-sfu v1.20.5/go.mod h1:dEdOG4KSqIftr5HxxqciNKBIdu0v3OD0ZYL7A3J09KA= github.com/livekit/protocol v0.5.9 h1:NIA/nX74dv199oVmfGCbBK5qpuHTDu6h0K7DAPiM++w= github.com/livekit/protocol v0.5.9/go.mod h1:wo3CGfYB7XMF8GoVJAfTARrYSP/ombi+sbLl6AYdKP0= github.com/lucsky/cuid v1.0.2 h1:z4XlExeoderxoPj2/dxKOyPxe9RCOu7yNq9/XWxIUMQ= diff --git a/pkg/rtc/mediatrack.go b/pkg/rtc/mediatrack.go index d7665f984..5ab4d2594 100644 --- a/pkg/rtc/mediatrack.go +++ b/pkg/rtc/mediatrack.go @@ -284,7 +284,9 @@ func (t *MediaTrack) AddReceiver(receiver *webrtc.RTPReceiver, track *webrtc.Tra }) if t.receiver == nil { - t.receiver = sfu.NewWebRTCReceiver(receiver, track, t.params.ParticipantID, sfu.WithPliThrottle(0)) + t.receiver = sfu.NewWebRTCReceiver(receiver, track, t.params.ParticipantID, + sfu.WithPliThrottle(0), + sfu.WithLoadBalanceThreshold(20)) t.receiver.SetRTCPCh(t.params.RTCPChan) t.receiver.OnCloseHandler(func() { t.lock.Lock()