From 8917326a246d52599ef5de18f939a3e035c245db Mon Sep 17 00:00:00 2001
From: kercylan98 <kercylan@gmail.com>
Date: Tue, 11 Jul 2023 19:38:50 +0800
Subject: [PATCH] =?UTF-8?q?other:=20=E4=BF=AE=E6=94=B9=20server.Server=20?=
 =?UTF-8?q?=E6=85=A2=E6=B6=88=E6=81=AF=E6=A3=80=E6=B5=8B=E7=9A=84=E5=BC=82?=
 =?UTF-8?q?=E6=AD=A5=E6=B6=88=E6=81=AF=E5=88=A4=E5=AE=9A=E6=9D=A1=E4=BB=B6?=
 =?UTF-8?q?=E4=B8=BA=201=20=E7=A7=92?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 server/server.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/server/server.go b/server/server.go
index 7118d0f..2365a54 100644
--- a/server/server.go
+++ b/server/server.go
@@ -479,9 +479,9 @@ func (slf *Server) pushMessage(message *Message) {
 	slf.messageChannel <- message
 }
 
-func (slf *Server) low(message *Message, present time.Time) {
+func (slf *Server) low(message *Message, present time.Time, expect time.Duration) {
 	cost := time.Since(present)
-	if cost > time.Millisecond*100 {
+	if cost > expect {
 		log.Warn("Server", zap.String("LowExecCost", cost.String()), zap.Any("Message", message))
 		slf.OnMessageLowExecEvent(message, cost)
 	}
@@ -516,7 +516,7 @@ func (slf *Server) dispatchMessage(msg *Message) {
 
 		if msg.t != MessageTypeAsync {
 			super.Handle(cancel)
-			slf.low(msg, present)
+			slf.low(msg, present, time.Millisecond*100)
 			if !slf.isShutdown.Load() {
 				slf.messagePool.Release(msg)
 			}
@@ -555,7 +555,7 @@ func (slf *Server) dispatchMessage(msg *Message) {
 					}
 				}
 				super.Handle(cancel)
-				slf.low(msg, present)
+				slf.low(msg, present, time.Second)
 				if !slf.isShutdown.Load() {
 					slf.messagePool.Release(msg)
 				}