gui: fix est slot duration

Author: jherrera-jump

src/disco/gui/fd_gui.c

@@ -144,6 +144,8 @@ fd_gui_new( void *                shmem,
   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;
 
+  for( ulong i=0UL; i < FD_GUI_TURBINE_RECV_TIMESTAMPS; i++ ) gui->turbine_slots[ i ].slot = ULONG_MAX;
+
   gui->summary.estimated_tps_history_idx = 0UL;
   memset( gui->summary.estimated_tps_history, 0, sizeof(gui->summary.estimated_tps_history) );
 
@@ -1848,6 +1850,28 @@ fd_gui_handle_shred( fd_gui_t * gui,
     fd_gui_printf_turbine_slot( gui );
     fd_http_server_ws_broadcast( gui->http );
 
+    gui->turbine_slots[ slot % FD_GUI_TURBINE_RECV_TIMESTAMPS ].slot = slot;
+    gui->turbine_slots[ slot % FD_GUI_TURBINE_RECV_TIMESTAMPS ].timestamp = tsorig;
+
+    ulong duration_sum = 0UL;
+    ulong slot_cnt = 0UL;
+
+    for( ulong i=0UL; i<FD_GUI_TURBINE_RECV_TIMESTAMPS; i++ ) {
+      fd_gui_turbine_slot_t * cur = &gui->turbine_slots[ i ];
+      fd_gui_turbine_slot_t * prev = &gui->turbine_slots[ (i+FD_GUI_TURBINE_RECV_TIMESTAMPS-1UL) % FD_GUI_TURBINE_RECV_TIMESTAMPS ];
+      if( FD_UNLIKELY( cur->slot==ULONG_MAX || prev->slot==ULONG_MAX || cur->slot!=prev->slot+1UL ) ) continue;
+
+      long slot_duration = cur->timestamp - prev->timestamp;
+      duration_sum += (ulong)fd_long_max( slot_duration, 0UL );
+      slot_cnt++;
+    }
+
+    if( FD_LIKELY( slot_cnt>0 ) ) {
+      gui->summary.estimated_slot_duration_nanos = (ulong)(duration_sum / slot_cnt);
+      fd_gui_printf_estimated_slot_duration_nanos( gui );
+      fd_http_server_ws_broadcast( gui->http );
+    }
+
     if( FD_UNLIKELY( gui->summary.slot_caught_up==ULONG_MAX ) ) fd_gui_try_insert_catch_up_slot( gui->summary.catch_up_turbine, FD_GUI_TURBINE_CATCH_UP_HISTORY_SZ, &gui->summary.catch_up_turbine_sz, slot );
   }
 
@@ -2037,7 +2061,7 @@ fd_gui_handle_reset_slot_legacy( fd_gui_t * gui,
     }
   }
 
-  if( FD_LIKELY( slot_cnt>0 )) {
+  if( FD_LIKELY( slot_cnt>0 ) ) {
     gui->summary.estimated_slot_duration_nanos = (ulong)(duration_sum / slot_cnt);
     fd_gui_printf_estimated_slot_duration_nanos( gui );
     fd_http_server_ws_broadcast( gui->http );

src/disco/gui/fd_gui.h

@@ -135,6 +135,8 @@ struct fd_gui_validator_info {
 #define FD_GUI_TXN_FLAGS_FROM_BUNDLE     ( 8U)
 #define FD_GUI_TXN_FLAGS_LANDED_IN_BLOCK (16U)
 
+#define FD_GUI_TURBINE_RECV_TIMESTAMPS (750UL)
+
 /* One use case for tracking ingress shred slot is to estimate when we
    have caught up to the tip of the blockchain.  A naive approach would
    be to track the maximum seen slot.
@@ -324,6 +326,13 @@ struct fd_gui_leader_slot {
 
 typedef struct fd_gui_leader_slot fd_gui_leader_slot_t;
 
+struct fd_gui_turbine_slot {
+ ulong slot;
+ long timestamp;
+};
+
+typedef struct fd_gui_turbine_slot fd_gui_turbine_slot_t;
+
 struct fd_gui_slot_completed {
   ulong slot;
   long  completed_time;
@@ -675,6 +684,9 @@ struct fd_gui {
 
   fd_gui_slot_t slots[ FD_GUI_SLOTS_CNT ][ 1 ];
 
+  /* used for estimating slot duration */
+  fd_gui_turbine_slot_t turbine_slots[ FD_GUI_TURBINE_RECV_TIMESTAMPS ];
+
   fd_gui_leader_slot_t leader_slots[ FD_GUI_LEADER_CNT ][ 1 ];
   ulong leader_slots_cnt;