From 4f8bbdbaaba0c3c10a3cffdef7a88255c4a1a0e1 Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Sat, 21 Oct 2023 01:47:50 +0530 Subject: [PATCH] Keeping revert of debug logs ready (#2163) --- pkg/sfu/downtrack.go | 8 -------- pkg/sfu/forwarder.go | 2 +- pkg/sfu/rtpmunger.go | 3 --- 3 files changed, 1 insertion(+), 12 deletions(-) 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