(ctx *cli.Context, stateHashHeight uint32)
| 250 | } |
| 251 | |
| 252 | func initLedger(ctx *cli.Context, stateHashHeight uint32) (*ledger.Ledger, error) { |
| 253 | events.Init() //Init event hub |
| 254 | |
| 255 | var err error |
| 256 | dbDir := utils.GetStoreDirPath(config.DefConfig.Common.DataDir, config.DefConfig.P2PNode.NetworkName) |
| 257 | ledger.DefLedger, err = ledger.NewLedger(dbDir, stateHashHeight) |
| 258 | if err != nil { |
| 259 | return nil, fmt.Errorf("NewLedger error: %s", err) |
| 260 | } |
| 261 | bookKeepers, err := config.DefConfig.GetBookkeepers() |
| 262 | if err != nil { |
| 263 | return nil, fmt.Errorf("GetBookkeepers error: %s", err) |
| 264 | } |
| 265 | genesisConfig := config.DefConfig.Genesis |
| 266 | genesisBlock, err := genesis.BuildGenesisBlock(bookKeepers, genesisConfig) |
| 267 | if err != nil { |
| 268 | return nil, fmt.Errorf("genesisBlock error %s", err) |
| 269 | } |
| 270 | err = ledger.DefLedger.Init(bookKeepers, genesisBlock) |
| 271 | if err != nil { |
| 272 | return nil, fmt.Errorf("Init ledger error: %s", err) |
| 273 | } |
| 274 | |
| 275 | log.Infof("Ledger init success") |
| 276 | return ledger.DefLedger, nil |
| 277 | } |
| 278 | |
| 279 | func initTxPool(ctx *cli.Context) (*proc.TXPoolServer, error) { |
| 280 | disablePreExec := ctx.GlobalBool(utils.GetFlagName(utils.TxpoolPreExecDisableFlag)) |
no test coverage detected