"github.com/vapor/env"
"github.com/vapor/event"
"github.com/vapor/mining/cpuminer"
- "github.com/vapor/mining/miningpool"
- "github.com/vapor/mining/tensority"
"github.com/vapor/net/websocket"
"github.com/vapor/netsync"
- "github.com/vapor/p2p"
"github.com/vapor/protocol"
w "github.com/vapor/wallet"
)
chain *protocol.Chain
txfeed *txfeed.Tracker
cpuMiner *cpuminer.CPUMiner
- miningPool *miningpool.MiningPool
miningEnable bool
}
dispatcher := event.NewDispatcher()
txPool := protocol.NewTxPool(store, dispatcher)
- chain, err := protocol.NewChain(store, txPool)
+ chain, err := protocol.NewChain(store, txPool, dispatcher)
if err != nil {
cmn.Exit(cmn.Fmt("Failed to create chain structure: %v", err))
}
}
node.cpuMiner = cpuminer.NewCPUMiner(chain, accounts, txPool, dispatcher)
- node.miningPool = miningpool.NewMiningPool(chain, accounts, txPool, dispatcher)
-
node.BaseService = *cmn.NewBaseService(nil, "Node", node)
-
- if config.Simd.Enable {
- tensority.UseSIMD = true
- }
-
return node
}
}
func (n *Node) initAndstartAPIServer() {
- n.api = api.NewAPI(n.syncManager, n.wallet, n.txfeed, n.cpuMiner, n.miningPool, n.chain, n.config, n.accessTokens, n.eventDispatcher, n.notificationMgr)
+ n.api = api.NewAPI(n.syncManager, n.wallet, n.txfeed, n.cpuMiner, n.chain, n.config, n.accessTokens, n.eventDispatcher, n.notificationMgr)
listenAddr := env.String("LISTEN", n.config.ApiAddress)
env.Parse()
n.Stop()
})
}
-
-func (n *Node) NodeInfo() *p2p.NodeInfo {
- return n.syncManager.NodeInfo()
-}
-
-func (n *Node) MiningPool() *miningpool.MiningPool {
- return n.miningPool
-}