From 4dad65cbc525951072557ce149341bcf145a3980 Mon Sep 17 00:00:00 2001 From: radik878 Date: Thu, 27 Nov 2025 12:32:19 +0200 Subject: [PATCH] auto-start next conversion batch after completion if pending --- core/txpool/blobpool/conversion.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/core/txpool/blobpool/conversion.go b/core/txpool/blobpool/conversion.go index 80b97af5d7..afdc10554f 100644 --- a/core/txpool/blobpool/conversion.go +++ b/core/txpool/blobpool/conversion.go @@ -161,6 +161,12 @@ func (q *conversionQueue) loop() { case <-done: done, interrupt = nil, nil + if len(txTasks) > 0 { + done, interrupt = make(chan struct{}), new(atomic.Int32) + tasks := slices.Clone(txTasks) + txTasks = txTasks[:0] + go q.run(tasks, done, interrupt) + } case fn := <-q.startBilly: q.billyQueue = append(q.billyQueue, fn)