Struct BlockChain

core/blockchain.go:145–208

BlockChain represents the canonical chain given a database with a genesis block. The Blockchain manages chain imports, reverts, chain reorganisations. Importing blocks in to the block chain happens according to the set of rules defined by the two stage Validator. Processing of blocks is done using

// included in the canonical one where as GetBlockByNumber always represents the
// canonical chain.
type BlockChain struct {
	chainConfig *configs.ChainConfig // Chain & network configuration
	cacheConfig *CacheConfig         // Cache configuration for pruning

	db     database.Database // Low level persistent database to store final content in
	triegc *prque.Prque      // Priority queue mapping block numbers to tries to gc
	gcproc time.Duration     // Accumulates canonical block processing for trie dumping

	hc              *HeaderChain
	rmLogsFeed      event.Feed
	chainFeed       event.Feed
	chainSideFeed   event.Feed
	chainHeadFeed   event.Feed
	chainLatestFeed event.Feed
	logsFeed        event.Feed
	scope           event.SubscriptionScope
	genesisBlock    *types.Block

	mu      sync.RWMutex // global mutex for locking chain operations
	chainmu sync.RWMutex // blockchain insertion lock
	procmu  sync.RWMutex // block processor lock

	checkpoint       int          // checkpoint counts towards the new checkpoint
	currentBlock     atomic.Value // Current head of the block chain
	currentFastBlock atomic.Value // Current head of the fast-sync chain (may be above the block chain!)

	stateCache       state.Database // State database to reuse between imports (contains state cache)
	bodyCache        *lru.Cache     // Cache for the most recent block bodies
	bodyRLPCache     *lru.Cache     // Cache for the most recent block bodies in RLP encoded format
	blockCache       *lru.Cache     // Cache for the most recent entire blocks
	futureBlocks     *lru.Cache     // future blocks are blocks added for later processing
	unknownAncestors *lru.Cache     // unknown ancestor blocks are blocks added for later processing

	Quit    chan struct{} // blockchain quit channel
	running int32         // running must be called atomically
	// procInterrupt must be atomically called
	procInterrupt int32          // interrupt signaler for block processing
	wg            sync.WaitGroup // chain processing wait group for shutting down

	engine    consensus.Engine
	processor Processor // block processor interface
	validator Validator // block and state validator interface
	vmConfig  vm.Config

	badBlocks *lru.Cache // Bad block cache
	// pendingBlocks *lru.Cache // not enough signatures block cache

	privateStateCache state.Database          // State database to reuse between imports (contains state cache)
	remoteDB          database.RemoteDatabase // Remote database for huge amount data storage

	insertChainProtectLock sync.RWMutex

	knownHeadNumber uint64      // number of known head of current chain
	knownHeadHash   common.Hash // hash of known head of current chain
	knownHeadLock   sync.RWMutex

	mux     *event.TypeMux
	srCache *statesAndReceiptsCache // state and receipt cache