From 7212dbd90f4cb8fe907617f804c8940db1ce657e Mon Sep 17 00:00:00 2001 From: Determinant Date: Mon, 21 Oct 2019 16:07:47 -0400 Subject: fix the pool reset bug --- examples/counter/main.go | 13 +++++-------- examples/payments/main.go | 5 +---- 2 files changed, 6 insertions(+), 12 deletions(-) (limited to 'examples') diff --git a/examples/counter/main.go b/examples/counter/main.go index 5ec83fc..e802a33 100644 --- a/examples/counter/main.go +++ b/examples/counter/main.go @@ -141,14 +141,11 @@ func main() { header.Extra = append(header.Extra, hid...) }) chain.SetOnSealFinish(func(block *types.Block) error { - go func() { - // generate 15 blocks - blockCount++ - if postGen(block) { - return - } - chain.GenBlock() - }() + blockCount++ + if postGen(block) { + return nil + } + chain.GenBlock() return nil }) diff --git a/examples/payments/main.go b/examples/payments/main.go index 5a56028..1eab70b 100644 --- a/examples/payments/main.go +++ b/examples/payments/main.go @@ -84,9 +84,7 @@ func main() { }) newBlockChan := make(chan *types.Block) chain.SetOnSealFinish(func(block *types.Block) error { - go func() { - newBlockChan <- block - }() + newBlockChan <- block return nil }) @@ -96,7 +94,6 @@ func main() { tx := types.NewTransaction(nonce, bob.Address, value, uint64(gasLimit), gasPrice, nil) signedTx, err := types.SignTx(tx, types.NewEIP155Signer(chainID), genKey.PrivateKey) checkError(err) - _ = signedTx chain.AddRemoteTxs([]*types.Transaction{signedTx}) nonce++ chain.GenBlock() -- cgit v1.2.3-70-g09d2