Method CommitStateDB

core/blockchain.go:798–838

()

}

func (bc *BlockChain) CommitStateDB() {
	// Ensure the state of a recent block is also stored to disk.
	// We're writing three different states to catch different restart scenarios:
	//  - HEAD:     So we don't need to reprocess any blocks in the general case
	//  - HEAD-1:   So we don't do large reorgs if our HEAD becomes an uncle
	//  - HEAD-127: So we have a hard limit on the number of blocks reexecuted
	if !bc.cacheConfig.Disabled {
		triedb := bc.stateCache.TrieDB()
		privTrieDB := bc.privateStateCache.TrieDB()

		for _, offset := range []uint64{0, 1, triesInMemory - 1} {
			if number := bc.CurrentBlock().NumberU64(); number > offset {
				recent := bc.GetBlockByNumber(number - offset)

				log.Debug("Writing cached state to disk", "block", recent.Number(), "hash", recent.Hash().Hex(), "root", recent.StateRoot())
				if err := triedb.Commit(recent.StateRoot(), true); err != nil {
					log.Error("Failed to commit recent state trie", "err", err)
				}

				if bc.syncMode == syncer.FullSync {
					log.Debug("Writing private cached state to disk", "block", recent.Number(), "hash", recent.Hash().Hex(), "root", recent.StateRoot())
					if err := privTrieDB.Commit(GetPrivateStateRoot(bc.db, recent.StateRoot()), true); err != nil {
						log.Error("Failed to commit recent private state trie", "err", err)
					}
				}

			}
		}
		for !bc.triegc.Empty() {
			triedb.Dereference(bc.triegc.PopItem().(common.Hash))
			// TODO: process GC on privTrieDB
		}
		if size, _ := triedb.Size(); size != 0 {
			log.Error("Dangling trie nodes after full cleanup")
		}

		if size, _ := privTrieDB.Size(); size != 0 {
			log.Error("Dangling trie nodes(private statedb) after full cleanup")
		}
	}
}

func (bc *BlockChain) procFutureBlocks() {
	blocks := make([]*types.Block, 0, bc.futureBlocks.Len())