Function NewChainWithContext

blockproducer/chain.go:107–322

NewChainWithContext creates a new blockchain with context.

(ctx context.Context, cfg *Config)

// NewChainWithContext creates a new blockchain with context.
func NewChainWithContext(ctx context.Context, cfg *Config) (c *Chain, err error) {
	var (
		ierr error

		st        xi.Storage
		cache     *lru.Cache
		lastIrre  *blockNode
		heads     []*blockNode
		immutable *metaState
		txPool    map[hash.Hash]pi.Transaction

		branches   []*branch
		headBranch *branch
		headIndex  int

		addr        proto.AccountAddress
		bpInfos     []*blockProducerInfo
		localBPInfo *blockProducerInfo
	)

	// Verify genesis block in config
	if cfg.Genesis == nil {
		err = ErrNilGenesis
		return
	}
	if ierr = cfg.Genesis.VerifyHash(); ierr != nil {
		err = errors.Wrap(ierr, "failed to verify genesis block hash")
		return
	}

	// Open storage
	var existed bool
	if fi, err := os.Stat(cfg.DataFile); err == nil && fi.Mode().IsRegular() {
		existed = true
	}
	if st, ierr = openStorage(fmt.Sprintf("file:%s", cfg.DataFile)); ierr != nil {
		err = errors.Wrap(ierr, "failed to open storage")
		return
	}
	defer func() {
		if err != nil {
			st.Close()
		}
	}()

	// Create block cache
	if cfg.BlockCacheSize > conf.MaxCachedBlock {
		cfg.BlockCacheSize = conf.MaxCachedBlock
	}
	if cfg.BlockCacheSize <= 0 {
		cfg.BlockCacheSize = 1 // Must provide a positive size
	}
	if cache, err = lru.NewWithEvict(cfg.BlockCacheSize, func(key interface{}, value interface{}) {
		if node, ok := value.(*blockNode); ok && node != nil {
			node.clear()
		}
	}); err != nil {
		return