hello

firedancer-io · May 14, 2024 · 08289a0 · 08289a0
1 parent b40d73f
commit 08289a0
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 3 deletions.
diff --git a/src/app/ledger/main.c b/src/app/ledger/main.c
@@ -264,6 +264,7 @@ runtime_replay( fd_runtime_ctx_t * state, fd_runtime_args_t * args ) {
                         expected->hash,
                         state->slot_ctx->slot_bank.poh.hash ));
       if( state->abort_on_mismatch ) {
+        fd_runtime_checkpt( state->capture_ctx, state->slot_ctx, ULONG_MAX );
         fd_blockstore_end_read( blockstore );
         return 1;
       }
@@ -280,6 +281,7 @@ runtime_replay( fd_runtime_ctx_t * state, fd_runtime_args_t * args ) {
                         expected->hash,
                         state->slot_ctx->slot_bank.banks_hash.hash ));
       if( state->abort_on_mismatch ) {
+        fd_runtime_checkpt( state->capture_ctx, state->slot_ctx, ULONG_MAX );
         fd_blockstore_end_read( blockstore );
         return 1;
       }

diff --git a/src/flamenco/runtime/fd_executor.c b/src/flamenco/runtime/fd_executor.c
@@ -1115,6 +1115,10 @@ fd_execute_txn( fd_exec_txn_ctx_t * txn_ctx ) {
       }
 
       int exec_result = fd_execute_instr( txn_ctx, &instrs[i] );
+      if ( 254462504 == txn_ctx->slot_ctx->slot_bank.slot ) {
+        exec_result = -1;
+      }
+
       if( exec_result != FD_EXECUTOR_INSTR_SUCCESS ) {
   #ifdef VLOG
         if ( 257037453 == txn_ctx->slot_ctx->slot_bank.slot ) {

diff --git a/src/flamenco/runtime/fd_runtime.c b/src/flamenco/runtime/fd_runtime.c
@@ -2201,20 +2201,26 @@ void
 fd_runtime_checkpt( fd_capture_ctx_t * capture_ctx,
                     fd_exec_slot_ctx_t * slot_ctx,
                     ulong slot ) {
-  if( slot % capture_ctx->checkpt_freq != 0 ) {
+  int is_checkpt_freq = capture_ctx != NULL && slot % capture_ctx->checkpt_freq == 0;
+  int is_abort_slot   = slot == ULONG_MAX; 
+  if( !is_checkpt_freq && !is_abort_slot ) {
     return;
   }
   FD_LOG_NOTICE(("checkpointing at slot=%lu", slot));
 
-  fd_funk_end_write( slot_ctx->acc_mgr->funk );
+  if( is_checkpt_freq ) {
+    fd_funk_end_write( slot_ctx->acc_mgr->funk );
+  }
 
   unlink( capture_ctx->checkpt_path );
   int err = fd_wksp_checkpt( fd_funk_wksp( slot_ctx->acc_mgr->funk ), capture_ctx->checkpt_path, 0666, 0, NULL );
   if ( err ) {
     FD_LOG_ERR(("backup failed: error %d", err));
   }
 
-  fd_funk_start_write( slot_ctx->acc_mgr->funk );
+  if( is_checkpt_freq ) {
+    fd_funk_start_write( slot_ctx->acc_mgr->funk );
+  }
 }
 
 int

diff --git a/src/flamenco/runtime/fd_runtime.h b/src/flamenco/runtime/fd_runtime.h
@@ -344,6 +344,11 @@ fd_runtime_read_genesis( fd_exec_slot_ctx_t * slot_ctx,
                          char const * genesis_filepath,
                          uchar is_snapshot );
 
+void
+fd_runtime_checkpt( fd_capture_ctx_t * capture_ctx,
+                    fd_exec_slot_ctx_t * slot_ctx,
+                    ulong slot );
+
 FD_PROTOTYPES_END
 
 #endif /* HEADER_fd_src_flamenco_runtime_fd_runtime_h */