Skip to content

Commit dfff219

Browse files
committed
fix close of closed channel issue
1 parent 3150755 commit dfff219

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

core/remote_state_verifier.go

+2-6
Original file line numberDiff line numberDiff line change
@@ -121,12 +121,8 @@ func (vm *remoteVerifyManager) mainLoop() {
121121
case <-pruneTicker.C:
122122
vm.taskLock.Lock()
123123
for hash, task := range vm.tasks {
124-
if vm.bc.insertStopped() {
125-
close(task.terminalCh)
126-
continue
127-
}
128-
if vm.bc.CurrentHeader().Number.Cmp(task.blockHeader.Number) == 1 &&
129-
vm.bc.CurrentHeader().Number.Uint64()-task.blockHeader.Number.Uint64() > pruneHeightDiff {
124+
if vm.bc.insertStopped() || (vm.bc.CurrentHeader().Number.Cmp(task.blockHeader.Number) == 1 &&
125+
vm.bc.CurrentHeader().Number.Uint64()-task.blockHeader.Number.Uint64() > pruneHeightDiff) {
130126
delete(vm.tasks, hash)
131127
verifyTaskCounter.Dec(1)
132128
verifyTaskFailedMeter.Mark(1)

0 commit comments

Comments
 (0)