gui: send active fork cnt

Author: jherrera-jump

src/disco/gui/fd_gui.c

@@ -137,6 +137,7 @@ fd_gui_new( void *                shmem,
   gui->summary.slot_turbine                  = ULONG_MAX;
   gui->summary.slot_reset                    = ULONG_MAX;
   gui->summary.slot_storage                  = ULONG_MAX;
+  gui->summary.active_fork_cnt               = 1UL;
 
   for( ulong i=0UL; i < (FD_GUI_REPAIR_SLOT_HISTORY_SZ+1UL); i++ )  gui->summary.slots_max_repair[ i ].slot  = ULONG_MAX;
   for( ulong i=0UL; i < (FD_GUI_TURBINE_SLOT_HISTORY_SZ+1UL); i++ ) gui->summary.slots_max_turbine[ i ].slot = ULONG_MAX;
@@ -229,6 +230,9 @@ fd_gui_ws_open( fd_gui_t * gui,
     fd_gui_printf_vote_balance,
     fd_gui_printf_estimated_slot_duration_nanos,
     fd_gui_printf_root_slot,
+    fd_gui_printf_storage_slot,
+    fd_gui_printf_reset_slot,
+    fd_gui_printf_active_fork_cnt,
     fd_gui_printf_optimistically_confirmed_slot,
     fd_gui_printf_completed_slot,
     fd_gui_printf_estimated_slot,
@@ -2631,6 +2635,12 @@ fd_gui_handle_tower_update( fd_gui_t *                   gui,
                             long                         now ) {
   (void)now;
 
+  if( FD_UNLIKELY( tower->active_fork_cnt!=gui->summary.active_fork_cnt ) ) {
+    gui->summary.active_fork_cnt = tower->active_fork_cnt;
+    fd_gui_printf_active_fork_cnt( gui );
+    fd_http_server_ws_broadcast( gui->http );
+  }
+
   /* handle new root */
   if( FD_LIKELY( tower->root_slot!=ULONG_MAX && gui->summary.slot_rooted!=tower->root_slot ) ) {
     fd_gui_handle_rooted_slot( gui, tower->root_slot );
@@ -2657,6 +2667,7 @@ fd_gui_handle_replay_update( fd_gui_t *                gui,
                              ulong                     identity_balance,
                              long                      now ) {
   (void)now;
+
   if( FD_LIKELY( gui->summary.slot_storage!=storage_slot ) ) {
     gui->summary.slot_storage = storage_slot;
     fd_gui_printf_storage_slot( gui );

src/disco/gui/fd_gui.h

@@ -635,6 +635,7 @@ struct fd_gui {
     ulong slot_turbine;
     ulong slot_reset;
     ulong slot_storage;
+    ulong active_fork_cnt;
 
     fd_gui_ephemeral_slot_t slots_max_turbine[ FD_GUI_TURBINE_SLOT_HISTORY_SZ+1UL ];
     fd_gui_ephemeral_slot_t slots_max_repair [ FD_GUI_REPAIR_SLOT_HISTORY_SZ +1UL ];

src/disco/gui/fd_gui_printf.c

@@ -275,6 +275,14 @@ fd_gui_printf_storage_slot( fd_gui_t * gui ) {
   jsonp_close_envelope( gui->http );
 }
 
+void
+fd_gui_printf_active_fork_cnt( fd_gui_t * gui ) {
+  jsonp_open_envelope( gui->http, "summary", "active_fork_count" );
+    if( FD_LIKELY( gui->summary.active_fork_cnt!=ULONG_MAX  ) ) jsonp_ulong( gui->http, "value", gui->summary.active_fork_cnt );
+    else                                                        jsonp_null ( gui->http, "value" );
+  jsonp_close_envelope( gui->http );
+}
+
 void
 fd_gui_printf_slot_caught_up( fd_gui_t * gui ) {
   jsonp_open_envelope( gui->http, "summary", "slot_caught_up" );

src/disco/gui/fd_gui_printf.h

@@ -39,6 +39,7 @@ void fd_gui_printf_catch_up_history( fd_gui_t * gui );
 void fd_gui_peers_printf_vote_slot( fd_gui_peers_ctx_t * peers );
 void fd_gui_printf_reset_slot( fd_gui_t * gui );
 void fd_gui_printf_storage_slot( fd_gui_t * gui );
+void fd_gui_printf_active_fork_cnt( fd_gui_t * gui );
 
 void
 fd_gui_printf_null_query_response( fd_http_server_t * http,

src/discof/tower/fd_tower_tile.c

@@ -648,6 +648,7 @@ replay_slot_completed( ctx_t *                      ctx,
 
   fd_tower_slot_done_t * msg = fd_chunk_to_laddr( ctx->out_mem, ctx->out_chunk );
   msg->replay_slot           = slot_info->slot;
+  msg->active_fork_cnt       = fd_tower_leaves_pool_used( ctx->forks->tower_leaves_pool );
   msg->vote_slot             = out.vote_slot;
   msg->reset_slot            = out.reset_slot;
   msg->reset_block_id        = out.reset_block_id;

src/discof/tower/fd_tower_tile.h

@@ -45,6 +45,9 @@ struct fd_tower_slot_done {
   ulong     root_slot;
   fd_hash_t root_block_id;
 
+  /* The number of leaves in the forks tree. */
+  ulong     active_fork_cnt;
+
   /* This tower_slot_done message is 1-to-1 with the completion of a
      replayed slot.  When that slot was done, the bank_idx was sent to
      tower, which tower used to query the bank and populate the vote