We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a73aad6 commit 734d17fCopy full SHA for 734d17f
core/remote_state_verifier.go
@@ -121,6 +121,10 @@ func (vm *remoteVerifyManager) mainLoop() {
121
case <-pruneTicker.C:
122
vm.taskLock.Lock()
123
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 {
130
delete(vm.tasks, hash)
@@ -136,7 +140,6 @@ func (vm *remoteVerifyManager) mainLoop() {
136
140
vt.messageCh <- message
137
141
}
138
142
vm.taskLock.RUnlock()
139
-
143
// System stopped
144
case <-vm.bc.quit:
145
vm.taskLock.RLock()
0 commit comments