diff --git a/internal/core/metrics_test.go b/internal/core/metrics_test.go index 3dd4a182..9c53c544 100644 --- a/internal/core/metrics_test.go +++ b/internal/core/metrics_test.go @@ -157,6 +157,7 @@ srt_conns_packets_received_nak 0 srt_conns_packets_sent_km 0 srt_conns_packets_received_km 0 srt_conns_us_snd_duration 0 +srt_conns_packets_received_belated 0 srt_conns_packets_send_drop 0 srt_conns_packets_received_drop 0 srt_conns_packets_received_undecrypt 0 @@ -167,6 +168,7 @@ srt_conns_bytes_received_unique 0 srt_conns_bytes_received_loss 0 srt_conns_bytes_retrans 0 srt_conns_bytes_received_retrans 0 +srt_conns_bytes_received_belated 0 srt_conns_bytes_send_drop 0 srt_conns_bytes_received_drop 0 srt_conns_bytes_received_undecrypt 0 @@ -498,6 +500,7 @@ webrtc_sessions_rtcp_packets_sent 0 `srt_conns_packets_sent_km\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_packets_received_km\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_us_snd_duration\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ + `srt_conns_packets_received_belated\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_packets_send_drop\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_packets_received_drop\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_packets_received_undecrypt\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ @@ -508,6 +511,7 @@ webrtc_sessions_rtcp_packets_sent 0 `srt_conns_bytes_received_loss\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_bytes_retrans\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_bytes_received_retrans\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ + `srt_conns_bytes_received_belated\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_bytes_send_drop\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_bytes_received_drop\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ `srt_conns_bytes_received_undecrypt\{id=".*?",path=".*?",remoteAddr=".*?",state="publish"\} [0-9]+`+"\n"+ diff --git a/internal/metrics/metrics.go b/internal/metrics/metrics.go index 99cc573b..66db0116 100644 --- a/internal/metrics/metrics.go +++ b/internal/metrics/metrics.go @@ -525,6 +525,7 @@ func (m *Metrics) onMetrics(ctx *gin.Context) { out += metric("srt_conns_packets_sent_km", ta, int64(i.PacketsSentKM)) out += metric("srt_conns_packets_received_km", ta, int64(i.PacketsReceivedKM)) out += metric("srt_conns_us_snd_duration", ta, int64(i.UsSndDuration)) + out += metric("srt_conns_packets_received_belated", ta, int64(i.PacketsReceivedBelated)) out += metric("srt_conns_packets_send_drop", ta, int64(i.PacketsSendDrop)) out += metric("srt_conns_packets_received_drop", ta, int64(i.PacketsReceivedDrop)) out += metric("srt_conns_packets_received_undecrypt", ta, int64(i.PacketsReceivedUndecrypt)) @@ -535,6 +536,7 @@ func (m *Metrics) onMetrics(ctx *gin.Context) { out += metric("srt_conns_bytes_received_loss", ta, int64(i.BytesReceivedLoss)) out += metric("srt_conns_bytes_retrans", ta, int64(i.BytesRetrans)) out += metric("srt_conns_bytes_received_retrans", ta, int64(i.BytesReceivedRetrans)) + out += metric("srt_conns_bytes_received_belated", ta, int64(i.BytesReceivedBelated)) out += metric("srt_conns_bytes_send_drop", ta, int64(i.BytesSendDrop)) out += metric("srt_conns_bytes_received_drop", ta, int64(i.BytesReceivedDrop)) out += metric("srt_conns_bytes_received_undecrypt", ta, int64(i.BytesReceivedUndecrypt)) @@ -580,6 +582,7 @@ func (m *Metrics) onMetrics(ctx *gin.Context) { out += metric("srt_conns_packets_sent_km", "", 0) out += metric("srt_conns_packets_received_km", "", 0) out += metric("srt_conns_us_snd_duration", "", 0) + out += metric("srt_conns_packets_received_belated", "", 0) out += metric("srt_conns_packets_send_drop", "", 0) out += metric("srt_conns_packets_received_drop", "", 0) out += metric("srt_conns_packets_received_undecrypt", "", 0) @@ -590,6 +593,7 @@ func (m *Metrics) onMetrics(ctx *gin.Context) { out += metric("srt_conns_bytes_received_loss", "", 0) out += metric("srt_conns_bytes_retrans", "", 0) out += metric("srt_conns_bytes_received_retrans", "", 0) + out += metric("srt_conns_bytes_received_belated", "", 0) out += metric("srt_conns_bytes_send_drop", "", 0) out += metric("srt_conns_bytes_received_drop", "", 0) out += metric("srt_conns_bytes_received_undecrypt", "", 0)