From 995efe4584f34d5a5dc17fe99561b2069da0ccf6 Mon Sep 17 00:00:00 2001 From: Steven Allen Date: Mon, 24 May 2021 16:31:50 -0700 Subject: [PATCH] feat: log dispute rate This way we can see if/when we need to optimize this code. --- cli/disputer.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/cli/disputer.go b/cli/disputer.go index 235c4cf03..ceebeb939 100644 --- a/cli/disputer.go +++ b/cli/disputer.go @@ -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) @@ -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) } @@ -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)