mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-06-08 07:58:40 +00:00
set prefetcher metrics upon completion
This commit is contained in:
parent
b7118dccfe
commit
da9e5177f9
1 changed files with 5 additions and 1 deletions
|
|
@ -118,6 +118,7 @@ func newPrefetchStateReaderInternal(reader StateReader, tasks []*fetchTask, nThr
|
|||
nThreads: nThreads,
|
||||
done: make(chan struct{}),
|
||||
term: make(chan struct{}),
|
||||
start: time.Now(),
|
||||
}
|
||||
go r.prefetch()
|
||||
return r
|
||||
|
|
@ -145,7 +146,10 @@ func (r *prefetchStateReader) Wait() error {
|
|||
}
|
||||
|
||||
func (r *prefetchStateReader) prefetch() {
|
||||
defer close(r.done)
|
||||
defer func() {
|
||||
r.metrics = PrefetchMetrics{time.Since(r.start)}
|
||||
close(r.done)
|
||||
}()
|
||||
|
||||
if len(r.tasks) == 0 {
|
||||
return
|
||||
|
|
|
|||
Loading…
Reference in a new issue