Skip to content

Commit

Permalink
feat: log dispute rate
Browse files Browse the repository at this point in the history
This way we can see if/when we need to optimize this code.
  • Loading branch information
Stebalien committed May 24, 2021
1 parent 216fa5c commit 995efe4
Showing 1 changed file with 9 additions and 1 deletion.
10 changes: 9 additions & 1 deletion cli/disputer.go
Original file line number Diff line number Diff line change
Expand Up @@ -238,6 +238,9 @@ var disputerStartCmd = &cli.Command{

dpmsgs := make([]*types.Message, 0)

startTime := time.Now()
proofsChecked := uint64(0)

// TODO: Parallelizeable
for _, dl := range dls {
fullDeadlines, err := api.StateMinerDeadlines(ctx, dl.miner, tsk)
Expand All @@ -249,7 +252,10 @@ var disputerStartCmd = &cli.Command{
return xerrors.Errorf("deadline index %d not found in deadlines", dl.index)
}

ms, err := makeDisputeWindowedPosts(ctx, api, dl, fullDeadlines[dl.index].DisputableProofCount, fromAddr)
disputableProofs := fullDeadlines[dl.index].DisputableProofCount
proofsChecked += disputableProofs

ms, err := makeDisputeWindowedPosts(ctx, api, dl, disputableProofs, fromAddr)
if err != nil {
return xerrors.Errorf("failed to check for disputes: %w", err)
}
Expand All @@ -264,6 +270,8 @@ var disputerStartCmd = &cli.Command{
deadlineMap[dClose+Confidence] = append(deadlineMap[dClose+Confidence], *dl)
}

disputeLog.Infow("checked proofs", "count", proofsChecked, "duration", time.Since(startTime))

// TODO: Parallelizeable / can be integrated into the previous deadline-iterating for loop
for _, dpmsg := range dpmsgs {
disputeLog.Infow("disputing a PoSt", "miner", dpmsg.To)
Expand Down

0 comments on commit 995efe4

Please sign in to comment.