9e5f03b6c4
With this commit, core/state's access to the underlying key/value database is mediated through an interface. Database errors are tracked in StateDB and returned by CommitTo or the new Error method. Motivation for this change: We can remove the light client's duplicated copy of core/state. The light client now supports node iteration, so tracing and storage enumeration can work with the light client (not implemented in this commit).
240 lines
6.8 KiB
Go
240 lines
6.8 KiB
Go
// Copyright 2017 The go-ethereum Authors
|
|
// This file is part of go-ethereum.
|
|
//
|
|
// go-ethereum is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
//
|
|
// go-ethereum is distributed in the hope that it will be useful,
|
|
// but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
// GNU General Public License for more details.
|
|
//
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with go-ethereum. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
package main
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/json"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"os"
|
|
"runtime/pprof"
|
|
"time"
|
|
|
|
goruntime "runtime"
|
|
|
|
"github.com/ethereum/go-ethereum/cmd/evm/internal/compiler"
|
|
"github.com/ethereum/go-ethereum/cmd/utils"
|
|
"github.com/ethereum/go-ethereum/common"
|
|
"github.com/ethereum/go-ethereum/core"
|
|
"github.com/ethereum/go-ethereum/core/state"
|
|
"github.com/ethereum/go-ethereum/core/vm"
|
|
"github.com/ethereum/go-ethereum/core/vm/runtime"
|
|
"github.com/ethereum/go-ethereum/ethdb"
|
|
"github.com/ethereum/go-ethereum/log"
|
|
"github.com/ethereum/go-ethereum/params"
|
|
cli "gopkg.in/urfave/cli.v1"
|
|
)
|
|
|
|
var runCommand = cli.Command{
|
|
Action: runCmd,
|
|
Name: "run",
|
|
Usage: "run arbitrary evm binary",
|
|
ArgsUsage: "<code>",
|
|
Description: `The run command runs arbitrary EVM code.`,
|
|
}
|
|
|
|
// readGenesis will read the given JSON format genesis file and return
|
|
// the initialized Genesis structure
|
|
func readGenesis(genesisPath string) *core.Genesis {
|
|
// Make sure we have a valid genesis JSON
|
|
//genesisPath := ctx.Args().First()
|
|
if len(genesisPath) == 0 {
|
|
utils.Fatalf("Must supply path to genesis JSON file")
|
|
}
|
|
file, err := os.Open(genesisPath)
|
|
if err != nil {
|
|
utils.Fatalf("Failed to read genesis file: %v", err)
|
|
}
|
|
defer file.Close()
|
|
|
|
genesis := new(core.Genesis)
|
|
if err := json.NewDecoder(file).Decode(genesis); err != nil {
|
|
utils.Fatalf("invalid genesis file: %v", err)
|
|
}
|
|
return genesis
|
|
}
|
|
|
|
func runCmd(ctx *cli.Context) error {
|
|
glogger := log.NewGlogHandler(log.StreamHandler(os.Stderr, log.TerminalFormat(false)))
|
|
glogger.Verbosity(log.Lvl(ctx.GlobalInt(VerbosityFlag.Name)))
|
|
log.Root().SetHandler(glogger)
|
|
logconfig := &vm.LogConfig{
|
|
DisableMemory: ctx.GlobalBool(DisableMemoryFlag.Name),
|
|
DisableStack: ctx.GlobalBool(DisableStackFlag.Name),
|
|
}
|
|
|
|
var (
|
|
tracer vm.Tracer
|
|
debugLogger *vm.StructLogger
|
|
statedb *state.StateDB
|
|
chainConfig *params.ChainConfig
|
|
sender = common.StringToAddress("sender")
|
|
)
|
|
if ctx.GlobalBool(MachineFlag.Name) {
|
|
tracer = NewJSONLogger(logconfig, os.Stdout)
|
|
} else if ctx.GlobalBool(DebugFlag.Name) {
|
|
debugLogger = vm.NewStructLogger(logconfig)
|
|
tracer = debugLogger
|
|
} else {
|
|
debugLogger = vm.NewStructLogger(logconfig)
|
|
}
|
|
if ctx.GlobalString(GenesisFlag.Name) != "" {
|
|
gen := readGenesis(ctx.GlobalString(GenesisFlag.Name))
|
|
_, statedb = gen.ToBlock()
|
|
chainConfig = gen.Config
|
|
} else {
|
|
db, _ := ethdb.NewMemDatabase()
|
|
statedb, _ = state.New(common.Hash{}, state.NewDatabase(db))
|
|
}
|
|
if ctx.GlobalString(SenderFlag.Name) != "" {
|
|
sender = common.HexToAddress(ctx.GlobalString(SenderFlag.Name))
|
|
}
|
|
|
|
statedb.CreateAccount(sender)
|
|
|
|
var (
|
|
code []byte
|
|
ret []byte
|
|
err error
|
|
)
|
|
if fn := ctx.Args().First(); len(fn) > 0 {
|
|
src, err := ioutil.ReadFile(fn)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
bin, err := compiler.Compile(fn, src, false)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
code = common.Hex2Bytes(bin)
|
|
} else if ctx.GlobalString(CodeFlag.Name) != "" {
|
|
code = common.Hex2Bytes(ctx.GlobalString(CodeFlag.Name))
|
|
} else {
|
|
var hexcode []byte
|
|
if ctx.GlobalString(CodeFileFlag.Name) != "" {
|
|
var err error
|
|
hexcode, err = ioutil.ReadFile(ctx.GlobalString(CodeFileFlag.Name))
|
|
if err != nil {
|
|
fmt.Printf("Could not load code from file: %v\n", err)
|
|
os.Exit(1)
|
|
}
|
|
} else {
|
|
var err error
|
|
hexcode, err = ioutil.ReadAll(os.Stdin)
|
|
if err != nil {
|
|
fmt.Printf("Could not load code from stdin: %v\n", err)
|
|
os.Exit(1)
|
|
}
|
|
}
|
|
code = common.Hex2Bytes(string(bytes.TrimRight(hexcode, "\n")))
|
|
}
|
|
initialGas := ctx.GlobalUint64(GasFlag.Name)
|
|
runtimeConfig := runtime.Config{
|
|
Origin: sender,
|
|
State: statedb,
|
|
GasLimit: initialGas,
|
|
GasPrice: utils.GlobalBig(ctx, PriceFlag.Name),
|
|
Value: utils.GlobalBig(ctx, ValueFlag.Name),
|
|
EVMConfig: vm.Config{
|
|
Tracer: tracer,
|
|
Debug: ctx.GlobalBool(DebugFlag.Name) || ctx.GlobalBool(MachineFlag.Name),
|
|
DisableGasMetering: ctx.GlobalBool(DisableGasMeteringFlag.Name),
|
|
},
|
|
}
|
|
|
|
if cpuProfilePath := ctx.GlobalString(CPUProfileFlag.Name); cpuProfilePath != "" {
|
|
f, err := os.Create(cpuProfilePath)
|
|
if err != nil {
|
|
fmt.Println("could not create CPU profile: ", err)
|
|
os.Exit(1)
|
|
}
|
|
if err := pprof.StartCPUProfile(f); err != nil {
|
|
fmt.Println("could not start CPU profile: ", err)
|
|
os.Exit(1)
|
|
}
|
|
defer pprof.StopCPUProfile()
|
|
}
|
|
|
|
if chainConfig != nil {
|
|
runtimeConfig.ChainConfig = chainConfig
|
|
}
|
|
tstart := time.Now()
|
|
var leftOverGas uint64
|
|
if ctx.GlobalBool(CreateFlag.Name) {
|
|
input := append(code, common.Hex2Bytes(ctx.GlobalString(InputFlag.Name))...)
|
|
ret, _, leftOverGas, err = runtime.Create(input, &runtimeConfig)
|
|
} else {
|
|
receiver := common.StringToAddress("receiver")
|
|
statedb.SetCode(receiver, code)
|
|
|
|
ret, leftOverGas, err = runtime.Call(receiver, common.Hex2Bytes(ctx.GlobalString(InputFlag.Name)), &runtimeConfig)
|
|
}
|
|
execTime := time.Since(tstart)
|
|
|
|
if ctx.GlobalBool(DumpFlag.Name) {
|
|
statedb.IntermediateRoot(true)
|
|
fmt.Println(string(statedb.Dump()))
|
|
}
|
|
|
|
if memProfilePath := ctx.GlobalString(MemProfileFlag.Name); memProfilePath != "" {
|
|
f, err := os.Create(memProfilePath)
|
|
if err != nil {
|
|
fmt.Println("could not create memory profile: ", err)
|
|
os.Exit(1)
|
|
}
|
|
if err := pprof.WriteHeapProfile(f); err != nil {
|
|
fmt.Println("could not write memory profile: ", err)
|
|
os.Exit(1)
|
|
}
|
|
f.Close()
|
|
}
|
|
|
|
if ctx.GlobalBool(DebugFlag.Name) {
|
|
if debugLogger != nil {
|
|
fmt.Fprintln(os.Stderr, "#### TRACE ####")
|
|
vm.WriteTrace(os.Stderr, debugLogger.StructLogs())
|
|
}
|
|
fmt.Fprintln(os.Stderr, "#### LOGS ####")
|
|
vm.WriteLogs(os.Stderr, statedb.Logs())
|
|
}
|
|
|
|
if ctx.GlobalBool(StatDumpFlag.Name) {
|
|
var mem goruntime.MemStats
|
|
goruntime.ReadMemStats(&mem)
|
|
fmt.Fprintf(os.Stderr, `evm execution time: %v
|
|
heap objects: %d
|
|
allocations: %d
|
|
total allocations: %d
|
|
GC calls: %d
|
|
Gas used: %d
|
|
|
|
`, execTime, mem.HeapObjects, mem.Alloc, mem.TotalAlloc, mem.NumGC, initialGas-leftOverGas)
|
|
}
|
|
if tracer != nil {
|
|
tracer.CaptureEnd(ret, initialGas-leftOverGas, execTime)
|
|
} else {
|
|
fmt.Printf("0x%x\n", ret)
|
|
}
|
|
|
|
if err != nil {
|
|
fmt.Printf(" error: %v\n", err)
|
|
}
|
|
return nil
|
|
}
|