Remove bad connections to avoid spamming errors

g3force · g3force · commit f673e082cf7a · 2025-04-08T07:46:17.000+02:00
diff --git a/pkg/sslnet/udp_client.go b/pkg/sslnet/udp_client.go
@@ -65,9 +65,11 @@ func (c *UdpClient) Stop() {
 func (c *UdpClient) Send(data []byte) {
 	c.mutex.Lock()
 	defer c.mutex.Unlock()
-	for _, conn := range c.conns {
+	for i, conn := range c.conns {
 		if _, err := conn.Write(data); err != nil {
 			log.Printf("%v - Could not write to %s at %s: %s", c.Name, conn.RemoteAddr(), conn.LocalAddr(), err)
+			// Remove this connection
+			c.conns = append(c.conns[:i], c.conns[i+1:]...)
 		}
 	}
 }

Original file line number	Diff line number	Diff line change
`@@ -65,9 +65,11 @@ func (c *UdpClient) Stop() {`
`65`	`65`	`func (c *UdpClient) Send(data []byte) {`
`66`	`66`	`c.mutex.Lock()`
`67`	`67`	`defer c.mutex.Unlock()`
`68`		`- for _, conn := range c.conns {`
	`68`	`+ for i, conn := range c.conns {`
`69`	`69`	`if _, err := conn.Write(data); err != nil {`
`70`	`70`	`log.Printf("%v - Could not write to %s at %s: %s", c.Name, conn.RemoteAddr(), conn.LocalAddr(), err)`
	`71`	`+ // Remove this connection`
	`72`	`+ c.conns = append(c.conns[:i], c.conns[i+1:]...)`
`71`	`73`	`}`
`72`	`74`	`}`
`73`	`75`	`}`