diff --git a/pkg/sfu/downtrack.go b/pkg/sfu/downtrack.go index c37cb7b21..b26080526 100644 --- a/pkg/sfu/downtrack.go +++ b/pkg/sfu/downtrack.go @@ -743,14 +743,6 @@ func (d *DownTrack) WriteRTP(extPkt *buffer.ExtPacket, layer int32) error { Pool: PacketFactory, PoolEntity: poolEntity, }) - if d.kind == webrtc.RTPCodecTypeAudio { - d.params.Logger.Infow("forwarding debug", - "incomingSN", extPkt.ExtSequenceNumber, - "outgoingSN", tp.rtp.extSequenceNumber, - "incomingTS", extPkt.ExtTimestamp, - "outgoingTS", tp.rtp.extTimestamp, - ) // TODO-REMOVE-AFTER-DEBUG - } return nil } diff --git a/pkg/sfu/forwarder.go b/pkg/sfu/forwarder.go index b174a2e9a..ea6ea29c1 100644 --- a/pkg/sfu/forwarder.go +++ b/pkg/sfu/forwarder.go @@ -1479,7 +1479,7 @@ func (f *Forwarder) processSourceSwitch(extPkt *buffer.ExtPacket, layer int32) e } logTransition := func(message string, extExpectedTS, extRefTS, extLastTS uint64, diffSeconds float64) { - f.logger.Infow( + f.logger.Debugw( message, "layer", layer, "extExpectedTS", extExpectedTS, diff --git a/pkg/sfu/rtpmunger.go b/pkg/sfu/rtpmunger.go index 636375d42..31c415f12 100644 --- a/pkg/sfu/rtpmunger.go +++ b/pkg/sfu/rtpmunger.go @@ -179,9 +179,6 @@ func (r *RTPMunger) UpdateAndGetSnTs(extPkt *buffer.ExtPacket) (*TranslationPara extMungedSN := extPkt.ExtSequenceNumber - r.snOffset extMungedTS := extPkt.ExtTimestamp - r.tsOffset - if extMungedTS > (r.extLastTS + 48000) { - r.logger.Infow("large jump in ts", "lastTS", r.extLastTS, "incomingTS", extPkt.ExtTimestamp, "mungedTS", extMungedTS, "tsOffset", r.tsOffset) // TODO-REMOVE-AFTER-DEBUG - } r.extSecondLastSN = r.extLastSN r.extLastSN = extMungedSN