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

eth/handler: fix unaligned 64-bit atomic operation error

Browse source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2025-04-29 14:49:18 +02:00 committed by Felix Lange
parent 129a94b6af
commit fcc53c7a0d
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
eth/handler.go
View file

@ -121,7 +121,7 @@ type handler struct {
txpool txPool txpool txPool
chain *core.BlockChain chain *core.BlockChain
maxPeers int maxPeers int
lastDirect int64 // Last number of peers we sent transactions to, used to stabilize the randomness lastDirect atomic.Int64 // Last number of peers we sent transactions to, used to stabilize the randomness
downloader *downloader.Downloader downloader *downloader.Downloader
txFetcher *fetcher.TxFetcher txFetcher *fetcher.TxFetcher
@ -491,13 +491,13 @@ func (h *handler) BroadcastTransactions(txs types.Transactions) {
// Use some hysteresis to avoid oscillating between two values, stabilising the modulus in the peer selection // Use some hysteresis to avoid oscillating between two values, stabilising the modulus in the peer selection
// If the number of peers is small, use a minimum of 1 peer // If the number of peers is small, use a minimum of 1 peer
var directInt int64 var directInt int64
lastDirect := atomic.LoadInt64(&h.lastDirect) lastDirect := h.lastDirect.Load()
if int64(sqrtPeers) >= lastDirect { if int64(sqrtPeers) >= lastDirect {
directInt = max(int64(sqrtPeers), 1) directInt = max(int64(sqrtPeers), 1)
} else { } else {
directInt = max(min(int64(sqrtPeers+directPeersHysteresis), lastDirect), 1) directInt = max(min(int64(sqrtPeers+directPeersHysteresis), lastDirect), 1)
} }
atomic.StoreInt64(&h.lastDirect, directInt) h.lastDirect.Store(directInt)
direct := big.NewInt(directInt) // Number of peers to send directly to direct := big.NewInt(directInt) // Number of peers to send directly to
total := big.NewInt(directInt * directInt) // Stabilise total peer count a bit based on sqrt peers total := big.NewInt(directInt * directInt) // Stabilise total peer count a bit based on sqrt peers