Call initial closure with proper tx argument

This commit is contained in:
obscuren 2014-04-23 15:53:53 +02:00
parent ef7f3f36e2
commit c81804444f
3 changed files with 5 additions and 33 deletions

View File

@ -46,6 +46,7 @@ func (bc *BlockChain) NewBlock(coinbase []byte, txs []*Transaction) *Block {
hash = bc.LastBlockHash hash = bc.LastBlockHash
lastBlockTime = bc.CurrentBlock.Time lastBlockTime = bc.CurrentBlock.Time
} }
block := CreateBlock( block := CreateBlock(
root, root,
hash, hash,

View File

@ -133,37 +133,6 @@ func (sm *StateManager) ApplyTransactions(block *Block, txs []*Transaction) {
} }
} }
} }
// Process each transaction/contract
for _, tx := range txs {
// If there's no recipient, it's a contract
// Check if this is a contract creation traction and if so
// create a contract of this tx.
if tx.IsContract() {
contract := sm.MakeContract(tx)
if contract != nil {
sm.EvalScript(contract.Init(), contract, tx, block)
} else {
ethutil.Config.Log.Infoln("[STATE] Unable to create contract")
}
} else {
// Figure out if the address this transaction was sent to is a
// contract or an actual account. In case of a contract, we process that
// contract instead of moving funds between accounts.
var err error
if contract := sm.procState.GetContract(tx.Recipient); contract != nil {
err = sm.Ethereum.TxPool().ProcessTransaction(tx, block, true)
if err == nil {
sm.EvalScript(contract.Script(), contract, tx, block)
}
} else {
err = sm.Ethereum.TxPool().ProcessTransaction(tx, block, false)
}
if err != nil {
ethutil.Config.Log.Infoln("[STATE]", err)
}
}
}
} }
// The prepare function, prepares the state manager for the next // The prepare function, prepares the state manager for the next
@ -359,7 +328,7 @@ func (sm *StateManager) EvalScript(script []byte, object *StateObject, tx *Trans
Diff: block.Difficulty, Diff: block.Difficulty,
//Price: tx.GasPrice, //Price: tx.GasPrice,
}) })
closure.Call(vm, nil, nil) closure.Call(vm, tx.Data, nil)
// Update the account (refunds) // Update the account (refunds)
sm.procState.UpdateStateObject(caller) sm.procState.UpdateStateObject(caller)

View File

@ -53,11 +53,12 @@ var isRequireError = false
func (vm *Vm) RunClosure(closure *Closure, hook DebugHook) (ret []byte, err error) { func (vm *Vm) RunClosure(closure *Closure, hook DebugHook) (ret []byte, err error) {
// Recover from any require exception // Recover from any require exception
defer func() { defer func() {
if r := recover(); r != nil && isRequireError { if r := recover(); r != nil /*&& isRequireError*/ {
fmt.Println(r) fmt.Println(r)
ret = closure.Return(nil) ret = closure.Return(nil)
err = fmt.Errorf("%v", r) err = fmt.Errorf("%v", r)
fmt.Println("vm err", err)
} }
}() }()
@ -315,6 +316,7 @@ func (vm *Vm) RunClosure(closure *Closure, hook DebugHook) (ret []byte, err erro
case oCALLDATALOAD: case oCALLDATALOAD:
require(1) require(1)
offset := stack.Pop().Int64() offset := stack.Pop().Int64()
fmt.Println(closure.Args)
val := closure.Args[offset : offset+31] val := closure.Args[offset : offset+31]
stack.Push(ethutil.BigD(val)) stack.Push(ethutil.BigD(val))