Parse receiver reports, save loss rate.

17941fa9 · Juliusz Chroboczek · b042bed9 · 17941fa9 · 17941fa9
Commit 17941fa9 authored Apr 29, 2020 by Juliusz Chroboczek
Hide whitespace changes
Inline Side-by-side

Showing with 9 additions and 0 deletions

client.go client.go +8 -0

group.go group.go +1 -0

No files found.
--- a/client.go
+++ b/client.go
@@ -616,6 +616,14 @@ func rtcpDownListener(g *group, conn *downConnection, track *downTrack, s *webrt
 					uint64(ms),
 				)
 			case *rtcp.ReceiverReport:
+				for _, r := range p.Reports {
+					if r.SSRC == track.track.SSRC() {
+						atomic.StoreUint32(
+							&track.loss,
+							uint32(r.FractionLost),
+						)
+					}
+				}
 			case *rtcp.TransportLayerNack:
 				sendRecovery(p, track)
 			default:

--- a/group.go
+++ b/group.go
@@ -75,6 +75,7 @@ type downTrack struct {
 	remote     *upTrack
 	isMuted    uint32
 	maxBitrate *timeStampedBitrate
+	loss       uint32
 }
 func (t *downTrack) muted() bool {