forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-05-24 08:49:29 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

eth/fether: make handleAddErrors return otherreject count

Browse source
This commit is contained in:
healthykim 2026-05-21 15:32:54 +02:00
parent 474a027d27
commit 72d31996c7
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
eth/fetcher/tx_fetcher.go
View file

@ -403,7 +403,13 @@ func (f *TxFetcher) Enqueue(peer string, version uint, txs []*types.Transaction,
break break
} }
} }
f.handleAddErrors(hashes, errs, metrics) otherreject := f.handleAddErrors(hashes, errs, metrics)
// If 'other reject' is >25% of the deliveries in any batch, sleep a bit
// to throttle the misbehaving peer.
if otherreject > int64((len(hashes)+3)/4) {
log.Debug("Peer delivering stale or invalid transactions", "rejected", otherreject)
time.Sleep(200 * time.Millisecond)
}
// If we encountered a protocol violation, disconnect this peer. // If we encountered a protocol violation, disconnect this peer.
if violation != nil { if violation != nil {
break break
@ -417,11 +423,10 @@ func (f *TxFetcher) Enqueue(peer string, version uint, txs []*types.Transaction,
} }
} }
func (f *TxFetcher) handleAddErrors(txs []common.Hash, errs []error, metrics deliveryMetrics) { func (f *TxFetcher) handleAddErrors(txs []common.Hash, errs []error, metrics deliveryMetrics) (otherreject int64) {
var ( var (
duplicate int64 duplicate int64
underpriced int64 underpriced int64
otherreject int64
) )
for i, err := range errs { for i, err := range errs {
// Track a few interesting failure types // Track a few interesting failure types
@ -445,12 +450,7 @@ func (f *TxFetcher) handleAddErrors(txs []common.Hash, errs []error, metrics del
metrics.knownMeter.Mark(duplicate) metrics.knownMeter.Mark(duplicate)
metrics.underpricedMeter.Mark(underpriced) metrics.underpricedMeter.Mark(underpriced)
metrics.otherRejectMeter.Mark(otherreject) metrics.otherRejectMeter.Mark(otherreject)
return otherreject
// If 'other reject' is >25% of the deliveries in any batch, sleep a bit.
if otherreject > int64((len(txs)+3)/4) {
log.Debug("Peer delivering stale or invalid transactions", "rejected", otherreject)
time.Sleep(200 * time.Millisecond)
}
} }
// Drop should be called when a peer disconnects. It cleans up all the internal // Drop should be called when a peer disconnects. It cleans up all the internal