We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 906e7c8 commit 4730e13Copy full SHA for 4730e13
core/txpool/blobpool/conversion.go
@@ -183,6 +183,15 @@ func (q *conversionQueue) loop() {
183
log.Debug("Waiting for blobpool billy conversion to exit")
184
<-q.billyTaskDone
185
}
186
+ // Signal any tasks that were queued for the next batch but never started
187
+ // so callers blocked in convert() receive an error instead of hanging.
188
+ for _, t := range txTasks {
189
+ // Best-effort notify; t.done is a buffered channel of size 1
190
+ // created by convert(), and we send exactly once per task.
191
+ t.done <- errors.New("conversion queue closed")
192
+ }
193
+ // Drop references to allow GC of the backing array.
194
+ txTasks = txTasks[:0]
195
return
196
197
0 commit comments