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

Merge pull request #457 from waynewyang/MinerActor-CommitSector

Browse Source 
Check if fromaddress equal workaddress when CommitSector
This commit is contained in:
Łukasz Magiera 2019-10-25 17:39:28 +02:00 committed by GitHub
commit 55f22884ab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
chain/actors/actor_miner.go
View File

@ -222,13 +222,17 @@ func (sma StorageMinerActor) CommitSector(act *types.Actor, vmctx types.VMContex
return nil, err return nil, err
} }
if vmctx.Message().From != mi.Worker {
return nil, aerrors.New(1, "not authorized to commit sector for miner")
}
// TODO: this needs to get normalized to either the ID address or the actor address // TODO: this needs to get normalized to either the ID address or the actor address
maddr := vmctx.Message().To maddr := vmctx.Message().To
if ok, err := ValidatePoRep(maddr, mi.SectorSize, params); err != nil { if ok, err := ValidatePoRep(maddr, mi.SectorSize, params); err != nil {
return nil, err return nil, err
} else if !ok { } else if !ok {
return nil, aerrors.New(1, "bad proof!") return nil, aerrors.New(2, "bad proof!")
} }
// make sure the miner isnt trying to submit a pre-existing sector // make sure the miner isnt trying to submit a pre-existing sector
@ -237,7 +241,7 @@ func (sma StorageMinerActor) CommitSector(act *types.Actor, vmctx types.VMContex
return nil, err return nil, err
} }
if !unique { if !unique {
return nil, aerrors.New(2, "sector already committed!") return nil, aerrors.New(3, "sector already committed!")
} }
// Power of the miner after adding this sector // Power of the miner after adding this sector
@ -246,7 +250,7 @@ func (sma StorageMinerActor) CommitSector(act *types.Actor, vmctx types.VMContex
// TODO: grab from market? // TODO: grab from market?
if act.Balance.LessThan(collateralRequired) { if act.Balance.LessThan(collateralRequired) {
return nil, aerrors.New(3, "not enough collateral") return nil, aerrors.New(4, "not enough collateral")
} }
// Note: There must exist a unique index in the miner's sector set for each // Note: There must exist a unique index in the miner's sector set for each