From 0ffb5a7ef1621eb2d84e640fec7d352ea6d927bc Mon Sep 17 00:00:00 2001 From: qydysky Date: Sat, 16 Dec 2023 05:20:53 +0800 Subject: [PATCH] =?utf8?q?=20Fix=20b=E6=9C=8D=E4=B8=8D=E7=A8=B3=E5=AE=9A?= =?utf8?q?=20#93?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- Reply/stream.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Reply/stream.go b/Reply/stream.go index 89940d1..1631e59 100644 --- a/Reply/stream.go +++ b/Reply/stream.go @@ -428,12 +428,12 @@ func (t *M4SStream) fetchParseM3U8(fmp4ListUpdateTo float64) (m4s_links []*m4s_l return } - // 检查是否服务器发生故障,产出多个切片 + // 检查是否服务器发生故障,产出切片错误 if t.last_m4s != nil { timed := tmp[len(tmp)-1].createdTime.Sub(t.last_m4s.createdTime).Seconds() nos, _ := tmp[len(tmp)-1].getNo() noe, _ := t.last_m4s.getNo() - if timed > 5 && nos-noe == 0 { + if (timed > 5 && nos-noe == 0) || (nos-noe > 50) { // 1min后重新启用 t.common.Live[k].DisableAuto() t.log.L("W: ", fmt.Sprintf("服务器 %s 发生故障 %d 秒产出了 %d 切片", F.ParseHost(v.Url), int(timed), nos-noe)) -- 2.39.2