fix: goroutine leak

minhd-vu · minhd-vu · commit 00de53875ff9 · 2026-03-03T17:33:36.000-05:00
diff --git a/p2p/conns.go b/p2p/conns.go
@@ -191,11 +191,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
`@@ -191,11 +191,14 @@ func (c *Conns) BroadcastTxHashes(hashes []common.Hash) int {`
`191`	`191`
`192`	`192`	`count := 0`
`193`	`193`	`for _, cn := range peers {`
	`194`	`+ // Non-blocking send, drop if queue full (matches Bor behavior)`
`194`	`195`	`select {`
`195`	`196`	`case cn.txAnnounce <- hashes:`
`196`	`197`	`count++`
`197`	`198`	`case <-cn.closeCh:`
`198`	`199`	`// Peer closing, skip`
	`200`	`+ default:`
	`201`	`+ // Channel full, skip to avoid goroutine leak`
`199`	`202`	`}`
`200`	`203`	`}`
`201`	`204`