fix: set ping

This commit is contained in:
int7 2023-10-30 19:07:19 +08:00
parent a6478aeac8
commit e9c67a354d

View File

@ -298,8 +298,8 @@ func (ctl *Control) msgHandler() {
xl.Debug("send heartbeat to server") xl.Debug("send heartbeat to server")
pingMsg := &msg.Ping{} pingMsg := &msg.Ping{}
if err := ctl.authSetter.SetPing(pingMsg); err != nil { if err := ctl.authSetter.SetPing(pingMsg); err != nil {
xl.Warn("error during ping authentication: %v", err) xl.Warn("error during ping authentication: %v. skip sending ping message", err)
return continue
} }
ctl.sendCh <- pingMsg ctl.sendCh <- pingMsg
case <-hbCheckCh: case <-hbCheckCh: