aboutsummaryrefslogtreecommitdiff
path: root/plugin
diff options
context:
space:
mode:
authorAaron Buchwald <[email protected]>2020-09-17 14:37:10 -0400
committerAaron Buchwald <[email protected]>2020-09-17 14:37:10 -0400
commitb0a75c03303fe22f31fe1e1f0fa29a1e1cd78253 (patch)
tree22c32abfd7dea90926100d4b85efda961d95ef14 /plugin
parent1a17fcec0e23aba017e3641c708e40e79be8e153 (diff)
Defer wg Done call instead of calling before returnv0.3.0-rc.4v0.3.0-rc.2
Diffstat (limited to 'plugin')
-rw-r--r--plugin/evm/vm.go4
1 files changed, 2 insertions, 2 deletions
diff --git a/plugin/evm/vm.go b/plugin/evm/vm.go
index 92e51e6..c02b835 100644
--- a/plugin/evm/vm.go
+++ b/plugin/evm/vm.go
@@ -730,6 +730,7 @@ func (vm *VM) writeBackMetadata() {
// expected block hash
// Waits for signal to shutdown from txPoolStabilizedShutdownChan chan
func (vm *VM) awaitTxPoolStabilized() {
+ defer vm.shutdownWg.Done()
for {
select {
case e := <-vm.newTxPoolHeadChan.Chan():
@@ -744,13 +745,13 @@ func (vm *VM) awaitTxPoolStabilized() {
default:
}
case <-vm.txPoolStabilizedShutdownChan:
- vm.shutdownWg.Done()
return
}
}
}
func (vm *VM) awaitSubmittedTxs() {
+ defer vm.shutdownWg.Done()
vm.txSubmitChan = vm.chain.GetTxSubmitCh()
for {
select {
@@ -763,7 +764,6 @@ func (vm *VM) awaitSubmittedTxs() {
case <-time.After(5 * time.Second):
vm.tryBlockGen()
case <-vm.shutdownSubmitChan:
- vm.shutdownWg.Done()
return
}
}