From 1b1f272a5df4b184554e761ba4a395479cdfc3f0 Mon Sep 17 00:00:00 2001 From: zuma Date: Wed, 12 Mar 2025 21:24:13 +0100 Subject: [PATCH] Fix: crashing when broken pipe (listeners + metadata) --- server.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/server.go b/server.go index ce51a20..0b6f85c 100644 --- a/server.go +++ b/server.go @@ -315,11 +315,11 @@ func main() { finalData, err := json.Marshal(data) if err != nil { - log.Fatal(err) + log.Print(err) } + if _, err := fmt.Fprintf(w, "data: %s\n\n", fmt.Sprintf("%s", finalData)); err != nil { - metadataConnPool.DeleteConnection(connection) - log.Printf("%s's connection to the metadata stream has been closed\n", r.Host) + log.Printf("Error on metadata stream : %s", err) return } w.(http.Flusher).Flush() @@ -354,7 +354,7 @@ func main() { _, err := w.Write([]byte(fmt.Sprintf("data: %d\n\n", connection.numberSent))) if err != nil { - log.Fatal(err) + log.Printf("Error on listeners stream : %s", err) return } }