tornadocontrib/bsc
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pool: add back removed logic

Browse Source
This commit is contained in:
emailtovamos 2024-09-26 14:24:13 +01:00
parent 355dee9000
commit 1ad40cda3f
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
eth/handler.go
View File

@ -851,8 +851,7 @@ func (h *handler) BroadcastTransactions(txs types.Transactions) {
txset = make(map[*ethPeer][]common.Hash) // Set peer->hash to transfer directly
annos = make(map[*ethPeer][]common.Hash) // Set peer->hash to announce
)
// for pool2 it is p = static+sqrt(peers) is total available.
// Send tx to sqrt(p) and announce to (p - sqrt(p)) peers
// Broadcast transactions to a batch of peers not knowing about it
for _, tx := range txs {
peers := h.peers.peersWithoutTransaction(tx.Hash())
@ -866,7 +865,6 @@ func (h *handler) BroadcastTransactions(txs types.Transactions) {
default:
numDirect = int(math.Sqrt(float64(len(peers))))
}
// Send the tx unconditionally to a subset of our peers
for _, peer := range peers[:numDirect] {
txset[peer] = append(txset[peer], tx.Hash())

3
eth/protocols/eth/peer.go
View File

@ -224,6 +224,9 @@ func (p *Peer) SendTransactions(txs types.Transactions) error {
// will force old sends to be dropped)
func (p *Peer) AsyncSendTransactions(hashes []common.Hash) {
select {
case p.txBroadcast <- hashes:
// Mark all the transactions as known, but ensure we don't overflow our limits
p.knownTxs.Add(hashes...)
case <-p.txTerm:
p.Log().Debug("Dropping transaction propagation", "count", len(hashes))
case <-p.term: