mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-06 02:52:19 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

save

Browse Source
This commit is contained in:
alex.sharov 2021-08-21 08:49:05 +07:00
parent b88f142291
commit 4c765516ba
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
txpool/pool.go
View File

@ -185,6 +185,8 @@ func (sc *SendersCache) onNewTxs(coreDBTx kv.Tx, newTxs TxSlots) error {
func (sc *SendersCache) onNewBlock(coreDBTx kv.Tx, stateChanges map[string]senderInfo, unwindTxs, minedTxs TxSlots, blockHeight uint64) error { func (sc *SendersCache) onNewBlock(coreDBTx kv.Tx, stateChanges map[string]senderInfo, unwindTxs, minedTxs TxSlots, blockHeight uint64) error {
//TODO: if see non-continuous block heigh - drop cache and reload from db //TODO: if see non-continuous block heigh - drop cache and reload from db
sc.blockHeight.Store(blockHeight) sc.blockHeight.Store(blockHeight)
//`loadSenders` goes by network to core - and it must be outside of SendersCache lock. But other methods must be locked
sc.mergeStateChanges(stateChanges, unwindTxs, minedTxs) sc.mergeStateChanges(stateChanges, unwindTxs, minedTxs)
toLoad := sc.setTxSenderID(unwindTxs) toLoad := sc.setTxSenderID(unwindTxs)
diff, err := loadSenders(coreDBTx, toLoad) diff, err := loadSenders(coreDBTx, toLoad)
@ -312,7 +314,6 @@ type TxPool struct {
// fields for transaction propagation // fields for transaction propagation
recentlyConnectedPeers *recentlyConnectedPeers recentlyConnectedPeers *recentlyConnectedPeers
newTxs chan Hashes newTxs chan Hashes
//lastTxPropagationTimestamp time.Time
} }
func New(newTxs chan Hashes, db kv.RwDB) (*TxPool, error) { func New(newTxs chan Hashes, db kv.RwDB) (*TxPool, error) {