cmd/evm, tests: minor polishes, dump state on fail

This commit is contained in:
Péter Szilágyi 2017-09-05 11:45:33 +03:00
parent f7162201a9
commit 93f581cbc1
No known key found for this signature in database
GPG key ID: E9AE538CEDF8293D
3 changed files with 50 additions and 51 deletions

View file

@ -23,6 +23,7 @@ import (
"io/ioutil" "io/ioutil"
"os" "os"
"github.com/ethereum/go-ethereum/core/state"
"github.com/ethereum/go-ethereum/core/vm" "github.com/ethereum/go-ethereum/core/vm"
"github.com/ethereum/go-ethereum/log" "github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/tests" "github.com/ethereum/go-ethereum/tests"
@ -38,84 +39,81 @@ var stateTestCommand = cli.Command{
} }
type StatetestResult struct { type StatetestResult struct {
Name string `json:"name"` Name string `json:"name"`
Pass bool `json:"pass"` Pass bool `json:"pass"`
Fork string `json:"fork"` Fork string `json:"fork"`
Error string `json:"error,omitempty"` Error string `json:"error,omitempty"`
State *state.Dump `json:"state,omitempty"`
} }
func stateTestCmd(ctx *cli.Context) error { func stateTestCmd(ctx *cli.Context) error {
if len(ctx.Args().First()) == 0 {
return errors.New("path-to-test argument required")
}
// Configure the go-ethereum logger
glogger := log.NewGlogHandler(log.StreamHandler(os.Stderr, log.TerminalFormat(false))) glogger := log.NewGlogHandler(log.StreamHandler(os.Stderr, log.TerminalFormat(false)))
glogger.Verbosity(log.Lvl(ctx.GlobalInt(VerbosityFlag.Name))) glogger.Verbosity(log.Lvl(ctx.GlobalInt(VerbosityFlag.Name)))
log.Root().SetHandler(glogger) log.Root().SetHandler(glogger)
logconfig := &vm.LogConfig{
// Configure the EVM logger
config := &vm.LogConfig{
DisableMemory: ctx.GlobalBool(DisableMemoryFlag.Name), DisableMemory: ctx.GlobalBool(DisableMemoryFlag.Name),
DisableStack: ctx.GlobalBool(DisableStackFlag.Name), DisableStack: ctx.GlobalBool(DisableStackFlag.Name),
} }
var ( var (
tracer vm.Tracer tracer vm.Tracer
debugLogger *vm.StructLogger debugger *vm.StructLogger
// statedb *state.StateDB
// chainConfig *params.ChainConfig
) )
if ctx.GlobalBool(MachineFlag.Name) { switch {
tracer = NewJSONLogger(logconfig, os.Stderr) case ctx.GlobalBool(MachineFlag.Name):
} else if ctx.GlobalBool(DebugFlag.Name) { tracer = NewJSONLogger(config, os.Stderr)
debugLogger = vm.NewStructLogger(logconfig)
tracer = debugLogger
} else {
debugLogger = vm.NewStructLogger(logconfig)
}
if len(ctx.Args().First()) == 0 { case ctx.GlobalBool(DebugFlag.Name):
return errors.New("filename required") debugger = vm.NewStructLogger(config)
} tracer = debugger
fn := ctx.Args().First() default:
src, err := ioutil.ReadFile(fn) debugger = vm.NewStructLogger(config)
}
// Load the test content from the input file
src, err := ioutil.ReadFile(ctx.Args().First())
if err != nil { if err != nil {
return err return err
} }
var tests map[string]tests.StateTest var tests map[string]tests.StateTest
if err = json.Unmarshal(src, &tests); err != nil { if err = json.Unmarshal(src, &tests); err != nil {
return err return err
} }
// Iterate over all the tests, run them and aggregate the results
var results = make([]StatetestResult, 0, len(tests))
cfg := vm.Config{ cfg := vm.Config{
Tracer: tracer, Tracer: tracer,
Debug: ctx.GlobalBool(DebugFlag.Name) || ctx.GlobalBool(MachineFlag.Name), Debug: ctx.GlobalBool(DebugFlag.Name) || ctx.GlobalBool(MachineFlag.Name),
} }
results := make([]StatetestResult, 0, len(tests))
for key, test := range tests { for key, test := range tests {
for _, st := range test.Subtests() { for _, st := range test.Subtests() {
result := &StatetestResult{ // Run the test and aggregate the result
Name: key, result := &StatetestResult{Name: key, Fork: st.Fork, Pass: true}
Fork: st.Fork, if state, err := test.Run(st, cfg); err != nil {
Pass: true, // Test failed, mark as so and dump any state to aid debugging
} result.Pass, result.Error = false, err.Error()
if ctx.GlobalBool(DumpFlag.Name) && state != nil {
if err = test.Run(st, cfg); err != nil { dump := state.RawDump()
result.Error = err.Error() result.State = &dump
result.Pass = false }
} }
results = append(results, *result) results = append(results, *result)
// Print any structured logs collected
if ctx.GlobalBool(DebugFlag.Name) { if ctx.GlobalBool(DebugFlag.Name) {
if debugLogger != nil { if debugger != nil {
fmt.Fprintln(os.Stderr, "#### TRACE ####") fmt.Fprintln(os.Stderr, "#### TRACE ####")
vm.WriteTrace(os.Stderr, debugLogger.StructLogs()) vm.WriteTrace(os.Stderr, debugger.StructLogs())
} }
} }
} }
} }
json.NewEncoder(os.Stdout).Encode(results) out, _ := json.MarshalIndent(results, "", " ")
fmt.Println(string(out))
if err != nil {
return err
}
return nil return nil
} }

View file

@ -50,7 +50,8 @@ func TestState(t *testing.T) {
t.Skip("constantinople not supported yet") t.Skip("constantinople not supported yet")
} }
withTrace(t, test.gasLimit(subtest), func(vmconfig vm.Config) error { withTrace(t, test.gasLimit(subtest), func(vmconfig vm.Config) error {
return st.checkFailure(t, name, test.Run(subtest, vmconfig)) _, err := test.Run(subtest, vmconfig)
return st.checkFailure(t, name, err)
}) })
}) })
} }

View file

@ -120,10 +120,10 @@ func (t *StateTest) Subtests() []StateSubtest {
} }
// Run executes a specific subtest. // Run executes a specific subtest.
func (t *StateTest) Run(subtest StateSubtest, vmconfig vm.Config) error { func (t *StateTest) Run(subtest StateSubtest, vmconfig vm.Config) (*state.StateDB, error) {
config, ok := Forks[subtest.Fork] config, ok := Forks[subtest.Fork]
if !ok { if !ok {
return UnsupportedForkError{subtest.Fork} return nil, UnsupportedForkError{subtest.Fork}
} }
block, _ := t.genesis(config).ToBlock() block, _ := t.genesis(config).ToBlock()
db, _ := ethdb.NewMemDatabase() db, _ := ethdb.NewMemDatabase()
@ -132,7 +132,7 @@ func (t *StateTest) Run(subtest StateSubtest, vmconfig vm.Config) error {
post := t.json.Post[subtest.Fork][subtest.Index] post := t.json.Post[subtest.Fork][subtest.Index]
msg, err := t.json.Tx.toMessage(post) msg, err := t.json.Tx.toMessage(post)
if err != nil { if err != nil {
return err return nil, err
} }
context := core.NewEVMContext(msg, block.Header(), nil, &t.json.Env.Coinbase) context := core.NewEVMContext(msg, block.Header(), nil, &t.json.Env.Coinbase)
context.GetHash = vmTestBlockHash context.GetHash = vmTestBlockHash
@ -145,13 +145,13 @@ func (t *StateTest) Run(subtest StateSubtest, vmconfig vm.Config) error {
statedb.RevertToSnapshot(snapshot) statedb.RevertToSnapshot(snapshot)
} }
if logs := rlpHash(statedb.Logs()); logs != common.Hash(post.Logs) { if logs := rlpHash(statedb.Logs()); logs != common.Hash(post.Logs) {
return fmt.Errorf("post state logs hash mismatch: got %x, want %x", logs, post.Logs) return statedb, fmt.Errorf("post state logs hash mismatch: got %x, want %x", logs, post.Logs)
} }
root, _ := statedb.CommitTo(db, config.IsEIP158(block.Number())) root, _ := statedb.CommitTo(db, config.IsEIP158(block.Number()))
if root != common.Hash(post.Root) { if root != common.Hash(post.Root) {
return fmt.Errorf("post state root mismatch: got %x, want %x", root, post.Root) return statedb, fmt.Errorf("post state root mismatch: got %x, want %x", root, post.Root)
} }
return nil return statedb, nil
} }
func (t *StateTest) gasLimit(subtest StateSubtest) uint64 { func (t *StateTest) gasLimit(subtest StateSubtest) uint64 {