[dag] e2e decoupled payload integration

aptos-labs · Feb 21, 2024 · 82d3dbd · 82d3dbd
1 parent 378cacd
commit 82d3dbd
Show file tree

Hide file tree

Showing 14 changed files with 454 additions and 107 deletions.
diff --git a/consensus/src/dag/adapter.rs b/consensus/src/dag/adapter.rs
@@ -4,6 +4,7 @@
 use super::{
     dag_store::DagStore,
     observability::counters::{NUM_NODES_PER_BLOCK, NUM_ROUNDS_PER_BLOCK},
+    payload::DagPayloadStore,
     types::DagPayload,
     NodeMessage,
 };
@@ -97,6 +98,7 @@ pub(crate) fn compute_initial_block_and_ledger_info(
 pub(super) struct OrderedNotifierAdapter {
     executor_channel: UnboundedSender<OrderedBlocks>,
     dag: Arc<DagStore>,
+    payload_store: Arc<DagPayloadStore>,
     parent_block_info: Arc<RwLock<BlockInfo>>,
     epoch_state: Arc<EpochState>,
     ledger_info_provider: Arc<RwLock<LedgerInfoProvider>>,
@@ -107,13 +109,15 @@ impl OrderedNotifierAdapter {
     pub(super) fn new(
         executor_channel: UnboundedSender<OrderedBlocks>,
         dag: Arc<DagStore>,
+        payload_store: Arc<DagPayloadStore>,
         epoch_state: Arc<EpochState>,
         parent_block_info: BlockInfo,
         ledger_info_provider: Arc<RwLock<LedgerInfoProvider>>,
     ) -> Self {
         Self {
             executor_channel,
             dag,
+            payload_store,
             parent_block_info: Arc::new(RwLock::new(parent_block_info)),
             epoch_state,
             ledger_info_provider,