From: qydysky <qydysky@foxmail.com>
Date: Fri, 24 May 2024 16:35:12 +0000 (+0000)
Subject: Improve fmp4最多获取8个服务器
X-Git-Tag: v0.14.3~5
X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=2c0df62412df9879988f270feecc116f603fa6ce;p=bili_danmu%2F.git

Improve fmp4最多获取8个服务器
---

diff --git a/Reply/stream.go b/Reply/stream.go
index 60e8a2b..b682db9 100644
--- a/Reply/stream.go
+++ b/Reply/stream.go
@@ -298,7 +298,7 @@ func (t *M4SStream) fetchCheckStream() bool {
 func (t *M4SStream) fetchParseM3U8(lastM4s *m4s_link_item, fmp4ListUpdateTo float64) (m4s_links []*m4s_link_item, e error) {
 	{
 		n := t.common.ValidNum()
-		if d, ok := t.common.K_v.LoadV("fmp4获取更多服务器").(bool); ok && d && n <= 1 {
+		if d, ok := t.common.K_v.LoadV("fmp4获取更多服务器").(bool); ok && d && n <= 1 && len(t.common.Live) <= 5 {
 			t.log.L("I: ", "获取更多服务器...")
 			if !t.fetchCheckStream() {
 				e = errors.New("全部流服务器发生故障")
@@ -1321,6 +1321,9 @@ func (t *M4SStream) Start() bool {
 				break
 			}
 
+			// 新循环，取消所有流
+			t.common.Live = t.common.Live[:0]
+
 			// 获取 and 检查流地址状态
 			if !t.fetchCheckStream() {
 				time.Sleep(time.Second * 5)