aboutsummaryrefslogtreecommitdiffstats
path: root/miner/stress_clique.go
diff options
context:
space:
mode:
authorgary rong <garyrong0905@gmail.com>2018-11-07 16:55:56 +0800
committerPéter Szilágyi <peterke@gmail.com>2018-11-07 16:55:56 +0800
commite2640a96d4311e3ac48de467a6eb3c88b95dfb3e (patch)
treecadf3d6173e51e953e4e09ab0dbada0357e2df5c /miner/stress_clique.go
parent79c7a69ac8066cc28ceee2ebaab3d0221a8adf57 (diff)
downloaddexon-e2640a96d4311e3ac48de467a6eb3c88b95dfb3e.tar
dexon-e2640a96d4311e3ac48de467a6eb3c88b95dfb3e.tar.gz
dexon-e2640a96d4311e3ac48de467a6eb3c88b95dfb3e.tar.bz2
dexon-e2640a96d4311e3ac48de467a6eb3c88b95dfb3e.tar.lz
dexon-e2640a96d4311e3ac48de467a6eb3c88b95dfb3e.tar.xz
dexon-e2640a96d4311e3ac48de467a6eb3c88b95dfb3e.tar.zst
dexon-e2640a96d4311e3ac48de467a6eb3c88b95dfb3e.zip
miner: fix miner stress test (#18039)
Diffstat (limited to 'miner/stress_clique.go')
-rw-r--r--miner/stress_clique.go23
1 files changed, 8 insertions, 15 deletions
diff --git a/miner/stress_clique.go b/miner/stress_clique.go
index 8961091d5..7e19975ae 100644
--- a/miner/stress_clique.go
+++ b/miner/stress_clique.go
@@ -22,7 +22,6 @@ package main
import (
"bytes"
"crypto/ecdsa"
- "fmt"
"io/ioutil"
"math/big"
"math/rand"
@@ -40,7 +39,7 @@ import (
"github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/node"
"github.com/ethereum/go-ethereum/p2p"
- "github.com/ethereum/go-ethereum/p2p/discover"
+ "github.com/ethereum/go-ethereum/p2p/enode"
"github.com/ethereum/go-ethereum/params"
)
@@ -62,11 +61,11 @@ func main() {
var (
nodes []*node.Node
- enodes []string
+ enodes []*enode.Node
)
for _, sealer := range sealers {
// Start the node and wait until it's up
- node, err := makeSealer(genesis, enodes)
+ node, err := makeSealer(genesis)
if err != nil {
panic(err)
}
@@ -76,18 +75,12 @@ func main() {
time.Sleep(250 * time.Millisecond)
}
// Connect the node to al the previous ones
- for _, enode := range enodes {
- enode, err := discover.ParseNode(enode)
- if err != nil {
- panic(err)
- }
- node.Server().AddPeer(enode)
+ for _, n := range enodes {
+ node.Server().AddPeer(n)
}
- // Start tracking the node and it's enode url
+ // Start tracking the node and it's enode
nodes = append(nodes, node)
-
- enode := fmt.Sprintf("enode://%s@127.0.0.1:%d", node.Server().NodeInfo().ID, node.Server().NodeInfo().Ports.Listener)
- enodes = append(enodes, enode)
+ enodes = append(enodes, node.Server().Self())
// Inject the signer key and start sealing with it
store := node.AccountManager().Backends(keystore.KeyStoreType)[0].(*keystore.KeyStore)
@@ -177,7 +170,7 @@ func makeGenesis(faucets []*ecdsa.PrivateKey, sealers []*ecdsa.PrivateKey) *core
return genesis
}
-func makeSealer(genesis *core.Genesis, nodes []string) (*node.Node, error) {
+func makeSealer(genesis *core.Genesis) (*node.Node, error) {
// Define the basic configurations for the Ethereum node
datadir, _ := ioutil.TempDir("", "")