]> 127.0.0.1 Git - bili_danmu/.git/commitdiff
Improve fmp4最多获取8个服务器
authorqydysky <qydysky@foxmail.com>
Fri, 24 May 2024 16:35:12 +0000 (16:35 +0000)
committerqydysky <qydysky@foxmail.com>
Fri, 24 May 2024 16:35:12 +0000 (16:35 +0000)
Reply/stream.go

index 60e8a2b7118c2035e4995311fc3a534b011eed86..b682db9492b0a4d4436747b44cb92ec3eab4d12a 100644 (file)
@@ -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)