mirror of
https://github.com/eosswedenorg/antelope-api-healthcheck
synced 2026-07-03 11:53:43 +02:00
internal/server.go: in onTcpMessage() check error return value of c.WriteString()
This commit is contained in:
parent
adb1ad3c6d
commit
bcc704c4c0
1 changed files with 9 additions and 2 deletions
|
|
@ -22,7 +22,11 @@ func onTcpMessage(c *tcp_server.Client, args string) {
|
||||||
logger.Warn("Agent request error", "message", err)
|
logger.Warn("Agent request error", "message", err)
|
||||||
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "")
|
resp := agentcheck.NewStatusMessageResponse(agentcheck.Failed, "")
|
||||||
|
|
||||||
c.WriteString(resp.String())
|
_, err = c.WriteString(resp.String())
|
||||||
|
if err != nil {
|
||||||
|
logger.Error("WriteString", "message", err)
|
||||||
|
}
|
||||||
|
|
||||||
c.Close()
|
c.Close()
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
@ -38,7 +42,10 @@ func onTcpMessage(c *tcp_server.Client, args string) {
|
||||||
|
|
||||||
logger.Info("API Check", params.Combine(healthCheckApi.LogInfo())...)
|
logger.Info("API Check", params.Combine(healthCheckApi.LogInfo())...)
|
||||||
// Report status to HAproxy
|
// Report status to HAproxy
|
||||||
c.WriteString(status.String())
|
_, err = c.WriteString(status.String())
|
||||||
|
if err != nil {
|
||||||
|
logger.Error("WriteString", "message", err)
|
||||||
|
}
|
||||||
c.Close()
|
c.Close()
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue