Method check_precommit_count

src/algorithm.rs:712–747

(&mut self)

    }

    fn check_precommit_count(&mut self) -> i8 {
        if let Some(precommit_set) =
            self.votes
                .get_voteset(self.height, self.round, VoteType::Precommit)
        {
            let mut tv = if self.cal_all_vote(precommit_set.count) {
                Duration::new(0, 0)
            } else {
                self.params.timer.get_precommit()
            };
            if !self.cal_above_threshold(precommit_set.count) {
                return PRECOMMIT_BELOW_TWO_THIRDS;
            }

            info!(
                "Receive over 2/3 precommit at height {:?}, round {:?}",
                self.height, self.round
            );

            for (hash, count) in &precommit_set.votes_by_proposal {
                if self.cal_above_threshold(*count) {
                    if hash.is_empty() {
                        info!("Reach nil consensus, goto next round {:?}", self.round + 1);
                        return PRECOMMIT_ON_NIL;
                    } else {
                        self.set_polc(&hash, &precommit_set, VoteType::Precommit);
                        return PRECOMMIT_ON_PROPOSAL;
                    }
                }
            }
            if self.step == Step::Precommit {
                self.set_timer(tv, Step::PrecommitWait);
            }
        }
        PRECOMMIT_ON_NOTHING
    }

    fn proc_commit(&mut self) {
        let result = self.lock_status.clone().expect("No lock when commit!");