From 05bf451940039ed74944f818c86c8d6e21367257 Mon Sep 17 00:00:00 2001
From: qydysky <qydysky@foxmail.com>
Date: Sun, 11 May 2025 15:59:15 +0800
Subject: [PATCH] =?utf8?q?Fix=20=E5=BD=93=E6=9C=89=E5=88=87=E7=89=87?=
 =?utf8?q?=E7=AD=89=E5=BE=85=E4=B8=8B=E8=BD=BD=E6=97=B6=20=E4=BC=9A?=
 =?utf8?q?=E8=8A=B1=E8=BE=83=E9=95=BF=E6=97=B6=E9=97=B4=E7=BB=93=E6=9D=9F?=
 =?utf8?q?=20(#202)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

---
 CV/Var.go     | 2 +-
 bili_danmu.go | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/CV/Var.go b/CV/Var.go
index d7f8235..6a97476 100644
--- a/CV/Var.go
+++ b/CV/Var.go
@@ -367,7 +367,7 @@ func (t *Common) Init() *Common {
 		80:    "流畅",
 	}
 
-	t.Danmu_Main_mq = mq.New(time.Second*5, time.Second*10)
+	t.Danmu_Main_mq = mq.New(time.Second*5, time.Second*90)
 
 	go func() { //日期变化
 		var old = time.Now().Hour()
diff --git a/bili_danmu.go b/bili_danmu.go
index a21449c..ceeb191 100644
--- a/bili_danmu.go
+++ b/bili_danmu.go
@@ -430,8 +430,8 @@ func entryRoom(rootCtx, mainCtx context.Context, danmulog *part.Log_interface, c
 				`interrupt`: func(_ any) (disable bool) {
 					exitloop = true
 					exitSign = true
-					ws_c.Close()
 					danmulog.L(`I: `, "停止，等待服务器断开连接")
+					ws_c.Close()
 					reply.StreamOStopAll() //停止录制
 					return true
 				},
-- 
2.39.2