Fix deadlock in senders closing (#211)

Author: OrlandoCo

pkg/receiver.go

@@ -141,8 +141,8 @@ func (w *WebRTCReceiver) SpatialLayer() uint8 {
 
 //closeSenders Close all senders from Receiver
 func (w *WebRTCReceiver) closeSenders() {
-	w.Lock()
-	defer w.Unlock()
+	w.RLock()
+	defer w.RUnlock()
 	for _, sender := range w.senders {
 		sender.Close()
 	}

pkg/sender.go

@@ -100,10 +100,6 @@ func (s *WebRTCSender) Close() {
 
 func (s *WebRTCSender) close() {
 	s.cancel()
-	// Remove sender from receiver
-	if recv := s.router.GetReceiver(0); recv != nil {
-		recv.DeleteSender(s.id)
-	}
 	if s.onCloseHandler != nil {
 		s.onCloseHandler()
 	}
@@ -118,6 +114,10 @@ func (s *WebRTCSender) receiveRTCP() {
 	for {
 		pkts, err := s.sender.ReadRTCP()
 		if err == io.ErrClosedPipe || s.ctx.Err() != nil {
+			// Remove sender from receiver
+			if recv := s.router.GetReceiver(0); recv != nil {
+				recv.DeleteSender(s.id)
+			}
 			s.Close()
 			return
 		}