|
|
@ -90,9 +90,11 @@ func (tracker *TxTracker) TrackAll(txs []*types.Transaction) { |
|
|
|
tracker.byAddr[addr] = legacypool.NewSortedMap() |
|
|
|
tracker.byAddr[addr] = legacypool.NewSortedMap() |
|
|
|
} |
|
|
|
} |
|
|
|
tracker.byAddr[addr].Put(tx) |
|
|
|
tracker.byAddr[addr].Put(tx) |
|
|
|
|
|
|
|
if tracker.journal != nil { |
|
|
|
_ = tracker.journal.insert(tx) |
|
|
|
_ = tracker.journal.insert(tx) |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// recheck checks and returns any transactions that needs to be resubmitted.
|
|
|
|
// recheck checks and returns any transactions that needs to be resubmitted.
|
|
|
|
func (tracker *TxTracker) recheck(journalCheck bool) (resubmits []*types.Transaction, rejournal map[common.Address]types.Transactions) { |
|
|
|
func (tracker *TxTracker) recheck(journalCheck bool) (resubmits []*types.Transaction, rejournal map[common.Address]types.Transactions) { |
|
|
|