[dag] dag rebootstrap

aptos-labs · Sep 11, 2023 · 60eace0 · 60eace0
1 parent 1db0e3f
commit 60eace0
Show file tree

Hide file tree

Showing 11 changed files with 395 additions and 192 deletions.
diff --git a/consensus/src/dag/adapter.rs b/consensus/src/dag/adapter.rs
@@ -33,9 +33,9 @@ use futures_channel::mpsc::UnboundedSender;
 use std::{collections::HashMap, sync::Arc};
 
 #[async_trait]
-pub trait Notifier: Send {
+pub trait Notifier: Send + Sync {
     fn send_ordered_nodes(
-        &mut self,
+        &self,
         ordered_nodes: Vec<Arc<CertifiedNode>>,
         failed_author: Vec<(Round, Author)>,
     ) -> anyhow::Result<()>;
@@ -64,7 +64,7 @@ impl NotifierAdapter {
 #[async_trait]
 impl Notifier for NotifierAdapter {
     fn send_ordered_nodes(
-        &mut self,
+        &self,
         ordered_nodes: Vec<Arc<CertifiedNode>>,
         failed_author: Vec<(Round, Author)>,
     ) -> anyhow::Result<()> {