From 6a9df50ebb7418de8a512ceadf7733e411d9fe58 Mon Sep 17 00:00:00 2001 From: blockchaindevsh <100516036+blockchaindevsh@users.noreply.github.com> Date: Fri, 18 Mar 2022 11:11:50 +0800 Subject: [PATCH] disable bootnode in stress test (#54) Co-authored-by: blockchaindevsh --- consensus/tendermint/tendermint.go | 1 + miner/stress/tendermint/main.go | 13 +++++++++++++ 2 files changed, 14 insertions(+) diff --git a/consensus/tendermint/tendermint.go b/consensus/tendermint/tendermint.go index d7472e1e18db..b8666e1e7c64 100644 --- a/consensus/tendermint/tendermint.go +++ b/consensus/tendermint/tendermint.go @@ -116,6 +116,7 @@ func (c *Tendermint) Authorize(signer common.Address, signFn SignerFn) { c.lock.Lock() defer c.lock.Unlock() + log.Info("Authorize", "signer", signer) c.privVal = NewEthPrivValidator(signer, signFn) } diff --git a/miner/stress/tendermint/main.go b/miner/stress/tendermint/main.go index a4983ac50e19..58f2683a5c76 100644 --- a/miner/stress/tendermint/main.go +++ b/miner/stress/tendermint/main.go @@ -62,9 +62,12 @@ func main() { for i := 0; i < len(sealers); i++ { sealers[i], _ = crypto.GenerateKey() } + // Create a Clique network based off of the Rinkeby config genesis := makeGenesis(faucets, sealers) + log.Warn("genesis", "NextValidators", genesis.NextValidators) + // Handle interrupts. interruptCh := make(chan os.Signal, 5) signal.Notify(interruptCh, os.Interrupt) @@ -119,6 +122,15 @@ func main() { // Connect libp2p tm := node.Engine().(*tendermint.Tendermint) for { + select { + case <-interruptCh: + for _, node := range stacks { + node.Close() + } + return + default: + } + if tm.P2pServer() == nil { log.Info("P2pServer nil") time.Sleep(250 * time.Millisecond) @@ -222,6 +234,7 @@ func makeGenesis(faucets []*ecdsa.PrivateKey, sealers []*ecdsa.PrivateKey) *core genesis := core.DefaultWeb3QGalileoGenesisBlock() genesis.GasLimit = 25000000 genesis.Config.Tendermint.P2pPort = 0 + genesis.Config.Tendermint.P2pBootstrap = "" genesis.Alloc = core.GenesisAlloc{} for _, faucet := range faucets {