From 2ab1822592af721ffea4b9286d84bf67304ae911 Mon Sep 17 00:00:00 2001 From: goshawk Date: Mon, 23 Oct 2023 11:55:23 +0300 Subject: [PATCH] node: Apply new msg IDs. Pass committee size to verify_step_votes. --- node/src/chain.rs | 3 ++- node/src/chain/acceptor.rs | 3 +++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/node/src/chain.rs b/node/src/chain.rs index 6d3999b9a2..bc1954a200 100644 --- a/node/src/chain.rs +++ b/node/src/chain.rs @@ -43,7 +43,8 @@ use self::fsm::SimpleFSM; const TOPICS: &[u8] = &[ Topics::Block as u8, Topics::NewBlock as u8, - Topics::Reduction as u8, + Topics::FirstReduction as u8, + Topics::SecondReduction as u8, Topics::AggrAgreement as u8, Topics::Agreement as u8, ]; diff --git a/node/src/chain/acceptor.rs b/node/src/chain/acceptor.rs index 98b2a6b185..435e3eeb41 100644 --- a/node/src/chain/acceptor.rs +++ b/node/src/chain/acceptor.rs @@ -31,6 +31,7 @@ use tokio::sync::{oneshot, Mutex, RwLock}; use tokio::task::JoinHandle; use tracing::{error, info, warn}; +use dusk_consensus::config; use std::any; use super::consensus::Task; @@ -454,6 +455,7 @@ async fn verify_block_cert( curr_seed, &hdr, 0, + config::FIRST_REDUCTION_COMMITTEE_SIZE, ) .await { @@ -467,6 +469,7 @@ async fn verify_block_cert( curr_seed, &hdr, 1, + config::SECOND_REDUCTION_COMMITTEE_SIZE, ) .await {