airlift frankendancer poh tile across

jumpsiegel · jumpsiegel · commit 9ba7ec8a3777 · 2025-05-13T16:09:28.000Z
diff --git a/src/app/firedancer-dev/main.c b/src/app/firedancer-dev/main.c
@@ -87,7 +87,7 @@ extern fd_topo_run_tile_t fd_tile_replay;
 extern fd_topo_run_tile_t fd_tile_execor;
 extern fd_topo_run_tile_t fd_tile_writer;
 extern fd_topo_run_tile_t fd_tile_batch;
-extern fd_topo_run_tile_t fd_tile_pohi;
+extern fd_topo_run_tile_t fd_tile_poh;
 extern fd_topo_run_tile_t fd_tile_sender;
 extern fd_topo_run_tile_t fd_tile_eqvoc;
 extern fd_topo_run_tile_t fd_tile_rpcserv;
@@ -126,7 +126,7 @@ fd_topo_run_tile_t * TILES[] = {
   &fd_tile_execor,
   &fd_tile_writer,
   &fd_tile_batch,
-  &fd_tile_pohi,
+  &fd_tile_poh,
   &fd_tile_sender,
   &fd_tile_eqvoc,
   &fd_tile_rpcserv,
diff --git a/src/app/firedancer/main.c b/src/app/firedancer/main.c
@@ -74,7 +74,7 @@ extern fd_topo_run_tile_t fd_tile_replay;
 extern fd_topo_run_tile_t fd_tile_execor;
 extern fd_topo_run_tile_t fd_tile_writer;
 extern fd_topo_run_tile_t fd_tile_batch;
-extern fd_topo_run_tile_t fd_tile_pohi;
+extern fd_topo_run_tile_t fd_tile_poh;
 extern fd_topo_run_tile_t fd_tile_sender;
 extern fd_topo_run_tile_t fd_tile_eqvoc;
 extern fd_topo_run_tile_t fd_tile_rpcserv;
@@ -102,7 +102,7 @@ fd_topo_run_tile_t * TILES[] = {
   &fd_tile_execor,
   &fd_tile_writer,
   &fd_tile_batch,
-  &fd_tile_pohi,
+  &fd_tile_poh,
   &fd_tile_sender,
   &fd_tile_eqvoc,
   &fd_tile_rpcserv,
diff --git a/src/app/firedancer/topology.c b/src/app/firedancer/topology.c
@@ -299,7 +299,7 @@ fd_topo_initialize( config_t * config ) {
   fd_topob_wksp( topo, "writer"      );
   fd_topob_wksp( topo, "bstore"      );
   fd_topob_wksp( topo, "tcache"      );
-  fd_topob_wksp( topo, "pohi"        );
+  fd_topob_wksp( topo, "poh"        );
   fd_topob_wksp( topo, "voter"       );
   fd_topob_wksp( topo, "poh_slot"    );
   fd_topob_wksp( topo, "turb_slot"   );
@@ -438,7 +438,7 @@ fd_topo_initialize( config_t * config ) {
   /**/                             fd_topob_tile( topo, "sign",    "sign",    "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,        1 );
   /**/                             fd_topob_tile( topo, "metric",  "metric",  "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,        0 );
   fd_topo_tile_t * pack_tile =     fd_topob_tile( topo, "pack",    "pack",    "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,        0 );
-  /**/                             fd_topob_tile( topo, "pohi",    "pohi",    "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,        0 );
+  /**/                             fd_topob_tile( topo, "poh",    "poh",    "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,          1 );
   /**/                             fd_topob_tile( topo, "gossip",  "gossip",  "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,        0 );
   fd_topo_tile_t * repair_tile =   fd_topob_tile( topo, "repair",  "repair",  "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,        0 );
   /**/                             fd_topob_tile( topo, "sender",  "voter",   "metric_in",  tile_to_cpu[ topo->tile_cnt ], 0,        0 );
@@ -689,12 +689,12 @@ fd_topo_initialize( config_t * config ) {
   /**/                 fd_topob_tile_in(  topo, "pack",   0UL,           "metric_in",  "dedup_pack",    0UL,         FD_TOPOB_RELIABLE,   FD_TOPOB_POLLED   ); /* No reliable consumers of networking fragments, may be dropped or overrun */
   /**/                 fd_topob_tile_in(  topo, "pack",   0UL,           "metric_in",  "poh_pack",      0UL,         FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED   );
   /**/                 fd_topob_tile_out( topo, "pack",   0UL,                         "pack_replay",   0UL                                                 );
-  FOR(bank_tile_cnt)   fd_topob_tile_in(  topo, "pohi",   0UL,           "metric_in",  "replay_poh",    i,           FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED   ); /* No reliable consumers of networking fragments, may be dropped or overrun */
-  /**/                 fd_topob_tile_in(  topo, "pohi",   0UL,           "metric_in",  "stake_out",     0UL,         FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED   ); /* No reliable consumers of networking fragments, may be dropped or overrun */
-  /**/                 fd_topob_tile_out( topo, "pohi",   0UL,                         "poh_shred",     0UL                                                 );
+  FOR(bank_tile_cnt)   fd_topob_tile_in(  topo, "poh",   0UL,           "metric_in",  "replay_poh",    i,           FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED   ); /* No reliable consumers of networking fragments, may be dropped or overrun */
+  /**/                 fd_topob_tile_in(  topo, "poh",   0UL,           "metric_in",  "stake_out",     0UL,         FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED   ); /* No reliable consumers of networking fragments, may be dropped or overrun */
+  /**/                 fd_topob_tile_out( topo, "poh",   0UL,                         "poh_shred",     0UL                                                 );
 
-  /**/                 fd_topob_tile_in(  topo, "pohi",  0UL,            "metric_in", "pack_replay",   0UL,          FD_TOPOB_RELIABLE,   FD_TOPOB_POLLED );
-                      fd_topob_tile_out( topo, "pohi",   0UL,                        "poh_pack",      0UL                                                );
+  /**/                 fd_topob_tile_in(  topo, "poh",  0UL,            "metric_in", "pack_replay",   0UL,          FD_TOPOB_RELIABLE,   FD_TOPOB_POLLED );
+                      fd_topob_tile_out( topo, "poh",   0UL,                        "poh_pack",      0UL                                                );
 
   /**/                 fd_topob_tile_in(  topo, "sign",     0UL,          "metric_in", "repair_sign",  0UL,          FD_TOPOB_UNRELIABLE, FD_TOPOB_POLLED   );
   /**/                 fd_topob_tile_out( topo, "repair",   0UL,                       "repair_sign",  0UL                                                  );
@@ -911,7 +911,7 @@ fd_topo_initialize( config_t * config ) {
       tile->pack.larger_shred_limits_per_block = config->development.bench.larger_shred_limits_per_block;
       tile->pack.use_consumed_cus              = config->tiles.pack.use_consumed_cus;
       if( FD_UNLIKELY( tile->pack.use_consumed_cus ) ) FD_LOG_ERR(( "Firedancer does not support CU rebating yet.  [tiles.pack.use_consumed_cus] must be false" ));
-    } else if( FD_UNLIKELY( !strcmp( tile->name, "pohi" ) ) ) {
+    } else if( FD_UNLIKELY( !strcmp( tile->name, "poh" ) ) ) {
       strncpy( tile->poh.identity_key_path, config->paths.identity_key, sizeof(tile->poh.identity_key_path) );
 
       tile->poh.bank_cnt = config->layout.bank_tile_count;
diff --git a/src/disco/topo/fd_topo.c b/src/disco/topo/fd_topo.c
@@ -206,7 +206,7 @@ fd_topo_tile_extra_normal_pages( fd_topo_tile_t const * tile ) {
 
                    !strcmp( tile->name, "gossip" ) ||
                    !strcmp( tile->name, "repair" ) ||
-                   !strcmp( tile->name, "pohi"   ) ||
+                   !strcmp( tile->name, "poh"   ) ||
                    !strcmp( tile->name, "storei" ) ) ) {
     /* Certain tiles using fd_keyload_load need normal pages to hold
        key material. */
diff --git a/src/disco/topo/fd_topob.c b/src/disco/topo/fd_topob.c
@@ -357,7 +357,7 @@ fd_topob_auto_layout( fd_topo_t * topo,
     "pack",
     "bank",   /* FRANK only */
     "poh",    /* FRANK only */
-    "pohi",   /* FIREDANCER only */
+    "poh",   /* FIREDANCER only */
     "shred",
     "store",  /* FRANK only */
     "storei", /* FIREDANCER only */
diff --git a/src/discof/bank/fd_bank_abi.c b/src/discof/bank/fd_bank_abi.c
@@ -59,3 +59,36 @@ fd_bank_abi_resolve_address_lookup_tables( void const *     bank FD_PARAM_UNUSED
 void fd_ext_bank_release( void const * bank  FD_PARAM_UNUSED) {
   FD_LOG_ERR(("nope"));
 }
+
+int
+fd_ext_admin_rpc_set_identity( uchar const * identity_keypair FD_PARAM_UNUSED,
+                               int           require_tower FD_PARAM_UNUSED) {
+  FD_LOG_ERR(("nope"));
+  return 0;
+}
+
+void
+fd_ext_bank_acquire( void const * bank FD_PARAM_UNUSED) {
+  FD_LOG_ERR(("nope"));
+}
+
+int
+fd_ext_bank_load_account( void const *  bank FD_PARAM_UNUSED,
+                          int           fixed_root FD_PARAM_UNUSED,
+                          uchar const * addr FD_PARAM_UNUSED,
+                          uchar *       owner FD_PARAM_UNUSED,
+                          uchar *       data FD_PARAM_UNUSED,
+                          ulong *       data_sz FD_PARAM_UNUSED) {
+  FD_LOG_ERR(("nope"));
+  return 0;
+}
+
+void
+fd_ext_poh_register_tick( void const * bank FD_PARAM_UNUSED, uchar const * hash FD_PARAM_UNUSED) {
+  FD_LOG_ERR(("nope"));
+}
+
+void
+fd_ext_poh_signal_leader_change( void * sender FD_PARAM_UNUSED) {
+  FD_LOG_ERR(("nope"));
+}
diff --git a/src/discof/bank/fd_bank_abi.h b/src/discof/bank/fd_bank_abi.h
@@ -39,6 +39,27 @@ fd_bank_abi_resolve_address_lookup_tables( void const *     bank,
 
 void fd_ext_bank_release( void const * bank );
 
+int
+fd_ext_admin_rpc_set_identity( uchar const * identity_keypair,
+                               int           require_tower );
+
+void
+fd_ext_bank_acquire( void const * bank );
+
+int
+fd_ext_bank_load_account( void const *  bank,
+                          int           fixed_root,
+                          uchar const * addr,
+                          uchar *       owner,
+                          uchar *       data,
+                          ulong *       data_sz );
+
+void
+fd_ext_poh_register_tick( void const * bank, uchar const * hash );
+
+void
+fd_ext_poh_signal_leader_change( void * sender );
+
 FD_PROTOTYPES_END
 
 #endif
diff --git a/src/discof/poh/Local.mk b/src/discof/poh/Local.mk
@@ -1,10 +1,3 @@
-ifdef FD_HAS_HOSTED
-ifdef FD_HAS_LINUX
-ifdef FD_HAS_INT128
 ifdef FD_HAS_SSE
-$(call add-hdrs,fd_poh.h)
-$(call add-objs,fd_pohi_tile fd_poh,fd_discof)
-endif
-endif
-endif
+$(call add-objs,fd_poh_tile,fd_discof)
 endif
diff --git a/src/discof/poh/fd_poh.c b/src/discof/poh/fd_poh.c
diff --git a/src/discof/poh/fd_poh.h b/src/discof/poh/fd_poh.h
diff --git a/src/discof/poh/fd_poh_tile.c b/src/discof/poh/fd_poh_tile.c
diff --git a/src/discof/poh/fd_pohi_tile.c b/src/discof/poh/fd_pohi_tile.c
