Method Process

core/state_processor.go:68–107

Process processes the state changes according to the Cpchain rules by running the transaction messages using the pubStateDB and applying any rewards to both the processor (coinbase) and any included uncles. Process returns the public receipts, private receipts(if have) and logs accumulated during t

(block *types.Block, statedb *state.StateDB, statePrivDB *state.StateDB,
	remoteDB database.RemoteDatabase, cfg vm.Config)

// returns the amount of gas that was used in the process. If any of the
// transactions failed to execute due to insufficient gas it will return an error.
func (p *StateProcessor) Process(block *types.Block, statedb *state.StateDB, statePrivDB *state.StateDB,
	remoteDB database.RemoteDatabase, cfg vm.Config) (types.Receipts, types.Receipts, []*types.Log, uint64, error) {
	var (
		pubReceipts  types.Receipts
		privReceipts types.Receipts
		usedGas      = new(uint64)
		header       = block.Header()
		allLogs      []*types.Log
		gp           = new(GasPool).AddGas(block.GasLimit())

		author = (*common.Address)(nil)
	)

	beneficiary, err := p.bc.Engine().Author(header)
	if err == nil {
		author = &beneficiary
	}

	// Iterate over and process the individual transactions
	for i, tx := range block.Transactions() {
		statedb.Prepare(tx.Hash(), block.Hash(), i)
		statePrivDB.Prepare(tx.Hash(), block.Hash(), i)
		pubReceipt, privReceipt, _, err := ApplyTransaction(p.config, p.bc, author, gp, statedb, statePrivDB, remoteDB, header, tx,
			usedGas, cfg, p.accm)
		if err != nil {
			return nil, nil, nil, 0, err
		}
		pubReceipts = append(pubReceipts, pubReceipt)
		if privReceipt != nil {
			privReceipts = append(privReceipts, privReceipt)
		}
		allLogs = append(allLogs, pubReceipt.Logs...) // not include private receipt's logs.
		// TODO: if need to add private receipt's logs to allLogs variable.
	}
	// Finalize the block, applying any consensus engine specific extras (e.g. block rewards)
	p.engine.Finalize(p.bc, header, statedb, block.Transactions(), []*types.Header{}, pubReceipts)

	// TODO: if return private logs separately or merge them together as a whole logs collection?
	return pubReceipts, privReceipts, allLogs, *usedGas, nil
}

// ApplyTransaction attempts to apply a transaction to the given state database
// and uses the input parameters for its environment. It returns the receipt