diff --git a/consensus/src/ratification/handler.rs b/consensus/src/ratification/handler.rs index 716d01ca45..a30107adbd 100644 --- a/consensus/src/ratification/handler.rs +++ b/consensus/src/ratification/handler.rs @@ -112,7 +112,7 @@ impl MsgHandler for RatificationHandler { Ok(HandleMsgOutput::Pending) } - /// Collects the reduction message from former iteration. + /// Collects the ratification message from former iteration. async fn collect_from_past( &mut self, msg: Message, @@ -121,7 +121,7 @@ impl MsgHandler for RatificationHandler { ) -> Result { let p = Self::unwrap_msg(msg)?; - // Collect vote, if msg payload is reduction type + // Collect vote, if msg payload is ratification type if let Some((sv, quorum_reached)) = self.aggregator.collect_vote( committee, p.header(), diff --git a/consensus/src/validation/handler.rs b/consensus/src/validation/handler.rs index 1b6668cfc3..01335a525f 100644 --- a/consensus/src/validation/handler.rs +++ b/consensus/src/validation/handler.rs @@ -65,7 +65,7 @@ impl ValidationHandler { #[async_trait] impl MsgHandler for ValidationHandler { - /// Verifies if a msg is a valid reduction message. + /// Verifies if a msg is a valid validation message. fn verify( &self, msg: &Message, @@ -83,7 +83,7 @@ impl MsgHandler for ValidationHandler { Ok(()) } - /// Collects the reduction message. + /// Collects the validation message. async fn collect( &mut self, msg: Message, @@ -103,7 +103,7 @@ impl MsgHandler for ValidationHandler { return Ok(HandleMsgOutput::Pending); } - // Collect vote, if msg payload is reduction type + // Collect vote, if msg payload is validation type if let Some((sv, quorum_reached)) = self.aggr.collect_vote( committee, p.header(), @@ -138,7 +138,7 @@ impl MsgHandler for ValidationHandler { Ok(HandleMsgOutput::Pending) } - /// Collects the reduction message from former iteration. + /// Collects the validation message from former iteration. async fn collect_from_past( &mut self, msg: Message, @@ -147,7 +147,7 @@ impl MsgHandler for ValidationHandler { ) -> Result { let p = Self::unwrap_msg(msg)?; - // Collect vote, if msg payload is reduction type + // Collect vote, if msg payload is validation type if let Some((sv, quorum_reached)) = self.aggr.collect_vote( committee, p.header(),