[dag] dag rebootstrap

aptos-labs · Sep 7, 2023 · b00b863 · b00b863
1 parent 7e41139
commit b00b863
Show file tree

Hide file tree

Showing 10 changed files with 416 additions and 188 deletions.
diff --git a/consensus/src/dag/adapter.rs b/consensus/src/dag/adapter.rs
@@ -22,9 +22,9 @@ use futures_channel::mpsc::UnboundedSender;
 use std::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<()>;
@@ -54,7 +54,7 @@ impl NotificationAdapter {
 #[async_trait]
 impl Notifier for NotificationAdapter {
     fn send_ordered_nodes(
-        &mut self,
+        &self,
         ordered_nodes: Vec<Arc<CertifiedNode>>,
         failed_author: Vec<(Round, Author)>,
     ) -> anyhow::Result<()> {