From b023a7eea1f59a286a11675c093028474f5f44a1 Mon Sep 17 00:00:00 2001 From: goshawk Date: Mon, 27 Nov 2023 15:26:31 +0200 Subject: [PATCH] node: Remove AggrAgreement usage --- node/src/chain.rs | 4 +--- node/src/chain/acceptor.rs | 2 +- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/node/src/chain.rs b/node/src/chain.rs index 1d9d9ae2a0..e8d376657e 100644 --- a/node/src/chain.rs +++ b/node/src/chain.rs @@ -48,7 +48,6 @@ const TOPICS: &[u8] = &[ Topics::NewBlock as u8, Topics::FirstReduction as u8, Topics::SecondReduction as u8, - Topics::AggrAgreement as u8, Topics::Agreement as u8, ]; @@ -179,8 +178,7 @@ impl // Re-route message to the acceptor Payload::NewBlock(_) | Payload::Reduction(_) - | Payload::Agreement(_) - | Payload::AggrAgreement(_) => { + | Payload::Agreement(_) => { acc.read().await.reroute_msg(msg).await; } _ => warn!("invalid inbound message"), diff --git a/node/src/chain/acceptor.rs b/node/src/chain/acceptor.rs index b74fbde32d..dac26ee251 100644 --- a/node/src/chain/acceptor.rs +++ b/node/src/chain/acceptor.rs @@ -111,7 +111,7 @@ impl Acceptor { Payload::NewBlock(_) | Payload::Reduction(_) => { self.task.read().await.main_inbound.send(msg).await; } - Payload::Agreement(_) | Payload::AggrAgreement(_) => { + Payload::Agreement(_) => { self.task.read().await.agreement_inbound.send(msg).await; } _ => warn!("invalid inbound message"),