Remove unused traffic load (#2734)

livekit · May 27, 2024 · 991ad5a · 991ad5a
1 parent 721c36f
commit 991ad5a
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 503 deletions.
diff --git a/pkg/rtc/participant.go b/pkg/rtc/participant.go
@@ -140,7 +140,6 @@ type ParticipantParams struct {
 	SubscriptionLimitVideo       int32
 	PlayoutDelay                 *livekit.PlayoutDelay
 	SyncStreams                  bool
-	EnableTrafficLoadTracking    bool
 	ForwardStats                 *sfu.ForwardStats
 }
 
@@ -187,7 +186,6 @@ type ParticipantImpl struct {
 	*TransportManager
 	*UpTrackManager
 	*SubscriptionManager
-	*ParticipantTrafficLoad
 
 	// keeps track of unpublished tracks in order to reuse trackID
 	unpublishedTracks []*livekit.TrackInfo
@@ -297,7 +295,6 @@ func NewParticipant(params ParticipantParams) (*ParticipantImpl, error) {
 
 	p.setupUpTrackManager()
 	p.setupSubscriptionManager()
-	p.setupParticipantTrafficLoad()
 
 	return p, nil
 }
@@ -865,9 +862,6 @@ func (p *ParticipantImpl) Close(sendLeave bool, reason types.ParticipantCloseRea
 	go func() {
 		p.SubscriptionManager.Close(isExpectedToResume)
 		p.TransportManager.Close()
-		if p.ParticipantTrafficLoad != nil {
-			p.ParticipantTrafficLoad.Close()
-		}
 	}()
 
 	p.dataChannelStats.Stop()
@@ -1373,16 +1367,6 @@ func (p *ParticipantImpl) setupSubscriptionManager() {
 	})
 }
 
-func (p *ParticipantImpl) setupParticipantTrafficLoad() {
-	if p.params.EnableTrafficLoadTracking {
-		p.ParticipantTrafficLoad = NewParticipantTrafficLoad(ParticipantTrafficLoadParams{
-			Participant:      p,
-			DataChannelStats: p.dataChannelStats,
-			Logger:           p.params.Logger,
-		})
-	}
-}
-
 func (p *ParticipantImpl) updateState(state livekit.ParticipantInfo_State) {
 	oldState := p.state.Swap(state).(livekit.ParticipantInfo_State)
 	if oldState == state {

diff --git a/pkg/rtc/participant_traffic_load.go b/pkg/rtc/participant_traffic_load.go
diff --git a/pkg/rtc/types/interfaces.go b/pkg/rtc/types/interfaces.go
@@ -394,7 +394,6 @@ type LocalParticipant interface {
 	OnSubscribeStatusChanged(fn func(publisherID livekit.ParticipantID, subscribed bool))
 	OnClose(callback func(LocalParticipant))
 	OnClaimsChanged(callback func(LocalParticipant))
-	OnTrafficLoad(callback func(trafficLoad *TrafficLoad))
 
 	HandleReceiverReport(dt *sfu.DownTrack, report *rtcp.ReceiverReport)
 
@@ -423,8 +422,6 @@ type LocalParticipant interface {
 	SetSubscriberChannelCapacity(channelCapacity int64)
 
 	GetPacer() pacer.Pacer
-
-	GetTrafficLoad() *TrafficLoad
 }
 
 // Room is a container of participants, and can provide room-level actions