From 83fd4826d7072bf165a36986b5ec225fa7def888 Mon Sep 17 00:00:00 2001 From: Henrik Hautakoski Date: Mon, 6 Feb 2023 12:45:50 +0100 Subject: [PATCH] internal/server/server.go: need to provide a callback to AsyncWrite to close the connection. --- internal/server/server.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/internal/server/server.go b/internal/server/server.go index 5402320..53191dd 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -109,7 +109,10 @@ func (s *Server) OnTraffic(c gnet.Conn) gnet.Action { logger.Info("API Check", params.Combine(healthCheckApi.LogInfo())...) // Report status to HAproxy - err = c.AsyncWrite([]byte(status.String()), nil) + err = c.AsyncWrite([]byte(status.String()), func(c gnet.Conn, err error) error { + return c.Close() + }) + if err != nil { logger.Error("Write", "message", err) }