mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 10:52:25 +00:00
revert cleanup: get make tests compiling
This commit is contained in:
parent
7fb3223052
commit
239012343a
1 changed files with 2 additions and 65 deletions
|
|
@ -39,8 +39,6 @@ import (
|
||||||
ethcatalyst "github.com/ethereum/go-ethereum/eth/catalyst"
|
ethcatalyst "github.com/ethereum/go-ethereum/eth/catalyst"
|
||||||
"github.com/ethereum/go-ethereum/eth/downloader"
|
"github.com/ethereum/go-ethereum/eth/downloader"
|
||||||
"github.com/ethereum/go-ethereum/eth/ethconfig"
|
"github.com/ethereum/go-ethereum/eth/ethconfig"
|
||||||
"github.com/ethereum/go-ethereum/les"
|
|
||||||
lescatalyst "github.com/ethereum/go-ethereum/les/catalyst"
|
|
||||||
"github.com/ethereum/go-ethereum/log"
|
"github.com/ethereum/go-ethereum/log"
|
||||||
"github.com/ethereum/go-ethereum/miner"
|
"github.com/ethereum/go-ethereum/miner"
|
||||||
"github.com/ethereum/go-ethereum/node"
|
"github.com/ethereum/go-ethereum/node"
|
||||||
|
|
@ -94,22 +92,19 @@ type ethNode struct {
|
||||||
enode *enode.Node
|
enode *enode.Node
|
||||||
api *ethcatalyst.ConsensusAPI
|
api *ethcatalyst.ConsensusAPI
|
||||||
ethBackend *eth.Ethereum
|
ethBackend *eth.Ethereum
|
||||||
lapi *lescatalyst.ConsensusAPI
|
|
||||||
lesBackend *les.LightEthereum
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func newNode(typ nodetype, genesis *core.Genesis, enodes []*enode.Node) *ethNode {
|
func newNode(typ nodetype, genesis *core.Genesis, enodes []*enode.Node) *ethNode {
|
||||||
var (
|
var (
|
||||||
err error
|
err error
|
||||||
api *ethcatalyst.ConsensusAPI
|
api *ethcatalyst.ConsensusAPI
|
||||||
lapi *lescatalyst.ConsensusAPI
|
|
||||||
stack *node.Node
|
stack *node.Node
|
||||||
ethBackend *eth.Ethereum
|
ethBackend *eth.Ethereum
|
||||||
lesBackend *les.LightEthereum
|
|
||||||
)
|
)
|
||||||
// Start the node and wait until it's up
|
// Start the node and wait until it's up
|
||||||
if typ == eth2LightClient {
|
if typ == eth2LightClient {
|
||||||
stack, lesBackend, lapi, err = makeLightNode(genesis)
|
//stack, lesBackend, lapi, err = makeLightNode(genesis)
|
||||||
|
panic("LES no longer supported")
|
||||||
} else {
|
} else {
|
||||||
stack, ethBackend, api, err = makeFullNode(genesis)
|
stack, ethBackend, api, err = makeFullNode(genesis)
|
||||||
}
|
}
|
||||||
|
|
@ -185,14 +180,6 @@ func (n *ethNode) insertBlock(eb engine.ExecutableData) error {
|
||||||
return errors.New("failed to insert block")
|
return errors.New("failed to insert block")
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
case eth2LightClient:
|
|
||||||
newResp, err := n.lapi.ExecutePayloadV1(eb)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
} else if newResp.Status != "VALID" {
|
|
||||||
return errors.New("failed to insert block")
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
default:
|
default:
|
||||||
return errors.New("undefined node")
|
return errors.New("undefined node")
|
||||||
}
|
}
|
||||||
|
|
@ -220,11 +207,6 @@ func (n *ethNode) insertBlockAndSetHead(parent *types.Header, ed engine.Executab
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
return nil
|
return nil
|
||||||
case eth2LightClient:
|
|
||||||
if _, err := n.lapi.ForkchoiceUpdatedV1(fcState, nil); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
return nil
|
|
||||||
default:
|
default:
|
||||||
return errors.New("undefined node")
|
return errors.New("undefined node")
|
||||||
}
|
}
|
||||||
|
|
@ -321,7 +303,6 @@ func (mgr *nodeManager) run() {
|
||||||
}
|
}
|
||||||
nodes := mgr.getNodes(eth2MiningNode)
|
nodes := mgr.getNodes(eth2MiningNode)
|
||||||
nodes = append(nodes, mgr.getNodes(eth2NormalNode)...)
|
nodes = append(nodes, mgr.getNodes(eth2NormalNode)...)
|
||||||
//nodes = append(nodes, mgr.getNodes(eth2LightClient)...)
|
|
||||||
for _, node := range nodes {
|
for _, node := range nodes {
|
||||||
fcState := engine.ForkchoiceStateV1{
|
fcState := engine.ForkchoiceStateV1{
|
||||||
HeadBlockHash: parentBlock.Hash(),
|
HeadBlockHash: parentBlock.Hash(),
|
||||||
|
|
@ -370,7 +351,6 @@ func (mgr *nodeManager) run() {
|
||||||
|
|
||||||
nodes := mgr.getNodes(eth2MiningNode)
|
nodes := mgr.getNodes(eth2MiningNode)
|
||||||
nodes = append(nodes, mgr.getNodes(eth2NormalNode)...)
|
nodes = append(nodes, mgr.getNodes(eth2NormalNode)...)
|
||||||
nodes = append(nodes, mgr.getNodes(eth2LightClient)...)
|
|
||||||
for _, node := range nodes {
|
for _, node := range nodes {
|
||||||
if err := node.insertBlockAndSetHead(parentBlock.Header(), *ed); err != nil {
|
if err := node.insertBlockAndSetHead(parentBlock.Header(), *ed); err != nil {
|
||||||
log.Error("Failed to insert block", "type", node.typ, "err", err)
|
log.Error("Failed to insert block", "type", node.typ, "err", err)
|
||||||
|
|
@ -405,7 +385,6 @@ func main() {
|
||||||
manager.createNode(eth2MiningNode)
|
manager.createNode(eth2MiningNode)
|
||||||
manager.createNode(legacyMiningNode)
|
manager.createNode(legacyMiningNode)
|
||||||
manager.createNode(legacyNormalNode)
|
manager.createNode(legacyNormalNode)
|
||||||
manager.createNode(eth2LightClient)
|
|
||||||
|
|
||||||
// Iterate over all the nodes and start mining
|
// Iterate over all the nodes and start mining
|
||||||
time.Sleep(3 * time.Second)
|
time.Sleep(3 * time.Second)
|
||||||
|
|
@ -504,52 +483,10 @@ func makeFullNode(genesis *core.Genesis) (*node.Node, *eth.Ethereum, *ethcatalys
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, nil, nil, err
|
return nil, nil, nil, err
|
||||||
}
|
}
|
||||||
_, err = les.NewLesServer(stack, ethBackend, econfig)
|
|
||||||
if err != nil {
|
|
||||||
log.Crit("Failed to create the LES server", "err", err)
|
|
||||||
}
|
|
||||||
err = stack.Start()
|
err = stack.Start()
|
||||||
return stack, ethBackend, ethcatalyst.NewConsensusAPI(ethBackend), err
|
return stack, ethBackend, ethcatalyst.NewConsensusAPI(ethBackend), err
|
||||||
}
|
}
|
||||||
|
|
||||||
func makeLightNode(genesis *core.Genesis) (*node.Node, *les.LightEthereum, *lescatalyst.ConsensusAPI, error) {
|
|
||||||
// Define the basic configurations for the Ethereum node
|
|
||||||
datadir, _ := os.MkdirTemp("", "")
|
|
||||||
|
|
||||||
config := &node.Config{
|
|
||||||
Name: "geth",
|
|
||||||
Version: params.Version,
|
|
||||||
DataDir: datadir,
|
|
||||||
P2P: p2p.Config{
|
|
||||||
ListenAddr: "0.0.0.0:0",
|
|
||||||
NoDiscovery: true,
|
|
||||||
MaxPeers: 25,
|
|
||||||
},
|
|
||||||
UseLightweightKDF: true,
|
|
||||||
}
|
|
||||||
// Create the node and configure a full Ethereum node on it
|
|
||||||
stack, err := node.New(config)
|
|
||||||
if err != nil {
|
|
||||||
return nil, nil, nil, err
|
|
||||||
}
|
|
||||||
lesBackend, err := les.New(stack, ðconfig.Config{
|
|
||||||
Genesis: genesis,
|
|
||||||
NetworkId: genesis.Config.ChainID.Uint64(),
|
|
||||||
SyncMode: downloader.LightSync,
|
|
||||||
DatabaseCache: 256,
|
|
||||||
DatabaseHandles: 256,
|
|
||||||
TxPool: txpool.DefaultConfig,
|
|
||||||
GPO: ethconfig.Defaults.GPO,
|
|
||||||
Ethash: ethconfig.Defaults.Ethash,
|
|
||||||
LightPeers: 10,
|
|
||||||
})
|
|
||||||
if err != nil {
|
|
||||||
return nil, nil, nil, err
|
|
||||||
}
|
|
||||||
err = stack.Start()
|
|
||||||
return stack, lesBackend, lescatalyst.NewConsensusAPI(lesBackend), err
|
|
||||||
}
|
|
||||||
|
|
||||||
func eth2types(typ nodetype) bool {
|
func eth2types(typ nodetype) bool {
|
||||||
if typ == eth2LightClient || typ == eth2NormalNode || typ == eth2MiningNode {
|
if typ == eth2LightClient || typ == eth2NormalNode || typ == eth2MiningNode {
|
||||||
return true
|
return true
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue