globuzma/mentalaradio
1
0
Fork 1
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Fix: crashing when broken pipe (listeners + metadata)

Browse source
This commit is contained in:
zuma 2025-03-12 21:24:13 +01:00
parent 560ea833b1
commit 1b1f272a5d
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
server.go
View file

@ -315,11 +315,11 @@ func main() {
finalData, err := json.Marshal(data) finalData, err := json.Marshal(data)
if err != nil { if err != nil {
log.Fatal(err) log.Print(err)
} }
if _, err := fmt.Fprintf(w, "data: %s\n\n", fmt.Sprintf("%s", finalData)); err != nil { if _, err := fmt.Fprintf(w, "data: %s\n\n", fmt.Sprintf("%s", finalData)); err != nil {
metadataConnPool.DeleteConnection(connection) log.Printf("Error on metadata stream : %s", err)
log.Printf("%s's connection to the metadata stream has been closed\n", r.Host)
return return
} }
w.(http.Flusher).Flush() w.(http.Flusher).Flush()
@ -354,7 +354,7 @@ func main() {
_, err := w.Write([]byte(fmt.Sprintf("data: %d\n\n", connection.numberSent))) _, err := w.Write([]byte(fmt.Sprintf("data: %d\n\n", connection.numberSent)))
if err != nil { if err != nil {
log.Fatal(err) log.Printf("Error on listeners stream : %s", err)
return return
} }
} }