fix stream stop

Former-commit-id: 390f8eec8b341d6274de3fbe3025d9fef299b97d [formerly 620e585c076d26b4015499e1e093cfd4baa8f1e2] [formerly 5ddbbb6abcd576cb3bb4ad273582332d0c89514f [formerly 0dedfac]]
Former-commit-id: 22250457f1af628483174238844231ab121cfc54 [formerly 4b87d89ec5dfd4631c700671994db995854177b9]
Former-commit-id: cc533d999b1abd3a9233763427fbc400d50f6fa4

incomingstream.go

@@ -311,14 +311,15 @@ func (i *IncomingStream) Stop() {
 		return
 	}
 
+	i.Lock()
 	for k, track := range i.tracks {
 		track.Stop()
 		delete(i.tracks, k)
 	}
+	i.Unlock()
 
 	for _, stopFunc := range i.onStopListeners {
 		stopFunc()
 	}
 
-	i.transport = nil
 }

incomingstreamtrack.go

@@ -1,7 +1,6 @@
 package mediaserver
 
 import (
-	"fmt"
 	"sort"
 	"strconv"
 	"time"
@@ -238,8 +237,6 @@ func NewIncomingStreamTrack(media string, id string, receiver native.RTPReceiver
 		return track.encodings[i].id < track.encodings[j].id
 	})
 
-	fmt.Println(track.encodings)
-
 	return track
 }
 
@@ -504,9 +501,10 @@ func (i *IncomingStreamTrack) Stop() {
 			encoding.depacketizer.Stop()
 			native.DeleteStreamTrackDepacketizer(encoding.depacketizer)
 		}
-		if encoding.source != nil {
-			native.DeleteRTPIncomingSourceGroup(encoding.source)
-		}
+		// does not
+		// if encoding.source != nil {
+		// 	native.DeleteRTPIncomingSourceGroup(encoding.source)
+		// }
 	}
 
 	if i.mediaStreamDuplicater != nil {

transport_test.go

@@ -216,7 +216,7 @@ func Test_TransportCreateStream(t *testing.T) {
 
 	fmt.Println(incoming)
 
-	// incoming.Stop()
-	// transport.Stop()
+	//incoming.Stop()
+	transport.Stop()
 
 }