Skip to content

Commit 6815a24

Browse files
committed
fix partial drain
1 parent bc016bd commit 6815a24

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

block/internal/reaping/reaper.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,10 @@ func (r *Reaper) drainMempool() (bool, error) {
170170

171171
n, err := r.submitFiltered(filtered)
172172
if err != nil {
173+
// partial drain, still submit
174+
if totalSubmitted > 0 && r.onTxsSubmitted != nil {
175+
r.onTxsSubmitted()
176+
}
173177
return totalSubmitted > 0, err
174178
}
175179
totalSubmitted += n

0 commit comments

Comments
 (0)