Enlarge pending buffer and nil it after use (#112)

eycorsican · Apr 9, 2020 · 7492950 · 7492950
1 parent ca0c721
commit 7492950
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/udp_conn.go b/core/udp_conn.go
@@ -46,7 +46,7 @@ func newUDPConn(pcb *C.struct_udp_pcb, handler UDPConnHandler, localIP C.ip_addr
 		localIP:   localIP,
 		localPort: localPort,
 		state:     udpConnecting,
-		pending:   make(chan *udpPacket, 1), // To hold the first packet on the connection
+		pending:   make(chan *udpPacket, 64), // To hold the early packets on the connection
 	}
 
 	go func() {
@@ -68,6 +68,7 @@ func newUDPConn(pcb *C.struct_udp_pcb, handler UDPConnHandler, localIP C.ip_addr
 					}
 					continue DrainPending
 				default:
+					conn.pending = nil
 					break DrainPending
 				}
 			}