fix: goroutine leak

minhd-vu · minhd-vu · commit 131e248265b8 · 2026-03-03T17:32:08.000-05:00
diff --git a/p2p/conns.go b/p2p/conns.go
@@ -192,11 +192,14 @@ func (c *Conns) BroadcastTxHashes(hashes []common.Hash) int {
 
 	count := 0
 	for _, cn := range peers {
+		// Non-blocking send, drop if queue full (matches Bor behavior)
 		select {
 		case cn.txAnnounce <- hashes:
 			count++
 		case <-cn.closeCh:
 			// Peer closing, skip
+		default:
+			// Channel full, skip to avoid goroutine leak
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -192,11 +192,14 @@ func (c *Conns) BroadcastTxHashes(hashes []common.Hash) int {`
`192`	`192`
`193`	`193`	`count := 0`
`194`	`194`	`for _, cn := range peers {`
	`195`	`+ // Non-blocking send, drop if queue full (matches Bor behavior)`
`195`	`196`	`select {`
`196`	`197`	`case cn.txAnnounce <- hashes:`
`197`	`198`	`count++`
`198`	`199`	`case <-cn.closeCh:`
`199`	`200`	`// Peer closing, skip`
	`201`	`+ default:`
	`202`	`+ // Channel full, skip to avoid goroutine leak`
`200`	`203`	`}`
`201`	`204`	`}`
`202`	`205`