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

Replace use of SectorsMax in bitfield All() calls with MaxInt

Browse Source
This commit is contained in:
Aayush Rajasekaran 2020-09-03 01:07:10 -04:00
parent 32eb647215
commit 9b1eb8f362
2 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
chain/stmgr/utils.go
View File

@ -3,6 +3,7 @@ package stmgr
import ( import (
"bytes" "bytes"
"context" "context"
"math"
"os" "os"
"reflect" "reflect"
@ -251,7 +252,7 @@ func GetSectorsForWinningPoSt(ctx context.Context, pv ffiwrapper.Verifier, sm *S
return nil, xerrors.Errorf("generating winning post challenges: %w", err) return nil, xerrors.Errorf("generating winning post challenges: %w", err)
} }
sectors, err := provingSectors.All(miner.SectorsMax) sectors, err := provingSectors.All(math.MaxInt64)
if err != nil { if err != nil {
return nil, xerrors.Errorf("failed to enumerate all sector IDs: %w", err) return nil, xerrors.Errorf("failed to enumerate all sector IDs: %w", err)
} }

11
cmd/lotus-chainwatch/processor/miner.go
View File

@ -4,6 +4,7 @@ import (
"bytes" "bytes"
"context" "context"
"fmt" "fmt"
"math"
"strings" "strings"
"time" "time"
@ -746,7 +747,7 @@ func (p *Processor) diffMinerPartitions(ctx context.Context, m minerActorInfo, e
return err return err
} }
recovered, err := partitionDiff.Recovered.All(miner.SectorsMax) recovered, err := partitionDiff.Recovered.All(math.MaxInt64)
if err != nil { if err != nil {
return err return err
} }
@ -756,7 +757,7 @@ func (p *Processor) diffMinerPartitions(ctx context.Context, m minerActorInfo, e
SectorIDs: recovered, SectorIDs: recovered,
Event: SectorRecovered, Event: SectorRecovered,
} }
inRecovery, err := partitionDiff.InRecovery.All(miner.SectorsMax) inRecovery, err := partitionDiff.InRecovery.All(math.MaxInt64)
if err != nil { if err != nil {
return err return err
} }
@ -766,7 +767,7 @@ func (p *Processor) diffMinerPartitions(ctx context.Context, m minerActorInfo, e
SectorIDs: inRecovery, SectorIDs: inRecovery,
Event: SectorRecovering, Event: SectorRecovering,
} }
faulted, err := partitionDiff.Faulted.All(miner.SectorsMax) faulted, err := partitionDiff.Faulted.All(math.MaxInt64)
if err != nil { if err != nil {
return err return err
} }
@ -776,7 +777,7 @@ func (p *Processor) diffMinerPartitions(ctx context.Context, m minerActorInfo, e
SectorIDs: faulted, SectorIDs: faulted,
Event: SectorFaulted, Event: SectorFaulted,
} }
terminated, err := partitionDiff.Terminated.All(miner.SectorsMax) terminated, err := partitionDiff.Terminated.All(math.MaxInt64)
if err != nil { if err != nil {
return err return err
} }
@ -786,7 +787,7 @@ func (p *Processor) diffMinerPartitions(ctx context.Context, m minerActorInfo, e
SectorIDs: terminated, SectorIDs: terminated,
Event: SectorTerminated, Event: SectorTerminated,
} }
expired, err := partitionDiff.Expired.All(miner.SectorsMax) expired, err := partitionDiff.Expired.All(math.MaxInt64)
if err != nil { if err != nil {
return err return err
} }