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

don't need to protect Update method

Browse source
This commit is contained in:
maskpp 2025-07-19 16:28:02 +08:00
parent f17df6db91
commit b23d43de3b
1 changed files with 0 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
core/txpool/blobpool/blobpool.go
View file

@ -794,9 +794,7 @@ func (p *BlobPool) offload(addr common.Address, nonce uint64, id uint64, inclusi
// kept in sync with the main transaction pool's internal state. // kept in sync with the main transaction pool's internal state.
func (p *BlobPool) Reset(oldHead, newHead *types.Header) { func (p *BlobPool) Reset(oldHead, newHead *types.Header) {
waitStart := time.Now() waitStart := time.Now()
p.lock.Lock()
resetwaitHist.Update(time.Since(waitStart).Nanoseconds()) resetwaitHist.Update(time.Since(waitStart).Nanoseconds())
defer p.lock.Unlock()
defer func(start time.Time) { defer func(start time.Time) {
resettimeHist.Update(time.Since(start).Nanoseconds()) resettimeHist.Update(time.Since(start).Nanoseconds())
@ -1234,9 +1232,7 @@ func (p *BlobPool) getRLP(hash common.Hash) []byte {
// Track the amount of time waiting to retrieve a fully resolved blob tx from // Track the amount of time waiting to retrieve a fully resolved blob tx from
// the pool and the amount of time actually spent on pulling the data from disk. // the pool and the amount of time actually spent on pulling the data from disk.
getStart := time.Now() getStart := time.Now()
p.lock.RLock()
getwaitHist.Update(time.Since(getStart).Nanoseconds()) getwaitHist.Update(time.Since(getStart).Nanoseconds())
defer p.lock.RUnlock()
defer func(start time.Time) { defer func(start time.Time) {
gettimeHist.Update(time.Since(start).Nanoseconds()) gettimeHist.Update(time.Since(start).Nanoseconds())
@ -1372,9 +1368,7 @@ func (p *BlobPool) add(tx *types.Transaction) (err error) {
// only even pulled from the network, so this method will act as the overload // only even pulled from the network, so this method will act as the overload
// protection for fetches. // protection for fetches.
waitStart := time.Now() waitStart := time.Now()
p.lock.Lock()
addwaitHist.Update(time.Since(waitStart).Nanoseconds()) addwaitHist.Update(time.Since(waitStart).Nanoseconds())
defer p.lock.Unlock()
defer func(start time.Time) { defer func(start time.Time) {
addtimeHist.Update(time.Since(start).Nanoseconds()) addtimeHist.Update(time.Since(start).Nanoseconds())
@ -1602,9 +1596,7 @@ func (p *BlobPool) Pending(filter txpool.PendingFilter) map[common.Address][]*tx
// The latter will be pretty much moot, but we've kept it to have symmetric // The latter will be pretty much moot, but we've kept it to have symmetric
// across all user operations. // across all user operations.
pendStart := time.Now() pendStart := time.Now()
p.lock.RLock()
pendwaitHist.Update(time.Since(pendStart).Nanoseconds()) pendwaitHist.Update(time.Since(pendStart).Nanoseconds())
defer p.lock.RUnlock()
execStart := time.Now() execStart := time.Now()
defer func() { defer func() {