From 83538e5cc587ad8c94997a3dcfe0f8e47f239d32 Mon Sep 17 00:00:00 2001 From: qydysky <32743305+qydysky@users.noreply.github.com> Date: Sun, 16 Oct 2022 05:21:16 +0800 Subject: [PATCH] fix --- Reply/F.go | 28 +++++++++++++++------------- 1 file changed, 15 insertions(+), 13 deletions(-) diff --git a/Reply/F.go b/Reply/F.go index 083d5ee..80857ee 100644 --- a/Reply/F.go +++ b/Reply/F.go @@ -1275,28 +1275,30 @@ var Recoder = websocket.Recorder{ } func StartRecDanmu(filePath string) { - if IsOn("弹幕回放") { - f := flog.Base("弹幕回放") - if e := Recoder.Start(filePath); e == nil { - f.L(`T: `, `开始`) - } else { - f.L(`E: `, e) - } + if !IsOn(`仅保存当前直播间流`) || !IsOn("弹幕回放") { + return + } + f := flog.Base("弹幕回放") + if e := Recoder.Start(filePath); e == nil { + f.L(`T: `, `开始`) + } else { + f.L(`E: `, e) } } func PlayRecDanmu(filePath string) (*websocket.Server, func()) { - if IsOn("弹幕回放") { - return websocket.Play(filePath, 70, 1000) + if !IsOn(`仅保存当前直播间流`) || !IsOn("弹幕回放") { + return nil, nil } - return nil, nil + return websocket.Play(filePath, 70, 1000) } func StopRecDanmu() { - if IsOn("弹幕回放") { - flog.Base("弹幕回放").L(`T: `, `停止`) - Recoder.Stop() + if !IsOn(`仅保存当前直播间流`) || !IsOn("弹幕回放") { + return } + flog.Base("弹幕回放").L(`T: `, `停止`) + Recoder.Stop() } // 此次直播的交互人数 -- 2.39.2