Fix error logging

This commit is contained in:
Zoltán Papp 2024-06-30 10:43:12 +02:00
parent aa55fba5ee
commit ed82ef7fe4

View File

@ -300,9 +300,11 @@ func (c *Client) readLoop(relayConn net.Conn) {
log.Debugf("on new heartbeat") log.Debugf("on new heartbeat")
msg := messages.MarshalHealthcheck() msg := messages.MarshalHealthcheck()
_, wErr := c.relayConn.Write(msg) _, wErr := c.relayConn.Write(msg)
if wErr != nil {
if c.serviceIsRunning && !internallyStoppedFlag.isSet() { if c.serviceIsRunning && !internallyStoppedFlag.isSet() {
c.log.Errorf("failed to send heartbeat: %s", wErr) c.log.Errorf("failed to send heartbeat: %s", wErr)
} }
}
hc.Heartbeat() hc.Heartbeat()
case messages.MsgTypeTransport: case messages.MsgTypeTransport:
peerID, payload, err := messages.UnmarshalTransportMsg(buf[:n]) peerID, payload, err := messages.UnmarshalTransportMsg(buf[:n])