|
|
@ -45,6 +45,7 @@ import ( |
|
|
|
"github.com/ethereum/go-ethereum/node" |
|
|
|
"github.com/ethereum/go-ethereum/node" |
|
|
|
"github.com/ethereum/go-ethereum/p2p" |
|
|
|
"github.com/ethereum/go-ethereum/p2p" |
|
|
|
"github.com/ethereum/go-ethereum/params" |
|
|
|
"github.com/ethereum/go-ethereum/params" |
|
|
|
|
|
|
|
"github.com/ethereum/go-ethereum/pow" |
|
|
|
"github.com/ethereum/go-ethereum/rpc" |
|
|
|
"github.com/ethereum/go-ethereum/rpc" |
|
|
|
) |
|
|
|
) |
|
|
|
|
|
|
|
|
|
|
@ -79,6 +80,7 @@ type Config struct { |
|
|
|
NatSpec bool |
|
|
|
NatSpec bool |
|
|
|
DocRoot string |
|
|
|
DocRoot string |
|
|
|
AutoDAG bool |
|
|
|
AutoDAG bool |
|
|
|
|
|
|
|
PowFake bool |
|
|
|
PowTest bool |
|
|
|
PowTest bool |
|
|
|
PowShared bool |
|
|
|
PowShared bool |
|
|
|
ExtraData []byte |
|
|
|
ExtraData []byte |
|
|
@ -125,7 +127,7 @@ type Ethereum struct { |
|
|
|
chainDb ethdb.Database // Block chain database
|
|
|
|
chainDb ethdb.Database // Block chain database
|
|
|
|
|
|
|
|
|
|
|
|
eventMux *event.TypeMux |
|
|
|
eventMux *event.TypeMux |
|
|
|
pow *ethash.Ethash |
|
|
|
pow pow.PoW |
|
|
|
accountManager *accounts.Manager |
|
|
|
accountManager *accounts.Manager |
|
|
|
|
|
|
|
|
|
|
|
ApiBackend *EthApiBackend |
|
|
|
ApiBackend *EthApiBackend |
|
|
@ -139,7 +141,6 @@ type Ethereum struct { |
|
|
|
solcPath string |
|
|
|
solcPath string |
|
|
|
|
|
|
|
|
|
|
|
NatSpec bool |
|
|
|
NatSpec bool |
|
|
|
PowTest bool |
|
|
|
|
|
|
|
netVersionId int |
|
|
|
netVersionId int |
|
|
|
netRPCService *ethapi.PublicNetAPI |
|
|
|
netRPCService *ethapi.PublicNetAPI |
|
|
|
} |
|
|
|
} |
|
|
@ -174,7 +175,6 @@ func New(ctx *node.ServiceContext, config *Config) (*Ethereum, error) { |
|
|
|
stopDbUpgrade: stopDbUpgrade, |
|
|
|
stopDbUpgrade: stopDbUpgrade, |
|
|
|
netVersionId: config.NetworkId, |
|
|
|
netVersionId: config.NetworkId, |
|
|
|
NatSpec: config.NatSpec, |
|
|
|
NatSpec: config.NatSpec, |
|
|
|
PowTest: config.PowTest, |
|
|
|
|
|
|
|
etherbase: config.Etherbase, |
|
|
|
etherbase: config.Etherbase, |
|
|
|
MinerThreads: config.MinerThreads, |
|
|
|
MinerThreads: config.MinerThreads, |
|
|
|
AutoDAG: config.AutoDAG, |
|
|
|
AutoDAG: config.AutoDAG, |
|
|
@ -293,15 +293,17 @@ func SetupGenesisBlock(chainDb *ethdb.Database, config *Config) error { |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// CreatePoW creates the required type of PoW instance for an Ethereum service
|
|
|
|
// CreatePoW creates the required type of PoW instance for an Ethereum service
|
|
|
|
func CreatePoW(config *Config) (*ethash.Ethash, error) { |
|
|
|
func CreatePoW(config *Config) (pow.PoW, error) { |
|
|
|
switch { |
|
|
|
switch { |
|
|
|
|
|
|
|
case config.PowFake: |
|
|
|
|
|
|
|
glog.V(logger.Info).Infof("ethash used in fake mode") |
|
|
|
|
|
|
|
return pow.PoW(core.FakePow{}), nil |
|
|
|
case config.PowTest: |
|
|
|
case config.PowTest: |
|
|
|
glog.V(logger.Info).Infof("ethash used in test mode") |
|
|
|
glog.V(logger.Info).Infof("ethash used in test mode") |
|
|
|
return ethash.NewForTesting() |
|
|
|
return ethash.NewForTesting() |
|
|
|
case config.PowShared: |
|
|
|
case config.PowShared: |
|
|
|
glog.V(logger.Info).Infof("ethash used in shared mode") |
|
|
|
glog.V(logger.Info).Infof("ethash used in shared mode") |
|
|
|
return ethash.NewShared(), nil |
|
|
|
return ethash.NewShared(), nil |
|
|
|
|
|
|
|
|
|
|
|
default: |
|
|
|
default: |
|
|
|
return ethash.New(), nil |
|
|
|
return ethash.New(), nil |
|
|
|
} |
|
|
|
} |
|
|
@ -399,7 +401,7 @@ func (s *Ethereum) AccountManager() *accounts.Manager { return s.accountManager |
|
|
|
func (s *Ethereum) BlockChain() *core.BlockChain { return s.blockchain } |
|
|
|
func (s *Ethereum) BlockChain() *core.BlockChain { return s.blockchain } |
|
|
|
func (s *Ethereum) TxPool() *core.TxPool { return s.txPool } |
|
|
|
func (s *Ethereum) TxPool() *core.TxPool { return s.txPool } |
|
|
|
func (s *Ethereum) EventMux() *event.TypeMux { return s.eventMux } |
|
|
|
func (s *Ethereum) EventMux() *event.TypeMux { return s.eventMux } |
|
|
|
func (s *Ethereum) Pow() *ethash.Ethash { return s.pow } |
|
|
|
func (s *Ethereum) Pow() pow.PoW { return s.pow } |
|
|
|
func (s *Ethereum) ChainDb() ethdb.Database { return s.chainDb } |
|
|
|
func (s *Ethereum) ChainDb() ethdb.Database { return s.chainDb } |
|
|
|
func (s *Ethereum) IsListening() bool { return true } // Always listening
|
|
|
|
func (s *Ethereum) IsListening() bool { return true } // Always listening
|
|
|
|
func (s *Ethereum) EthVersion() int { return int(s.protocolManager.SubProtocols[0].Version) } |
|
|
|
func (s *Ethereum) EthVersion() int { return int(s.protocolManager.SubProtocols[0].Version) } |
|
|
|