wip

Author: mjain-jump

src/discof/replay/fd_replay_tile.c

@@ -19,6 +19,8 @@
 #include "../../flamenco/leaders/fd_multi_epoch_leaders.h"
 #include "../../disco/metrics/fd_metrics.h"
 
+#include "../../flamenco/runtime/tests/fd_dump_pb.h"
+
 #include <errno.h>
 
 /* Replay concepts:
@@ -371,7 +373,6 @@ FD_FN_CONST static inline ulong
 scratch_align( void ) {
   return 128UL;
 }
-
 FD_FN_PURE static inline ulong
 scratch_footprint( fd_topo_tile_t const * tile ) {
   ulong chain_cnt = fd_block_id_map_chain_cnt_est( tile->replay.max_live_slots );
@@ -789,6 +790,37 @@ replay_block_finalize( fd_replay_tile_t *  ctx,
   }
 
   fd_bank_hash_cmp_unlock( bank_hash_cmp );
+
+  /* Block dumping */
+  if( FD_LIKELY( !ctx->capture_ctx->dump_block_to_pb ) ) return;
+
+  /* Get the bank for the parent slot */
+  fd_bank_t * parent_bank = fd_banks_get_parent( ctx->banks, bank );
+  if( FD_UNLIKELY( !parent_bank ) ) {
+    FD_LOG_WARNING(( "Could not find parent bank for bank %lu", bank_idx ));
+    return;
+  }
+
+  /* Get the parent funk txn xid */
+  ulong parent_slot = fd_bank_slot_get( parent_bank );
+  fd_funk_txn_xid_t parent_xid = { .ul = { parent_slot, parent_slot } };
+  fd_funk_txn_t * parent_txn = fd_funk_txn_query( &parent_xid, ctx->funk->txn_map );
+  if( FD_UNLIKELY( !parent_txn ) ) {
+    FD_LOG_WARNING(( "Could not find parent funk txn for bank %lu", bank_idx ));
+    return;
+  }
+
+  /* Fetch all transactions from the block
+     TODO: Implement this */
+  fd_block_id_ele_t * block_id_ele       = &ctx->block_id_arr[ bank->parent_idx ];
+  fd_hash_t *         parent_merkle_root = &block_id_ele->block_id;
+  fd_reasm_fec_t *    parent_fec         = fd_reasm_query( ctx->reasm, parent_merkle_root );
+  FD_TEST( parent_fec ); // TODO: delete
+  // fd_sched_block_t * block = block_pool_ele( ctx->sched, fec->bank_idx );
+
+
+  /* Dump the block to pb */
+  fd_dump_block_to_protobuf( ctx->banks, parent_bank, ctx->funk, &parent_xid, ctx->capture_ctx, ctx->runtime_spad );
 }
 
 /**********************************************************************/

src/flamenco/runtime/tests/fd_dump_pb.c

@@ -951,12 +951,13 @@ fd_dump_block_to_protobuf( fd_banks_t *                   banks,
                            fd_capture_ctx_t const *       capture_ctx,
                            fd_spad_t *                    spad,
                            fd_exec_test_block_context_t * block_context_msg /* output */ ) {
-  /* No spad frame because these allocations must persist beyond the lifetime of this function call */
-  if( FD_UNLIKELY( capture_ctx==NULL ) ) {
-    FD_LOG_WARNING(( "Capture context may not be NULL when dumping blocks." ));
-    return;
-  }
-  create_block_context_protobuf_from_block( block_context_msg, banks, bank, funk, xid, spad );
+  FD_SPAD_FRAME_BEGIN( spad ) {
+    if( FD_UNLIKELY( capture_ctx==NULL ) ) {
+      FD_LOG_WARNING(( "Capture context may not be NULL when dumping blocks." ));
+      return;
+    }
+    create_block_context_protobuf_from_block( block_context_msg, banks, bank, funk, xid, spad );
+  } FD_SPAD_FRAME_END;
 }
 
 void