Skip to content

Commit 05a52e2

Browse files
authored
tests: fix flushing in TestVotersReloadFromDiskAfterOneStateProofCommitted (#6090)
1 parent 8eca278 commit 05a52e2

File tree

1 file changed

+13
-0
lines changed

1 file changed

+13
-0
lines changed

ledger/ledger_test.go

Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2952,6 +2952,19 @@ func testVotersReloadFromDiskAfterOneStateProofCommitted(t *testing.T, cfg confi
29522952
<-l.trackers.commitSyncerClosed
29532953
l.trackers.commitSyncerClosed = nil
29542954

2955+
// it is possible a commmit was scheduled while commitSyncer was closing so that there is one pending task
2956+
// that required to be done before before the ledger can be closed, so drain the queue
2957+
outer:
2958+
for {
2959+
select {
2960+
case <-l.trackers.deferredCommits:
2961+
log.Info("drained deferred commit")
2962+
l.trackers.accountsWriting.Done()
2963+
default:
2964+
break outer
2965+
}
2966+
}
2967+
29552968
// flush one final time
29562969
triggerTrackerFlush(t, l)
29572970

0 commit comments

Comments
 (0)