Skip to content

Commit 29cf08c

Browse files
committed
garbage collect old quorum round values
1 parent bbab939 commit 29cf08c

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

epoch.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2342,7 +2342,7 @@ func (e *Epoch) processReplicationState() error {
23422342
// first we check if we can commit the next sequence
23432343
block, fCert, exists := e.replicationState.GetFinalizedBlockForSequence(nextSeqToCommit)
23442344
if exists {
2345-
// delete(e.replicationState.receivedQuorumRounds, finalizedBlock.Block.BlockHeader().Round)
2345+
delete(e.replicationState.receivedQuorumRounds, block.BlockHeader().Round)
23462346
e.replicationState.maybeCollectFutureSequences(e.round, e.Storage.Height())
23472347
return e.processFinalizedBlock(block, fCert)
23482348
}
@@ -2361,7 +2361,7 @@ func (e *Epoch) processReplicationState() error {
23612361
// TODO: we need to make sure that we do not forget about notarizations missing for rounds < e.round
23622362
notarizedBlock := e.replicationState.GetNotarizedBlockForRound(e.round)
23632363
if notarizedBlock != nil {
2364-
// delete(e.replicationState.receivedQuorumRounds, e.round)
2364+
delete(e.replicationState.receivedQuorumRounds, e.round)
23652365
e.processNotarizedBlock(notarizedBlock)
23662366
}
23672367

@@ -2392,7 +2392,7 @@ func (e *Epoch) maybeAdvanceRoundFromEmptyNotarizations() (bool, error) {
23922392
if err != nil {
23932393
return false, err
23942394
}
2395-
// delete(e.replicationState.receivedQuorumRounds, qRound.GetRound())
2395+
delete(e.replicationState.receivedQuorumRounds, qRound.GetRound())
23962396
return true, nil
23972397
}
23982398

0 commit comments

Comments
 (0)