chenyh
/
vRp.CD2g_test
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix: server 修复消息计数始终为1的问题

This commit is contained in:
kercylan98 2023-09-08 16:47:23 +08:00
parent 483ace2fa9
commit 6c882edb09
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
server/server.go
View File

@ -592,12 +592,13 @@ func (slf *Server) pushMessage(message *Message) {
defer slf.OnShuntChannelCreatedEvent(channelGuid) defer slf.OnShuntChannelCreatedEvent(channelGuid)
} }
if channel != nil { if channel != nil {
slf.messageCounter.Add(1)
channel <- message channel <- message
return return
} }
} }
slf.messageCounter.Add(1)
slf.messageChannel <- message slf.messageChannel <- message
} }
func (slf *Server) low(message *Message, present time.Time, expect time.Duration, messageReplace ...string) { func (slf *Server) low(message *Message, present time.Time, expect time.Duration, messageReplace ...string) {
@ -616,7 +617,6 @@ func (slf *Server) low(message *Message, present time.Time, expect time.Duration
// dispatchMessage 消息分发 // dispatchMessage 消息分发
func (slf *Server) dispatchMessage(msg *Message) { func (slf *Server) dispatchMessage(msg *Message) {
slf.messageCounter.Add(1)
var ( var (
ctx context.Context ctx context.Context
cancel context.CancelFunc cancel context.CancelFunc