commit batch: Initialize the FailedSectors map
This commit is contained in:
parent
6a5b94ca3b
commit
88bb9f422e
5
extern/storage-sealing/commit_batch.go
vendored
5
extern/storage-sealing/commit_batch.go
vendored
@ -242,7 +242,9 @@ func (b *CommitBatcher) processBatch(cfg sealiface.Config) ([]sealiface.CommitBa
|
|||||||
|
|
||||||
total := len(b.todo)
|
total := len(b.todo)
|
||||||
|
|
||||||
var res sealiface.CommitBatchRes
|
res := sealiface.CommitBatchRes{
|
||||||
|
FailedSectors: map[abi.SectorNumber]string{},
|
||||||
|
}
|
||||||
|
|
||||||
params := miner5.ProveCommitAggregateParams{
|
params := miner5.ProveCommitAggregateParams{
|
||||||
SectorNumbers: bitfield.New(),
|
SectorNumbers: bitfield.New(),
|
||||||
@ -357,6 +359,7 @@ func (b *CommitBatcher) processIndividually() ([]sealiface.CommitBatchRes, error
|
|||||||
for sn, info := range b.todo {
|
for sn, info := range b.todo {
|
||||||
r := sealiface.CommitBatchRes{
|
r := sealiface.CommitBatchRes{
|
||||||
Sectors: []abi.SectorNumber{sn},
|
Sectors: []abi.SectorNumber{sn},
|
||||||
|
FailedSectors: map[abi.SectorNumber]string{},
|
||||||
}
|
}
|
||||||
|
|
||||||
mcid, err := b.processSingle(mi, sn, info, tok)
|
mcid, err := b.processSingle(mi, sn, info, tok)
|
||||||
|
Loading…
Reference in New Issue
Block a user