From: qydysky <32743305+qydysky@users.noreply.github.com> Date: Fri, 27 Jan 2023 16:43:49 +0000 (+0800) Subject: Fix 避免短时间重复开播导致的重复录制 X-Git-Tag: v0.5.11~17 X-Git-Url: http://127.0.0.1:8081/?a=commitdiff_plain;h=02eea8f5dea6d365cd3d791b8ab5ff605bff4bb6;p=bili_danmu%2F.git Fix 避免短时间重复开播导致的重复录制 --- diff --git a/Reply/stream.go b/Reply/stream.go index a18ca68..ef9dc91 100644 --- a/Reply/stream.go +++ b/Reply/stream.go @@ -1042,16 +1042,18 @@ func (t *M4SStream) Start() bool { return false } + // 实例回调 + if t.Callback_start != nil { + if e := t.Callback_start(t); e != nil { + t.log.L(`W: `, `开始回调错误`, e.Error()) + return false + } + } + t.Status = signal.Init() go func() { defer t.Status.Done() - // 实例回调 - if t.Callback_start != nil { - if e := t.Callback_start(t); e != nil { - t.log.L(`W: `, `开始回调错误`, e.Error()) - } - } if t.Callback_stop != nil { defer t.Callback_stop(t) }