liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

更改设置心跳断线时机

Browse Source
This commit is contained in:
meixiongfeng 2023-01-30 17:31:52 +08:00
parent ec3610dc6e
commit d27ece2da0
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
modules/gateway/agent.go
View File

@ -70,7 +70,7 @@ locp:
go this.Close() go this.Close()
break locp break locp
} }
this.wsConn.SetReadDeadline(time.Now().Add(time.Second * 30))
if err = proto.Unmarshal(data, msg); err != nil { if err = proto.Unmarshal(data, msg); err != nil {
this.gateway.Errorf("agent:%s uId:%s Unmarshal err:%v", this.sessionId, this.uId, err) this.gateway.Errorf("agent:%s uId:%s Unmarshal err:%v", this.sessionId, this.uId, err)
go this.Close() go this.Close()
@ -88,6 +88,7 @@ locp:
SubType: "heartbeat", SubType: "heartbeat",
Data: data, Data: data,
}) })
this.wsConn.SetReadDeadline(time.Now().Add(time.Second * 30))
continue continue
} }
if err := this.messageDistribution(msg); err != nil { if err := this.messageDistribution(msg); err != nil {