forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-26 14:46:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

eth/downloader: add metric that tracks the throttle target ratio

Browse source
This commit is contained in:
Jared Wasinger 2025-04-25 13:00:07 +08:00
parent 8b7f061b12
commit e5350c9b81
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
eth/downloader/metrics.go
View file

@ -38,5 +38,6 @@ var (
receiptDropMeter = metrics.NewRegisteredMeter("eth/downloader/receipts/drop", nil) receiptDropMeter = metrics.NewRegisteredMeter("eth/downloader/receipts/drop", nil)
receiptTimeoutMeter = metrics.NewRegisteredMeter("eth/downloader/receipts/timeout", nil) receiptTimeoutMeter = metrics.NewRegisteredMeter("eth/downloader/receipts/timeout", nil)
throttleCounter = metrics.NewRegisteredCounter("eth/downloader/throttle", nil) throttleCounter = metrics.NewRegisteredCounter("eth/downloader/throttle", nil)
blockGasSizeRatioGauge = metrics.NewRegisteredGaugeFloat64("eth/downloader/gassizeratio", nil)
) )

1
eth/downloader/queue.go
View file

@ -333,6 +333,7 @@ func (q *queue) Results(block bool) []*fetchResult {
(1-common.StorageSize(blockCacheSizeWeight))*q.resultGasSizeRatio (1-common.StorageSize(blockCacheSizeWeight))*q.resultGasSizeRatio
} }
throttleThreshold := q.resultCache.SetThrottleTarget(q.resultGasSizeRatio) throttleThreshold := q.resultCache.SetThrottleTarget(q.resultGasSizeRatio)
blockGasSizeRatioGauge.Update(float64(q.resultGasSizeRatio))
// With results removed from the cache, wake throttled fetchers // With results removed from the cache, wake throttled fetchers
for _, ch := range []chan bool{q.blockWakeCh, q.receiptWakeCh} { for _, ch := range []chan bool{q.blockWakeCh, q.receiptWakeCh} {