Skip to content

Commit 7f5aedb

Browse files
authored
fix(consensus): schedule timeout to retry querying for the proposal or votes (#1698)
1 parent c159188 commit 7f5aedb

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

consensus/prepare.go

+4
Original file line numberDiff line numberDiff line change
@@ -68,6 +68,10 @@ func (s *prepareState) onTimeout(ticker *ticker) {
6868
if s.isProposer() {
6969
s.queryVote()
7070
}
71+
72+
// Schedule another timeout to retry querying for the proposal or votes.
73+
// This ensures that delayed or missing data doesn't cause the process to stall.
74+
s.scheduleTimeout(ticker.Duration*2, s.height, s.round, tickerTargetQueryProposal)
7175
} else if ticker.Target == tickerTargetChangeProposer {
7276
s.startChangingProposer()
7377
}

0 commit comments

Comments
 (0)