smeb_y/0g-chain
1
0
Fork 0
mirror of https://github.com/0glabs/0g-chain.git synced 2025-04-04 15:55:23 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge pull request #132 from 0glabs/issue-gas-price-and-block-build

Browse Source 
pref: skiplist using static rand generator
This commit is contained in:
Solovyov1796 2025-03-31 11:30:34 +08:00 committed by GitHub
commit 8d5e81154a
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/priority_nonce.go
View File

@ -2,7 +2,9 @@ package app
import ( import (
"context" "context"
"math/rand"
"sync" "sync"
"time"
"fmt" "fmt"
"math" "math"
@ -27,6 +29,9 @@ var (
errMempoolTooManyTxs = errors.New("tx sender has too many txs in mempool") errMempoolTooManyTxs = errors.New("tx sender has too many txs in mempool")
errMempoolIsFull = errors.New("mempool is full") errMempoolIsFull = errors.New("mempool is full")
errTxInMempool = errors.New("tx already in mempool") errTxInMempool = errors.New("tx already in mempool")
staticSrc = rand.NewSource(time.Now().UnixNano())
staticRng = rand.New(staticSrc)
) )
// PriorityNonceMempool is a mempool implementation that stores txs // PriorityNonceMempool is a mempool implementation that stores txs
@ -160,6 +165,8 @@ func NewPriorityMempool(opts ...PriorityNonceMempoolOption) *PriorityNonceMempoo
txRecord: make(map[txMeta]struct{}), txRecord: make(map[txMeta]struct{}),
} }
mp.priorityIndex.SetRandSource(staticSrc)
for _, opt := range opts { for _, opt := range opts {
opt(mp) opt(mp)
} }
@ -218,6 +225,7 @@ func (mp *PriorityNonceMempool) Insert(ctx context.Context, tx sdk.Tx) error {
senderIndex = skiplist.New(skiplist.LessThanFunc(func(a, b any) int { senderIndex = skiplist.New(skiplist.LessThanFunc(func(a, b any) int {
return skiplist.Uint64.Compare(b.(txMeta).nonce, a.(txMeta).nonce) return skiplist.Uint64.Compare(b.(txMeta).nonce, a.(txMeta).nonce)
})) }))
senderIndex.SetRandSource(staticRng)
// initialize sender index if not found // initialize sender index if not found
mp.senderIndices[txInfo.Sender] = senderIndex mp.senderIndices[txInfo.Sender] = senderIndex
@ -306,7 +314,7 @@ func (mp *PriorityNonceMempool) doInsert(newKey txMeta, tx sdk.Tx, incrCnt bool)
senderIndex = skiplist.New(skiplist.LessThanFunc(func(a, b any) int { senderIndex = skiplist.New(skiplist.LessThanFunc(func(a, b any) int {
return skiplist.Uint64.Compare(b.(txMeta).nonce, a.(txMeta).nonce) return skiplist.Uint64.Compare(b.(txMeta).nonce, a.(txMeta).nonce)
})) }))
senderIndex.SetRandSource(staticRng)
// initialize sender index if not found // initialize sender index if not found
mp.senderIndices[newKey.sender] = senderIndex mp.senderIndices[newKey.sender] = senderIndex
} }