hls client: fix freeze that happened during a video decoding error

4 years ago · 6e75093992
1 changed files with 4 additions and 1 deletions
--- a/internal/hls/client_video_processor.go
+++ b/internal/hls/client_video_processor.go
@ -137,7 +137,10 @@ func (p *clientVideoProcessor) process(
 	data []byte,
 	pts time.Duration,
 	dts time.Duration) {
-	p.queue <- clientVideoProcessorData{data, pts, dts}
+	select {
 	case p.queue <- clientVideoProcessorData{data, pts, dts}:
 	case <-p.ctx.Done():
 	}
 }
 func (p *clientVideoProcessor) initializeTrack() error {