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

Validate length of RLE

Browse Source 
Signed-off-by: Jakub Sztandera <kubuxu@protocol.ai>
This commit is contained in:
Jakub Sztandera 2020-01-06 20:53:03 +01:00
parent 7b134b8317
commit dbc729d049
No known key found for this signature in database
GPG Key ID: 9A9AF56F8B3879BA
2 changed files with 31 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
chain/actors/actor_miner.go
View File

@ -467,7 +467,12 @@ func (sma StorageMinerActor) SubmitFallbackPoSt(act *types.Actor, vmctx types.VM
return nil, aerrors.HandleExternalError(lerr, "could not load proving set node") return nil, aerrors.HandleExternalError(lerr, "could not load proving set node")
} }
faults, nerr := self.FaultSet.AllMap() ss, lerr := amt.LoadAMT(types.WrapStorage(vmctx.Storage()), self.Sectors)
if lerr != nil {
return nil, aerrors.HandleExternalError(lerr, "could not load proving set node")
}
faults, nerr := self.FaultSet.AllMap(ss.Count)
if nerr != nil { if nerr != nil {
return nil, aerrors.Absorb(err, 5, "RLE+ invalid") return nil, aerrors.Absorb(err, 5, "RLE+ invalid")
} }
@ -937,7 +942,12 @@ func onSuccessfulPoSt(self *StorageMinerActorState, vmctx types.VMContext) aerro
return aerrors.HandleExternalError(nerr, "failed to load proving set") return aerrors.HandleExternalError(nerr, "failed to load proving set")
} }
faults, nerr := self.FaultSet.All() ss, nerr := amt.LoadAMT(types.WrapStorage(vmctx.Storage()), self.Sectors)
if nerr != nil {
return aerrors.HandleExternalError(nerr, "failed to load proving set")
}
faults, nerr := self.FaultSet.All(ss.Count)
if nerr != nil { if nerr != nil {
return aerrors.Absorb(nerr, 1, "invalid bitfield (fatal?)") return aerrors.Absorb(nerr, 1, "invalid bitfield (fatal?)")
} }

21
chain/types/bitfield.go
View File

@ -1,6 +1,7 @@
package types package types
import ( import (
"errors"
"fmt" "fmt"
"io" "io"
@ -9,6 +10,8 @@ import (
"golang.org/x/xerrors" "golang.org/x/xerrors"
) )
var ErrBitFieldTooMany = errors.New("to many items in RLE")
type BitField struct { type BitField struct {
rle rlepluslazy.RLE rle rlepluslazy.RLE
@ -106,7 +109,14 @@ func (bf BitField) Count() (uint64, error) {
} }
// All returns all set bits // All returns all set bits
func (bf BitField) All() ([]uint64, error) { func (bf BitField) All(max uint64) ([]uint64, error) {
c, err := bf.Count()
if err != nil {
return nil, xerrors.Errorf("count errror: %w", err)
}
if c > max {
return nil, xerrors.Errorf("expected %d, got %d: %w", max, c, ErrBitFieldTooMany)
}
runs, err := bf.sum() runs, err := bf.sum()
if err != nil { if err != nil {
@ -121,7 +131,14 @@ func (bf BitField) All() ([]uint64, error) {
return res, nil return res, nil
} }
func (bf BitField) AllMap() (map[uint64]bool, error) { func (bf BitField) AllMap(max uint64) (map[uint64]bool, error) {
c, err := bf.Count()
if err != nil {
return nil, xerrors.Errorf("count errror: %w", err)
}
if c > max {
return nil, xerrors.Errorf("expected %d, got %d: %w", max, c, ErrBitFieldTooMany)
}
runs, err := bf.sum() runs, err := bf.sum()
if err != nil { if err != nil {