gilles/go2rtc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix broken incoming sources after v1.9.7 #1458

Browse Source
This commit is contained in:
Alex X
2024-11-14 19:39:26 +03:00
committed by seydx
parent 3ddf8b5922
commit a8edaedc8b
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/streams/play.go
+1 -1
View File
@@ -103,7 +103,7 @@ func (s *Stream) Play(source string) error {
} }
func (s *Stream) AddInternalProducer(conn core.Producer) { func (s *Stream) AddInternalProducer(conn core.Producer) {
producer := &Producer{conn: conn, state: stateInternal} producer := &Producer{conn: conn, state: stateInternal, url: "internal"}
s.mu.Lock() s.mu.Lock()
s.producers = append(s.producers, producer) s.producers = append(s.producers, producer)
s.mu.Unlock() s.mu.Unlock()
internal/streams/stream.go
+1 -1
View File
@@ -76,7 +76,7 @@ func (s *Stream) RemoveConsumer(cons core.Consumer) {
} }
func (s *Stream) AddProducer(prod core.Producer) { func (s *Stream) AddProducer(prod core.Producer) {
producer := &Producer{conn: prod, state: stateExternal} producer := &Producer{conn: prod, state: stateExternal, url: "external"}
s.mu.Lock() s.mu.Lock()
s.producers = append(s.producers, producer) s.producers = append(s.producers, producer)
s.mu.Unlock() s.mu.Unlock()