fix: send query votes message, if there is no proposal yet

pactus-project · Oct 2, 2023 · 5ee737a · 5ee737a
1 parent 6b66ab0
commit 5ee737a
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/consensus/consensus.go b/consensus/consensus.go
@@ -661,6 +661,11 @@ func (cs *consensus) queryProposal() {
 		message.NewQueryProposalMessage(cs.height, cs.round))
 }
 
+func (cs *consensus) queryVotes() {
+	cs.broadcaster(cs.valKey.Address(),
+		message.NewQueryVotesMessage(cs.height, cs.round))
+}
+
 func (cs *consensus) broadcastProposal(p *proposal.Proposal) {
 	go cs.mediator.OnPublishProposal(cs, p)
 	cs.broadcaster(cs.valKey.Address(),

diff --git a/consensus/prepare.go b/consensus/prepare.go
@@ -65,6 +65,7 @@ func (s *prepareState) onTimeout(t *ticker) {
 		roundProposal := s.log.RoundProposal(s.round)
 		if roundProposal == nil {
 			s.queryProposal()
+			s.queryVotes()
 		}
 	} else if t.Target == tickerTargetChangeProposer {
 		s.startChangingProposer()