apps/engine
1
0
Fork 0
mirror of https://github.com/Monibuca/engine.git synced 2025-10-05 16:46:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: publish lost not shutdown

Browse Source
This commit is contained in:
langhuihui
2024-10-09 09:06:55 +08:00
parent 26dfd0b5cb
commit a0cca4d152
1 changed files with 0 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
stream.go
View File

@@ -492,16 +492,10 @@ func (s *Stream) run() {
s.Warn("no tracks") s.Warn("no tracks")
if time.Since(s.StartTime) > timeout { if time.Since(s.StartTime) > timeout {
lost = true lost = true
s.action(ACTION_CLOSE)
continue
} }
} else if s.Publisher != nil && s.Publisher.IsClosed() { } else if s.Publisher != nil && s.Publisher.IsClosed() {
s.Warn("publish is closed", zap.Error(context.Cause(s.publisher)), zap.String("ptr", fmt.Sprintf("%p", s.publisher.Context))) s.Warn("publish is closed", zap.Error(context.Cause(s.publisher)), zap.String("ptr", fmt.Sprintf("%p", s.publisher.Context)))
lost = true lost = true
if len(s.Tracks.Audio)+len(s.Tracks.Video) == 0 {
s.action(ACTION_CLOSE)
continue
}
} }
} }
if lost { if lost {