From 79b03f97a2ebb1d1ae8bbe4e66ebfa1f69e24cef Mon Sep 17 00:00:00 2001
From: Raja Subramanian <raja.gobi@tutanota.com>
Date: Mon, 27 Oct 2025 15:27:03 +0530
Subject: [PATCH] Log queueing latency when encountering high forwarding
 latency (#4034)

---
 pkg/sfu/receiver.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/pkg/sfu/receiver.go b/pkg/sfu/receiver.go
index 02e3b6caf..52ea1326b 100644
--- a/pkg/sfu/receiver.go
+++ b/pkg/sfu/receiver.go
@@ -790,6 +790,7 @@ func (w *WebRTCReceiver) forwardRTP(layer int32, buff *buffer.Buffer) {
 		if err == io.EOF {
 			return
 		}
+		dequeuedAt := mono.UnixNano()
 
 		if pkt.Packet.PayloadType != uint8(w.codec.PayloadType) {
 			// drop packets as we don't support codec fallback directly
@@ -832,6 +833,7 @@ func (w *WebRTCReceiver) forwardRTP(layer int32, buff *buffer.Buffer) {
 					"high forwarding latency",
 					"latency", latency,
 					"writeCount", writeCount,
+					"queuingLatency", dequeuedAt-pkt.Arrival,
 				)
 			}
 		}