Skip to content

Commit f72764b

Browse files
authored
ledger: create catchpoint tracker (#3085)
## Summary Extract catchpoint logic out of the accounts update tracker. ## Test Plan Refactor existing unit tests.
1 parent 9b39c66 commit f72764b

18 files changed

+1752
-1478
lines changed

data/pools/transactionPool.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -170,6 +170,9 @@ var ErrStaleBlockAssemblyRequest = fmt.Errorf("AssembleBlock: requested block as
170170

171171
// Reset resets the content of the transaction pool
172172
func (pool *TransactionPool) Reset() {
173+
pool.mu.Lock()
174+
defer pool.mu.Unlock()
175+
defer pool.cond.Broadcast()
173176
pool.pendingTxids = make(map[transactions.Txid]transactions.SignedTxn)
174177
pool.pendingTxGroups = nil
175178
pool.rememberedTxids = make(map[transactions.Txid]transactions.SignedTxn)

ledger/acctupdates.go

Lines changed: 24 additions & 953 deletions
Large diffs are not rendered by default.

0 commit comments

Comments
 (0)