日志优化
This commit is contained in:
parent
59a8d692b1
commit
ed7ec40d34
@ -198,7 +198,8 @@ func ClusterSyncHandler(data *msg.Msg) (interface{}, error) {
|
||||
messageMgrData.mu.Lock()
|
||||
TempMessageList := messageMgrData.MessageList
|
||||
messageMgrData.MessageList = make(map[int64]*MessageList)
|
||||
messageMgrData.mu.Unlock()
|
||||
defer messageMgrData.mu.Unlock()
|
||||
log.Debug("[Middleware] Cluster sync send temp message len: %d", len(TempMessageList))
|
||||
for _, Message := range TempMessageList {
|
||||
for _, msgItem := range Message.Messages {
|
||||
SendMsgToCenterAsync(msgItem)
|
||||
|
||||
Loading…
Reference in New Issue
Block a user