Check for closed receiver before setting up rid

Author: boks1971

peerconnection.go

@@ -1875,9 +1875,6 @@ func (pc *PeerConnection) handleIncomingSSRC(rtpStream *srtp.ReadStreamSRTP, ssr
 			}
 
 			if rsid != "" {
-				receiver.mu.Lock()
-				defer receiver.mu.Unlock()
-
 				return receiver.receiveForRtx(SSRC(0), rsid, streamInfo, readStream, interceptor, rtcpReadStream, rtcpInterceptor)
 			}
 

rtpreceiver.go

@@ -552,6 +552,10 @@ func (r *RTPReceiver) receiveForRid(
 	r.mu.Lock()
 	defer r.mu.Unlock()
 
+	if r.haveClosed() {
+		return nil, io.EOF
+	}
+
 	for i := range r.tracks {
 		if r.tracks[i].track.RID() == rid {
 			r.tracks[i].track.mu.Lock()
@@ -577,7 +581,7 @@ func (r *RTPReceiver) receiveForRid(
 
 // receiveForRtx starts a routine that processes the repair stream.
 //
-//nolint:cyclop
+//nolint:gocognit,cyclop
 func (r *RTPReceiver) receiveForRtx(
 	ssrc SSRC,
 	rsid string,
@@ -587,6 +591,13 @@ func (r *RTPReceiver) receiveForRtx(
 	rtcpReadStream *srtp.ReadStreamSRTCP,
 	rtcpInterceptor interceptor.RTCPReader,
 ) error {
+	r.mu.Lock()
+	defer r.mu.Unlock()
+
+	if r.haveClosed() {
+		return io.EOF
+	}
+
 	var track *trackStreams
 	if ssrc != 0 && len(r.tracks) == 1 {
 		track = &r.tracks[0]