Skip to content

Commit

Permalink
log verification progress
Browse files Browse the repository at this point in the history
  • Loading branch information
zhangchiqing committed Dec 20, 2024
1 parent a2ad9e6 commit fe827a3
Showing 1 changed file with 10 additions and 0 deletions.
10 changes: 10 additions & 0 deletions engine/verification/verifier/verifiers.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ import (
"github.com/onflow/flow-go/module"
"github.com/onflow/flow-go/module/chunks"
"github.com/onflow/flow-go/module/metrics"
"github.com/onflow/flow-go/module/util"
"github.com/onflow/flow-go/state/protocol"
"github.com/onflow/flow-go/storage"
storagepebble "github.com/onflow/flow-go/storage/pebble"
Expand Down Expand Up @@ -158,13 +159,22 @@ func verifyConcurrently(
}
}

lg := util.LogProgress(
log.Logger,
util.DefaultLogProgressConfig(
fmt.Sprintf("verifying heights progress for [%v:%v]", from, to),
int(to+1-from),
),
)

// Start nWorker workers
var wg sync.WaitGroup
for i := 0; i < int(nWorker); i++ {
wg.Add(1)
go func() {
defer wg.Done()
worker()
lg(1)
}()
}

Expand Down

0 comments on commit fe827a3

Please sign in to comment.