Skip to content

Commit

Permalink
node: Remove AggrAgreement usage
Browse files Browse the repository at this point in the history
  • Loading branch information
goshawk authored and goshawk-3 committed Nov 27, 2023
1 parent 25cfe16 commit b023a7e
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
4 changes: 1 addition & 3 deletions node/src/chain.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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,
];

Expand Down Expand Up @@ -179,8 +178,7 @@ impl<N: Network, DB: database::DB, VM: vm::VMExecution>
// 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"),
Expand Down
2 changes: 1 addition & 1 deletion node/src/chain/acceptor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -111,7 +111,7 @@ impl<DB: database::DB, VM: vm::VMExecution, N: Network> Acceptor<N, DB, VM> {
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"),
Expand Down

0 comments on commit b023a7e

Please sign in to comment.