mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-18 18:02:24 +00:00
Merge 70c1f89caf into f9c456e02d
This commit is contained in:
commit
4a31d4e63c
1 changed files with 3 additions and 3 deletions
|
|
@ -652,8 +652,8 @@ func (pool *TxPool) add(tx *types.Transaction, local bool) (bool, error) {
|
||||||
|
|
||||||
log.Trace("Pooled new executable transaction", "hash", hash, "from", from, "to", tx.To())
|
log.Trace("Pooled new executable transaction", "hash", hash, "from", from, "to", tx.To())
|
||||||
|
|
||||||
// We've directly injected a replacement transaction, notify subsystems
|
// We've directly injected a replacement transaction, notify subsystems.
|
||||||
go pool.txFeed.Send(TxPreEvent{tx})
|
pool.txFeed.Send(TxPreEvent{tx})
|
||||||
|
|
||||||
return old != nil, nil
|
return old != nil, nil
|
||||||
}
|
}
|
||||||
|
|
@ -747,7 +747,7 @@ func (pool *TxPool) promoteTx(addr common.Address, hash common.Hash, tx *types.T
|
||||||
pool.beats[addr] = time.Now()
|
pool.beats[addr] = time.Now()
|
||||||
pool.pendingState.SetNonce(addr, tx.Nonce()+1)
|
pool.pendingState.SetNonce(addr, tx.Nonce()+1)
|
||||||
|
|
||||||
go pool.txFeed.Send(TxPreEvent{tx})
|
pool.txFeed.Send(TxPreEvent{tx})
|
||||||
}
|
}
|
||||||
|
|
||||||
// AddLocal enqueues a single transaction into the pool if it is valid, marking
|
// AddLocal enqueues a single transaction into the pool if it is valid, marking
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue