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

Bugfix: Eligible miners should be computed based on start tipset, not end tipset

Browse Source
This commit is contained in:
Aayush Rajasekaran 2020-10-14 03:01:41 -04:00
parent 20c57fcd0e
commit 2613e837a9
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
cmd/lotus-shed/postfind.go
View File

@ -45,23 +45,24 @@ var postFindCmd = &cli.Command{
verbose := c.Bool("verbose") verbose := c.Bool("verbose")
withpower := c.Bool("withpower") withpower := c.Bool("withpower")
ts, err := lcli.LoadTipSet(ctx, c, api) startTs, err := lcli.LoadTipSet(ctx, c, api)
if err != nil { if err != nil {
return err return err
} }
if ts == nil { if startTs == nil {
ts, err = api.ChainHead(ctx) startTs, err = api.ChainHead(ctx)
if err != nil { if err != nil {
return err return err
} }
} }
oneDayAgo := ts.Height() - abi.ChainEpoch(c.Int("lookback")) stopEpoch := startTs.Height() - abi.ChainEpoch(c.Int("lookback"))
if verbose { if verbose {
fmt.Printf("Collecting messages between %d and %d\n", ts.Height(), oneDayAgo) fmt.Printf("Collecting messages between %d and %d\n", startTs.Height(), stopEpoch)
} }
// Get all messages over the last day // Get all messages over the last day
ts := startTs
msgs := make([]*types.Message, 0) msgs := make([]*types.Message, 0)
for ts.Height() > oneDayAgo { for ts.Height() > stopEpoch {
// Get messages on ts parent // Get messages on ts parent
next, err := api.ChainGetParentMessages(ctx, ts.Cids()[0]) next, err := api.ChainGetParentMessages(ctx, ts.Cids()[0])
if err != nil { if err != nil {
@ -80,7 +81,7 @@ var postFindCmd = &cli.Command{
} }
fmt.Printf("Loaded messages to height %d\n", ts.Height()) fmt.Printf("Loaded messages to height %d\n", ts.Height())
mAddrs, err := api.StateListMiners(ctx, ts.Key()) mAddrs, err := api.StateListMiners(ctx, startTs.Key())
if err != nil { if err != nil {
return err return err
} }
@ -90,7 +91,7 @@ var postFindCmd = &cli.Command{
// if they have no power ignore. This filters out 14k inactive miners // if they have no power ignore. This filters out 14k inactive miners
// so we can do 100x fewer expensive message queries // so we can do 100x fewer expensive message queries
if withpower { if withpower {
power, err := api.StateMinerPower(ctx, mAddr, ts.Key()) power, err := api.StateMinerPower(ctx, mAddr, startTs.Key())
if err != nil { if err != nil {
return err return err
} }