mirror of
https://github.com/livekit/livekit.git
synced 2026-05-17 02:45:32 +00:00
Keeping revert of debug logs ready (#2163)
This commit is contained in:
@@ -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
|
||||
}
|
||||
|
||||
|
||||
@@ -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,
|
||||
|
||||
@@ -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
|
||||
|
||||
Reference in New Issue
Block a user