From f0080f35b2bcd7cc8287424a03ebc4f95c151faa Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Sat, 3 Jan 2026 23:25:44 +0530 Subject: [PATCH] Remove enable arrival time forwarding method. (#4217) Will add it if necessary. --- pkg/sfu/downtrack.go | 4 ---- pkg/sfu/receiver_base.go | 22 ++++++++++------------ 2 files changed, 10 insertions(+), 16 deletions(-) diff --git a/pkg/sfu/downtrack.go b/pkg/sfu/downtrack.go index aeddc9b8b..d6a097e2a 100644 --- a/pkg/sfu/downtrack.go +++ b/pkg/sfu/downtrack.go @@ -71,7 +71,6 @@ type TrackSender interface { Resync() SetReceiver(TrackReceiver) ReceiverRestart() - EnableForwardPacketArrivalTime(enable bool) } // ------------------------------------------------------------------- @@ -1648,9 +1647,6 @@ func (d *DownTrack) ReceiverRestart() { d.forwarder.DetermineCodec(codec, receiver.HeaderExtensions(), receiver.VideoLayerMode()) } -func (d *DownTrack) EnableForwardPacketArrivalTime(_enable bool) { -} - func (d *DownTrack) CreateSourceDescriptionChunks() []rtcp.SourceDescriptionChunk { transceiver := d.transceiver.Load() if d.bindState.Load() != bindStateBound || transceiver == nil { diff --git a/pkg/sfu/receiver_base.go b/pkg/sfu/receiver_base.go index 4a1ac8041..12c16a230 100644 --- a/pkg/sfu/receiver_base.go +++ b/pkg/sfu/receiver_base.go @@ -173,17 +173,16 @@ type REDTransformer interface { // -------------------------------------- type ReceiverBaseParams struct { - TrackID livekit.TrackID - StreamID string - Kind webrtc.RTPCodecType - Codec webrtc.RTPCodecParameters - HeaderExtensions []webrtc.RTPHeaderExtensionParameter - Logger logger.Logger - StreamTrackerManagerConfig StreamTrackerManagerConfig - StreamTrackerManagerListener StreamTrackerManagerListener - IsSelfClosing bool - IsForwardPacketArrivalTimeEnabled bool - OnClosed func() + TrackID livekit.TrackID + StreamID string + Kind webrtc.RTPCodecType + Codec webrtc.RTPCodecParameters + HeaderExtensions []webrtc.RTPHeaderExtensionParameter + Logger logger.Logger + StreamTrackerManagerConfig StreamTrackerManagerConfig + StreamTrackerManagerListener StreamTrackerManagerListener + IsSelfClosing bool + OnClosed func() } type ReceiverBase struct { @@ -522,7 +521,6 @@ func (r *ReceiverBase) AddDownTrack(track TrackSender) error { track.UpTrackMaxPublishedLayerChange(r.streamTrackerManager.GetMaxPublishedLayer()) track.UpTrackMaxTemporalLayerSeenChange(r.streamTrackerManager.GetMaxTemporalLayerSeen()) - track.EnableForwardPacketArrivalTime(r.params.IsForwardPacketArrivalTimeEnabled) r.downTrackSpreader.Store(track) r.params.Logger.Debugw("downtrack added", "subscriberID", track.SubscriberID())