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

core/txpool/legacypool: move addressesByHeartbeat to queue

Browse source 
Signed-off-by: Csaba Kiraly <csaba.kiraly@gmail.com>
This commit is contained in:
Csaba Kiraly 2025-09-23 17:58:16 +02:00
parent 07d28277af
commit 39ce64b8b0
No known key found for this signature in database
GPG key ID: 0FE274EE8C95166E
2 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
core/txpool/legacypool/legacypool.go
View file

@ -1569,18 +1569,6 @@ func (pool *LegacyPool) demoteUnexecutables() {
} }
} }
// addressByHeartbeat is an account address tagged with its last activity timestamp.
type addressByHeartbeat struct {
address common.Address
heartbeat time.Time
}
type addressesByHeartbeat []addressByHeartbeat
func (a addressesByHeartbeat) Len() int { return len(a) }
func (a addressesByHeartbeat) Less(i, j int) bool { return a[i].heartbeat.Before(a[j].heartbeat) }
func (a addressesByHeartbeat) Swap(i, j int) { a[i], a[j] = a[j], a[i] }
// accountSet is simply a set of addresses to check for existence, and a signer // accountSet is simply a set of addresses to check for existence, and a signer
// capable of deriving addresses from transactions. // capable of deriving addresses from transactions.
type accountSet struct { type accountSet struct {

12
core/txpool/legacypool/queue.go
View file

@ -240,3 +240,15 @@ func (q *queue) truncate() []common.Hash {
} }
return removed return removed
} }
// addressByHeartbeat is an account address tagged with its last activity timestamp.
type addressByHeartbeat struct {
address common.Address
heartbeat time.Time
}
type addressesByHeartbeat []addressByHeartbeat
func (a addressesByHeartbeat) Len() int { return len(a) }
func (a addressesByHeartbeat) Less(i, j int) bool { return a[i].heartbeat.Before(a[j].heartbeat) }
func (a addressesByHeartbeat) Swap(i, j int) { a[i], a[j] = a[j], a[i] }