Merge pull request #6451 from GFZRZK/GFZRZK/handle_failed_sector
clean failed sectors in batch commit
This commit is contained in:
commit
0403fc416c
3
extern/storage-sealing/commit_batch.go
vendored
3
extern/storage-sealing/commit_batch.go
vendored
@ -246,6 +246,8 @@ func (b *CommitBatcher) processBatch(cfg sealiface.Config) ([]sealiface.CommitBa
|
|||||||
break
|
break
|
||||||
}
|
}
|
||||||
|
|
||||||
|
res.Sectors = append(res.Sectors, id)
|
||||||
|
|
||||||
sc, err := b.getSectorCollateral(id, tok)
|
sc, err := b.getSectorCollateral(id, tok)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
res.FailedSectors[id] = err.Error()
|
res.FailedSectors[id] = err.Error()
|
||||||
@ -254,7 +256,6 @@ func (b *CommitBatcher) processBatch(cfg sealiface.Config) ([]sealiface.CommitBa
|
|||||||
|
|
||||||
collateral = big.Add(collateral, sc)
|
collateral = big.Add(collateral, sc)
|
||||||
|
|
||||||
res.Sectors = append(res.Sectors, id)
|
|
||||||
params.SectorNumbers.Set(uint64(id))
|
params.SectorNumbers.Set(uint64(id))
|
||||||
infos = append(infos, p.info)
|
infos = append(infos, p.info)
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user