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

sealing: Fix max commit batch size check

Browse Source
This commit is contained in:
Łukasz Magiera 2021-05-20 12:11:11 +02:00
parent 678812f35b
commit bb889a5976
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
extern/storage-sealing/commit_batch.go vendored
View File

@ -185,6 +185,11 @@ func (b *CommitBatcher) processBatch(notif, after bool) (*cid.Cid, error) {
infos := make([]proof5.AggregateSealVerifyInfo, 0, total) infos := make([]proof5.AggregateSealVerifyInfo, 0, total)
for id, p := range b.todo { for id, p := range b.todo {
if len(infos) >= cfg.MaxCommitBatch {
log.Infow("commit batch full")
break
}
params.SectorNumbers.Set(uint64(id)) params.SectorNumbers.Set(uint64(id))
infos = append(infos, p.info) infos = append(infos, p.info)
} }
@ -194,11 +199,6 @@ func (b *CommitBatcher) processBatch(notif, after bool) (*cid.Cid, error) {
}) })
for _, info := range infos { for _, info := range infos {
if len(infos) >= cfg.MaxCommitBatch {
log.Infow("commit batch full")
break
}
proofs = append(proofs, b.todo[info.Number].proof) proofs = append(proofs, b.todo[info.Number].proof)
} }