From 7b8af0518e943ded08c6c53c96ca83d263a2af82 Mon Sep 17 00:00:00 2001 From: kercylan98 Date: Fri, 7 Jul 2023 19:02:30 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E5=BC=82=E6=AD=A5?= =?UTF-8?q?=E6=85=A2=E6=B6=88=E6=81=AF=E8=BF=BD=E8=B8=AA=E4=B8=8D=E7=94=9F?= =?UTF-8?q?=E6=95=88=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/server.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/server.go b/server/server.go index 5c35441..1ba4e5b 100644 --- a/server/server.go +++ b/server/server.go @@ -463,7 +463,7 @@ func (slf *Server) pushMessage(message *Message) { func (slf *Server) low(message *Message, present time.Time) { cost := time.Since(present) if cost > time.Millisecond*100 { - log.Warn("Server", zap.String("MessageType", messageNames[message.t]), zap.String("LowExecCost", cost.String())) + log.Warn("Server", zap.String("LowExecCost", cost.String()), zap.Any("Message", message)) slf.OnMessageLowExecEvent(message, cost) } } @@ -526,7 +526,7 @@ func (slf *Server) dispatchMessage(msg *Message) { attrs[0].(func())() case MessageTypeAsync: handle := attrs[0].(func() error) - callbacks := attrs[1].([]func(err error)) + callback, cb := attrs[1].(func(err error)) if err := slf.ants.Submit(func() { defer func() { if err := recover(); err != nil { @@ -536,12 +536,13 @@ func (slf *Server) dispatchMessage(msg *Message) { } } super.Handle(cancel) + slf.low(msg, present) if !slf.isShutdown.Load() { slf.messagePool.Release(msg) } }() if err := handle(); err != nil { - for _, callback := range callbacks { + if cb { callback(err) } }