fix

Former-commit-id: e4ce74fc7cea9a9b8de8fba159246591676ee4a8 [formerly 56527a312290e9038ba3abc7679729d8900e3121] [formerly c8ba9070783205bc9a74040222f3ea8136979689 [formerly d45c4f5]]
Former-commit-id: d0f3e222892a45ca12017b55754ae0188e005c4a [formerly 54da6d72716a8a76d1b461d91e3f14420dd5d4d7]
Former-commit-id: b4c47ae79c49e3c4e18d07957de0c3d0358ccdc2

incomingstream.go

@@ -3,7 +3,6 @@ package mediaserver
 import (
 	"errors"
 	"fmt"
-	"runtime"
 	"strconv"
 	"strings"
 	"sync"
@@ -212,9 +211,9 @@ func (i *IncomingStream) CreateTrack(track *sdp.TrackInfo) *IncomingStreamTrack
 				i.transport.AddIncomingSourceGroup(source)
 				sources[rid] = source
 
-				runtime.SetFinalizer(source, func(source native.RTPIncomingSourceGroup) {
-					i.transport.RemoveIncomingSourceGroup(source)
-				})
+				// runtime.SetFinalizer(source, func(source native.RTPIncomingSourceGroup) {
+				// 	i.transport.RemoveIncomingSourceGroup(source)
+				// })
 
 			}
 		}
@@ -251,9 +250,9 @@ func (i *IncomingStream) CreateTrack(track *sdp.TrackInfo) *IncomingStreamTrack
 
 			sources[strconv.Itoa(j)] = source
 
-			runtime.SetFinalizer(source, func(source native.RTPIncomingSourceGroup) {
-				i.transport.RemoveIncomingSourceGroup(source)
-			})
+			// runtime.SetFinalizer(source, func(source native.RTPIncomingSourceGroup) {
+			// 	i.transport.RemoveIncomingSourceGroup(source)
+			// })
 		}
 
 	} else {

outgoingstream.go

@@ -1,7 +1,6 @@
 package mediaserver
 
 import (
-	"runtime"
 	"strings"
 	"sync"
 
@@ -217,9 +216,9 @@ func (o *OutgoingStream) CreateTrack(track *sdp.TrackInfo) *OutgoingStreamTrack
 
 	outgoingTrack := newOutgoingStreamTrack(track.GetMedia(), track.GetID(), native.TransportToSender(o.transport), source)
 
-	runtime.SetFinalizer(source, func(source native.RTPOutgoingSourceGroup) {
-		o.transport.RemoveOutgoingSourceGroup(source)
-	})
+	// runtime.SetFinalizer(source, func(source native.RTPOutgoingSourceGroup) {
+	// 	o.transport.RemoveOutgoingSourceGroup(source)
+	// })
 
 	o.Lock()
 	o.tracks[outgoingTrack.GetID()] = outgoingTrack