in Stable-Diffusion-UI-Agones/agones-sidecar/main.go [336:356]
func udpReadWriteLoop(conn net.PacketConn, cancel context.CancelFunc, s *sdk.SDK) {
b := make([]byte, 1024)
for {
sender, txt := readPacket(conn, b)
log.Printf("Received UDP: %v", txt)
response, addACK, err := handleResponse(txt, s, cancel)
if err != nil {
response = "ERROR: " + response + "\n"
} else if addACK {
response = "ACK: " + response + "\n"
}
udpRespond(conn, sender, response)
if txt == "EXIT" {
exit(s)
}
}
}