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

reduce most vm errors to non-fatal, explicitly mark disk issues as fatal

Browse Source
This commit is contained in:
whyrusleeping 2020-01-07 19:46:55 -08:00
parent f019b80af0
commit e41dbdad90
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
chain/actors/actor_paych.go
View File

@ -116,7 +116,7 @@ func (pca PaymentChannelActor) UpdateChannelState(act *types.Actor, vmctx types.
vb, nerr := sv.SigningBytes() vb, nerr := sv.SigningBytes()
if nerr != nil { if nerr != nil {
return nil, aerrors.Escalate(nerr, "failed to serialize signedvoucher") return nil, aerrors.Newf(1, nerr, "failed to serialize signedvoucher")
} }
if err := vmctx.VerifySignature(sv.Signature, self.From, vb); err != nil { if err := vmctx.VerifySignature(sv.Signature, self.From, vb); err != nil {

3
chain/actors/aerrors/wrap.go
View File

@ -171,7 +171,8 @@ func HandleExternalError(err error, msg string) ActorError {
} }
return &actorError{ return &actorError{
fatal: true, fatal: false,
retCode: 219,
msg: msg, msg: msg,
frame: xerrors.Caller(1), frame: xerrors.Caller(1),

7
chain/vm/vm.go
View File

@ -259,7 +259,7 @@ func (bs *gasChargingBlocks) GetBlock(ctx context.Context, c cid.Cid) (block.Blo
} }
blk, err := bs.under.GetBlock(ctx, c) blk, err := bs.under.GetBlock(ctx, c)
if err != nil { if err != nil {
return nil, err return nil, aerrors.Escalate(err, "failed to get block from blockstore")
} }
if err := bs.chargeGas(uint64(len(blk.RawData())) * gasGetPerByte); err != nil { if err := bs.chargeGas(uint64(len(blk.RawData())) * gasGetPerByte); err != nil {
return nil, err return nil, err
@ -272,7 +272,10 @@ func (bs *gasChargingBlocks) AddBlock(blk block.Block) error {
if err := bs.chargeGas(gasPutObj + uint64(len(blk.RawData()))*gasPutPerByte); err != nil { if err := bs.chargeGas(gasPutObj + uint64(len(blk.RawData()))*gasPutPerByte); err != nil {
return err return err
} }
return bs.under.AddBlock(blk) if err := bs.under.AddBlock(blk); err != nil {
return aerrors.Escalate(err, "failed to write data to disk")
}
return nil
} }
func (vm *VM) makeVMContext(ctx context.Context, sroot cid.Cid, msg *types.Message, origin address.Address, usedGas types.BigInt) *VMContext { func (vm *VM) makeVMContext(ctx context.Context, sroot cid.Cid, msg *types.Message, origin address.Address, usedGas types.BigInt) *VMContext {