fix close of closed channel issue

j75689 · j75689 · commit dfff21934cfd · 2022-04-25T10:25:23.000+08:00
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)
