()
| 125 | } |
| 126 | |
| 127 | func (h *HeartbeatChecker) SendHeartBeatMsg() error { |
| 128 | |
| 129 | msg := h.makeMsg(h.conn) |
| 130 | |
| 131 | err := h.conn.SendMsg(h.msgID, msg) |
| 132 | if err != nil { |
| 133 | zlog.Ins().ErrorF("send heartbeat msg error: %v, msgId=%+v msg=%+v", err, h.msgID, msg) |
| 134 | return err |
| 135 | } |
| 136 | |
| 137 | return nil |
| 138 | } |
| 139 | |
| 140 | func (h *HeartbeatChecker) check() (err error) { |
| 141 |