From de40cc00a5706873a3123ff12b143f282539df4f Mon Sep 17 00:00:00 2001
From: Juliusz Chroboczek <jch@irif.fr>
Date: Fri, 6 Jan 2023 23:00:32 +0100
Subject: [PATCH] Handle VP8 packets with no PID.

---
 rtpconn/rtpconn.go | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git a/rtpconn/rtpconn.go b/rtpconn/rtpconn.go
index 9f5739e..b19346a 100644
--- a/rtpconn/rtpconn.go
+++ b/rtpconn/rtpconn.go
@@ -283,7 +283,15 @@ func (down *rtpDownTrack) Write(buf []byte) (int, error) {
 		}
 	}
 
-	ok, newseqno, piddelta := down.packetmap.Map(flags.Seqno, flags.Pid)
+	var ok bool
+	var newseqno, piddelta uint16
+	if flags.MissingPid {
+		ok, newseqno, piddelta =
+			down.packetmap.MapContinuation(flags.Seqno)
+	} else {
+		ok, newseqno, piddelta =
+			down.packetmap.Map(flags.Seqno, flags.Pid)
+	}
 	if !ok {
 		return 0, nil
 	}
@@ -923,7 +931,7 @@ func maxUpBitrate(t *rtpUpTrack) uint64 {
 	// assume that lower spatial layers take up 1/5 of
 	// the throughput
 	if maxsid > 0 {
-		maxrate = sadd(maxrate, maxrate / 4)
+		maxrate = sadd(maxrate, maxrate/4)
 	}
 	// assume that each layer takes two times less
 	// throughput than the higher one.  Then we've
@@ -1003,7 +1011,7 @@ func sendUpRTCP(up *rtpUpConnection) error {
 		}
 		ssrcs = append(ssrcs, uint32(t.track.SSRC()))
 		if t.Kind() == webrtc.RTPCodecTypeAudio {
-			rate = sadd(rate, 100 * 1024)
+			rate = sadd(rate, 100*1024)
 		} else if t.Label() == "l" {
 			rate = sadd(rate, group.LowBitrate)
 		} else {