cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

fvm: time message execution

Browse Source
This commit is contained in:
Steven Allen 2022-02-23 19:23:20 +00:00
parent aad376296e
commit 420c5fb568
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
chain/vm/fvm.go
View File

@ -3,9 +3,11 @@ package vm
import ( import (
"bytes" "bytes"
"context" "context"
"time"
"github.com/filecoin-project/go-state-types/big" "github.com/filecoin-project/go-state-types/big"
"github.com/filecoin-project/lotus/build"
"github.com/filecoin-project/lotus/chain/state" "github.com/filecoin-project/lotus/chain/state"
cbor "github.com/ipfs/go-ipld-cbor" cbor "github.com/ipfs/go-ipld-cbor"
@ -150,7 +152,7 @@ func (x *FvmExtern) VerifyConsensusFault(ctx context.Context, a, b, extra []byte
ret.Type = faultType ret.Type = faultType
ret.Target = blockA.Miner ret.Target = blockA.Miner
return ret, totalGas return ret, totalGas
} }
@ -227,6 +229,7 @@ func NewFVM(ctx context.Context, opts *VMOpts) (*FVM, error) {
} }
func (vm *FVM) ApplyMessage(ctx context.Context, cmsg types.ChainMsg) (*ApplyRet, error) { func (vm *FVM) ApplyMessage(ctx context.Context, cmsg types.ChainMsg) (*ApplyRet, error) {
start := build.Clock.Now()
msgBytes, err := cmsg.VMMessage().Serialize() msgBytes, err := cmsg.VMMessage().Serialize()
if err != nil { if err != nil {
return nil, xerrors.Errorf("serializing msg: %w", err) return nil, xerrors.Errorf("serializing msg: %w", err)
@ -256,16 +259,16 @@ func (vm *FVM) ApplyMessage(ctx context.Context, cmsg types.ChainMsg) (*ApplyRet
// TODO: do these eventually, not consensus critical // TODO: do these eventually, not consensus critical
ActorErr: nil, ActorErr: nil,
ExecutionTrace: types.ExecutionTrace{}, ExecutionTrace: types.ExecutionTrace{},
Duration: 0, Duration: time.Since(start),
}, nil }, nil
} }
func (vm *FVM) ApplyImplicitMessage(ctx context.Context, cmsg *types.Message) (*ApplyRet, error) { func (vm *FVM) ApplyImplicitMessage(ctx context.Context, cmsg *types.Message) (*ApplyRet, error) {
start := build.Clock.Now()
msgBytes, err := cmsg.VMMessage().Serialize() msgBytes, err := cmsg.VMMessage().Serialize()
if err != nil { if err != nil {
return nil, xerrors.Errorf("serializing msg: %w", err) return nil, xerrors.Errorf("serializing msg: %w", err)
} }
ret, err := vm.fvm.ApplyImplicitMessage(msgBytes) ret, err := vm.fvm.ApplyImplicitMessage(msgBytes)
if err != nil { if err != nil {
return nil, xerrors.Errorf("applying msg: %w", err) return nil, xerrors.Errorf("applying msg: %w", err)
@ -281,7 +284,7 @@ func (vm *FVM) ApplyImplicitMessage(ctx context.Context, cmsg *types.Message) (*
// TODO: do these eventually, not consensus critical // TODO: do these eventually, not consensus critical
ActorErr: nil, ActorErr: nil,
ExecutionTrace: types.ExecutionTrace{}, ExecutionTrace: types.ExecutionTrace{},
Duration: 0, Duration: time.Since(start),
}, nil }, nil
} }