apps/monibuca
1
0
Fork 0
mirror of https://github.com/langhuihui/monibuca.git synced 2025-12-24 13:48:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: avoid hls transform task to retry

Browse Source
This commit is contained in:
langhuihui
2025-10-11 13:20:25 +08:00
parent 29870fb579
commit 3151d9c101
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
plugin/hls/pkg/writer.go
View File

@@ -10,6 +10,7 @@ import (
"sync"
"time"
task "github.com/langhuihui/gotask"
"m7s.live/v5"
"m7s.live/v5/pkg/codec"
"m7s.live/v5/pkg/format"
@@ -94,12 +95,12 @@ func (w *HLSWriter) Run() (err error) {
return m7s.PlayBlock(subscriber, func(audio *format.Mpeg2Audio) error {
pesAudio.Pts = uint64(subscriber.AudioReader.AbsTime) * 90
if w.checkNoBodyRead() {
return ErrNoBodyRead
return errors.Join(ErrNoBodyRead, task.ErrStopByUser)
}
return pesAudio.WritePESPacket(audio.Memory, &w.ts.RecyclableMemory)
}, func(video *mpegts.VideoFrame) (err error) {
if w.checkNoBodyRead() {
return ErrNoBodyRead
return errors.Join(ErrNoBodyRead, task.ErrStopByUser)
}
vr := w.TransformJob.Subscriber.VideoReader
if vr.Value.IDR {