135 lines
3.3 KiB
Go
135 lines
3.3 KiB
Go
package vm
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/filecoin-project/go-state-types/abi"
|
|
"github.com/filecoin-project/go-state-types/exitcode"
|
|
|
|
"golang.org/x/xerrors"
|
|
|
|
"github.com/filecoin-project/lotus/blockstore"
|
|
"github.com/filecoin-project/lotus/chain/state"
|
|
cbor "github.com/ipfs/go-ipld-cbor"
|
|
|
|
ffi "github.com/filecoin-project/filecoin-ffi"
|
|
ffi_cgo "github.com/filecoin-project/filecoin-ffi/cgo"
|
|
|
|
"github.com/filecoin-project/lotus/chain/types"
|
|
"github.com/ipfs/go-cid"
|
|
)
|
|
|
|
var _ VMI = (*FVM)(nil)
|
|
|
|
type FvmExtern struct {
|
|
Rand
|
|
blockstore.Blockstore
|
|
}
|
|
|
|
func (x *FvmExtern) VerifyConsensusFault(ctx context.Context, h1, h2, extra []byte) (*ffi_cgo.ConsensusFault, error) {
|
|
// TODO
|
|
panic("unimplemented")
|
|
}
|
|
|
|
type FVM struct {
|
|
fvm *ffi.FVM
|
|
}
|
|
|
|
func NewFVM(ctx context.Context, opts *VMOpts) (*FVM, error) {
|
|
buf := blockstore.NewBuffered(opts.Bstore)
|
|
cst := cbor.NewCborStore(buf)
|
|
state, err := state.LoadStateTree(cst, opts.StateBase)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
baseCirc, err := opts.CircSupplyCalc(ctx, opts.Epoch, state)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
fvm, err := ffi.CreateFVM(0,
|
|
&FvmExtern{Rand: opts.Rand, Blockstore: opts.Bstore},
|
|
opts.Epoch, opts.BaseFee, baseCirc, opts.NetworkVersion, opts.StateBase,
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &FVM{
|
|
fvm: fvm,
|
|
}, nil
|
|
}
|
|
|
|
func (vm *FVM) ApplyMessage(ctx context.Context, cmsg types.ChainMsg) (*ApplyRet, error) {
|
|
msgBytes, err := cmsg.VMMessage().Serialize()
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("serializing msg: %w", err)
|
|
}
|
|
|
|
ret, err := vm.fvm.ApplyMessage(msgBytes)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("applying msg: %w", err)
|
|
}
|
|
|
|
return &ApplyRet{
|
|
MessageReceipt: types.MessageReceipt{
|
|
Return: ret.Return,
|
|
ExitCode: exitcode.ExitCode(ret.ExitCode),
|
|
GasUsed: ret.GasUsed,
|
|
},
|
|
GasCosts: &GasOutputs{
|
|
// TODO: do the other optional fields eventually
|
|
BaseFeeBurn: abi.TokenAmount{},
|
|
OverEstimationBurn: abi.TokenAmount{},
|
|
MinerPenalty: ret.MinerPenalty,
|
|
MinerTip: ret.MinerTip,
|
|
Refund: abi.TokenAmount{},
|
|
GasRefund: 0,
|
|
GasBurned: 0,
|
|
},
|
|
// TODO: do these eventually, not consensus critical
|
|
ActorErr: nil,
|
|
ExecutionTrace: types.ExecutionTrace{},
|
|
Duration: 0,
|
|
}, nil
|
|
}
|
|
|
|
func (vm *FVM) ApplyImplicitMessage(ctx context.Context, cmsg *types.Message) (*ApplyRet, error) {
|
|
msgBytes, err := cmsg.VMMessage().Serialize()
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("serializing msg: %w", err)
|
|
}
|
|
|
|
ret, err := vm.fvm.ApplyMessage(msgBytes)
|
|
if err != nil {
|
|
return nil, xerrors.Errorf("applying msg: %w", err)
|
|
}
|
|
|
|
return &ApplyRet{
|
|
MessageReceipt: types.MessageReceipt{
|
|
Return: ret.Return,
|
|
ExitCode: exitcode.ExitCode(ret.ExitCode),
|
|
GasUsed: ret.GasUsed,
|
|
},
|
|
GasCosts: &GasOutputs{
|
|
// TODO: do the other optional fields eventually
|
|
BaseFeeBurn: abi.TokenAmount{},
|
|
OverEstimationBurn: abi.TokenAmount{},
|
|
MinerPenalty: ret.MinerPenalty,
|
|
MinerTip: ret.MinerTip,
|
|
Refund: abi.TokenAmount{},
|
|
GasRefund: 0,
|
|
GasBurned: 0,
|
|
},
|
|
// TODO: do these eventually, not consensus critical
|
|
ActorErr: nil,
|
|
ExecutionTrace: types.ExecutionTrace{},
|
|
Duration: 0,
|
|
}, nil
|
|
}
|
|
|
|
func (vm *FVM) Flush(ctx context.Context) (cid.Cid, error) {
|
|
return vm.fvm.Flush()
|
|
}
|