This commit is contained in:
@@ -233,12 +233,16 @@ func (h *ClientData) OnEvent(v []byte) {
|
||||
|
||||
}
|
||||
func (p *ClientData) SendPack(b []byte) error {
|
||||
if _, ok := p.Conn.Context().(*ClientData); !ok {
|
||||
cli, ok := p.Conn.Context().(*ClientData)
|
||||
if !ok {
|
||||
return fmt.Errorf("链接错误,取消发包")
|
||||
|
||||
}
|
||||
if cli.Wsmsg == nil {
|
||||
return fmt.Errorf("ws空")
|
||||
}
|
||||
|
||||
if p.Conn.Context().(*ClientData).Wsmsg.Upgraded {
|
||||
if cli.Wsmsg.Upgraded {
|
||||
// This is the echo server
|
||||
err := wsutil.WriteServerMessage(p.Conn, ws.OpBinary, b)
|
||||
if err != nil {
|
||||
|
||||
@@ -29,7 +29,7 @@ func (p *Player) Save() {
|
||||
p.Info.OnlineTime = p.Info.OnlineTime + (newtime-uint32(p.Logintime))/60 //每次退出时候保存已经在线的分钟数
|
||||
if p.FightC != nil {
|
||||
|
||||
go p.FightC.Over(p, info.BattleOverReason.PlayerOffline) //玩家逃跑,但是不能锁线程
|
||||
defer p.FightC.Over(p, info.BattleOverReason.PlayerOffline) //玩家逃跑,但是不能锁线程
|
||||
|
||||
}
|
||||
p.IsLogin = false
|
||||
|
||||
Reference in New Issue
Block a user