好友优化
This commit is contained in:
parent
46b93a0a5d
commit
19ebb2d6b6
@ -3,7 +3,6 @@ package game
|
||||
import (
|
||||
mergeCluster "server/cluster"
|
||||
"server/game/mod/msg"
|
||||
"server/pkg/github.com/name5566/leaf/log"
|
||||
)
|
||||
|
||||
var clusterHandler map[int]func(*msg.Msg) error
|
||||
@ -22,7 +21,7 @@ func clusterHandlerProcess(m *msg.Msg) {
|
||||
if fun, ok := clusterHandler[m.Type]; ok {
|
||||
fun(m)
|
||||
} else {
|
||||
log.Debug("clusterHandlerProcess not found handler %d", m.Type)
|
||||
FriendMgrSend(m)
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -144,7 +144,13 @@ func ClusterFriendSync(m *msg.Msg) error {
|
||||
log.Debug("ClusterFriendSync")
|
||||
if v, ok := G_GameLogicPtr.FriendMgr.getData().ClusterMsg[m.To]; ok {
|
||||
for _, msg := range v {
|
||||
mergeCluster.SendServerMsg(msg.Clone(), m.To)
|
||||
if msg.H == 1 {
|
||||
continue
|
||||
}
|
||||
err := mergeCluster.SendServerMsg(msg.Clone(), m.To)
|
||||
if err == nil {
|
||||
msg.H = 1
|
||||
}
|
||||
}
|
||||
}
|
||||
return nil
|
||||
|
||||
Loading…
Reference in New Issue
Block a user