mirror/erigon-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/erigon-pulse.git synced 2025-01-07 11:32:20 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

add state check assert routine

Browse Source
This commit is contained in:
alex.sharov 2021-08-28 14:18:17 +07:00
parent 422abc394b
commit 0e208e5862
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
txpool/pool.go
View File

@ -220,22 +220,27 @@ func (sc *SendersCache) onNewTxs(tx kv.Tx, newTxs TxSlots) (cacheMisses map[uint
if err != nil { if err != nil {
return nil, err return nil, err
} }
if len(cacheMisses) > 0 {
for i, j := range cacheMisses {
fmt.Printf("cache misses: %d,%x\n", i, j)
}
}
return cacheMisses, nil return cacheMisses, nil
} }
func (sc *SendersCache) loadFromCore(coreTx kv.Tx, toLoad map[uint64]string) error { func (sc *SendersCache) loadFromCore(coreTx kv.Tx, toLoad map[uint64]string) error {
diff := make(map[uint64]senderInfo, len(toLoad)) diff := make(map[uint64]*senderInfo, len(toLoad))
for id := range toLoad { for id := range toLoad {
info, err := loadSender(coreTx, []byte(toLoad[id])) info, err := loadSender(coreTx, []byte(toLoad[id]))
if err != nil { if err != nil {
return err return err
} }
diff[id] = *info diff[id] = info
} }
sc.lock.Lock() sc.lock.Lock()
defer sc.lock.Unlock() defer sc.lock.Unlock()
for id := range diff { // merge state changes for id := range diff { // merge state changes
a := diff[id] a := diff[id]
sc.senderInfo[id] = &a sc.senderInfo[id] = a
} }
return nil return nil
} }
@ -682,7 +687,8 @@ func loadSender(coreTx kv.Tx, addr []byte) (*senderInfo, error) {
return nil, err return nil, err
} }
if len(encoded) == 0 { if len(encoded) == 0 {
return newSenderInfo(0, *uint256.NewInt(0)), nil return nil, err
//return newSenderInfo(0, *uint256.NewInt(0)), nil
} }
nonce, balance, err := DecodeSender(encoded) nonce, balance, err := DecodeSender(encoded)
if err != nil { if err != nil {