fix close of closed channel issue

j75689 · Apr 25, 2022 · dfff219 · dfff219
1 parent 3150755
commit dfff219
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/core/remote_state_verifier.go b/core/remote_state_verifier.go
@@ -121,12 +121,8 @@ func (vm *remoteVerifyManager) mainLoop() {
 		case <-pruneTicker.C:
 			vm.taskLock.Lock()
 			for hash, task := range vm.tasks {
-				if vm.bc.insertStopped() {
-					close(task.terminalCh)
-					continue
-				}
-				if vm.bc.CurrentHeader().Number.Cmp(task.blockHeader.Number) == 1 &&
-					vm.bc.CurrentHeader().Number.Uint64()-task.blockHeader.Number.Uint64() > pruneHeightDiff {
+				if vm.bc.insertStopped() || (vm.bc.CurrentHeader().Number.Cmp(task.blockHeader.Number) == 1 &&
+					vm.bc.CurrentHeader().Number.Uint64()-task.blockHeader.Number.Uint64() > pruneHeightDiff) {
 					delete(vm.tasks, hash)
 					verifyTaskCounter.Dec(1)
 					verifyTaskFailedMeter.Mark(1)