From f5bb0ba9dca80b397af47e87d9b2524b8f14195b Mon Sep 17 00:00:00 2001
From: qydysky <qydysky@foxmail.com>
Date: Sun, 8 May 2022 04:26:22 +0800
Subject: [PATCH] =?utf8?q?=E4=BF=AE=E5=A4=8D=E7=94=B1=E4=BA=8Em3u8?=
 =?utf8?q?=E4=B8=8B=E8=BD=BD=E8=B6=85=E6=97=B6=E5=AF=BC=E8=87=B4=E7=9A=84?=
 =?utf8?q?=E4=B8=AD=E6=96=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 Reply/stream.go | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/Reply/stream.go b/Reply/stream.go
index f607469..10c4f79 100644
--- a/Reply/stream.go
+++ b/Reply/stream.go
@@ -177,6 +177,7 @@ func (t *M4SStream) fetchParseM3U8() (m4s_links []*m4s_link_item, m3u8_addon []b
 		// 设置请求参数
 		rval := reqf.Rval{
 			Url:            m3u8_url.String(),
+			Retry:          2,
 			ConnectTimeout: 2000,
 			ReadTimeout:    1000,
 			Timeout:        2000,
@@ -454,10 +455,11 @@ func (t *M4SStream) saveStream() {
 			if err != nil {
 				t.log.L(`E: `, `获取解析m3u8发生错误`, err)
 				if len(download_seq) != 0 {
-					t.log.L(`I: `, `下载最后切片:`, len(download_seq))
 					continue
 				}
-				break
+				if !reqf.IsTimeout(err) {
+					break
+				}
 			}
 			if len(m4s_links) == 0 {
 				time.Sleep(time.Second)
@@ -511,7 +513,7 @@ func (t *M4SStream) Start() {
 		// 是否在直播
 		F.Get(&t.common).Get(`Liveing`)
 		if !t.common.Liveing {
-			t.log.L(`T: `, `未直播`)
+			t.log.L(`W: `, `未直播`)
 			break
 		}
 
@@ -540,6 +542,9 @@ func (t *M4SStream) Start() {
 }
 
 func (t *M4SStream) Stop() {
+	if !t.Status.Islive() {
+		return
+	}
 	t.exitSign = signal.Init()
 	t.Status.Done()
 	t.log.L(`I: `, `正在等待切片下载...`)
-- 
2.39.2