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, ) } }