fd_ledger: add solcap-start-slot

Author: kbhargava-jump

src/app/ledger/main.c

@@ -65,6 +65,7 @@ struct fd_ledger_args {
   char const *          shredcap;                /* path to replay using shredcap instead of rocksdb */
   int                   abort_on_mismatch;       /* determine if execution should abort on mismatch*/
   char const *          capture_fpath;           /* solcap: path for solcap file to be created */
+  ulong                 solcap_start_slot;       /* solcap capture start slot */
   int                   capture_txns;            /* solcap: determine if transaction results should be captured for solcap*/
   char const *          checkpt_path;            /* path to dump funk wksp checkpoints during execution*/
   ulong                 checkpt_freq;            /* how often funk wksp checkpoints will be dumped (defaults to never) */
@@ -679,6 +680,7 @@ fd_ledger_main_setup( fd_ledger_args_t * args ) {
     args->capture_ctx = fd_capture_ctx_new( capture_ctx_mem );
 
     args->capture_ctx->checkpt_freq = ULONG_MAX;
+    args->capture_ctx->solcap_start_slot = args->solcap_start_slot;
 
     if( has_solcap ) {
       capture_file = fopen( args->capture_fpath, "w+" );
@@ -1390,6 +1392,7 @@ initial_setup( int argc, char ** argv, fd_ledger_args_t * args ) {
   char const * checkpt               = fd_env_strip_cmdline_cstr  ( &argc, &argv, "--checkpt",               NULL, NULL                                               );
   char const * checkpt_funk          = fd_env_strip_cmdline_cstr  ( &argc, &argv, "--checkpt-funk",          NULL, NULL                                               );
   char const * capture_fpath         = fd_env_strip_cmdline_cstr  ( &argc, &argv, "--capture-solcap",        NULL, NULL                                               );
+  ulong        solcap_start_slot     = fd_env_strip_cmdline_ulong ( &argc, &argv, "--solcap-start-slot",     NULL, 0                                                  );
   int          capture_txns          = fd_env_strip_cmdline_int   ( &argc, &argv, "--capture-txns",          NULL, 1                                                  );
   char const * checkpt_path          = fd_env_strip_cmdline_cstr  ( &argc, &argv, "--checkpt-path",          NULL, NULL                                               );
   ulong        checkpt_freq          = fd_env_strip_cmdline_ulong ( &argc, &argv, "--checkpt-freq",          NULL, ULONG_MAX                                          );
@@ -1497,6 +1500,7 @@ initial_setup( int argc, char ** argv, fd_ledger_args_t * args ) {
   args->verify_acc_hash         = verify_acc_hash;
   args->trash_hash              = trash_hash;
   args->capture_fpath           = capture_fpath;
+  args->solcap_start_slot       = solcap_start_slot;
   args->capture_txns            = capture_txns;
   args->checkpt_path            = checkpt_path;
   args->checkpt_freq            = checkpt_freq;

src/flamenco/runtime/context/fd_capture_ctx.h

@@ -10,6 +10,7 @@ struct __attribute__((aligned(FD_CAPTURE_CTX_ALIGN))) fd_capture_ctx {
   ulong magic; /* ==FD_CAPTURE_CTX_MAGIC */
 
   /* Solcap */
+  ulong                    solcap_start_slot;
   int                      trace_dirfd;
   int                      trace_mode;
   fd_solcap_writer_t *     capture;

src/flamenco/runtime/fd_hashes.c

@@ -260,7 +260,7 @@ fd_hash_bank( fd_exec_slot_ctx_t *    slot_ctx,
     }
   }
 
-  if( capture_ctx != NULL && capture_ctx->capture != NULL ) {
+  if( capture_ctx != NULL && capture_ctx->capture != NULL && slot_ctx->slot_bank.slot>=capture_ctx->solcap_start_slot ) {
     fd_solcap_write_bank_preimage(
         capture_ctx->capture,
         hash->hash,
@@ -543,7 +543,7 @@ fd_update_hash_bank_exec_hash( fd_exec_slot_ctx_t *           slot_ctx,
                     acc_rec->vt->get_rent_epoch( acc_rec ),
                     acc_rec->vt->get_data_len( acc_rec ) ));
 
-      if( capture_ctx != NULL && capture_ctx->capture != NULL ) {
+      if( capture_ctx != NULL && capture_ctx->capture != NULL && slot_ctx->slot_bank.slot>=capture_ctx->solcap_start_slot ) {
         fd_account_meta_t const * acc_meta = fd_funk_get_acc_meta_readonly( slot_ctx->funk,
                                                                             slot_ctx->funk_txn,
                                                                             task_info->acc_pubkey,

src/flamenco/runtime/fd_runtime.c

@@ -1860,7 +1860,7 @@ fd_runtime_finalize_txn( fd_exec_slot_ctx_t *         slot_ctx,
   int                 exec_txn_err = task_info->exec_res;
 
   /* For ledgers that contain txn status, decode and write out for solcap */
-  if( capture_ctx != NULL && capture_ctx->capture && capture_ctx->capture_txns ) {
+  if( capture_ctx != NULL && capture_ctx->capture && capture_ctx->capture_txns && slot_ctx->slot_bank.slot>=capture_ctx->solcap_start_slot ) {
     fd_runtime_write_transaction_status( capture_ctx, slot_ctx, txn_ctx, exec_txn_err );
   }
   FD_ATOMIC_FETCH_AND_ADD( &slot_ctx->signature_cnt, txn_ctx->txn_descriptor->signature_cnt );
@@ -4080,7 +4080,7 @@ fd_runtime_block_execute_tpool( fd_exec_slot_ctx_t *    slot_ctx,
                                 ulong                   exec_spad_cnt,
                                 fd_spad_t *             runtime_spad ) {
 
-  if ( capture_ctx != NULL && capture_ctx->capture ) {
+  if ( capture_ctx != NULL && capture_ctx->capture && slot_ctx->slot_bank.slot>=capture_ctx->solcap_start_slot ) {
     fd_solcap_writer_set_slot( capture_ctx->capture, slot_ctx->slot_bank.slot );
   }