flamenco, choreo, app: integrate new Funkier

Author: topointon-jump

src/app/fdctl/topos/fd_firedancer.c

@@ -302,7 +302,7 @@ fd_topo_initialize( config_t * config ) {
   /**/                 fd_topob_link( topo, "rstart_gossi", "rstart_gossi", 128UL,                                    4UL + 128UL + 8192UL,          1UL );
   /**/                 fd_topob_link( topo, "gossi_rstart", "gossi_rstart", 128UL,                                    4UL + 128UL + 8192UL,          1UL );
   /**/                 fd_topob_link( topo, "rstart_store", "rstart_store", 128UL,                                    sizeof(ulong) * 2,             1UL );
-  /**/                 fd_topob_link( topo, "store_rstart", "store_rstart", 128UL,                                    sizeof(fd_funk_txn_xid_t),     1UL );
+  /**/                 fd_topob_link( topo, "store_rstart", "store_rstart", 128UL,                                    sizeof(fd_funkier_txn_xid_t),     1UL );
 
   ushort parsed_tile_to_cpu[ FD_TILE_MAX ];
   /* Unassigned tiles will be floating, unless auto topology is enabled. */

src/app/ledger/main.c

@@ -14,7 +14,7 @@
 #include "../../flamenco/fd_flamenco.h"
 #include "../../flamenco/nanopb/pb_decode.h"
 #include "../../flamenco/runtime/fd_hashes.h"
-#include "../../funk/fd_funk_filemap.h"
+#include "../../funkier/fd_funkier_filemap.h"
 #include "../../flamenco/types/fd_types.h"
 #include "../../flamenco/runtime/fd_runtime.h"
 #include "../../flamenco/runtime/fd_runtime_public.h"
@@ -38,7 +38,7 @@ struct fd_ledger_args {
   fd_wksp_t *           status_cache_wksp;       /* wksp for status cache. */
   fd_blockstore_t       blockstore_ljoin;
   fd_blockstore_t *     blockstore;              /* blockstore for replay */
-  fd_funk_t *           funk;                    /* handle to funk */
+  fd_funkier_t *           funk;                    /* handle to funk */
   fd_alloc_t *          alloc;                   /* handle to alloc */
   char const *          cmd;                     /* user passed command to fd_ledger */
   ulong                 start_slot;              /* start slot for offline replay */
@@ -56,7 +56,7 @@ struct fd_ledger_args {
   ulong                 index_max;               /* size of funk index (same as rec max) */
   char const *          funk_file;               /* path to funk backing store */
   ulong                 funk_page_cnt;
-  fd_funk_close_file_args_t funk_close_args;
+  fd_funkier_close_file_args_t funk_close_args;
   char const *          snapshot;                /* path to agave snapshot */
   char const *          incremental;             /* path to agave incremental snapshot */
   char const *          genesis;                 /* path to agave genesis */
@@ -664,7 +664,6 @@ allocator_setup( fd_wksp_t * wksp ) {
 void
 fd_ledger_main_setup( fd_ledger_args_t * args ) {
   fd_flamenco_boot( NULL, NULL );
-  fd_funk_t * funk = args->funk;
 
   /* Setup capture context */
   int has_solcap           = args->capture_fpath && args->capture_fpath[0] != '\0';
@@ -720,9 +719,7 @@ fd_ledger_main_setup( fd_ledger_args_t * args ) {
   fd_runtime_update_leaders( args->slot_ctx, args->slot_ctx->slot_bank.slot, args->runtime_spad );
   fd_calculate_epoch_accounts_hash_values( args->slot_ctx );
 
-  fd_funk_start_write( funk );
   fd_bpf_scan_and_create_bpf_program_cache_entry_tpool( args->slot_ctx, args->slot_ctx->funk_txn, args->tpool, args->runtime_spad );
-  fd_funk_end_write( funk );
 
   /* First, load in the sysvars into the sysvar cache. This is required to
       make the StakeHistory sysvar available to the rewards calculation. */
@@ -902,21 +899,20 @@ parse_rocksdb_list( fd_ledger_args_t * args,
 
 void
 init_funk( fd_ledger_args_t * args ) {
-  fd_funk_t * funk;
+  fd_funkier_t * funk;
   if( args->restore_funk ) {
-    funk = fd_funk_recover_checkpoint( args->funk_file, 1, args->restore_funk, &args->funk_close_args );
+    funk = fd_funkier_recover_checkpoint( args->funk_file, 1, args->restore_funk, &args->funk_close_args );
   } else  {
-    funk = fd_funk_open_file( args->funk_file, 1, args->hashseed, args->txns_max, args->index_max, args->funk_page_cnt*(1UL<<30), FD_FUNK_OVERWRITE, &args->funk_close_args );
+    funk = fd_funkier_open_file( args->funk_file, 1, args->hashseed, args->txns_max, args->index_max, args->funk_page_cnt*(1UL<<30), FD_FUNKIER_OVERWRITE, &args->funk_close_args );
   }
   args->funk = funk;
-  args->funk_wksp = fd_funk_wksp( funk );
-  FD_LOG_NOTICE(( "funky at global address 0x%016lx with %lu records", fd_wksp_gaddr_fast( args->funk_wksp, funk ),
-                                                                       fd_funk_rec_cnt( fd_funk_rec_map( funk, args->funk_wksp ) ) ));
+  args->funk_wksp = fd_funkier_wksp( funk );
+  FD_LOG_NOTICE(( "funky at global address 0x%016lx", fd_wksp_gaddr_fast( args->funk_wksp, funk ) ));
 }
 
 void
 cleanup_funk( fd_ledger_args_t * args ) {
-  fd_funk_close_file( &args->funk_close_args );
+  fd_funkier_close_file( &args->funk_close_args );
 }
 
 void
@@ -958,13 +954,7 @@ checkpt( fd_ledger_args_t * args ) {
     }
     FD_LOG_NOTICE(( "writing funk checkpt %s", args->checkpt_funk ));
     unlink( args->checkpt_funk );
-#ifdef FD_FUNK_WKSP_PROTECT
-    fd_wksp_mprotect( args->funk_wksp, 0 );
-#endif
     int err = fd_wksp_checkpt( args->funk_wksp, args->checkpt_funk, 0666, 0, NULL );
-#ifdef FD_FUNK_WKSP_PROTECT
-    fd_wksp_mprotect( args->funk_wksp, 1 );
-#endif
     if( err ) {
       FD_LOG_ERR(( "funk checkpt failed: error %d", err ));
     }
@@ -1085,7 +1075,7 @@ ingest( fd_ledger_args_t * args ) {
 
   fd_spad_t * spad = args->runtime_spad;
 
-  fd_funk_t * funk = args->funk;
+  fd_funkier_t * funk = args->funk;
 
   args->valloc = allocator_setup( args->wksp );
   uchar * epoch_ctx_mem = fd_spad_alloc( spad, fd_exec_epoch_ctx_align(), fd_exec_epoch_ctx_footprint( args->vote_acct_max ) );
@@ -1129,7 +1119,7 @@ ingest( fd_ledger_args_t * args ) {
                           args->exec_spads,
                           args->exec_spad_cnt,
                           args->runtime_spad );
-    FD_LOG_NOTICE(( "imported %lu records from snapshot", fd_funk_rec_cnt( fd_funk_rec_map( funk, fd_funk_wksp( funk ) ) ) ));
+    FD_LOG_NOTICE(( "imported records from snapshot" ));
   }
   if( args->incremental ) {
     fd_snapshot_load_all( args->incremental,
@@ -1142,7 +1132,7 @@ ingest( fd_ledger_args_t * args ) {
                           args->exec_spads,
                           args->exec_spad_cnt,
                           args->runtime_spad );
-    FD_LOG_NOTICE(( "imported %lu records from incremental snapshot", fd_funk_rec_cnt( fd_funk_rec_map( funk, fd_funk_wksp( funk ) ) ) ));
+    FD_LOG_NOTICE(( "imported records from incremental snapshot" ));
   }
 
   if( args->genesis ) {
@@ -1185,12 +1175,14 @@ ingest( fd_ledger_args_t * args ) {
     }
   }
 
+#ifdef FD_FUNKIER_HANDHOLDING
   if( args->verify_funk ) {
     FD_LOG_NOTICE(( "verifying funky" ));
-    if( fd_funk_verify( funk ) ) {
+    if( fd_funkier_verify( funk ) ) {
       FD_LOG_ERR(( "verification failed" ));
     }
   }
+#endif
 
   checkpt( args );
 
@@ -1259,7 +1251,7 @@ replay( fd_ledger_args_t * args ) {
 
 
   /* Setup slot_ctx */
-  fd_funk_t * funk = args->funk;
+  fd_funkier_t * funk = args->funk;
 
   void * epoch_ctx_mem = fd_spad_alloc( spad, FD_EXEC_EPOCH_CTX_ALIGN, fd_exec_epoch_ctx_footprint( args->vote_acct_max ) );
   fd_memset( epoch_ctx_mem, 0, fd_exec_epoch_ctx_footprint( args->vote_acct_max ) );
@@ -1304,22 +1296,19 @@ replay( fd_ledger_args_t * args ) {
   /* Check number of records in funk. If rec_cnt == 0, then it can be assumed
      that you need to load in snapshot(s). */
 
-  ulong rec_cnt = fd_funk_rec_cnt( fd_funk_rec_map( funk, fd_funk_wksp( funk ) ) );
-  if( !rec_cnt ) {
-    /* Load in snapshot(s) */
-    if( args->snapshot ) {
-      fd_snapshot_load_all( args->snapshot,
-                            args->slot_ctx,
-                            NULL,
-                            args->tpool,
-                            args->verify_acc_hash,
-                            args->check_acc_hash,
-                            FD_SNAPSHOT_TYPE_FULL,
-                            args->exec_spads,
-                            args->exec_spad_cnt,
-                            args->runtime_spad );
-      FD_LOG_NOTICE(( "imported %lu records from snapshot", fd_funk_rec_cnt( fd_funk_rec_map( funk, fd_funk_wksp( funk ) ) ) ));
-    }
+  /* Load in snapshot(s) */
+  if( args->snapshot ) {
+    fd_snapshot_load_all( args->snapshot,
+                          args->slot_ctx,
+                          NULL,
+                          args->tpool,
+                          args->verify_acc_hash,
+                          args->check_acc_hash,
+                          FD_SNAPSHOT_TYPE_FULL,
+                          args->exec_spads,
+                          args->exec_spad_cnt,
+                          args->runtime_spad );
+    FD_LOG_NOTICE(( "imported from snapshot" ));
     if( args->incremental ) {
       fd_snapshot_load_all( args->incremental,
                             args->slot_ctx,
@@ -1331,13 +1320,11 @@ replay( fd_ledger_args_t * args ) {
                             args->exec_spads,
                             args->exec_spad_cnt,
                             args->runtime_spad );
-      FD_LOG_NOTICE(( "imported %lu records from snapshot", fd_funk_rec_cnt( fd_funk_rec_map( funk, fd_funk_wksp( funk ) ) ) ));
-    }
-    if( args->genesis ) {
-      fd_runtime_read_genesis( args->slot_ctx, args->genesis, args->snapshot != NULL, NULL, args->tpool, args->runtime_spad );
+      FD_LOG_NOTICE(( "imported from snapshot" ));
     }
-  } else {
-    FD_LOG_NOTICE(( "found funk with %lu records", rec_cnt ));
+  }
+  if( args->genesis ) {
+    fd_runtime_read_genesis( args->slot_ctx, args->genesis, args->snapshot != NULL, NULL, args->tpool, args->runtime_spad );
   }
 
   FD_LOG_NOTICE(( "Used memory in spad after loading in snapshot %lu", args->runtime_spad->mem_used ));

src/app/rpcserver/main.c

@@ -1,8 +1,5 @@
 #define _DEFAULT_SOURCE
 
-#include "../../discof/rpcserver/fd_rpc_service.h"
-#include "../../funk/fd_funk_filemap.h"
-
 #include <fcntl.h>
 #include <stdio.h>
 #include <stdlib.h>
@@ -13,6 +10,8 @@
 #include <sys/socket.h>
 #include <netinet/in.h>
 #include <arpa/inet.h>
+#include "../../discof/rpcserver/fd_rpc_service.h"
+#include "../../funkier/fd_funkier_filemap.h"
 
 #define SHAM_LINK_CONTEXT fd_rpc_ctx_t
 #define SHAM_LINK_STATE   fd_replay_notif_msg_t
@@ -33,7 +32,7 @@ init_args( int * argc, char *** argv, fd_rpcserver_args_t * args ) {
   char const * funk_file = fd_env_strip_cmdline_cstr( argc, argv, "--funk-file", NULL, NULL );
   if( FD_UNLIKELY( !funk_file ))
     FD_LOG_ERR(( "--funk-file argument is required" ));
-  args->funk = fd_funk_open_file( funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
+  args->funk = fd_funkier_open_file( funk_file, 1, 0, 0, 0, 0, FD_FUNKIER_READONLY, NULL );
   if( args->funk == NULL ) {
     FD_LOG_ERR(( "failed to join a funky" ));
   }
@@ -109,9 +108,9 @@ init_args_offline( int * argc, char *** argv, fd_rpcserver_args_t * args ) {
     FD_LOG_ERR(( "--funk-file argument is required" ));
   char const * restore = fd_env_strip_cmdline_cstr ( argc, argv, "--restore-funk", NULL, NULL );
   if( restore != NULL )
-    args->funk = fd_funk_recover_checkpoint( funk_file, 1, restore, NULL );
+    args->funk = fd_funkier_recover_checkpoint( funk_file, 1, restore, NULL );
   else
-    args->funk = fd_funk_open_file( funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
+    args->funk = fd_funkier_open_file( funk_file, 1, 0, 0, 0, 0, FD_FUNKIER_READONLY, NULL );
 
   fd_wksp_t * wksp;
   const char * wksp_name = fd_env_strip_cmdline_cstr ( argc, argv, "--wksp-name-blockstore", NULL, NULL );

src/choreo/epoch/fd_epoch.c

@@ -115,16 +115,16 @@ fd_epoch_init( fd_epoch_t * epoch, fd_epoch_bank_t const * epoch_bank ) {
            vote_accounts->vote_accounts_root );
        curr;
        curr = fd_vote_accounts_pair_t_map_successor( vote_accounts->vote_accounts_pool, curr ) ) {
-    
+
     if( FD_UNLIKELY( curr->elem.stake > 0UL ) ) {
-      
+
       #if FD_EPOCH_USE_HANDHOLDING
       FD_TEST( !fd_epoch_voters_query( epoch_voters, curr->elem.key, NULL ) );
       FD_TEST( fd_epoch_voters_key_cnt( epoch_voters ) < fd_epoch_voters_key_max( epoch_voters ) );
       #endif
 
       fd_voter_t * voter = fd_epoch_voters_insert( epoch_voters, curr->elem.key );
-      voter->rec.c[FD_FUNK_REC_KEY_FOOTPRINT - 1] = FD_FUNK_KEY_TYPE_ACC;
+      voter->rec.c[FD_FUNKIER_REC_KEY_FOOTPRINT - 1] = FD_FUNK_KEY_TYPE_ACC;
 
       #if FD_EPOCH_USE_HANDHOLDING
       FD_TEST( 0 == memcmp( &voter->key, &curr->elem.key, sizeof(fd_pubkey_t) ) );