From c0d20885db163b8b766aba3499a33ad27531bbf8 Mon Sep 17 00:00:00 2001 From: Raja Subramanian Date: Wed, 27 Nov 2024 11:26:13 +0530 Subject: [PATCH] Log last switch time stamp (#3205) --- pkg/sfu/forwarder.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/sfu/forwarder.go b/pkg/sfu/forwarder.go index fa535391e..7dcd032e4 100644 --- a/pkg/sfu/forwarder.go +++ b/pkg/sfu/forwarder.go @@ -1685,6 +1685,7 @@ func (f *Forwarder) processSourceSwitch(extPkt *buffer.ExtPacket, layer int32) e "extLastTS", extLastTS, "diffSeconds", math.Abs(diffSeconds), "refInfos", logger.ObjectSlice(f.refInfos[:]), + "lastSwitchExtIncomingTS", f.lastSwitchExtIncomingTS, "rtpStats", f.rtpStats, ) } @@ -1701,6 +1702,7 @@ func (f *Forwarder) processSourceSwitch(extPkt *buffer.ExtPacket, layer int32) e "extLastTS", extLastTS, "diffSeconds", math.Abs(diffSeconds), "refInfos", logger.ObjectSlice(f.refInfos[:]), + "lastSwitchExtIncomingTS", f.lastSwitchExtIncomingTS, "rtpStats", f.rtpStats, ) } @@ -1900,6 +1902,7 @@ func (f *Forwarder) getTranslationParamsCommon(extPkt *buffer.ExtPacket, layer i "error", err, "layer", layer, "refInfos", logger.ObjectSlice(f.refInfos[:]), + "lastSwitchExtIncomingTS", f.lastSwitchExtIncomingTS, "rtpStats", f.rtpStats, "currentLayer", f.vls.GetCurrent(), "targetLayer", f.vls.GetCurrent(), @@ -1914,6 +1917,7 @@ func (f *Forwarder) getTranslationParamsCommon(extPkt *buffer.ExtPacket, layer i "to", extPkt.Packet.SSRC, "layer", layer, "refInfos", logger.ObjectSlice(f.refInfos[:]), + "lastSwitchExtIncomingTS", f.lastSwitchExtIncomingTS, "currentLayer", f.vls.GetCurrent(), "targetLayer", f.vls.GetCurrent(), "maxLayer", f.vls.GetMax(),