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

v1.27.0-a #10

Closed
jonathanface wants to merge 473 commits from v1.27.0-a into master
pull from: v1.27.0-a
merge into: cerc-io:master
Conversation 0 Commits 473 Files Changed 452 +11 -5
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 72fac27a4d - Show all commits

16
storage/pipeline/commit_batch.go
View File

@ -371,17 +371,19 @@ func (b *CommitBatcher) processBatchV2(cfg sealiface.Config, sectors []abi.Secto
collateral = big.Add(collateral, sc) collateral = big.Add(collateral, sc)
pieces := b.todo[sector].ActivationManifest.Pieces manifest := b.todo[sector].ActivationManifest
precomitInfo, err := b.api.StateSectorPreCommitInfo(b.mctx, b.maddr, sector, ts.Key()) precomitInfo, err := b.api.StateSectorPreCommitInfo(b.mctx, b.maddr, sector, ts.Key())
if err != nil { if err != nil {
res.FailedSectors[sector] = err.Error() res.FailedSectors[sector] = err.Error()
continue continue
} }
err = b.allocationCheck(pieces, precomitInfo, abi.ActorID(mid), ts) if len(manifest.Pieces) > 0 {
if err != nil { err = b.allocationCheck(manifest.Pieces, precomitInfo, abi.ActorID(mid), ts)
res.FailedSectors[sector] = err.Error() if err != nil {
continue res.FailedSectors[sector] = err.Error()
continue
}
} }
params.SectorActivations = append(params.SectorActivations, b.todo[sector].ActivationManifest) params.SectorActivations = append(params.SectorActivations, b.todo[sector].ActivationManifest)
@ -925,6 +927,10 @@ func (b *CommitBatcher) aggregateProofType(nv network.Version) (abi.RegisteredAg
func (b *CommitBatcher) allocationCheck(Pieces []miner.PieceActivationManifest, precomitInfo *miner.SectorPreCommitOnChainInfo, miner abi.ActorID, ts *types.TipSet) error { func (b *CommitBatcher) allocationCheck(Pieces []miner.PieceActivationManifest, precomitInfo *miner.SectorPreCommitOnChainInfo, miner abi.ActorID, ts *types.TipSet) error {
for _, p := range Pieces { for _, p := range Pieces {
p := p p := p
// skip filler pieces
if p.VerifiedAllocationKey == nil {
continue
}
addr, err := address.NewIDAddress(uint64(p.VerifiedAllocationKey.Client)) addr, err := address.NewIDAddress(uint64(p.VerifiedAllocationKey.Client))
if err != nil { if err != nil {
return err return err