From 83c1cec4aaea455f54aa5d74d0406ba96eb3b13c Mon Sep 17 00:00:00 2001 From: qydysky Date: Sun, 8 May 2022 22:55:35 +0800 Subject: [PATCH] =?utf8?q?=E4=BF=AE=E5=A4=8D=E7=9B=B4=E6=92=AD=E6=B5=81?= =?utf8?q?=E4=BF=9D=E5=AD=98=E8=8E=AB=E5=90=8D=E4=B8=AD=E6=AD=A2?= MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit --- Reply/stream.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/Reply/stream.go b/Reply/stream.go index 1364ffb..591476e 100644 --- a/Reply/stream.go +++ b/Reply/stream.go @@ -359,15 +359,15 @@ func (t *M4SStream) saveStream() { t.stream_expires = time.Now().Add(time.Minute * 2).Unix() // 流链接过期时间 // 同时下载数限制 - var download_limit = funcCtrl.BlockFuncN{ + var download_limit = &funcCtrl.BlockFuncN{ Max: 3, } // 下载循环 for download_seq := []*m4s_link_item{}; ; { // 过多需下载切片提示 - if len(download_seq) > 15 { - t.log.L(`W: `, `待下载切片过多:`, len(download_seq)) + if len(download_seq) > 3 { + t.log.L(`T: `, `待下载切片过多:`, len(download_seq)) } // 下载切片 @@ -377,6 +377,8 @@ func (t *M4SStream) saveStream() { continue } + download_limit.Block() + v.status = 1 // 设置切片状态为正在下载 // 均衡负载 @@ -395,7 +397,6 @@ func (t *M4SStream) saveStream() { v.Url = link_url.String() } - download_limit.Block() go func(link *m4s_link_item, path string) { defer download_limit.UnBlock() -- 2.39.2