Line data Source code
1 : #include "fd_gui.h"
2 : #include "fd_gui_printf.h"
3 : #include "fd_gui_metrics.h"
4 : #include "fd_gui_hist.h"
5 :
6 : #include "../metrics/fd_metrics.h"
7 : #include "../../discof/gossip/fd_gossip_tile.h"
8 : #include "../bundle/fd_bundle_tile.h"
9 :
10 : #include "../../ballet/base58/fd_base58.h"
11 : #include "../../ballet/json/fd_jtok.h"
12 : #include "../../ballet/shred/fd_shred.h"
13 : #include "../../disco/genesis/fd_genesis_cluster.h"
14 : #include "../../disco/pack/fd_pack.h"
15 : #include "../../disco/pack/fd_pack_cost.h"
16 : #include "../shred/fd_fec_set.h"
17 :
18 : FD_STATIC_ASSERT( FD_FEC_SHRED_CNT==32UL, fec_shred_count );
19 :
20 : #include <stdio.h>
21 :
22 : FD_FN_CONST ulong
23 621 : fd_gui_align( void ) {
24 621 : return 128UL;
25 621 : }
26 :
27 : ulong
28 : fd_gui_footprint( ulong tile_cnt,
29 : ulong max_live_slots,
30 138 : ulong max_txn_per_slot ) {
31 138 : FD_TEST( tile_cnt && tile_cnt <=FD_DIAG_SYSTEM_TILE_MAX );
32 138 : FD_TEST( max_live_slots && max_live_slots<=ULONG_MAX/sizeof(fd_gui_ag_slot_t) );
33 138 : FD_TEST( max_txn_per_slot && max_txn_per_slot<=ULONG_MAX/sizeof(fd_gui_store_txn_start_t) );
34 :
35 138 : ulong l = FD_LAYOUT_INIT;
36 138 : l = FD_LAYOUT_APPEND( l, fd_gui_align(), sizeof(fd_gui_t) );
37 138 : l = FD_LAYOUT_APPEND( l, alignof(fd_gui_ag_slot_t), max_live_slots*sizeof(fd_gui_ag_slot_t) );
38 138 : l = FD_LAYOUT_APPEND( l, fd_gui_rate_deque_align(), fd_gui_rate_deque_footprint() ); /* ingress_maxq */
39 138 : l = FD_LAYOUT_APPEND( l, fd_gui_rate_deque_align(), fd_gui_rate_deque_footprint() ); /* egress_maxq */
40 138 : l = FD_LAYOUT_APPEND( l, fd_gui_hist_align(), fd_gui_hist_footprint() );
41 138 : l = FD_LAYOUT_APPEND( l, alignof(fd_gui_store_txn_start_t), max_txn_per_slot*sizeof(fd_gui_store_txn_start_t) );
42 138 : l = FD_LAYOUT_APPEND( l, alignof(fd_gui_store_txn_end_t), max_txn_per_slot*sizeof(fd_gui_store_txn_end_t) );
43 138 : l = FD_LAYOUT_APPEND( l, alignof(fd_gui_slot_txn_join_t), max_txn_per_slot*sizeof(fd_gui_slot_txn_join_t) );
44 138 : l = FD_LAYOUT_APPEND( l, alignof(fd_gui_shred_scratch_t), FD_GUI_SHRED_SCRATCH_MAX*sizeof(fd_gui_shred_scratch_t) );
45 138 : l = FD_LAYOUT_APPEND( l, alignof(long), FD_GUI_EXEC_DONE_SLOT_CNT*FD_SHRED_BLK_MAX*sizeof(long) );
46 138 : return FD_LAYOUT_FINI( l, fd_gui_align() );
47 138 : }
48 :
49 : static inline void
50 0 : fd_gui_build_tile_order( fd_gui_t * gui ) {
51 0 : ulong tile_cnt = gui->topo->tile_cnt;
52 0 : ulong order_cnt = 0UL;
53 0 : uchar placed[ FD_DIAG_SYSTEM_TILE_MAX ] = {0};
54 :
55 0 : char const * const tile_display_order[] = {
56 0 : "gossvf", "gossip", "snapct", "snapld", "snapdc", "snapin",
57 0 : "net", "shred", "repair", "replay", "execrp", "votor", "sign",
58 0 : "quic", "verify", "dedup", "pack", "execle"
59 0 : };
60 :
61 0 : for( ulong n=0UL; n<sizeof(tile_display_order)/sizeof(tile_display_order[0]); n++ ) {
62 0 : for( ulong i=0UL; i<tile_cnt; i++ ) {
63 0 : if( FD_LIKELY( placed[ i ] ) ) continue;
64 0 : if( FD_UNLIKELY( !strcmp( gui->topo->tiles[ i ].name, tile_display_order[ n ] ) ) ) {
65 0 : gui->summary.tile[ order_cnt++ ] = i;
66 0 : placed[ i ] = 1;
67 0 : }
68 0 : }
69 0 : }
70 :
71 0 : for( ulong i=0UL; i<tile_cnt; i++ ) {
72 0 : if( FD_UNLIKELY( !placed[ i ] ) ) gui->summary.tile[ order_cnt++ ] = i;
73 0 : }
74 :
75 0 : gui->summary.tile_cnt = order_cnt;
76 0 : }
77 :
78 : void *
79 : fd_gui_new( void * shmem,
80 : fd_http_server_t * http,
81 : char const * version,
82 : char const * cluster,
83 : uchar const * identity_key,
84 : int has_vote_key,
85 : uchar const * vote_key,
86 : ulong max_live_slots,
87 : ulong max_txn_per_slot,
88 : int snapshots_enabled,
89 : int is_voting,
90 : int schedule_strategy,
91 : char const * wfs_expected_bank_hash_cstr,
92 : ushort expected_shred_version,
93 : ulong wfs_slot,
94 : char const * accounts_database_path,
95 : char const * gui_database_path,
96 : void * db,
97 : fd_topo_t const * topo,
98 : fd_accdb_shmem_t const * accdb_shmem,
99 0 : long now ) {
100 :
101 0 : if( FD_UNLIKELY( !shmem ) ) {
102 0 : FD_LOG_WARNING(( "NULL shmem" ));
103 0 : return NULL;
104 0 : }
105 :
106 0 : if( FD_UNLIKELY( !fd_ulong_is_aligned( (ulong)shmem, fd_gui_align() ) ) ) {
107 0 : FD_LOG_WARNING(( "misaligned shmem" ));
108 0 : return NULL;
109 0 : }
110 :
111 0 : if( FD_UNLIKELY( topo->tile_cnt>FD_DIAG_SYSTEM_TILE_MAX ) ) {
112 0 : FD_LOG_WARNING(( "too many tiles" ));
113 0 : return NULL;
114 0 : }
115 :
116 0 : ulong tile_cnt = topo->tile_cnt;
117 :
118 0 : FD_SCRATCH_ALLOC_INIT( l, shmem );
119 0 : fd_gui_t * gui = FD_SCRATCH_ALLOC_APPEND( l, fd_gui_align(), sizeof(fd_gui_t) );
120 0 : void * ag_slot_mem = FD_SCRATCH_ALLOC_APPEND( l, alignof(fd_gui_ag_slot_t), max_live_slots*sizeof(fd_gui_ag_slot_t) );
121 0 : void * ingress_maxq_mem = FD_SCRATCH_ALLOC_APPEND( l, fd_gui_rate_deque_align(), fd_gui_rate_deque_footprint() );
122 0 : void * egress_maxq_mem = FD_SCRATCH_ALLOC_APPEND( l, fd_gui_rate_deque_align(), fd_gui_rate_deque_footprint() );
123 0 : void * hist_mem = FD_SCRATCH_ALLOC_APPEND( l, fd_gui_hist_align(), fd_gui_hist_footprint() );
124 0 : void * txn_starts_mem = FD_SCRATCH_ALLOC_APPEND( l, alignof(fd_gui_store_txn_start_t), max_txn_per_slot*sizeof(fd_gui_store_txn_start_t) );
125 0 : void * txn_ends_mem = FD_SCRATCH_ALLOC_APPEND( l, alignof(fd_gui_store_txn_end_t), max_txn_per_slot*sizeof(fd_gui_store_txn_end_t) );
126 0 : void * txn_joined_mem = FD_SCRATCH_ALLOC_APPEND( l, alignof(fd_gui_slot_txn_join_t), max_txn_per_slot*sizeof(fd_gui_slot_txn_join_t) );
127 0 : void * shred_sc_mem = FD_SCRATCH_ALLOC_APPEND( l, alignof(fd_gui_shred_scratch_t), FD_GUI_SHRED_SCRATCH_MAX*sizeof(fd_gui_shred_scratch_t) );
128 0 : void * exec_done_mem = FD_SCRATCH_ALLOC_APPEND( l, alignof(long), FD_GUI_EXEC_DONE_SLOT_CNT*FD_SHRED_BLK_MAX*sizeof(long) );
129 :
130 0 : gui->slot_txn_scratch.max = max_txn_per_slot;
131 0 : gui->slot_txn_scratch.starts = txn_starts_mem;
132 0 : gui->slot_txn_scratch.ends = txn_ends_mem;
133 0 : gui->slot_txn_scratch.joined = txn_joined_mem;
134 0 : gui->shred_scratch.ev = shred_sc_mem;
135 0 : gui->shred_scratch.max = FD_GUI_SHRED_SCRATCH_MAX;
136 0 : gui->exec_done.ts = exec_done_mem;
137 0 : for( ulong i=0UL; i<FD_GUI_EXEC_DONE_SLOT_CNT; i++ ) gui->exec_done.slot[ i ] = ULONG_MAX;
138 :
139 0 : gui->http = http;
140 0 : gui->topo = topo;
141 0 : gui->accdb_shmem = accdb_shmem;
142 0 : gui->tick_per_ns = fd_tempo_tick_per_ns( NULL );
143 0 : gui->tile_cnt = tile_cnt;
144 :
145 0 : gui->db = db;
146 0 : gui->hist = fd_gui_hist_join( fd_gui_hist_new( hist_mem, (fd_gui_store_t const *)db ) );
147 0 : if( FD_UNLIKELY( !gui->hist ) ) {
148 0 : FD_LOG_WARNING(( "fd_gui_hist_new failed" ));
149 0 : return NULL;
150 0 : }
151 :
152 0 : gui->summary.ingress_maxq = fd_gui_rate_deque_join( fd_gui_rate_deque_new( ingress_maxq_mem ) );
153 0 : gui->summary.egress_maxq = fd_gui_rate_deque_join( fd_gui_rate_deque_new( egress_maxq_mem ) );
154 :
155 0 : gui->summary.network_stats_has_prev = 0;
156 0 : gui->summary.net_rate_prev_ts = 0L;
157 0 : for( ulong i=0UL; i<FD_GUI_NET_PROTO_CNT; i++ ) {
158 0 : fd_gui_ema_init( &gui->summary.ingress_ema[ i ], now, FD_GUI_NETWORK_EMA_HALF_LIFE_NS );
159 0 : fd_gui_ema_init( &gui->summary.egress_ema [ i ], now, FD_GUI_NETWORK_EMA_HALF_LIFE_NS );
160 0 : }
161 :
162 0 : gui->leader_begin_slot = 0UL;
163 0 : gui->leader_end_slot = 0UL;
164 0 : gui->leader_slot_pending = ULONG_MAX;
165 0 : gui->leader_bank_seq_pending = ULONG_MAX;
166 :
167 0 : gui->system.valid = 0;
168 :
169 0 : gui->summary.slot_tower = ULONG_MAX;
170 0 : gui->summary.slot_tower_bank_seq = ULONG_MAX;
171 0 : gui->summary.schedule_strategy = schedule_strategy;
172 :
173 :
174 0 : gui->next_sample_1sec = now;
175 0 : gui->next_sample_200millis = now;
176 0 : gui->next_sample_100millis = now;
177 0 : gui->next_sample_50millis = now;
178 0 : gui->next_sample_40millis = now;
179 0 : gui->next_sample_25millis = now;
180 0 : gui->next_sample_10millis = now;
181 :
182 0 : memcpy( gui->summary.identity_key->uc, identity_key, 32UL );
183 0 : fd_base58_encode_32( identity_key, NULL, gui->summary.identity_key_base58 );
184 0 : gui->summary.identity_key_base58[ FD_BASE58_ENCODED_32_SZ-1UL ] = '\0';
185 :
186 0 : if( FD_LIKELY( has_vote_key ) ) {
187 0 : gui->summary.has_vote_key = 1;
188 0 : memcpy( gui->summary.vote_key->uc, vote_key, 32UL );
189 0 : fd_base58_encode_32( vote_key, NULL, gui->summary.vote_key_base58 );
190 0 : gui->summary.vote_key_base58[ FD_BASE58_ENCODED_32_SZ-1UL ] = '\0';
191 0 : } else {
192 0 : gui->summary.has_vote_key = 0;
193 0 : memset( gui->summary.vote_key_base58, 0, sizeof(gui->summary.vote_key_base58) );
194 0 : }
195 :
196 0 : gui->summary.version = version;
197 0 : gui->summary.cluster = cluster;
198 0 : fd_cstr_ncpy( gui->summary.accounts_database_path, accounts_database_path, sizeof(gui->summary.accounts_database_path) );
199 0 : fd_cstr_ncpy( gui->summary.gui_database_path, gui_database_path, sizeof(gui->summary.gui_database_path) );
200 0 : gui->summary.startup_time_nanos = gui->next_sample_200millis;
201 0 : gui->summary.expected_shred_version = expected_shred_version;
202 0 : gui->summary.wfs_enabled = 0;
203 0 : gui->summary.wfs_bank_hash[ 0UL ] = '\0';
204 0 : gui->summary.wfs_slot = wfs_slot;
205 :
206 0 : {
207 0 : fd_cstr_ncpy( gui->summary.wfs_bank_hash, wfs_expected_bank_hash_cstr, sizeof(gui->summary.wfs_bank_hash) );
208 0 : gui->summary.wfs_enabled = !!strcmp( wfs_expected_bank_hash_cstr, "" );
209 :
210 0 : if( FD_UNLIKELY( snapshots_enabled ) ) {
211 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_JOINING_GOSSIP;
212 0 : gui->summary.boot_progress.joining_gossip_time_nanos = gui->next_sample_200millis;
213 0 : memset( gui->summary.boot_progress.loading_snapshot, 0, sizeof(gui->summary.boot_progress.loading_snapshot) );
214 0 : for( ulong i=0UL; i<FD_GUI_BOOT_PROGRESS_SNAPSHOT_CNT; i++ ) {
215 0 : gui->summary.boot_progress.loading_snapshot[ i ].reset_cnt = ULONG_MAX; /* ensures other fields are reset initially */
216 0 : gui->summary.boot_progress.loading_snapshot[ i ].slot = ULONG_MAX;
217 0 : }
218 0 : gui->summary.boot_progress.catching_up_time_nanos = 0L;
219 0 : gui->summary.boot_progress.catching_up_first_replay_slot = ULONG_MAX;
220 0 : gui->summary.boot_progress.wfs_total_stake = 0UL;
221 0 : gui->summary.boot_progress.wfs_connected_stake = 0UL;
222 0 : gui->summary.boot_progress.wfs_total_peers = 0UL;
223 0 : gui->summary.boot_progress.wfs_connected_peers = 0UL;
224 0 : gui->summary.boot_progress.wfs_attempt = 0UL;
225 0 : } else {
226 0 : fd_memset( &gui->summary.boot_progress, 0, sizeof(gui->summary.boot_progress) );
227 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_RUNNING;
228 0 : }
229 0 : gui->summary.boot_progress.boot_target_slot_duration_nanos = ULONG_MAX;
230 0 : }
231 :
232 0 : gui->summary.identity_account_balance = 0UL;
233 0 : gui->summary.vote_account_balance = 0UL;
234 0 : gui->summary.vote_commission = USHORT_MAX;
235 0 : gui->summary.estimated_slot_duration_nanos = 0UL;
236 :
237 0 : gui->summary.is_voting = !!is_voting;
238 0 : gui->summary.vote_state = is_voting ? FD_GUI_VOTE_STATE_VOTING : FD_GUI_VOTE_STATE_NON_VOTING;
239 :
240 0 : gui->summary.sock_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "sock" );
241 0 : gui->summary.mlx5_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "mlx5" );
242 0 : gui->summary.iavf_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "iavf" );
243 0 : gui->summary.net_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "net" );
244 0 : gui->summary.quic_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "quic" );
245 0 : gui->summary.verify_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "verify" );
246 0 : gui->summary.resolv_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "resolv" );
247 0 : gui->summary.execle_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "execle" );
248 0 : gui->summary.execrp_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "execrp" );
249 0 : gui->summary.shred_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "shred" );
250 :
251 0 : fd_gui_build_tile_order( gui );
252 :
253 0 : gui->summary.slot_rooted = ULONG_MAX;
254 0 : gui->summary.slot_finalized = ULONG_MAX;
255 0 : gui->summary.slot_notarized = ULONG_MAX;
256 0 : gui->summary.slot_estimated = ULONG_MAX;
257 0 : gui->summary.slot_caught_up = ULONG_MAX;
258 0 : gui->summary.slot_repair = ULONG_MAX;
259 0 : gui->summary.slot_turbine = ULONG_MAX;
260 0 : gui->summary.slot_reset = ULONG_MAX;
261 0 : gui->summary.slot_storage = ULONG_MAX;
262 0 : gui->summary.slot_voted = ULONG_MAX;
263 0 : gui->summary.active_fork_cnt = 1UL;
264 :
265 0 : gui->ag.slot_cnt = max_live_slots;
266 0 : gui->max_consecutive_skips = fd_ulong_if( max_live_slots>FD_VOTOR_REWARD_SLOT_DELTA, max_live_slots-FD_VOTOR_REWARD_SLOT_DELTA, 1UL );
267 0 : gui->ag.slot = (fd_gui_ag_slot_t *)ag_slot_mem;
268 0 : memset( gui->ag.slot, 0, max_live_slots*sizeof(fd_gui_ag_slot_t) );
269 0 : for( ulong i=0UL; i<gui->ag.slot_cnt; i++ ) {
270 0 : gui->ag.slot[ i ].slot = ULONG_MAX;
271 0 : gui->ag.slot[ i ].bank_seq = ULONG_MAX;
272 0 : }
273 :
274 0 : memset( gui->cpu_util.total, 0, sizeof(gui->cpu_util.total) );
275 0 : memset( gui->cpu_util.idle, 0, sizeof(gui->cpu_util.idle) );
276 0 : gui->cpu_util.last_slot = ULONG_MAX;
277 0 : gui->cpu_util.cur_day = ULONG_MAX;
278 :
279 0 : memset( gui->summary.skip_rate, 0, sizeof(gui->summary.skip_rate) );
280 0 : gui->summary.skip_rate[ 0 ].epoch = ULONG_MAX;
281 0 : gui->summary.skip_rate[ 1 ].epoch = ULONG_MAX;
282 :
283 0 : for( ulong i=0UL; i < (FD_GUI_REPAIR_SLOT_HISTORY_SZ+1UL); i++ ) gui->summary.slots_max_repair[ i ].slot = ULONG_MAX;
284 0 : for( ulong i=0UL; i < (FD_GUI_TURBINE_SLOT_HISTORY_SZ+1UL); i++ ) gui->summary.slots_max_turbine[ i ].slot = ULONG_MAX;
285 :
286 0 : for( ulong i=0UL; i < FD_GUI_TURBINE_RECV_TIMESTAMPS; i++ ) gui->turbine_slots[ i ].slot = ULONG_MAX;
287 :
288 0 : gui->summary.estimated_tps_history_idx = 0UL;
289 0 : memset( gui->summary.estimated_tps_history, 0, sizeof(gui->summary.estimated_tps_history) );
290 :
291 0 : memset( gui->summary.txn_waterfall_reference, 0, sizeof(gui->summary.txn_waterfall_reference) );
292 0 : memset( gui->summary.txn_waterfall_current, 0, sizeof(gui->summary.txn_waterfall_current) );
293 :
294 0 : memset( gui->summary.tile_stats_reference, 0, sizeof(gui->summary.tile_stats_reference) );
295 0 : memset( gui->summary.tile_stats_current, 0, sizeof(gui->summary.tile_stats_current) );
296 :
297 0 : gui->summary.progcache_history_idx = 0UL;
298 0 : memset( gui->summary.progcache_hits_history, 0, sizeof(gui->summary.progcache_hits_history) );
299 0 : memset( gui->summary.progcache_lookups_history, 0, sizeof(gui->summary.progcache_lookups_history) );
300 0 : gui->summary.progcache_hits_1min = 0UL;
301 0 : gui->summary.progcache_lookups_1min = 0UL;
302 :
303 0 : memset( gui->summary.accounts_stats_reference, 0, sizeof(gui->summary.accounts_stats_reference) );
304 0 : memset( gui->summary.accounts_stats_current, 0, sizeof(gui->summary.accounts_stats_current ) );
305 0 : gui->summary.accounts_stats_have_reference = 0;
306 0 : gui->summary.accdb->accdb_win_idx = 0UL;
307 0 : gui->summary.accdb->accdb_win_count = 0UL;
308 0 : memset( gui->summary.accdb->accdb_win_dt_nanos, 0, sizeof(gui->summary.accdb->accdb_win_dt_nanos) );
309 0 : memset( gui->summary.accdb->agg_acquired_win, 0, sizeof(gui->summary.accdb->agg_acquired_win) );
310 0 : memset( gui->summary.accdb->agg_acquired_writable_win, 0, sizeof(gui->summary.accdb->agg_acquired_writable_win) );
311 0 : memset( gui->summary.accdb->agg_bytes_read_win, 0, sizeof(gui->summary.accdb->agg_bytes_read_win) );
312 0 : memset( gui->summary.accdb->agg_bytes_copied_win, 0, sizeof(gui->summary.accdb->agg_bytes_copied_win) );
313 0 : memset( gui->summary.accdb->agg_bytes_written_win, 0, sizeof(gui->summary.accdb->agg_bytes_written_win) );
314 0 : memset( gui->summary.accdb->agg_bytes_written_accdb_win, 0, sizeof(gui->summary.accdb->agg_bytes_written_accdb_win) );
315 0 : memset( gui->summary.accdb->agg_read_ops_win, 0, sizeof(gui->summary.accdb->agg_read_ops_win) );
316 0 : memset( gui->summary.accdb->agg_write_ops_win, 0, sizeof(gui->summary.accdb->agg_write_ops_win) );
317 0 : memset( gui->summary.accdb->agg_relocated_bytes_win, 0, sizeof(gui->summary.accdb->agg_relocated_bytes_win) );
318 0 : memset( gui->summary.accdb->agg_misses_win, 0, sizeof(gui->summary.accdb->agg_misses_win) );
319 0 : memset( gui->summary.accdb->class_acq_win, 0, sizeof(gui->summary.accdb->class_acq_win) );
320 0 : memset( gui->summary.accdb->class_acq_wr_win, 0, sizeof(gui->summary.accdb->class_acq_wr_win) );
321 0 : memset( gui->summary.accdb->class_not_found_win, 0, sizeof(gui->summary.accdb->class_not_found_win) );
322 0 : memset( gui->summary.accdb->class_evicted_win, 0, sizeof(gui->summary.accdb->class_evicted_win) );
323 0 : memset( gui->summary.accdb->class_preevicted_win, 0, sizeof(gui->summary.accdb->class_preevicted_win) );
324 0 : memset( gui->summary.accdb->class_commit_new_win, 0, sizeof(gui->summary.accdb->class_commit_new_win) );
325 0 : memset( gui->summary.accdb->class_commit_over_win, 0, sizeof(gui->summary.accdb->class_commit_over_win) );
326 :
327 0 : gui->summary.accdb->partition_cnt = 0UL;
328 0 : memset( gui->summary.accdb->partition_read_ops_win, 0, sizeof(gui->summary.accdb->partition_read_ops_win) );
329 0 : memset( gui->summary.accdb->partition_bytes_read_win, 0, sizeof(gui->summary.accdb->partition_bytes_read_win) );
330 0 : memset( gui->summary.accdb->partition_write_ops_win, 0, sizeof(gui->summary.accdb->partition_write_ops_win) );
331 0 : memset( gui->summary.accdb->partition_bytes_written_win, 0, sizeof(gui->summary.accdb->partition_bytes_written_win) );
332 0 : memset( gui->summary.accdb->partitions, 0, sizeof(gui->summary.accdb->partitions) );
333 0 : memset( gui->summary.accdb->partition_prev_read_ops, 0, sizeof(gui->summary.accdb->partition_prev_read_ops) );
334 0 : memset( gui->summary.accdb->partition_prev_bytes_read, 0, sizeof(gui->summary.accdb->partition_prev_bytes_read) );
335 0 : memset( gui->summary.accdb->partition_prev_write_ops, 0, sizeof(gui->summary.accdb->partition_prev_write_ops) );
336 0 : memset( gui->summary.accdb->partition_prev_bytes_written, 0, sizeof(gui->summary.accdb->partition_prev_bytes_written) );
337 0 : for( ulong k=0UL; k<FD_ACCDB_COMPACTION_LAYER_CNT; k++ ) {
338 0 : fd_gui_ema_init( &gui->summary.accdb->tier_fill_bps_ema[ k ], now, FD_GUI_ACCDB_EMA_HALF_LIFE_NS );
339 0 : fd_gui_ema_init( &gui->summary.accdb->tier_free_bps_ema[ k ], now, FD_GUI_ACCDB_EMA_HALF_LIFE_NS );
340 0 : }
341 0 : gui->summary.accdb->tier_sample_nanos = LONG_MAX;
342 0 : gui->summary.accdb->next_compaction_remaining_secs = 0.0;
343 0 : gui->summary.accdb->next_compaction_partition_idx = ULONG_MAX;
344 :
345 : /* Build the per-tile accdb slot table from the topology. Order
346 : matters only for stable JSON ordering: RW joiners first, RO
347 : joiners, then snapin and accdb. */
348 0 : gui->summary.accdb->accdb_tile_cnt = 0UL;
349 0 : static const struct { char const * name; uchar kind; } accdb_kinds[] = {
350 0 : { "execle", FD_GUI_ACCDB_TILE_KIND_RW },
351 0 : { "execrp", FD_GUI_ACCDB_TILE_KIND_RW },
352 0 : { "replay", FD_GUI_ACCDB_TILE_KIND_RW },
353 0 : { "rpc", FD_GUI_ACCDB_TILE_KIND_RO },
354 0 : { "resolv", FD_GUI_ACCDB_TILE_KIND_RO },
355 0 : { "snapin", FD_GUI_ACCDB_TILE_KIND_SNAPIN },
356 0 : { "accdb", FD_GUI_ACCDB_TILE_KIND_ACCDB },
357 0 : };
358 0 : for( ulong k=0UL; k<sizeof(accdb_kinds)/sizeof(accdb_kinds[0]); k++ ) {
359 0 : ulong cnt = fd_topo_tile_name_cnt( gui->topo, accdb_kinds[ k ].name );
360 0 : for( ulong i=0UL; i<cnt; i++ ) {
361 0 : ulong t_idx = fd_topo_find_tile( gui->topo, accdb_kinds[ k ].name, i );
362 0 : if( FD_UNLIKELY( t_idx==ULONG_MAX ) ) continue;
363 0 : ulong slot = gui->summary.accdb->accdb_tile_cnt++;
364 0 : gui->summary.accdb->accdb_tile_topo_idx[ slot ] = (ushort)t_idx;
365 0 : gui->summary.accdb->accdb_tile_kind [ slot ] = accdb_kinds[ k ].kind;
366 0 : }
367 0 : }
368 0 : memset( gui->summary.accdb->tile_cur_acquired, 0, sizeof(gui->summary.accdb->tile_cur_acquired) );
369 0 : memset( gui->summary.accdb->tile_cur_acquired_writable, 0, sizeof(gui->summary.accdb->tile_cur_acquired_writable) );
370 0 : memset( gui->summary.accdb->tile_cur_bytes_read, 0, sizeof(gui->summary.accdb->tile_cur_bytes_read) );
371 0 : memset( gui->summary.accdb->tile_cur_bytes_copied, 0, sizeof(gui->summary.accdb->tile_cur_bytes_copied) );
372 0 : memset( gui->summary.accdb->tile_cur_bytes_written, 0, sizeof(gui->summary.accdb->tile_cur_bytes_written) );
373 0 : memset( gui->summary.accdb->tile_cur_read_ops, 0, sizeof(gui->summary.accdb->tile_cur_read_ops) );
374 0 : memset( gui->summary.accdb->tile_cur_write_ops, 0, sizeof(gui->summary.accdb->tile_cur_write_ops) );
375 0 : memset( gui->summary.accdb->tile_cur_misses, 0, sizeof(gui->summary.accdb->tile_cur_misses) );
376 0 : memset( gui->summary.accdb->tile_cur_evicted, 0, sizeof(gui->summary.accdb->tile_cur_evicted) );
377 0 : memset( gui->summary.accdb->tile_cur_committed, 0, sizeof(gui->summary.accdb->tile_cur_committed) );
378 0 : memset( gui->summary.accdb->tile_cur_acquire_calls, 0, sizeof(gui->summary.accdb->tile_cur_acquire_calls) );
379 0 : memset( gui->summary.accdb->tile_cur_status, 0, sizeof(gui->summary.accdb->tile_cur_status) );
380 0 : memset( gui->summary.accdb->tile_prev_acquired, 0, sizeof(gui->summary.accdb->tile_prev_acquired) );
381 0 : memset( gui->summary.accdb->tile_prev_acquired_writable, 0, sizeof(gui->summary.accdb->tile_prev_acquired_writable) );
382 0 : memset( gui->summary.accdb->tile_prev_bytes_read, 0, sizeof(gui->summary.accdb->tile_prev_bytes_read) );
383 0 : memset( gui->summary.accdb->tile_prev_bytes_copied, 0, sizeof(gui->summary.accdb->tile_prev_bytes_copied) );
384 0 : memset( gui->summary.accdb->tile_prev_bytes_written, 0, sizeof(gui->summary.accdb->tile_prev_bytes_written) );
385 0 : memset( gui->summary.accdb->tile_prev_read_ops, 0, sizeof(gui->summary.accdb->tile_prev_read_ops) );
386 0 : memset( gui->summary.accdb->tile_prev_write_ops, 0, sizeof(gui->summary.accdb->tile_prev_write_ops) );
387 0 : memset( gui->summary.accdb->tile_prev_misses, 0, sizeof(gui->summary.accdb->tile_prev_misses) );
388 0 : memset( gui->summary.accdb->tile_prev_evicted, 0, sizeof(gui->summary.accdb->tile_prev_evicted) );
389 0 : memset( gui->summary.accdb->tile_prev_committed, 0, sizeof(gui->summary.accdb->tile_prev_committed) );
390 0 : memset( gui->summary.accdb->tile_prev_acquire_calls, 0, sizeof(gui->summary.accdb->tile_prev_acquire_calls) );
391 0 : memset( gui->summary.accdb->tile_acquired_win, 0, sizeof(gui->summary.accdb->tile_acquired_win) );
392 0 : memset( gui->summary.accdb->tile_acquired_writable_win, 0, sizeof(gui->summary.accdb->tile_acquired_writable_win) );
393 0 : memset( gui->summary.accdb->tile_bytes_read_win, 0, sizeof(gui->summary.accdb->tile_bytes_read_win) );
394 0 : memset( gui->summary.accdb->tile_bytes_copied_win, 0, sizeof(gui->summary.accdb->tile_bytes_copied_win) );
395 0 : memset( gui->summary.accdb->tile_bytes_written_win, 0, sizeof(gui->summary.accdb->tile_bytes_written_win) );
396 0 : memset( gui->summary.accdb->tile_read_ops_win, 0, sizeof(gui->summary.accdb->tile_read_ops_win) );
397 0 : memset( gui->summary.accdb->tile_write_ops_win, 0, sizeof(gui->summary.accdb->tile_write_ops_win) );
398 0 : memset( gui->summary.accdb->tile_misses_win, 0, sizeof(gui->summary.accdb->tile_misses_win) );
399 0 : memset( gui->summary.accdb->tile_evicted_win, 0, sizeof(gui->summary.accdb->tile_evicted_win) );
400 0 : memset( gui->summary.accdb->tile_committed_win, 0, sizeof(gui->summary.accdb->tile_committed_win) );
401 0 : memset( gui->summary.accdb->tile_acquire_calls_win, 0, sizeof(gui->summary.accdb->tile_acquire_calls_win) );
402 :
403 0 : memset( gui->summary.accdb->tile_sparkline_bucket_start_nanos, 0, sizeof(gui->summary.accdb->tile_sparkline_bucket_start_nanos) );
404 0 : memset( gui->summary.accdb->tile_sparkline_acq_bucket, 0, sizeof(gui->summary.accdb->tile_sparkline_acq_bucket) );
405 0 : memset( gui->summary.accdb->tile_sparkline_acq_wr_bucket, 0, sizeof(gui->summary.accdb->tile_sparkline_acq_wr_bucket) );
406 0 : memset( gui->summary.accdb->tile_sparkline_acq_text_len, 0, sizeof(gui->summary.accdb->tile_sparkline_acq_text_len) );
407 0 : memset( gui->summary.accdb->tile_sparkline_acq_wr_text_len, 0, sizeof(gui->summary.accdb->tile_sparkline_acq_wr_text_len) );
408 0 : memset( gui->summary.accdb->tile_sparkline_count, 0, sizeof(gui->summary.accdb->tile_sparkline_count) );
409 :
410 0 : memset( gui->summary.tile_timers_reference, 0, sizeof(gui->summary.tile_timers_reference) );
411 0 : memset( gui->summary.tile_timers_current, 0, sizeof(gui->summary.tile_timers_current) );
412 0 : memset( gui->summary.tile_timers_packed, 0, sizeof(gui->summary.tile_timers_packed) );
413 :
414 0 : gui->block_engine.has_block_engine = 0;
415 :
416 0 : gui->epoch.current_epoch = ULONG_MAX;
417 0 : gui->epoch.has_epoch_schedule = 0;
418 0 : gui->epoch.missed_vote_history_dirty = ULONG_MAX;
419 :
420 0 : gui->shreds.leader_shred_cnt = 0UL;
421 0 : gui->shreds.leader_shred_slot = ULONG_MAX;
422 0 : gui->shreds.dropped_event_cnt = 0UL;
423 0 : fd_memset( &gui->shreds.builder, 0, sizeof(gui->shreds.builder) );
424 0 : gui->shreds.closed_slot_wmark = 0UL;
425 0 : gui->shreds.fec_marker_sequence = 0UL;
426 0 : gui->shreds.fec_insert_time_ns = 0L;
427 0 : gui->shreds.dropped_fec_event_cnt = 0UL;
428 0 : gui->shreds.clamped_fec_event_cnt = 0UL;
429 0 : gui->shreds.broadcast_watermark_ns = now;
430 0 : gui->summary.catch_up_repair_sz = 0UL;
431 0 : gui->summary.catch_up_turbine_sz = 0UL;
432 :
433 0 : fd_memset( &gui->snapsv, 0, sizeof(gui->snapsv) );
434 :
435 0 : return gui;
436 0 : }
437 :
438 : fd_gui_t *
439 0 : fd_gui_join( void * shmem ) {
440 0 : return (fd_gui_t *)shmem;
441 0 : }
442 :
443 : void
444 : fd_gui_set_identity( fd_gui_t * gui,
445 0 : uchar const * identity_pubkey ) {
446 0 : memcpy( gui->summary.identity_key->uc, identity_pubkey, 32UL );
447 0 : fd_base58_encode_32( identity_pubkey, NULL, gui->summary.identity_key_base58 );
448 0 : gui->summary.identity_key_base58[ FD_BASE58_ENCODED_32_SZ-1UL ] = '\0';
449 :
450 0 : if( FD_LIKELY( gui->summary.is_voting ) ) gui->summary.vote_state = FD_GUI_VOTE_STATE_VOTING;
451 :
452 0 : gui->summary.slot_voted = ULONG_MAX;
453 :
454 0 : fd_gui_printf_identity_key( gui );
455 0 : fd_http_server_ws_broadcast( gui->http );
456 0 : fd_gui_printf_vote_slot( gui );
457 0 : fd_http_server_ws_broadcast( gui->http );
458 0 : fd_gui_printf_vote_state( gui );
459 0 : fd_http_server_ws_broadcast( gui->http );
460 0 : fd_gui_printf_missed_vote_history( gui, gui->epoch.current_epoch );
461 0 : fd_http_server_ws_broadcast( gui->http );
462 0 : }
463 :
464 : void
465 : fd_gui_handle_diag_snapshot( fd_gui_t * gui,
466 : void const * data,
467 0 : ulong data_sz ) {
468 0 : if( FD_UNLIKELY( !data ) ) return;
469 :
470 0 : if( FD_UNLIKELY( data_sz!=sizeof(fd_diag_system_resources_t) ) ) return;
471 :
472 0 : fd_diag_system_resources_t snapshot[ 1 ];
473 0 : fd_memcpy( snapshot, data, sizeof(snapshot) );
474 0 : if( FD_UNLIKELY( snapshot->cpu_cnt >FD_DIAG_SYSTEM_CPU_MAX ||
475 0 : snapshot->numa_mem_cnt>FD_DIAG_SYSTEM_NUMA_MAX ||
476 0 : snapshot->tile_mem_cnt>FD_DIAG_SYSTEM_TILE_MEM_MAX ||
477 0 : snapshot->mount_cnt >FD_DIAG_SYSTEM_FILE_MAX ||
478 0 : snapshot->file_cnt >FD_DIAG_SYSTEM_FILE_MAX ) ) return;
479 0 : for( ulong i=0UL; i<(ulong)snapshot->cpu_cnt; i++ ) {
480 0 : fd_diag_system_cpu_t const * cpu = &snapshot->cpu[ i ];
481 0 : if( FD_UNLIKELY( cpu->cpu_idx>=FD_DIAG_SYSTEM_CPU_MAX ) ) return;
482 0 : if( FD_UNLIKELY( cpu->die_idx!=USHORT_MAX && cpu->die_idx>=snapshot->cpu_cnt ) ) return;
483 0 : }
484 0 : for( ulong i=0UL; i<(ulong)snapshot->tile_mem_cnt; i++ ) {
485 0 : fd_diag_system_tile_mem_t const * tile = &snapshot->tile_mem[ i ];
486 0 : if( FD_UNLIKELY( tile->tile_idx>=gui->topo->tile_cnt ) ) return;
487 0 : }
488 0 : for( ulong i=0UL; i<(ulong)snapshot->mount_cnt; i++ ) {
489 0 : if( FD_UNLIKELY( !memchr( snapshot->mount[ i ].path, '\0', sizeof(snapshot->mount[ i ].path) ) ) ) return;
490 0 : }
491 0 : for( ulong i=0UL; i<(ulong)snapshot->file_cnt; i++ ) {
492 0 : fd_diag_system_file_t const * file = &snapshot->file[ i ];
493 0 : if( FD_UNLIKELY( file->mount_idx>=snapshot->mount_cnt ||
494 0 : file->path[ 0 ]!='/' ||
495 0 : !memchr( file->path, '\0', sizeof(file->path) ) ) ) return;
496 0 : }
497 :
498 0 : gui->system.resources = *snapshot;
499 0 : gui->system.valid = 1;
500 0 : fd_gui_printf_system_resources( gui );
501 0 : fd_http_server_ws_broadcast( gui->http );
502 0 : }
503 :
504 : void
505 : fd_gui_ws_open( fd_gui_t * gui,
506 : ulong ws_conn_id,
507 0 : long now ) {
508 0 : fd_gui_printf_is_alpenglow( gui );
509 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
510 :
511 0 : void (* printers[] )( fd_gui_t * gui ) = {
512 0 : fd_gui_printf_boot_progress,
513 0 : fd_gui_printf_version,
514 0 : fd_gui_printf_cluster,
515 0 : fd_gui_printf_commit_hash,
516 0 : fd_gui_printf_identity_key,
517 0 : fd_gui_printf_vote_key,
518 0 : fd_gui_printf_startup_time_nanos,
519 0 : fd_gui_printf_vote_state,
520 0 : fd_gui_printf_turbine_slot,
521 0 : fd_gui_printf_repair_slot,
522 0 : fd_gui_printf_slot_caught_up,
523 0 : fd_gui_printf_tps_history,
524 0 : fd_gui_printf_estimated_tps,
525 0 : fd_gui_printf_tiles,
526 0 : fd_gui_printf_schedule_strategy,
527 0 : fd_gui_printf_identity_balance,
528 0 : fd_gui_printf_vote_balance,
529 0 : fd_gui_printf_vote_commission,
530 0 : fd_gui_printf_estimated_slot_duration_nanos,
531 0 : fd_gui_printf_root_slot,
532 0 : fd_gui_printf_storage_slot,
533 0 : fd_gui_printf_reset_slot,
534 0 : fd_gui_printf_active_fork_cnt,
535 0 : fd_gui_printf_completed_slot,
536 0 : fd_gui_printf_estimated_slot,
537 0 : fd_gui_printf_live_tile_timers,
538 0 : fd_gui_printf_live_tile_metrics,
539 0 : fd_gui_printf_catch_up_history,
540 0 : fd_gui_printf_health
541 0 : };
542 :
543 0 : ulong printers_len = sizeof(printers) / sizeof(printers[0]);
544 0 : for( ulong i=0UL; i<printers_len; i++ ) {
545 0 : printers[ i ]( gui );
546 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
547 0 : }
548 :
549 0 : fd_gui_printf_finalized_slot( gui );
550 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
551 0 : fd_gui_printf_notarized_slot( gui );
552 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
553 0 : fd_gui_printf_vote_slot( gui );
554 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
555 :
556 0 : if( FD_LIKELY( gui->system.valid ) ) {
557 0 : fd_gui_printf_system_resources( gui );
558 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
559 0 : }
560 :
561 0 : {
562 0 : fd_gui_printf_live_program_cache( gui );
563 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
564 :
565 0 : if( FD_LIKELY( gui->summary.accounts_stats_have_reference ) ) {
566 0 : fd_gui_printf_accounts_stats( gui );
567 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
568 0 : }
569 0 : }
570 :
571 0 : if( FD_LIKELY( gui->block_engine.has_block_engine ) ) {
572 0 : fd_gui_printf_block_engine( gui );
573 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
574 0 : }
575 :
576 0 : if( FD_LIKELY( gui->epoch.current_epoch!=ULONG_MAX ) ) {
577 0 : for( ulong e=gui->epoch.current_epoch; e<=gui->epoch.current_epoch+1UL; e++ ) {
578 0 : if( FD_LIKELY( fd_gui_epoch( gui, e ) ) ) {
579 0 : fd_gui_printf_skip_rate( gui, e );
580 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
581 0 : fd_gui_printf_epoch( gui, e );
582 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
583 0 : }
584 0 : }
585 :
586 0 : fd_gui_printf_skipped_history( gui, gui->epoch.current_epoch );
587 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
588 0 : fd_gui_printf_skipped_history_cluster( gui, gui->epoch.current_epoch );
589 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
590 :
591 0 : fd_gui_printf_missed_vote_history( gui, gui->epoch.current_epoch );
592 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
593 0 : }
594 :
595 : /* rebroadcast 10s of historical shred data */
596 0 : long const shred_history_start = now-10L*1000L*1000L*1000L;
597 0 : if( FD_LIKELY( !fd_gui_shred_window_is_empty( gui, shred_history_start, now ) ) ) {
598 0 : fd_gui_printf_shred_rebroadcast( gui, shred_history_start, now );
599 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
600 0 : }
601 0 : }
602 :
603 :
604 :
605 : static inline ushort
606 0 : fd_gui_tile_timers_pct( ulong delta, ulong total ) {
607 0 : if( FD_UNLIKELY( !total ) ) return USHORT_MAX;
608 0 : double percent = ( (double)delta / (double)total ) * 100.0;
609 0 : long hundredths = (long)( percent * 100.0 );
610 0 : if( FD_UNLIKELY( hundredths<0L ) ) hundredths = 0L;
611 0 : if( FD_UNLIKELY( hundredths>(USHORT_MAX-1U) ) ) hundredths = (USHORT_MAX-1U);
612 0 : return (ushort)hundredths;
613 0 : }
614 :
615 : void
616 : fd_gui_tile_timers_diff( fd_gui_tile_timers_hist_t * out,
617 : fd_gui_tile_timers_t const * prev,
618 : fd_gui_tile_timers_t const * cur,
619 : ulong tile_idx,
620 0 : long sample_time_nanos ) {
621 0 : memset( out, 0, sizeof(*out) );
622 0 : out->sample_time_nanos = sample_time_nanos;
623 0 : out->tile_idx = (ushort)tile_idx;
624 :
625 0 : ulong cur_total = 0UL, prev_total = 0UL;
626 0 : for( ulong j=0UL; j<FD_METRICS_ENUM_TILE_REGIME_CNT; j++ ) {
627 0 : cur_total += cur->timers[ j ]; prev_total += prev->timers[ j ];
628 0 : }
629 0 : ulong busy = cur_total - prev_total;
630 0 : for( ulong j=0UL; j<FD_METRICS_ENUM_TILE_REGIME_CNT; j++ ) {
631 0 : out->timers[ j ] = fd_gui_tile_timers_pct( cur->timers[ j ] - prev->timers[ j ], busy );
632 0 : }
633 0 : if( FD_UNLIKELY( !busy ) ) {
634 0 : out->idle_ratio = USHORT_MAX;
635 0 : } else {
636 0 : ulong mask = FD_METRICS_ENUM_TILE_REGIME_G_IDLE_MASK | FD_METRICS_ENUM_TILE_REGIME_G_BACKPRESSURE_MASK;
637 0 : ulong idle = fd_metrics_enum_group_sum( cur->timers, mask ) - fd_metrics_enum_group_sum( prev->timers, mask );
638 0 : out->idle_ratio = fd_gui_tile_timers_pct( idle, busy );
639 0 : }
640 :
641 0 : ulong cur_ctot = 0UL, prev_ctot = 0UL;
642 0 : for( ulong j=0UL; j<FD_METRICS_ENUM_THREAD_REGIME_CNT; j++ ) { cur_ctot += cur->sched_timers[ j ]; prev_ctot += prev->sched_timers[ j ]; }
643 0 : ulong cbusy = cur_ctot - prev_ctot;
644 0 : for( ulong j=0UL; j<FD_METRICS_ENUM_THREAD_REGIME_CNT; j++ ) {
645 0 : out->sched_timers[ j ] = fd_gui_tile_timers_pct( cur->sched_timers[ j ] - prev->sched_timers[ j ], cbusy );
646 0 : }
647 :
648 0 : out->alive = (uchar)fd_ulong_if( cur->status==2U, 2UL, (ulong)( cur->heartbeat>prev->heartbeat ) );
649 0 : out->in_backp = (uchar)( !!cur->in_backp );
650 0 : out->last_cpu = cur->last_cpu;
651 :
652 0 : out->backp_msgs = cur->backp_cnt;
653 0 : out->nvcsw = cur->nvcsw;
654 0 : out->nivcsw = cur->nivcsw;
655 0 : out->minflt = cur->minflt;
656 0 : out->majflt = cur->majflt;
657 0 : out->interrupts = cur->interrupts;
658 0 : out->tlb_shootdowns = cur->tlb_shootdowns;
659 0 : out->timer_ticks = cur->timer_ticks;
660 0 : }
661 :
662 : static void
663 0 : fd_gui_tile_timers_snap( fd_gui_t * gui, long now ) {
664 0 : fd_gui_tile_timers_t * cur = gui->summary.tile_timers_current;
665 0 : fd_memcpy( gui->summary.tile_timers_reference, cur, gui->tile_cnt * sizeof(fd_gui_tile_timers_t) );
666 0 : for( ulong i=0UL; i<gui->topo->tile_cnt; i++ ) {
667 0 : fd_topo_tile_t const * tile = &gui->topo->tiles[ i ];
668 : /* NULL when the tile's metrics live in a workspace not mapped to
669 : this tile (e.g. bench tiles use the "bench" workspace, not
670 : "metric_in"). */
671 0 : if( FD_UNLIKELY( !tile->metrics ) ) continue;
672 0 : volatile ulong const * tile_metrics = fd_metrics_tile( tile->metrics );
673 :
674 0 : cur[ i ].sample_time_nanos = now;
675 :
676 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_CAUGHT_UP_HOUSEKEEPING_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_CAUGHT_UP_HOUSEKEEPING ) ];
677 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_PROCESSING_HOUSEKEEPING_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_PROCESSING_HOUSEKEEPING ) ];
678 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_BACKPRESSURE_HOUSEKEEPING_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_BACKPRESSURE_HOUSEKEEPING ) ];
679 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_CAUGHT_UP_PREFRAG_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_CAUGHT_UP_PREFRAG ) ];
680 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_PROCESSING_PREFRAG_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_PROCESSING_PREFRAG ) ];
681 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_BACKPRESSURE_PREFRAG_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_BACKPRESSURE_PREFRAG ) ];
682 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_CAUGHT_UP_POSTFRAG_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_CAUGHT_UP_POSTFRAG ) ];
683 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_PROCESSING_POSTFRAG_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_PROCESSING_POSTFRAG ) ];
684 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_CAUGHT_UP_SLEEPING_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_CAUGHT_UP_SLEEPING ) ];
685 0 : cur[ i ].timers[ FD_METRICS_ENUM_TILE_REGIME_V_BACKPRESSURE_SLEEPING_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, REGIME_DURATION_NANOS_BACKPRESSURE_SLEEPING ) ];
686 :
687 0 : cur[ i ].sched_timers[ FD_METRICS_ENUM_THREAD_REGIME_V_WAIT_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, THREAD_DURATION_NANOS_WAIT ) ];
688 0 : cur[ i ].sched_timers[ FD_METRICS_ENUM_THREAD_REGIME_V_USER_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, THREAD_DURATION_NANOS_USER ) ];
689 0 : cur[ i ].sched_timers[ FD_METRICS_ENUM_THREAD_REGIME_V_SYSTEM_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, THREAD_DURATION_NANOS_SYSTEM ) ];
690 0 : cur[ i ].sched_timers[ FD_METRICS_ENUM_THREAD_REGIME_V_IDLE_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, THREAD_DURATION_NANOS_IDLE ) ];
691 0 : cur[ i ].sched_timers[ FD_METRICS_ENUM_THREAD_REGIME_V_INTERRUPT_IDX ] = tile_metrics[ MIDX( COUNTER, TILE, THREAD_DURATION_NANOS_INTERRUPT ) ];
692 :
693 0 : cur[ i ].in_backp = (int)tile_metrics[ MIDX(GAUGE, TILE, IS_BACKPRESSURED) ];
694 0 : cur[ i ].status = (uchar)tile_metrics[ MIDX( GAUGE, TILE, STATE ) ];
695 0 : cur[ i ].heartbeat = tile_metrics[ MIDX( GAUGE, TILE, HEARTBEAT_TIME ) ];
696 0 : cur[ i ].backp_cnt = tile_metrics[ MIDX( COUNTER, TILE, BACKPRESSURE ) ];
697 0 : cur[ i ].nvcsw = tile_metrics[ MIDX( COUNTER, TILE, CONTEXT_SWITCH_VOLUNTARY ) ];
698 0 : cur[ i ].nivcsw = tile_metrics[ MIDX( COUNTER, TILE, CONTEXT_SWITCH_INVOLUNTARY ) ];
699 0 : cur[ i ].minflt = tile_metrics[ MIDX( COUNTER, TILE, PAGE_FAULT_MINOR ) ];
700 0 : cur[ i ].majflt = tile_metrics[ MIDX( COUNTER, TILE, PAGE_FAULT_MAJOR ) ];
701 0 : cur[ i ].last_cpu = (ushort)tile_metrics[ MIDX( GAUGE, TILE, LAST_CPU_INDEX ) ];
702 0 : cur[ i ].interrupts = tile_metrics[ MIDX( COUNTER, TILE, DEVICE_IRQ ) ];
703 0 : cur[ i ].tlb_shootdowns = tile_metrics[ MIDX( COUNTER, TILE, TLB_SHOOTDOWN ) ];
704 0 : cur[ i ].timer_ticks = tile_metrics[ MIDX( COUNTER, TILE, TIMER_IRQ ) ];
705 0 : }
706 :
707 0 : for( ulong i=0UL; i<gui->tile_cnt; i++ ) {
708 0 : cur[ i ].tile_idx = i;
709 0 : fd_gui_tile_timers_diff( &gui->summary.tile_timers_packed[ i ], &gui->summary.tile_timers_reference[ i ], &cur[ i ], i, now );
710 0 : }
711 0 : }
712 :
713 : static void
714 0 : fd_gui_scheduler_counts_snap( fd_gui_t * gui, long now ) {
715 0 : ulong pack_tile_idx = fd_topo_find_tile( gui->topo, "pack", 0UL );
716 0 : if( FD_UNLIKELY( pack_tile_idx==ULONG_MAX ) ) return;
717 :
718 0 : fd_gui_scheduler_counts_t cur[ 1 ];
719 :
720 0 : fd_topo_tile_t const * pack = &gui->topo->tiles[ fd_topo_find_tile( gui->topo, "pack", 0UL ) ];
721 0 : volatile ulong const * pack_metrics = fd_metrics_tile( pack->metrics );
722 :
723 0 : cur->sample_time_ns = now;
724 :
725 0 : cur->regular = pack_metrics[ MIDX( GAUGE, PACK, TXN_PENDING_USED_REGULAR ) ];
726 0 : cur->votes = pack_metrics[ MIDX( GAUGE, PACK, TXN_PENDING_USED_VOTE ) ];
727 0 : cur->conflicting = pack_metrics[ MIDX( GAUGE, PACK, TXN_PENDING_USED_CONFLICTING ) ];
728 0 : cur->bundles = pack_metrics[ MIDX( GAUGE, PACK, TXN_PENDING_USED_BUNDLE ) ];
729 0 : cur->next_auction = pack_metrics[ MIDX( GAUGE, PACK, TXN_PENDING_USED_NEXT_AUCTION ) ];
730 :
731 0 : fd_gui_hist_ts_append( gui, FD_GUI_HIST_SCHEDULER_COUNTS, cur );
732 0 : }
733 :
734 : static void
735 0 : fd_gui_estimated_tps_snap( fd_gui_t * gui ) {
736 0 : ulong vote_failed = 0UL;
737 0 : ulong vote_success = 0UL;
738 0 : ulong nonvote_success = 0UL;
739 0 : ulong nonvote_failed = 0UL;
740 :
741 0 : if( FD_LIKELY( gui->summary.slot_tower==ULONG_MAX ) ) return;
742 0 : ulong first_replay_slot = fd_gui_first_replay_slot( gui );
743 0 : for( ulong i=0UL; i<fd_ulong_min( gui->summary.slot_tower+1UL, MAX_SLOTS_PER_EPOCH ); i++ ) {
744 0 : ulong _slot = gui->summary.slot_tower-i;
745 0 : if( FD_UNLIKELY( first_replay_slot!=ULONG_MAX && _slot<first_replay_slot ) ) break;
746 0 : fd_gui_slot_t const * slot = fd_gui_slot_get_canon( gui, _slot );
747 0 : if( FD_UNLIKELY( !slot ) ) continue;
748 0 : if( FD_UNLIKELY( slot->completed_time==LONG_MAX ) ) continue; /* Slot is on this fork but was never completed, must have been in root path on boot. */
749 0 : if( FD_UNLIKELY( slot->completed_time+FD_GUI_TPS_HISTORY_WINDOW_DURATION_SECONDS*1000L*1000L*1000L<gui->next_sample_200millis ) ) break; /* Slot too old. */
750 0 : if( FD_UNLIKELY( slot->skip!=FD_GUI_SKIP_STATUS_NOT_SKIPPED ) ) continue; /* Skipped slots don't count to TPS. */
751 0 : if( FD_UNLIKELY( slot->vote_failed==UINT_MAX ) ) continue; /* Slot transaction counts not yet populated. */
752 0 : vote_failed += slot->vote_failed;
753 0 : vote_success += slot->vote_success;
754 0 : nonvote_success += slot->nonvote_success;
755 0 : nonvote_failed += slot->nonvote_failed;
756 0 : }
757 :
758 0 : gui->summary.estimated_tps_history[ gui->summary.estimated_tps_history_idx ].vote_failed = vote_failed;
759 0 : gui->summary.estimated_tps_history[ gui->summary.estimated_tps_history_idx ].vote_success = vote_success;
760 0 : gui->summary.estimated_tps_history[ gui->summary.estimated_tps_history_idx ].nonvote_success = nonvote_success;
761 0 : gui->summary.estimated_tps_history[ gui->summary.estimated_tps_history_idx ].nonvote_failed = nonvote_failed;
762 0 : gui->summary.estimated_tps_history_idx = (gui->summary.estimated_tps_history_idx+1UL) % FD_GUI_TPS_HISTORY_SAMPLE_CNT;
763 0 : }
764 :
765 : static void
766 : fd_gui_network_stats_snap_egress( fd_topo_t const * topo,
767 : char const * tile_name,
768 0 : fd_gui_network_stats_t * cur ) {
769 0 : ulong tile_cnt = fd_topo_tile_name_cnt( topo, tile_name );
770 0 : for( ulong i=0UL; i<tile_cnt; i++ ) {
771 0 : ulong tile_idx = fd_topo_find_tile( topo, tile_name, i );
772 0 : if( FD_UNLIKELY( tile_idx==ULONG_MAX ) ) continue;
773 0 : fd_topo_tile_t const * tile = &topo->tiles[ tile_idx ];
774 0 : for( ulong j=0UL; j<tile->in_cnt; j++ ) {
775 0 : ulong bytes = fd_metrics_link_in( tile->metrics, j )[ FD_METRICS_COUNTER_LINK_FRAG_CONSUMED_BYTES_OFF ];
776 0 : char const * link_name = topo->links[ tile->in_link_id[ j ] ].name;
777 0 : if( FD_UNLIKELY( !strcmp( link_name, "shred_net" ) ) ) cur->out.turbine += bytes;
778 0 : if( FD_UNLIKELY( !strcmp( link_name, "repair_net" ) ) ) cur->out.repair += bytes;
779 0 : if( FD_UNLIKELY( !strcmp( link_name, "rserve_net" ) ) ) cur->out.rserve += bytes;
780 0 : if( FD_UNLIKELY( !strcmp( link_name, "txsend_net" ) ) ) cur->out.tpu += bytes;
781 0 : if( FD_UNLIKELY( !strcmp( link_name, "votor_net" ) ) ) cur->out.votor += bytes;
782 0 : }
783 0 : }
784 0 : }
785 :
786 : static void
787 : fd_gui_network_stats_snap( fd_gui_t * gui,
788 0 : fd_gui_network_stats_t * cur ) {
789 0 : fd_topo_t const * topo = gui->topo;
790 0 : ulong gossvf_tile_cnt = fd_topo_tile_name_cnt( topo, "gossvf" );
791 0 : ulong gossip_tile_cnt = fd_topo_tile_name_cnt( topo, "gossip" );
792 0 : ulong shred_tile_cnt = fd_topo_tile_name_cnt( topo, "shred" );
793 0 : ulong quic_tile_cnt = fd_topo_tile_name_cnt( topo, "quic" );
794 :
795 0 : cur->in.gossip = fd_gui_metrics_gossip_total_ingress_bytes( topo, gossvf_tile_cnt );
796 0 : cur->out.gossip = fd_gui_metrics_gossip_total_egress_bytes( topo, gossip_tile_cnt );
797 0 : cur->in.turbine = fd_gui_metrics_sum_tiles_counter( topo, "shred", shred_tile_cnt, MIDX( COUNTER, SHRED, TURBINE_RX_BYTES ) );
798 :
799 0 : cur->out.turbine = 0UL;
800 0 : cur->out.repair = 0UL;
801 0 : cur->out.rserve = 0UL;
802 0 : cur->out.tpu = 0UL;
803 0 : cur->out.votor = 0UL;
804 0 : cur->in.votor = 0UL;
805 0 : fd_gui_network_stats_snap_egress( topo, "net", cur );
806 0 : fd_gui_network_stats_snap_egress( topo, "mlx5", cur );
807 0 : fd_gui_network_stats_snap_egress( topo, "iavf", cur );
808 :
809 0 : ulong votor_tile_idx = fd_topo_find_tile( topo, "votor", 0UL );
810 0 : if( FD_UNLIKELY( votor_tile_idx!=ULONG_MAX ) ) {
811 0 : fd_topo_tile_t const * votor = &topo->tiles[ votor_tile_idx ];
812 0 : for( ulong i=0UL; i<votor->in_cnt; i++ ) {
813 0 : if( FD_UNLIKELY( !strcmp( topo->links[ votor->in_link_id[ i ] ].name, "net_votor" ) ) ) {
814 0 : cur->in.votor += fd_metrics_link_in( votor->metrics, i )[ FD_METRICS_COUNTER_LINK_FRAG_CONSUMED_BYTES_OFF ];
815 0 : }
816 0 : }
817 0 : }
818 :
819 0 : cur->in.repair = fd_gui_metrics_sum_tiles_counter( topo, "shred", shred_tile_cnt, MIDX( COUNTER, SHRED, REPAIR_RX_BYTES ) );
820 0 : ulong repair_tile_idx = fd_topo_find_tile( topo, "repair", 0UL );
821 0 : if( FD_LIKELY( repair_tile_idx!=ULONG_MAX ) ) {
822 0 : fd_topo_tile_t const * repair = &topo->tiles[ repair_tile_idx ];
823 :
824 0 : for( ulong i=0UL; i<repair->in_cnt; i++ ) {
825 0 : if( FD_UNLIKELY( !strcmp( topo->links[ repair->in_link_id[ i ] ].name, "shred_repair" ) ) ) {
826 0 : cur->in.repair += fd_metrics_link_in( repair->metrics, i )[ FD_METRICS_COUNTER_LINK_FRAG_CONSUMED_BYTES_OFF ];
827 0 : }
828 0 : }
829 0 : }
830 :
831 0 : cur->in.rserve = 0UL;
832 0 : ulong rserve_tile_idx = fd_topo_find_tile( topo, "rserve", 0UL );
833 0 : if( FD_LIKELY( rserve_tile_idx!=ULONG_MAX ) ) {
834 0 : fd_topo_tile_t const * rserve = &topo->tiles[ rserve_tile_idx ];
835 :
836 0 : for( ulong i=0UL; i<rserve->in_cnt; i++ ) {
837 0 : if( FD_UNLIKELY( !strcmp( topo->links[ rserve->in_link_id[ i ] ].name, "net_rserve" ) ) ) {
838 0 : cur->in.rserve += fd_metrics_link_in( rserve->metrics, i )[ FD_METRICS_COUNTER_LINK_FRAG_CONSUMED_BYTES_OFF ];
839 0 : }
840 0 : }
841 0 : }
842 :
843 0 : cur->in.tpu = 0UL;
844 0 : for( ulong i=0UL; i<quic_tile_cnt; i++ ) {
845 0 : ulong quic_tile_idx = fd_topo_find_tile( topo, "quic", i );
846 0 : if( FD_UNLIKELY( quic_tile_idx==ULONG_MAX ) ) continue;
847 0 : fd_topo_tile_t const * quic = &topo->tiles[ quic_tile_idx ];
848 0 : volatile ulong * quic_metrics = fd_metrics_tile( quic->metrics );
849 0 : cur->in.tpu += quic_metrics[ MIDX( COUNTER, QUIC, PKT_RX_BYTES ) ];
850 0 : }
851 :
852 0 : ulong bundle_tile_idx = fd_topo_find_tile( topo, "bundle", 0UL );
853 0 : if( FD_LIKELY( bundle_tile_idx!=ULONG_MAX ) ) {
854 0 : fd_topo_tile_t const * bundle = &topo->tiles[ bundle_tile_idx ];
855 0 : volatile ulong * bundle_metrics = fd_metrics_tile( bundle->metrics );
856 0 : cur->in.tpu += bundle_metrics[ MIDX( COUNTER, BUNDLE, PROTOBUF_RX_BYTES ) ];
857 0 : }
858 :
859 0 : ulong metric_tile_idx = fd_topo_find_tile( topo, "metric", 0UL );
860 0 : if( FD_LIKELY( metric_tile_idx!=ULONG_MAX ) ) {
861 0 : fd_topo_tile_t const * metric = &topo->tiles[ metric_tile_idx ];
862 0 : volatile ulong * metric_metrics = fd_metrics_tile( metric->metrics );
863 0 : cur->in.metric = metric_metrics[ MIDX( COUNTER, METRIC, CONN_RX_BYTES ) ];
864 0 : cur->out.metric = metric_metrics[ MIDX( COUNTER, METRIC, CONN_TX_BYTES ) ];
865 0 : } else {
866 0 : cur->in.metric = 0UL;
867 0 : cur->out.metric = 0UL;
868 0 : }
869 0 : }
870 :
871 : static void
872 : fd_gui_network_rate_max_update( fd_gui_t * gui,
873 0 : long now ) {
874 0 : fd_gui_network_stats_t * cur = gui->summary.network_stats_current;
875 0 : fd_gui_network_stats_t * prev = gui->summary.network_stats_prev;
876 :
877 : /* On the first sample we have no previous value. */
878 0 : if( FD_UNLIKELY( !gui->summary.network_stats_has_prev ) ) {
879 0 : *prev = *cur;
880 0 : gui->summary.network_stats_has_prev = 1;
881 0 : gui->summary.net_rate_prev_ts = now;
882 0 : return;
883 0 : }
884 :
885 0 : ulong d_in[ FD_GUI_NET_PROTO_CNT ];
886 0 : d_in[ 0 ] = fd_ulong_sat_sub( cur->in.turbine, prev->in.turbine );
887 0 : d_in[ 1 ] = fd_ulong_sat_sub( cur->in.gossip, prev->in.gossip );
888 0 : d_in[ 2 ] = fd_ulong_sat_sub( cur->in.tpu, prev->in.tpu );
889 0 : d_in[ 3 ] = fd_ulong_sat_sub( cur->in.repair, prev->in.repair );
890 0 : d_in[ 4 ] = fd_ulong_sat_sub( cur->in.rserve, prev->in.rserve );
891 0 : d_in[ 5 ] = fd_ulong_sat_sub( cur->in.metric, prev->in.metric );
892 0 : d_in[ 6 ] = fd_ulong_sat_sub( cur->in.votor, prev->in.votor );
893 :
894 0 : ulong d_out[ FD_GUI_NET_PROTO_CNT ];
895 0 : d_out[ 0 ] = fd_ulong_sat_sub( cur->out.turbine, prev->out.turbine );
896 0 : d_out[ 1 ] = fd_ulong_sat_sub( cur->out.gossip, prev->out.gossip );
897 0 : d_out[ 2 ] = fd_ulong_sat_sub( cur->out.tpu, prev->out.tpu );
898 0 : d_out[ 3 ] = fd_ulong_sat_sub( cur->out.repair, prev->out.repair );
899 0 : d_out[ 4 ] = fd_ulong_sat_sub( cur->out.rserve, prev->out.rserve );
900 0 : d_out[ 5 ] = fd_ulong_sat_sub( cur->out.metric, prev->out.metric );
901 0 : d_out[ 6 ] = fd_ulong_sat_sub( cur->out.votor, prev->out.votor );
902 :
903 : /* Compute per-protocol instantaneous bytes/sec rate and feed the EMA. */
904 0 : long dt_ns = now - gui->summary.net_rate_prev_ts;
905 0 : if( FD_LIKELY( dt_ns>0L ) ) {
906 0 : double dt_sec = (double)dt_ns / 1.0e9;
907 :
908 0 : for( ulong i=0UL; i<FD_GUI_NET_PROTO_CNT; i++ ) {
909 0 : double rate_in = (double)d_in[ i ] / dt_sec;
910 0 : double rate_out = (double)d_out[ i ] / dt_sec;
911 :
912 0 : fd_gui_ema_advance( &gui->summary.ingress_ema[ i ], now, rate_in );
913 0 : fd_gui_ema_advance( &gui->summary.egress_ema [ i ], now, rate_out );
914 0 : }
915 0 : }
916 0 : gui->summary.net_rate_prev_ts = now;
917 :
918 : /* Track max total EMA in a rolling 5-minute window using monotonic
919 : deques.
920 :
921 : Invariant: deque entries are strictly decreasing in value from
922 : head to tail. The head is always the current window maximum.
923 :
924 : Insert: pop tail entries whose value <= new value (they can
925 : never become the maximum), then push the new entry.
926 : Expire: pop head entries older than 5 minutes. */
927 0 : if( FD_LIKELY( gui->summary.ingress_ema[ 0 ].last_update_nanos ) ) {
928 0 : double sum_in = 0.0;
929 0 : double sum_out = 0.0;
930 0 : for( ulong i=0UL; i<FD_GUI_NET_PROTO_CNT; i++ ) {
931 0 : sum_in += gui->summary.ingress_ema[ i ].value;
932 0 : sum_out += gui->summary.egress_ema[ i ].value;
933 0 : }
934 :
935 0 : while( !fd_gui_rate_deque_empty( gui->summary.ingress_maxq ) && fd_gui_rate_deque_peek_head_const( gui->summary.ingress_maxq )->ts_nanos<now-FD_GUI_NET_RATE_MAX_WINDOW_NS ) {
936 0 : fd_gui_rate_deque_pop_head( gui->summary.ingress_maxq );
937 0 : }
938 0 : while( !fd_gui_rate_deque_empty( gui->summary.ingress_maxq ) && fd_gui_rate_deque_peek_tail_const( gui->summary.ingress_maxq )->value<=sum_in ) {
939 0 : fd_gui_rate_deque_pop_tail( gui->summary.ingress_maxq );
940 0 : }
941 0 : if( FD_UNLIKELY( fd_gui_rate_deque_full( gui->summary.ingress_maxq ) ) ) {
942 0 : fd_gui_rate_deque_pop_tail( gui->summary.ingress_maxq );
943 0 : }
944 0 : fd_gui_rate_deque_push_tail( gui->summary.ingress_maxq, (fd_gui_rate_entry_t){ .ts_nanos=now, .value=sum_in } );
945 :
946 0 : while( !fd_gui_rate_deque_empty( gui->summary.egress_maxq ) && fd_gui_rate_deque_peek_head_const( gui->summary.egress_maxq )->ts_nanos<now-FD_GUI_NET_RATE_MAX_WINDOW_NS ) {
947 0 : fd_gui_rate_deque_pop_head( gui->summary.egress_maxq );
948 0 : }
949 0 : while( !fd_gui_rate_deque_empty( gui->summary.egress_maxq ) && fd_gui_rate_deque_peek_tail_const( gui->summary.egress_maxq )->value<=sum_out ) {
950 0 : fd_gui_rate_deque_pop_tail( gui->summary.egress_maxq );
951 0 : }
952 0 : if( FD_UNLIKELY( fd_gui_rate_deque_full( gui->summary.egress_maxq ) ) ) {
953 0 : fd_gui_rate_deque_pop_tail( gui->summary.egress_maxq );
954 0 : }
955 0 : fd_gui_rate_deque_push_tail( gui->summary.egress_maxq, (fd_gui_rate_entry_t){ .ts_nanos=now, .value=sum_out } );
956 0 : }
957 :
958 0 : *prev = *cur;
959 0 : }
960 :
961 : /* Snapshot accdb statistics by reading the accdb tile's metric page
962 : (for gauges) and summing counters across all tiles that join accdb
963 : (executors, replay, rpc, resolv, plus the accdb tile itself).
964 : The result feeds the GUI "Accounts" page. */
965 :
966 : static void
967 : fd_gui_accounts_stats_snap( fd_gui_t * gui,
968 0 : fd_gui_accounts_stats_t * cur ) {
969 0 : fd_topo_t const * topo = gui->topo;
970 :
971 0 : memset( cur, 0, sizeof(*cur) );
972 0 : cur->sample_time_nanos = fd_log_wallclock();
973 :
974 0 : ulong accdb_tile_idx = fd_topo_find_tile( topo, "accdb", 0UL );
975 0 : if( FD_UNLIKELY( accdb_tile_idx==ULONG_MAX ) ) return;
976 :
977 : /* Gauges + accdb-tile-only counters. */
978 0 : fd_topo_tile_t const * accdb = &topo->tiles[ accdb_tile_idx ];
979 0 : volatile ulong const * am = fd_metrics_tile( accdb->metrics );
980 :
981 0 : cur->accounts_total = am[ MIDX( GAUGE, ACCDB, ACCOUNT_USED ) ];
982 0 : cur->accounts_capacity = am[ MIDX( GAUGE, ACCDB, ACCOUNT_CAPACITY ) ];
983 0 : cur->disk_allocated_bytes = am[ MIDX( GAUGE, ACCDB, DISK_ALLOCATED_BYTES ) ];
984 0 : cur->disk_current_bytes = am[ MIDX( GAUGE, ACCDB, DISK_CONSUMED_BYTES ) ];
985 0 : cur->disk_used_bytes = am[ MIDX( GAUGE, ACCDB, DISK_USED_BYTES ) ];
986 0 : cur->in_compaction = am[ MIDX( GAUGE, ACCDB, IS_COMPACTING ) ];
987 0 : cur->compactions_requested = am[ MIDX( COUNTER, ACCDB, COMPACTION_REQUESTED ) ];
988 0 : cur->compactions_completed = am[ MIDX( COUNTER, ACCDB, COMPACTION_COMPLETED ) ];
989 0 : cur->accounts_relocated_bytes = am[ MIDX( COUNTER, ACCDB, ACCOUNT_RELOCATED_BYTES ) ];
990 0 : cur->bytes_written_accdb = am[ MIDX( COUNTER, ACCDB, DISK_WRITTEN_BYTES ) ];
991 :
992 : /* The accdb tile owns the prewrite and compaction writes; include
993 : those in the aggregate bytes_written / write_ops so the IO panel
994 : reflects all on-disk write activity, not just consumer-driven
995 : commits. */
996 0 : cur->bytes_written += am[ MIDX( COUNTER, ACCDB, DISK_WRITTEN_BYTES ) ];
997 0 : cur->write_ops += am[ MIDX( COUNTER, ACCDB, WRITEBACK_WRITTEN ) ];
998 :
999 0 : for( ulong c=0UL; c<FD_ACCDB_CACHE_CLASS_CNT; c++ ) {
1000 0 : cur->cache_class_used [ c ] = am[ MIDX( GAUGE, ACCDB, CACHE_CLASS_USED ) + c ];
1001 0 : cur->cache_class_max [ c ] = am[ MIDX( GAUGE, ACCDB, CACHE_CLASS_CAPACITY ) + c ];
1002 0 : int tracked = !!am[ MIDX( GAUGE, ACCDB, IS_CACHE_CLASS_RESERVATION_TRACKED ) + c ];
1003 0 : cur->cache_class_reserved [ c ] = fd_ulong_if( tracked, am[ MIDX( GAUGE, ACCDB, CACHE_CLASS_RESERVED ) + c ], ULONG_MAX );
1004 0 : ulong free_target = am[ MIDX( GAUGE, ACCDB, CACHE_CLASS_FREE_TARGET ) + c ];
1005 0 : ulong free_low_water = am[ MIDX( GAUGE, ACCDB, CACHE_CLASS_FREE_LOW_WATER ) + c ];
1006 0 : cur->cache_class_target_used [ c ] = fd_ulong_sat_sub( cur->cache_class_max[ c ], free_target );
1007 0 : cur->cache_class_low_water_used[c ] = fd_ulong_sat_sub( cur->cache_class_max[ c ], free_low_water );
1008 0 : cur->preevicted_per_class [ c ] = am[ MIDX( COUNTER, ACCDB, ACCOUNT_PREEVICTED ) + c ];
1009 0 : }
1010 :
1011 : /* Walk the per-tile slot table built at init. Each slot reads its
1012 : tile's accdb counters according to its kind (RW, RO, or ACCDB),
1013 : accumulates into the aggregate (cur->*), and stashes the per-tile
1014 : cumulative values into gui->summary.accdb->tile_cur_* for the
1015 : per-tile rate window pushes done later in
1016 : fd_gui_printf_accounts_stats. */
1017 0 : for( ulong s=0UL; s<gui->summary.accdb->accdb_tile_cnt; s++ ) {
1018 0 : ulong t_idx = (ulong)gui->summary.accdb->accdb_tile_topo_idx[ s ];
1019 0 : uchar kind = gui->summary.accdb->accdb_tile_kind[ s ];
1020 0 : volatile ulong const * m = fd_metrics_tile( topo->tiles[ t_idx ].metrics );
1021 :
1022 0 : gui->summary.accdb->tile_cur_status[ s ] = (uchar)m[ MIDX( GAUGE, TILE, STATE ) ];
1023 :
1024 0 : ulong t_acq=0UL, t_acw=0UL, t_misses=0UL, t_evicted=0UL, t_committed=0UL;
1025 0 : ulong t_bytes_read=0UL, t_bytes_copied=0UL, t_bytes_written=0UL;
1026 0 : ulong t_read_ops=0UL, t_write_ops=0UL;
1027 0 : ulong t_acquire_calls=0UL;
1028 :
1029 0 : switch( kind ) {
1030 0 : # define DO_RW( TILE_UPPER ) \
1031 0 : t_bytes_read = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_DISK_READ_BYTES ) ]; \
1032 0 : t_bytes_copied = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_COPIED_BYTES ) ]; \
1033 0 : t_bytes_written = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_DISK_WRITTEN_BYTES ) ]; \
1034 0 : t_read_ops = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_DISK_READ ) ]; \
1035 0 : t_write_ops = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_DISK_WRITTEN ) ]; \
1036 0 : t_acquire_calls = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_BATCH_ACQUIRED ) ]; \
1037 0 : for( ulong c=0UL; c<FD_ACCDB_CACHE_CLASS_CNT; c++ ) { \
1038 0 : ulong _acq = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_READONLY_ACQUIRED ) + c ]; \
1039 0 : ulong _acw = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_WRITABLE_ACQUIRED ) + c ]; \
1040 0 : ulong _nf = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_CACHE_MISSED ) + c ]; \
1041 0 : ulong _ev = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_EVICTED ) + c ]; \
1042 0 : ulong _cn = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_NEW_COMMITTED ) + c ]; \
1043 0 : ulong _co = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_OVERWRITE_COMMITTED ) + c ]; \
1044 0 : t_acq+=_acq; t_acw+=_acw; t_misses+=_nf; t_evicted+=_ev; t_committed+=_cn+_co; \
1045 0 : cur->acquired_per_class [ c ] += _acq; \
1046 0 : cur->acquired_writable_per_class [ c ] += _acw; \
1047 0 : cur->not_found_per_class [ c ] += _nf; \
1048 0 : cur->evicted_per_class [ c ] += _ev; \
1049 0 : cur->committed_new_per_class [ c ] += _cn; \
1050 0 : cur->committed_overwrite_per_class [ c ] += _co; \
1051 0 : }
1052 0 : case FD_GUI_ACCDB_TILE_KIND_RW:
1053 0 : if( !strcmp( topo->tiles[ t_idx ].name, "execle" ) ) { DO_RW( EXECLE ); }
1054 0 : else if( !strcmp( topo->tiles[ t_idx ].name, "execrp" ) ) { DO_RW( EXECRP ); }
1055 0 : else if( !strcmp( topo->tiles[ t_idx ].name, "replay" ) ) { DO_RW( REPLAY ); }
1056 0 : cur->acquired += t_acq;
1057 0 : cur->acquired_writable += t_acw;
1058 0 : cur->bytes_read += t_bytes_read;
1059 0 : cur->bytes_copied += t_bytes_copied;
1060 0 : cur->bytes_written += t_bytes_written;
1061 0 : cur->read_ops += t_read_ops;
1062 0 : cur->write_ops += t_write_ops;
1063 0 : break;
1064 0 : # undef DO_RW
1065 :
1066 0 : # define DO_RO( TILE_UPPER ) \
1067 0 : t_bytes_read = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_DISK_READ_BYTES ) ]; \
1068 0 : t_bytes_copied = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_COPIED_BYTES ) ]; \
1069 0 : t_read_ops = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_DISK_READ ) ]; \
1070 0 : for( ulong c=0UL; c<FD_ACCDB_CACHE_CLASS_CNT; c++ ) { \
1071 0 : ulong _acq = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_READONLY_ACQUIRED ) + c ]; \
1072 0 : ulong _nf = m[ MIDX( COUNTER, TILE_UPPER, ACCDB_ACCOUNT_CACHE_MISSED ) + c ]; \
1073 0 : t_acq+=_acq; t_misses+=_nf; \
1074 0 : cur->acquired_per_class [ c ] += _acq; \
1075 0 : cur->not_found_per_class[ c ] += _nf; \
1076 0 : }
1077 0 : case FD_GUI_ACCDB_TILE_KIND_RO:
1078 0 : if( !strcmp( topo->tiles[ t_idx ].name, "rpc" ) ) { DO_RO( RPC ); }
1079 0 : else if( !strcmp( topo->tiles[ t_idx ].name, "resolv" ) ) { DO_RO( RESOLV ); }
1080 0 : cur->acquired += t_acq;
1081 0 : cur->bytes_read += t_bytes_read;
1082 0 : cur->bytes_copied += t_bytes_copied;
1083 0 : cur->read_ops += t_read_ops;
1084 0 : break;
1085 0 : # undef DO_RO
1086 :
1087 0 : case FD_GUI_ACCDB_TILE_KIND_SNAPIN:
1088 : /* snapin writes account data to disk directly during snapshot
1089 : load. */
1090 0 : t_bytes_written = m[ MIDX( COUNTER, SNAPIN, DISK_WRITTEN_BYTES ) ];
1091 0 : cur->bytes_written += t_bytes_written;
1092 0 : break;
1093 :
1094 0 : case FD_GUI_ACCDB_TILE_KIND_ACCDB:
1095 : /* The accdb tile owns prewrite and compaction writes. Its own
1096 : bytes_written/write_ops were already folded into the aggregate
1097 : above (see ACCDB_DISK_WRITTEN_BYTES / ACCDB_WRITE_OPS reads). Here
1098 : we only stash per-slot values so the per-tile row reflects
1099 : them; do not re-add to cur->* or we'd double-count. The accdb
1100 : tile does not expose acquired/not_found/committed (no account
1101 : joiner) or read_ops/bytes_copied. Preevicts are owned by the
1102 : accdb tile's background preevict pass, so map them to the
1103 : per-tile evicted column for this row. */
1104 0 : t_bytes_read = m[ MIDX( COUNTER, ACCDB, DISK_READ_BYTES ) ];
1105 0 : t_bytes_written = m[ MIDX( COUNTER, ACCDB, DISK_WRITTEN_BYTES ) ];
1106 0 : t_write_ops = m[ MIDX( COUNTER, ACCDB, WRITEBACK_WRITTEN ) ];
1107 0 : for( ulong c=0UL; c<FD_ACCDB_CACHE_CLASS_CNT; c++ ) {
1108 0 : t_evicted += m[ MIDX( COUNTER, ACCDB, ACCOUNT_PREEVICTED ) + c ];
1109 0 : }
1110 0 : break;
1111 0 : }
1112 :
1113 0 : gui->summary.accdb->tile_cur_acquired [ s ] = t_acq;
1114 0 : gui->summary.accdb->tile_cur_acquired_writable[ s ] = t_acw;
1115 0 : gui->summary.accdb->tile_cur_bytes_read [ s ] = t_bytes_read;
1116 0 : gui->summary.accdb->tile_cur_bytes_copied [ s ] = t_bytes_copied;
1117 0 : gui->summary.accdb->tile_cur_bytes_written [ s ] = t_bytes_written;
1118 0 : gui->summary.accdb->tile_cur_read_ops [ s ] = t_read_ops;
1119 0 : gui->summary.accdb->tile_cur_write_ops [ s ] = t_write_ops;
1120 0 : gui->summary.accdb->tile_cur_misses [ s ] = t_misses;
1121 0 : gui->summary.accdb->tile_cur_evicted [ s ] = t_evicted;
1122 0 : gui->summary.accdb->tile_cur_committed [ s ] = t_committed;
1123 0 : gui->summary.accdb->tile_cur_acquire_calls [ s ] = t_acquire_calls;
1124 0 : }
1125 :
1126 0 : if( FD_UNLIKELY( !gui->accdb_shmem ) ) return;
1127 :
1128 : /* Snapshot per-partition utilization and fragmentation and also
1129 : their respective per-tier rate of growth. Actively-compacting
1130 : partitions excluded so relocation churn does not degrade estimates. */
1131 0 : ulong pcnt = fd_ulong_min( fd_accdb_shmem_partition_max( gui->accdb_shmem ), FD_GUI_MAX_PARTITIONS );
1132 0 : gui->summary.accdb->partition_cnt = pcnt;
1133 :
1134 0 : double tier_fill_delta[ FD_ACCDB_COMPACTION_LAYER_CNT ] = { 0.0 };
1135 0 : double tier_free_delta[ FD_ACCDB_COMPACTION_LAYER_CNT ] = { 0.0 };
1136 0 : ulong compaction_idx = ULONG_MAX;
1137 0 : ulong compaction_layer = FD_ACCDB_COMPACTION_LAYER_CNT;
1138 0 : ulong compaction_state = 0UL;
1139 0 : for( ulong p=0UL; p<pcnt; p++ ) {
1140 0 : fd_accdb_shmem_partition_info_t prev_info = gui->summary.accdb->partitions[ p ];
1141 0 : fd_accdb_shmem_partition_info_t * info = &gui->summary.accdb->partitions[ p ];
1142 0 : fd_accdb_shmem_partition_info( gui->accdb_shmem, p, info );
1143 :
1144 0 : if( FD_UNLIKELY( info->compaction_state && ( compaction_state<info->compaction_state || ( compaction_state==info->compaction_state && info->layer<compaction_layer ) ) ) ) {
1145 0 : compaction_idx = p;
1146 0 : compaction_layer = info->layer;
1147 0 : compaction_state = info->compaction_state;
1148 0 : }
1149 :
1150 0 : if( FD_LIKELY( info->layer<FD_ACCDB_COMPACTION_LAYER_CNT ) ) {
1151 : /* Only the <=3 write-head partitions advance, and freed bytes
1152 : land in a handful of partitions per 100ms snap. */
1153 0 : if( FD_UNLIKELY( info->write_offset>prev_info.write_offset ) )
1154 0 : tier_fill_delta[ info->layer ] += (double)(info->write_offset-prev_info.write_offset);
1155 0 : if( FD_UNLIKELY( info->compaction_state!=2 && info->bytes_freed>prev_info.bytes_freed ) )
1156 0 : tier_free_delta[ info->layer ] += (double)(info->bytes_freed-prev_info.bytes_freed);
1157 0 : }
1158 0 : }
1159 :
1160 : /* First snap has no valid deltas. */
1161 0 : if( FD_LIKELY( gui->summary.accdb->tier_sample_nanos!=LONG_MAX ) ) {
1162 0 : double dt_sec = (double)(cur->sample_time_nanos-gui->summary.accdb->tier_sample_nanos)/1e9;
1163 0 : if( FD_LIKELY( dt_sec>0.0 ) ) {
1164 0 : for( ulong k=0UL; k<FD_ACCDB_COMPACTION_LAYER_CNT; k++ ) {
1165 0 : fd_gui_ema_advance( &gui->summary.accdb->tier_fill_bps_ema[ k ], cur->sample_time_nanos, tier_fill_delta[ k ]/dt_sec );
1166 0 : fd_gui_ema_advance( &gui->summary.accdb->tier_free_bps_ema[ k ], cur->sample_time_nanos, tier_free_delta[ k ]/dt_sec );
1167 0 : }
1168 0 : }
1169 0 : }
1170 0 : gui->summary.accdb->tier_sample_nanos = cur->sample_time_nanos;
1171 :
1172 : /* Estimate next compaction time/partition. */
1173 0 : double next_secs = 0.0;
1174 0 : ulong next_idx = ULONG_MAX;
1175 0 : double partition_sz = (double)fd_accdb_shmem_partition_sz( gui->accdb_shmem );
1176 0 : double tier_live_bytes[ FD_ACCDB_COMPACTION_LAYER_CNT ] = { 0.0 };
1177 0 : for( ulong p=0UL; p<pcnt; p++ ) {
1178 0 : fd_accdb_shmem_partition_info_t const * info = &gui->summary.accdb->partitions[ p ];
1179 0 : if( info->layer<FD_ACCDB_COMPACTION_LAYER_CNT && info->compaction_state!=2 && info->write_offset>info->bytes_freed && info->compaction_offset<info->write_offset )
1180 0 : tier_live_bytes[ info->layer ] += (double)(info->write_offset-info->bytes_freed);
1181 0 : }
1182 0 : for( ulong p=0UL; p<pcnt; p++ ) {
1183 0 : fd_accdb_shmem_partition_info_t const * info = &gui->summary.accdb->partitions[ p ];
1184 0 : if( FD_LIKELY( info->compaction_state || !info->write_offset ) ) continue;
1185 0 : if( FD_UNLIKELY( info->layer>=FD_ACCDB_COMPACTION_LAYER_CNT ) ) continue;
1186 0 : if( FD_UNLIKELY( info->compaction_offset>=info->write_offset ) ) continue; /* compacted, awaiting reclaim */
1187 :
1188 0 : double free_bps = gui->summary.accdb->tier_free_bps_ema[ info->layer ].value;
1189 0 : double live = info->write_offset>info->bytes_freed ? (double)(info->write_offset-info->bytes_freed) : 0.0;
1190 0 : double frag_rate = tier_live_bytes[ info->layer ]>0.0 ? free_bps*live/tier_live_bytes[ info->layer ] : 0.0;
1191 0 : double deficit = (double)FD_ACCDB_COMPACTION_THRESHOLD_PCT/100.0*partition_sz - (double)info->bytes_freed;
1192 0 : double frag_secs = deficit<=0.0 ? 0.0 : ( frag_rate>0.0 ? deficit/frag_rate : -1.0 );
1193 0 : double fill_secs = 0.0;
1194 0 : if( FD_UNLIKELY( info->is_write_head ) ) {
1195 0 : double fill_bps = gui->summary.accdb->tier_fill_bps_ema[ info->layer ].value;
1196 0 : fill_secs = fill_bps>0.0 ? (partition_sz-(double)info->write_offset)/fill_bps : -1.0;
1197 0 : }
1198 :
1199 0 : if( FD_UNLIKELY( frag_secs<0.0 || fill_secs<0.0 ) ) continue; /* no usable rate estimate (EMA warm-up) */
1200 0 : double est = fmax( frag_secs, fill_secs );
1201 0 : if( next_idx==ULONG_MAX || est<next_secs ) {
1202 0 : next_secs = est;
1203 0 : next_idx = p;
1204 0 : }
1205 0 : }
1206 :
1207 0 : int has_compaction = compaction_idx!=ULONG_MAX;
1208 0 : gui->summary.accdb->next_compaction_remaining_secs = fd_double_if( has_compaction, 0.0, next_secs );
1209 0 : gui->summary.accdb->next_compaction_partition_idx = fd_ulong_if( has_compaction, compaction_idx, next_idx );
1210 0 : }
1211 :
1212 : /* Snapshot all of the data from metrics to construct a view of the
1213 : transaction waterfall.
1214 :
1215 : Tiles are sampled in reverse pipeline order: this helps prevent data
1216 : discrepancies where a later tile has "seen" more transactions than an
1217 : earlier tile, which shouldn't typically happen. */
1218 :
1219 : static void
1220 : fd_gui_txn_waterfall_snap( fd_gui_t * gui,
1221 6 : fd_gui_txn_waterfall_t * cur ) {
1222 6 : memset( cur, 0, sizeof(fd_gui_txn_waterfall_t) );
1223 6 : fd_topo_t const * topo = gui->topo;
1224 :
1225 6 : for( ulong i=0UL; i<gui->summary.execle_tile_cnt; i++ ) {
1226 0 : fd_topo_tile_t const * execle = &topo->tiles[ fd_topo_find_tile( topo, "execle", i ) ];
1227 :
1228 0 : volatile ulong const * execle_metrics = fd_metrics_tile( execle->metrics );
1229 :
1230 0 : cur->out.block_success += execle_metrics[ MIDX( COUNTER, EXECLE, TXN_PROCESSED_BY_LANDING_SUCCESS ) ];
1231 0 : cur->out.block_fail +=
1232 0 : execle_metrics[ MIDX( COUNTER, EXECLE, TXN_PROCESSED_BY_LANDING_FEES_ONLY ) ]
1233 0 : + execle_metrics[ MIDX( COUNTER, EXECLE, TXN_PROCESSED_BY_LANDING_FAILED ) ];
1234 0 : cur->out.bank_invalid += execle_metrics[ MIDX( COUNTER, EXECLE, TXN_PROCESSED_BY_LANDING_DROPPED ) ];
1235 :
1236 0 : cur->out.bank_nonce_already_advanced += execle_metrics[ MIDX( COUNTER, EXECLE, TXN_PROCESSED_NONCE_ALREADY_ADVANCED ) ];
1237 0 : cur->out.bank_nonce_advance_failed += execle_metrics[ MIDX( COUNTER, EXECLE, TXN_PROCESSED_NONCE_ADVANCE_FAILED ) ];
1238 0 : cur->out.bank_nonce_wrong_blockhash += execle_metrics[ MIDX( COUNTER, EXECLE, TXN_PROCESSED_NONCE_WRONG_BLOCKHASH ) ];
1239 0 : }
1240 :
1241 6 : ulong pack_tile_idx = fd_topo_find_tile( topo, "pack", 0UL );
1242 6 : if( pack_tile_idx!=ULONG_MAX ) {
1243 0 : fd_topo_tile_t const * pack = &topo->tiles[ pack_tile_idx ];
1244 0 : volatile ulong const * pack_metrics = fd_metrics_tile( pack->metrics );
1245 :
1246 0 : cur->out.pack_invalid_bundle =
1247 0 : pack_metrics[ MIDX( COUNTER, PACK, TXN_DROPPED_PARTIAL_BUNDLE ) ]
1248 0 : + pack_metrics[ MIDX( COUNTER, PACK, BUNDLE_CRANK_ATTEMPTED_INSERTION_FAILED ) ]
1249 0 : + pack_metrics[ MIDX( COUNTER, PACK, BUNDLE_CRANK_ATTEMPTED_CREATION_FAILED ) ];
1250 :
1251 0 : cur->out.pack_invalid =
1252 0 : pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_INSTR_TOO_MANY_ACCOUNTS ) ]
1253 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_NONCE_CONFLICT ) ]
1254 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_BUNDLE_BLOCKLISTED ) ]
1255 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_INVALID_NONCE ) ]
1256 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_WRITE_SYSVAR ) ]
1257 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_ESTIMATION_FAILED ) ]
1258 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_DUPLICATE_ACCOUNT ) ]
1259 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_TOO_MANY_ACCOUNTS ) ]
1260 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_TOO_MANY_CU ) ]
1261 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_LUT_UNSUPPORTED ) ]
1262 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_UNAFFORDABLE ) ]
1263 0 : + pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_DUPLICATE ) ]
1264 0 : - pack_metrics[ MIDX( COUNTER, PACK, BUNDLE_CRANK_ATTEMPTED_INSERTION_FAILED ) ]; /* so we don't double count this, since its already accounted for in invalid_bundle */
1265 :
1266 0 : cur->out.pack_expired = pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_EXPIRED ) ] +
1267 0 : pack_metrics[ MIDX( COUNTER, PACK, TXN_DROPPED_EXPIRED ) ] +
1268 0 : pack_metrics[ MIDX( COUNTER, PACK, TXN_EVICTED ) ] +
1269 0 : pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_NONCE_PRIORITY_TOO_LOW ) ];
1270 :
1271 0 : cur->out.pack_already_executed = pack_metrics[ MIDX( COUNTER, PACK, TXN_DROPPED_ALREADY_EXECUTED ) ];
1272 :
1273 0 : cur->out.pack_leader_slow = pack_metrics[ MIDX( COUNTER, PACK, TXN_INSERT_ATTEMPTED_PRIORITY_TOO_LOW ) ];
1274 :
1275 0 : cur->out.pack_retained = fd_metrics_enum_group_sum( pack_metrics+MIDX( GAUGE, PACK, TXN_PENDING_USED ), FD_METRICS_ENUM_PENDING_TXN_TYPE_G_ALL_MASK );
1276 :
1277 0 : cur->in.pack_cranked =
1278 0 : pack_metrics[ MIDX( COUNTER, PACK, BUNDLE_CRANK_ATTEMPTED_INSERTED ) ]
1279 0 : + pack_metrics[ MIDX( COUNTER, PACK, BUNDLE_CRANK_ATTEMPTED_INSERTION_FAILED ) ]
1280 0 : + pack_metrics[ MIDX( COUNTER, PACK, BUNDLE_CRANK_ATTEMPTED_CREATION_FAILED ) ];
1281 0 : }
1282 :
1283 6 : for( ulong i=0UL; i<gui->summary.resolv_tile_cnt; i++ ) {
1284 0 : fd_topo_tile_t const * resolv = &topo->tiles[ fd_topo_find_tile( topo, "resolv", i ) ];
1285 0 : volatile ulong const * resolv_metrics = fd_metrics_tile( resolv->metrics );
1286 :
1287 0 : cur->out.resolv_no_ledger += resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_DROPPED_NO_BANK ) ];
1288 0 : cur->out.resolv_expired += resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_DROPPED_BLOCKHASH_EXPIRED ) ]
1289 0 : + resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_DROPPED_BUNDLE_PEER_FAILED ) ];
1290 0 : cur->out.resolv_lut_failed += resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_LUT_RESOLVE_ATTEMPTED_ACCOUNT_NOT_FOUND ) ]
1291 0 : + resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_LUT_RESOLVE_ATTEMPTED_INVALID_ACCOUNT_OWNER ) ]
1292 0 : + resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_LUT_RESOLVE_ATTEMPTED_INVALID_ACCOUNT_DATA ) ]
1293 0 : + resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_LUT_RESOLVE_ATTEMPTED_ACCOUNT_UNINITIALIZED ) ]
1294 0 : + resolv_metrics[ MIDX( COUNTER, RESOLV, TXN_LUT_RESOLVE_ATTEMPTED_INVALID_LOOKUP_INDEX ) ];
1295 0 : cur->out.resolv_ancient += resolv_metrics[ MIDX( COUNTER, RESOLV, STASH_TXN_REMOVED_EVICTED ) ];
1296 :
1297 0 : ulong inserted_to_resolv = resolv_metrics[ MIDX( COUNTER, RESOLV, STASH_TXN_INSERTED ) ];
1298 0 : ulong removed_from_resolv = resolv_metrics[ MIDX( COUNTER, RESOLV, STASH_TXN_REMOVED_EVICTED ) ]
1299 0 : + resolv_metrics[ MIDX( COUNTER, RESOLV, STASH_TXN_REMOVED_PUBLISHED ) ]
1300 0 : + resolv_metrics[ MIDX( COUNTER, RESOLV, STASH_TXN_REMOVED_FAILED ) ];
1301 0 : cur->out.resolv_retained += fd_ulong_if( inserted_to_resolv>=removed_from_resolv, inserted_to_resolv-removed_from_resolv, 0UL );
1302 0 : }
1303 :
1304 6 : ulong dedup_tile_idx = fd_topo_find_tile( topo, "dedup", 0UL );
1305 6 : if( FD_UNLIKELY( dedup_tile_idx!=ULONG_MAX ) ) {
1306 0 : fd_topo_tile_t const * dedup = &topo->tiles[ dedup_tile_idx ];
1307 0 : volatile ulong const * dedup_metrics = fd_metrics_tile( dedup->metrics );
1308 :
1309 0 : cur->out.dedup_duplicate = dedup_metrics[ MIDX( COUNTER, DEDUP, TXN_PROCESSED_DUPLICATE ) ]
1310 0 : + dedup_metrics[ MIDX( COUNTER, DEDUP, TXN_PROCESSED_BUNDLE_PEER_FAILED ) ];
1311 0 : }
1312 :
1313 6 : for( ulong i=0UL; i<gui->summary.verify_tile_cnt; i++ ) {
1314 0 : fd_topo_tile_t const * verify = &topo->tiles[ fd_topo_find_tile( topo, "verify", i ) ];
1315 0 : volatile ulong const * verify_metrics = fd_metrics_tile( verify->metrics );
1316 :
1317 0 : for( ulong j=0UL; j<gui->summary.quic_tile_cnt; j++ ) {
1318 : /* TODO: Not precise... even if 1 frag gets skipped, it could have been for this verify tile. */
1319 0 : cur->out.verify_overrun += fd_metrics_link_in( verify->metrics, j )[ FD_METRICS_COUNTER_LINK_FRAG_POLLING_OVERRUN_OFF ] / gui->summary.verify_tile_cnt;
1320 0 : cur->out.verify_overrun += fd_metrics_link_in( verify->metrics, j )[ FD_METRICS_COUNTER_LINK_FRAG_READING_OVERRUN_OFF ];
1321 0 : }
1322 :
1323 0 : cur->out.verify_failed += verify_metrics[ MIDX( COUNTER, VERIFY, TXN_PROCESSED_SIGNATURE_FAILED ) ] +
1324 0 : verify_metrics[ MIDX( COUNTER, VERIFY, TXN_PROCESSED_BUNDLE_PEER_FAILED ) ];
1325 0 : cur->out.verify_parse += verify_metrics[ MIDX( COUNTER, VERIFY, TXN_PROCESSED_PARSE_FAILED ) ];
1326 0 : cur->out.verify_duplicate += verify_metrics[ MIDX( COUNTER, VERIFY, TXN_PROCESSED_DUPLICATE ) ];
1327 0 : }
1328 :
1329 6 : for( ulong i=0UL; i<gui->summary.quic_tile_cnt; i++ ) {
1330 0 : fd_topo_tile_t const * quic = &topo->tiles[ fd_topo_find_tile( topo, "quic", i ) ];
1331 0 : volatile ulong * quic_metrics = fd_metrics_tile( quic->metrics );
1332 :
1333 0 : cur->out.tpu_udp_invalid += quic_metrics[ MIDX( COUNTER, QUIC, UDP_TXN_UNDERSIZE_DROPPED ) ];
1334 0 : cur->out.tpu_udp_invalid += quic_metrics[ MIDX( COUNTER, QUIC, UDP_TXN_OVERSIZE_DROPPED ) ];
1335 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, PKT_DROPPED )+FD_METRICS_ENUM_QUIC_PKT_DROP_REASON_V_UNDERSIZE_IDX ];
1336 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, PKT_DROPPED )+FD_METRICS_ENUM_QUIC_PKT_DROP_REASON_V_OVERSIZE_IDX ];
1337 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, TXN_OVERSIZE_DROPPED ) ];
1338 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, PKT_DECRYPT_FAILED ) ];
1339 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, PKT_NO_CONN_DROPPED ) ];
1340 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, PKT_DROPPED )+FD_METRICS_ENUM_QUIC_PKT_DROP_REASON_V_SRC_IP_MISMATCH_IDX ];
1341 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, PKT_DROPPED )+FD_METRICS_ENUM_QUIC_PKT_DROP_REASON_V_NET_HEADER_INVALID_IDX ];
1342 0 : cur->out.tpu_quic_invalid += quic_metrics[ MIDX( COUNTER, QUIC, PKT_DROPPED )+FD_METRICS_ENUM_QUIC_PKT_DROP_REASON_V_HEADER_INVALID_IDX ];
1343 0 : cur->out.quic_abandoned += quic_metrics[ MIDX( COUNTER, QUIC, TXN_REASSEMBLY_ABANDONED ) ];
1344 0 : cur->out.quic_frag_drop += quic_metrics[ MIDX( COUNTER, QUIC, TXN_REASSEMBLY_EVICTED ) ];
1345 :
1346 0 : for( ulong j=0UL; j<gui->summary.sock_tile_cnt+gui->summary.net_tile_cnt+gui->summary.mlx5_tile_cnt+gui->summary.iavf_tile_cnt; j++ ) {
1347 : /* TODO: Not precise... net frags that were skipped might not have been destined for QUIC tile */
1348 : /* TODO: Not precise... even if 1 frag gets skipped, it could have been for this QUIC tile */
1349 0 : cur->out.quic_overrun += fd_metrics_link_in( quic->metrics, j )[ FD_METRICS_COUNTER_LINK_FRAG_POLLING_OVERRUN_OFF ] / gui->summary.quic_tile_cnt;
1350 0 : cur->out.quic_overrun += fd_metrics_link_in( quic->metrics, j )[ FD_METRICS_COUNTER_LINK_FRAG_READING_OVERRUN_OFF ];
1351 0 : }
1352 0 : }
1353 :
1354 6 : for( ulong i=0UL; i<gui->summary.net_tile_cnt; i++ ) {
1355 0 : fd_topo_tile_t const * net = &topo->tiles[ fd_topo_find_tile( topo, "net", i ) ];
1356 0 : volatile ulong * net_metrics = fd_metrics_tile( net->metrics );
1357 :
1358 0 : cur->out.net_overrun += net_metrics[ MIDX( COUNTER, NET, XDP_RX_RING_FULL_DROPPED ) ];
1359 0 : cur->out.net_overrun += net_metrics[ MIDX( COUNTER, NET, XDP_RX_OTHER_DROPPED ) ];
1360 0 : cur->out.net_overrun += net_metrics[ MIDX( COUNTER, NET, XDP_RX_FILL_RING_EMPTY ) ];
1361 0 : }
1362 6 : ulong bundle_txns_received = 0UL;
1363 6 : ulong bundle_tile_idx = fd_topo_find_tile( topo, "bundle", 0UL );
1364 6 : if( FD_LIKELY( bundle_tile_idx!=ULONG_MAX ) ) {
1365 0 : fd_topo_tile_t const * bundle = &topo->tiles[ bundle_tile_idx ];
1366 0 : volatile ulong const * bundle_metrics = fd_metrics_tile( bundle->metrics );
1367 :
1368 0 : bundle_txns_received = bundle_metrics[ MIDX( COUNTER, BUNDLE, TXN_RX ) ];
1369 0 : }
1370 :
1371 6 : cur->in.quic = cur->out.tpu_quic_invalid +
1372 6 : cur->out.quic_overrun +
1373 6 : cur->out.quic_frag_drop +
1374 6 : cur->out.quic_abandoned +
1375 6 : cur->out.net_overrun;
1376 6 : cur->in.udp = cur->out.tpu_udp_invalid;
1377 6 : cur->in.block_engine = bundle_txns_received;
1378 6 : for( ulong i=0UL; i<gui->summary.quic_tile_cnt; i++ ) {
1379 0 : fd_topo_tile_t const * quic = &topo->tiles[ fd_topo_find_tile( topo, "quic", i ) ];
1380 0 : volatile ulong * quic_metrics = fd_metrics_tile( quic->metrics );
1381 :
1382 0 : cur->in.quic += quic_metrics[ MIDX( COUNTER, QUIC, TXN_RX_QUIC_FAST ) ];
1383 0 : cur->in.quic += quic_metrics[ MIDX( COUNTER, QUIC, TXN_RX_QUIC_FRAG ) ];
1384 0 : cur->in.udp += quic_metrics[ MIDX( COUNTER, QUIC, TXN_RX_UDP ) ];
1385 0 : }
1386 6 : }
1387 :
1388 : static void
1389 : fd_gui_tile_stats_snap( fd_gui_t * gui,
1390 : fd_gui_txn_waterfall_t const * waterfall,
1391 : fd_gui_tile_stats_t * stats,
1392 0 : long now ) {
1393 0 : memset( stats, 0, sizeof(fd_gui_tile_stats_t) );
1394 0 : fd_topo_t const * topo = gui->topo;
1395 :
1396 0 : stats->sample_time_nanos = now;
1397 :
1398 0 : for( ulong i=0UL; i<gui->summary.net_tile_cnt; i++ ) {
1399 0 : fd_topo_tile_t const * net = &topo->tiles[ fd_topo_find_tile( topo, "net", i ) ];
1400 0 : volatile ulong * net_metrics = fd_metrics_tile( net->metrics );
1401 :
1402 0 : stats->net_in_rx_bytes += net_metrics[ MIDX( COUNTER, NET, PKT_RX_BYTES ) ];
1403 0 : stats->net_out_tx_bytes += net_metrics[ MIDX( COUNTER, NET, PKT_TX_SUBMITTED_BYTES ) ];
1404 0 : }
1405 :
1406 0 : for( ulong i=0UL; i<gui->summary.sock_tile_cnt; i++ ) {
1407 0 : fd_topo_tile_t const * sock = &topo->tiles[ fd_topo_find_tile( topo, "sock", i ) ];
1408 0 : volatile ulong * sock_metrics = fd_metrics_tile( sock->metrics );
1409 :
1410 0 : stats->net_in_rx_bytes += sock_metrics[ MIDX( COUNTER, SOCK, PKT_RX_BYTES ) ];
1411 0 : stats->net_out_tx_bytes += sock_metrics[ MIDX( COUNTER, SOCK, PKT_TX_BYTES ) ];
1412 0 : }
1413 :
1414 0 : for( ulong i=0UL; i<gui->summary.mlx5_tile_cnt; i++ ) {
1415 0 : fd_topo_tile_t const * mlx5 = &topo->tiles[ fd_topo_find_tile( topo, "mlx5", i ) ];
1416 0 : volatile ulong * mlx5_metrics = fd_metrics_tile( mlx5->metrics );
1417 :
1418 0 : stats->net_in_rx_bytes += mlx5_metrics[ MIDX( COUNTER, MLX5, PKT_RX_BYTES ) ];
1419 0 : stats->net_out_tx_bytes += mlx5_metrics[ MIDX( COUNTER, MLX5, PKT_TX_COMPLETED_BYTES ) ];
1420 0 : }
1421 :
1422 0 : for( ulong i=0UL; i<gui->summary.iavf_tile_cnt; i++ ) {
1423 0 : fd_topo_tile_t const * iavf = &topo->tiles[ fd_topo_find_tile( topo, "iavf", i ) ];
1424 0 : volatile ulong * iavf_metrics = fd_metrics_tile( iavf->metrics );
1425 0 : stats->net_in_rx_bytes += iavf_metrics[ MIDX( COUNTER, IAVF, PKT_RX_BYTES ) ];
1426 0 : stats->net_out_tx_bytes += iavf_metrics[ MIDX( COUNTER, IAVF, PKT_TX_COMPLETED_BYTES ) ];
1427 0 : }
1428 :
1429 0 : for( ulong i=0UL; i<gui->summary.quic_tile_cnt; i++ ) {
1430 0 : fd_topo_tile_t const * quic = &topo->tiles[ fd_topo_find_tile( topo, "quic", i ) ];
1431 0 : volatile ulong * quic_metrics = fd_metrics_tile( quic->metrics );
1432 :
1433 0 : for( ulong s=0UL; s<FD_METRICS_ENUM_QUIC_CONN_STATE_CNT; s++ ) stats->quic_conn_cnt += quic_metrics[ MIDX( GAUGE, QUIC, CONN_USED )+s ];
1434 0 : }
1435 :
1436 0 : ulong bundle_tile_idx = fd_topo_find_tile( topo, "bundle", 0UL );
1437 0 : if( FD_LIKELY( bundle_tile_idx!=ULONG_MAX ) ) {
1438 0 : fd_topo_tile_t const * bundle = &topo->tiles[ bundle_tile_idx ];
1439 0 : volatile ulong * bundle_metrics = fd_metrics_tile( bundle->metrics );
1440 0 : stats->bundle_rtt_smoothed_nanos = bundle_metrics[ MIDX( GAUGE, BUNDLE, RTT_SMOOTHED_NANOS ) ];
1441 :
1442 0 : fd_histf_new( &stats->bundle_rx_delay_hist, FD_MHIST_MIN( BUNDLE, MESSAGE_RX_DELAY_NANOS ), FD_MHIST_MAX( BUNDLE, MESSAGE_RX_DELAY_NANOS ) );
1443 0 : stats->bundle_rx_delay_hist.sum = bundle_metrics[ MIDX( HISTOGRAM, BUNDLE, MESSAGE_RX_DELAY_NANOS ) + FD_HISTF_BUCKET_CNT ];
1444 0 : for( ulong b=0; b<FD_HISTF_BUCKET_CNT; b++ ) stats->bundle_rx_delay_hist.counts[ b ] = bundle_metrics[ MIDX( HISTOGRAM, BUNDLE, MESSAGE_RX_DELAY_NANOS ) + b ];
1445 0 : }
1446 :
1447 0 : stats->verify_drop_cnt = waterfall->out.verify_duplicate +
1448 0 : waterfall->out.verify_parse +
1449 0 : waterfall->out.verify_failed;
1450 0 : stats->verify_total_cnt = waterfall->in.quic +
1451 0 : waterfall->in.udp -
1452 0 : waterfall->out.net_overrun -
1453 0 : waterfall->out.tpu_quic_invalid -
1454 0 : waterfall->out.tpu_udp_invalid -
1455 0 : waterfall->out.quic_abandoned -
1456 0 : waterfall->out.quic_frag_drop -
1457 0 : waterfall->out.quic_overrun -
1458 0 : waterfall->out.verify_overrun;
1459 0 : stats->dedup_drop_cnt = waterfall->out.dedup_duplicate;
1460 0 : stats->dedup_total_cnt = stats->verify_total_cnt -
1461 0 : waterfall->out.verify_duplicate -
1462 0 : waterfall->out.verify_parse -
1463 0 : waterfall->out.verify_failed;
1464 :
1465 0 : ulong pack_tile_idx = fd_topo_find_tile( topo, "pack", 0UL );
1466 0 : if( pack_tile_idx!=ULONG_MAX ) {
1467 0 : fd_topo_tile_t const * pack = &topo->tiles[ pack_tile_idx ];
1468 0 : volatile ulong const * pack_metrics = fd_metrics_tile( pack->metrics );
1469 0 : stats->pack_buffer_cnt = fd_metrics_enum_group_sum( pack_metrics+MIDX( GAUGE, PACK, TXN_PENDING_USED ), FD_METRICS_ENUM_PENDING_TXN_TYPE_G_ALL_MASK );
1470 0 : stats->pack_buffer_capacity = pack->pack.max_pending_transactions;
1471 0 : }
1472 :
1473 0 : stats->bank_txn_exec_cnt = waterfall->out.block_fail + waterfall->out.block_success;
1474 :
1475 0 : fd_gui_hist_ts_append( gui, FD_GUI_HIST_TILE_STATS, stats );
1476 0 : }
1477 :
1478 : static void
1479 0 : fd_gui_run_boot_progress( fd_gui_t * gui, long now ) {
1480 0 : fd_topo_tile_t const * snapct = &gui->topo->tiles[ fd_topo_find_tile( gui->topo, "snapct", 0UL ) ];
1481 0 : volatile ulong * snapct_metrics = fd_metrics_tile( snapct->metrics );
1482 :
1483 0 : ulong snapdc_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "snapdc" );
1484 0 : ulong snapin_tile_cnt = fd_topo_tile_name_cnt( gui->topo, "snapin" );
1485 :
1486 : /* Backtest topologies have no gossip tile; treat wait-for-supermajority
1487 : as done. */
1488 0 : ulong wfs_state = FD_GOSSIP_WFS_STATE_DONE;
1489 0 : volatile ulong * gossip_metrics = NULL;
1490 0 : ulong gossip_tile_idx = fd_topo_find_tile( gui->topo, "gossip", 0UL );
1491 0 : if( FD_LIKELY( gossip_tile_idx!=ULONG_MAX ) ) {
1492 0 : fd_topo_tile_t const * gossip = &gui->topo->tiles[ gossip_tile_idx ];
1493 0 : gossip_metrics = fd_metrics_tile( gossip->metrics );
1494 0 : wfs_state = gossip_metrics[ MIDX( GAUGE, GOSSIP, WAIT_FOR_SUPERMAJORITY_STATE ) ];
1495 0 : }
1496 :
1497 0 : ulong snapshot_phase = snapct_metrics[ MIDX( GAUGE, SNAPCT, LOAD_STATE ) ];
1498 :
1499 : /* Backtest topologies have no turbine, so the regular catch-up
1500 : detection (turbine slot vs. replayed slot) can never trigger.
1501 : Consider replay caught up at the first reset slot after the
1502 : snapshot finishes loading. */
1503 0 : if( FD_UNLIKELY( gui->summary.slot_caught_up==ULONG_MAX &&
1504 0 : snapshot_phase==FD_SNAPCT_STATE_SHUTDOWN &&
1505 0 : gui->summary.slot_tower!=ULONG_MAX &&
1506 0 : fd_topo_find_tile( gui->topo, "backt", 0UL )!=ULONG_MAX ) ) {
1507 0 : gui->summary.slot_caught_up = gui->summary.slot_tower;
1508 0 : gui->summary.boot_progress.catching_up_time_nanos = now;
1509 :
1510 0 : fd_gui_printf_slot_caught_up( gui );
1511 0 : fd_http_server_ws_broadcast( gui->http );
1512 0 : }
1513 :
1514 : /* state transitions */
1515 0 : if( FD_UNLIKELY( gui->summary.slot_caught_up!=ULONG_MAX ) ) {
1516 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_RUNNING;
1517 0 : for( ulong k=0UL; k<FD_ACCDB_COMPACTION_LAYER_CNT; k++ ) {
1518 0 : fd_gui_ema_init( &gui->summary.accdb->tier_fill_bps_ema[ k ], now, FD_GUI_ACCDB_EMA_HALF_LIFE_NS );
1519 0 : fd_gui_ema_init( &gui->summary.accdb->tier_free_bps_ema[ k ], now, FD_GUI_ACCDB_EMA_HALF_LIFE_NS );
1520 0 : }
1521 0 : } else if( FD_LIKELY( snapshot_phase == FD_SNAPCT_STATE_SHUTDOWN && wfs_state==FD_GOSSIP_WFS_STATE_DONE && ( gui->summary.slots_max_turbine[ 0 ].slot!=ULONG_MAX || gui->summary.slot_turbine!=ULONG_MAX ) && gui->summary.slot_tower!=ULONG_MAX ) ) {
1522 0 : if( FD_UNLIKELY( fd_gui_wfs_mode( gui )==FD_WFS_MODE_MATCH ) ) {
1523 0 : if( FD_UNLIKELY( gui->summary.slot_caught_up==ULONG_MAX ) ) {
1524 0 : gui->summary.slot_caught_up = fd_gui_boot_snapshot_slot( gui );
1525 0 : gui->summary.boot_progress.catching_up_time_nanos = now;
1526 :
1527 0 : fd_gui_printf_slot_caught_up( gui );
1528 0 : fd_http_server_ws_broadcast( gui->http );
1529 0 : }
1530 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_RUNNING;
1531 0 : for( ulong k=0UL; k<FD_ACCDB_COMPACTION_LAYER_CNT; k++ ) {
1532 0 : fd_gui_ema_init( &gui->summary.accdb->tier_fill_bps_ema[ k ], now, FD_GUI_ACCDB_EMA_HALF_LIFE_NS );
1533 0 : fd_gui_ema_init( &gui->summary.accdb->tier_free_bps_ema[ k ], now, FD_GUI_ACCDB_EMA_HALF_LIFE_NS );
1534 0 : }
1535 0 : } else {
1536 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_CATCHING_UP;
1537 0 : }
1538 0 : } else if( FD_UNLIKELY( snapshot_phase == FD_SNAPCT_STATE_SHUTDOWN && wfs_state==FD_GOSSIP_WFS_STATE_WAIT ) ) {
1539 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_WAITING_FOR_SUPERMAJORITY;
1540 0 : } else if( FD_LIKELY( snapshot_phase==FD_SNAPCT_STATE_READING_FULL_FILE
1541 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_FULL_FILE_FINI
1542 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_FULL_FILE_DONE
1543 0 : || snapshot_phase==FD_SNAPCT_STATE_READING_FULL_HTTP
1544 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_FULL_HTTP_FINI
1545 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_FULL_HTTP_DONE ) ) {
1546 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_LOADING_FULL_SNAPSHOT;
1547 0 : } else if( FD_LIKELY( snapshot_phase==FD_SNAPCT_STATE_READING_INCREMENTAL_FILE
1548 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_INCREMENTAL_FILE_FINI
1549 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_INCREMENTAL_FILE_DONE
1550 0 : || snapshot_phase==FD_SNAPCT_STATE_READING_INCREMENTAL_HTTP
1551 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_INCREMENTAL_HTTP_FINI
1552 0 : || snapshot_phase==FD_SNAPCT_STATE_FLUSHING_INCREMENTAL_HTTP_DONE ) ) {
1553 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_LOADING_INCREMENTAL_SNAPSHOT;
1554 0 : }
1555 :
1556 : /* It's possible for the incremental snapshot phase to be skipped, or
1557 : complete before we can sample it. This ensures we always get at
1558 : least one pass of the metrics. */
1559 0 : if( FD_UNLIKELY( gui->summary.boot_progress.phase==FD_GUI_BOOT_PROGRESS_TYPE_CATCHING_UP
1560 0 : && gui->summary.boot_progress.loading_snapshot[ FD_GUI_BOOT_PROGRESS_INCREMENTAL_SNAPSHOT_IDX ].reset_cnt==ULONG_MAX ) ) {
1561 0 : gui->summary.boot_progress.phase = FD_GUI_BOOT_PROGRESS_TYPE_LOADING_INCREMENTAL_SNAPSHOT;
1562 0 : }
1563 :
1564 0 : switch ( gui->summary.boot_progress.phase ) {
1565 0 : case FD_GUI_BOOT_PROGRESS_TYPE_JOINING_GOSSIP: {
1566 0 : gui->summary.boot_progress.joining_gossip_time_nanos = now;
1567 0 : break;
1568 0 : }
1569 0 : case FD_GUI_BOOT_PROGRESS_TYPE_LOADING_FULL_SNAPSHOT:
1570 0 : case FD_GUI_BOOT_PROGRESS_TYPE_LOADING_INCREMENTAL_SNAPSHOT: {
1571 0 : ulong snapshot_idx = fd_ulong_if( gui->summary.boot_progress.phase==FD_GUI_BOOT_PROGRESS_TYPE_LOADING_FULL_SNAPSHOT, FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, FD_GUI_BOOT_PROGRESS_INCREMENTAL_SNAPSHOT_IDX );
1572 0 : ulong _retry_cnt = fd_ulong_if( snapshot_idx==FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, snapct_metrics[ MIDX( COUNTER, SNAPCT, LOAD_RETRIED_FULL ) ], snapct_metrics[ MIDX( COUNTER, SNAPCT, LOAD_RETRIED_INCREMENTAL ) ]);
1573 :
1574 : /* reset boot state if necessary */
1575 0 : if( FD_UNLIKELY( gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].reset_cnt!=_retry_cnt ) ) {
1576 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].reset_time_nanos = now;
1577 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].reset_cnt = _retry_cnt;
1578 0 : }
1579 :
1580 0 : ulong _total_bytes = fd_ulong_if( snapshot_idx==FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, snapct_metrics[ MIDX( GAUGE, SNAPCT, READ_EXPECTED_BYTES_FULL ) ], snapct_metrics[ MIDX( GAUGE, SNAPCT, READ_EXPECTED_BYTES_INCREMENTAL ) ] );
1581 0 : ulong _read_bytes = fd_ulong_if( snapshot_idx==FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, snapct_metrics[ MIDX( GAUGE, SNAPCT, READ_PROGRESS_BYTES_FULL ) ], snapct_metrics[ MIDX( GAUGE, SNAPCT, READ_PROGRESS_BYTES_INCREMENTAL ) ] );
1582 0 : ulong _decompress_decompressed_bytes = fd_gui_metrics_sum_tiles_counter( gui->topo, "snapdc", snapdc_tile_cnt, fd_ulong_if( snapshot_idx==FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, MIDX( GAUGE, SNAPDC, DECOMPRESSED_PROGRESS_BYTES_FULL ), MIDX( GAUGE, SNAPDC, DECOMPRESSED_PROGRESS_BYTES_INCREMENTAL ) ) );
1583 0 : ulong _decompress_compressed_bytes = fd_gui_metrics_sum_tiles_counter( gui->topo, "snapdc", snapdc_tile_cnt, fd_ulong_if( snapshot_idx==FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, MIDX( GAUGE, SNAPDC, COMPRESSED_PROGRESS_BYTES_FULL ), MIDX( GAUGE, SNAPDC, COMPRESSED_PROGRESS_BYTES_INCREMENTAL ) ) );
1584 0 : ulong _insert_metric = fd_ulong_if( snapshot_idx==FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, MIDX( GAUGE, SNAPIN, PARSE_PROGRESS_BYTES_FULL ), MIDX( GAUGE, SNAPIN, PARSE_PROGRESS_BYTES_INCREMENTAL ) );
1585 0 : ulong _insert_bytes = ULONG_MAX;
1586 0 : for( ulong i=0UL; i<snapin_tile_cnt; i++ ) {
1587 0 : fd_topo_tile_t const * snapin = &gui->topo->tiles[ fd_topo_find_tile( gui->topo, "snapin", i ) ];
1588 0 : volatile ulong const * snapin_metrics = fd_metrics_tile( snapin->metrics );
1589 0 : _insert_bytes = fd_ulong_min( _insert_bytes, snapin_metrics[ _insert_metric ] );
1590 0 : }
1591 :
1592 0 : ulong _insert_accounts_total = fd_gui_metrics_sum_tiles_counter( gui->topo, "snapin", snapin_tile_cnt, MIDX( GAUGE, SNAPIN, ACCOUNT_PROGRESS_NEW ) );
1593 0 : ulong _insert_accounts_baseline = fd_ulong_if( snapshot_idx==FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, 0UL, gui->summary.boot_progress.loading_snapshot[ FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX ].insert_accounts_current );
1594 0 : ulong _insert_accounts = fd_ulong_sat_sub( _insert_accounts_total, _insert_accounts_baseline );
1595 :
1596 : /* metadata */
1597 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].total_bytes_compressed = _total_bytes;
1598 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].sample_time_nanos = now;
1599 :
1600 : /* read stage */
1601 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].read_bytes_compressed = _read_bytes;
1602 :
1603 : /* decompress stage */
1604 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].decompress_bytes_compressed = _decompress_compressed_bytes;
1605 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].decompress_bytes_decompressed = _decompress_decompressed_bytes;
1606 :
1607 : /* insert stage */
1608 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].insert_bytes_decompressed = _insert_bytes;
1609 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].insert_accounts_current = _insert_accounts;
1610 :
1611 0 : break;
1612 0 : }
1613 0 : case FD_GUI_BOOT_PROGRESS_TYPE_WAITING_FOR_SUPERMAJORITY: {
1614 : /* Only reachable when the topology has a gossip tile. */
1615 0 : gui->summary.boot_progress.wfs_total_stake = gossip_metrics[ MIDX( GAUGE, GOSSIP, WAIT_FOR_SUPERMAJORITY_STAKE_TRACKED_LAMPORTS ) ];
1616 0 : gui->summary.boot_progress.wfs_connected_stake = gossip_metrics[ MIDX( GAUGE, GOSSIP, WAIT_FOR_SUPERMAJORITY_STAKE_ONLINE_LAMPORTS ) ];
1617 0 : gui->summary.boot_progress.wfs_total_peers = gossip_metrics[ MIDX( GAUGE, GOSSIP, WAIT_FOR_SUPERMAJORITY_STAKED_PEER_COUNT ) ];
1618 0 : gui->summary.boot_progress.wfs_connected_peers = gossip_metrics[ MIDX( GAUGE, GOSSIP, WAIT_FOR_SUPERMAJORITY_STAKED_PEER_ONLINE ) ];
1619 0 : break;
1620 0 : }
1621 0 : case FD_GUI_BOOT_PROGRESS_TYPE_CATCHING_UP: {
1622 0 : gui->summary.boot_progress.catching_up_time_nanos = now;
1623 0 : break;
1624 0 : }
1625 0 : case FD_GUI_BOOT_PROGRESS_TYPE_RUNNING: break;
1626 0 : default: FD_LOG_ERR(( "unknown boot progress phase: %d", gui->summary.boot_progress.phase ));
1627 0 : }
1628 0 : }
1629 :
1630 : static inline int
1631 27 : fd_gui_ephemeral_slots_contains( fd_gui_ephemeral_slot_t * slots, ulong slots_sz, ulong slot ) {
1632 120 : for( ulong i=0UL; i<slots_sz; i++ ) {
1633 114 : if( FD_UNLIKELY( slots[ i ].slot==ULONG_MAX ) ) break;
1634 102 : if( FD_UNLIKELY( slots[ i ].slot==slot ) ) return 1;
1635 102 : }
1636 18 : return 0;
1637 27 : }
1638 :
1639 : #define SORT_NAME fd_gui_ephemeral_slot_sort
1640 525 : #define SORT_KEY_T fd_gui_ephemeral_slot_t
1641 345 : #define SORT_BEFORE(a,b) fd_int_if( (a).slot==ULONG_MAX, 0, fd_int_if( (b).slot==ULONG_MAX, 1, fd_int_if( (a).slot==(b).slot, (a).timestamp_arrival_nanos>(b).timestamp_arrival_nanos, (a).slot>(b).slot ) ) )
1642 : #include "../../util/tmpl/fd_sort.c"
1643 :
1644 : static inline void
1645 21 : fd_gui_try_insert_ephemeral_slot( fd_gui_ephemeral_slot_t * slots, ulong slots_sz, ulong slot, long now ) {
1646 21 : int already_present = 0;
1647 273 : for( ulong i=0UL; i<slots_sz; i++ ) {
1648 : /* evict any slots older than 4.8 seconds */
1649 252 : if( FD_UNLIKELY( slots[ i ].slot!=ULONG_MAX && now-slots[ i ].timestamp_arrival_nanos>4800000000L ) ) {
1650 72 : slots[ i ].slot = ULONG_MAX;
1651 72 : continue;
1652 72 : }
1653 :
1654 : /* if we've already seen this slot, just update the timestamp */
1655 180 : if( FD_UNLIKELY( slots[ i ].slot==slot ) ) {
1656 6 : slots[ i ].timestamp_arrival_nanos = now;
1657 6 : already_present = 1;
1658 6 : }
1659 180 : }
1660 21 : if( FD_LIKELY( already_present ) ) return;
1661 :
1662 : /* Insert the new slot number, evicting a smaller slot if necessary */
1663 15 : slots[ slots_sz ].timestamp_arrival_nanos = now;
1664 15 : slots[ slots_sz ].slot = slot;
1665 15 : fd_gui_ephemeral_slot_sort_insert( slots, slots_sz+1UL );
1666 15 : }
1667 :
1668 : static inline void
1669 0 : fd_gui_try_insert_run_length_slot( ulong * slots, ulong capacity, ulong * slots_sz, ulong slot ) {
1670 : /* catch up history is run-length encoded */
1671 0 : ulong range_idx = fd_sort_up_ulong_split( slots, *slots_sz, slot );
1672 0 : if( FD_UNLIKELY( range_idx<(*slots_sz)-1UL && range_idx%2UL==0UL && slots[ range_idx ]<=slot && slots[ range_idx+1UL ]>=slot ) ) return;
1673 0 : if( FD_UNLIKELY( range_idx<(*slots_sz) && range_idx>0UL && range_idx%2UL==1UL && slots[ range_idx-1UL ]<=slot && slots[ range_idx ]>=slot ) ) return;
1674 :
1675 0 : slots[ (*slots_sz)++ ] = slot;
1676 0 : slots[ (*slots_sz)++ ] = slot;
1677 :
1678 0 : fd_sort_up_ulong_insert( slots, (*slots_sz) );
1679 :
1680 : /* colesce ranges */
1681 0 : ulong removed = 0UL;
1682 0 : for( ulong i=1UL; i<(*slots_sz)-1UL; i+=2 ) {
1683 0 : if( FD_UNLIKELY( slots[ i ]+1UL==slots[ i+1UL ] ) ) {
1684 0 : slots[ i ] = ULONG_MAX;
1685 0 : slots[ i+1UL ] = ULONG_MAX;
1686 0 : removed += 2;
1687 0 : }
1688 0 : }
1689 :
1690 0 : if( FD_UNLIKELY( (*slots_sz)>=removed+capacity-2UL && (*slots_sz)>=4UL ) ) {
1691 : /* We are at capacity, start coalescing earlier intervals. */
1692 0 : slots[ 1 ] = ULONG_MAX;
1693 0 : slots[ 2 ] = ULONG_MAX;
1694 0 : removed += 2;
1695 0 : }
1696 :
1697 0 : fd_sort_up_ulong_insert( slots, (*slots_sz) );
1698 0 : (*slots_sz) -= removed;
1699 0 : }
1700 :
1701 : void
1702 0 : fd_gui_handle_repair_slot( fd_gui_t * gui, ulong slot, long now ) {
1703 0 : int was_sent = fd_gui_ephemeral_slots_contains( gui->summary.slots_max_repair, FD_GUI_REPAIR_SLOT_HISTORY_SZ, slot );
1704 0 : fd_gui_try_insert_ephemeral_slot( gui->summary.slots_max_repair, FD_GUI_REPAIR_SLOT_HISTORY_SZ, slot, now );
1705 :
1706 0 : if( FD_UNLIKELY( !was_sent && slot!=gui->summary.slot_repair ) ) {
1707 0 : gui->summary.slot_repair = slot;
1708 :
1709 0 : fd_gui_printf_repair_slot( gui );
1710 0 : fd_http_server_ws_broadcast( gui->http );
1711 :
1712 0 : if( FD_UNLIKELY( gui->summary.slot_caught_up==ULONG_MAX ) ) fd_gui_try_insert_run_length_slot( gui->summary.catch_up_repair, FD_GUI_REPAIR_CATCH_UP_HISTORY_SZ, &gui->summary.catch_up_repair_sz, slot );
1713 0 : }
1714 0 : }
1715 :
1716 : static void
1717 0 : fd_gui_sample_repair_slot( fd_gui_t * gui, long now ) {
1718 0 : ulong slot;
1719 :
1720 0 : ulong repair_tile_idx = fd_topo_find_tile( gui->topo, "repair", 0UL );
1721 0 : if( FD_UNLIKELY( repair_tile_idx==ULONG_MAX ) ) return;
1722 0 : fd_topo_tile_t const * repair = &gui->topo->tiles[ repair_tile_idx ];
1723 0 : volatile ulong const * repair_metrics = fd_metrics_tile( repair->metrics );
1724 0 : slot = repair_metrics[ MIDX( GAUGE, REPAIR, HIGHEST_DELIVERED_SLOT ) ];
1725 :
1726 0 : fd_gui_handle_repair_slot( gui, slot, now );
1727 0 : }
1728 :
1729 : static void
1730 0 : fd_gui_sample_catchup_slot( fd_gui_t * gui ) {
1731 0 : if( FD_LIKELY( gui->summary.slot_caught_up!=ULONG_MAX ) ) return;
1732 0 : ulong repair_tile_idx = fd_topo_find_tile( gui->topo, "repair", 0UL );
1733 0 : if( FD_UNLIKELY( repair_tile_idx==ULONG_MAX ) ) return;
1734 0 : fd_topo_tile_t const * repair = &gui->topo->tiles[ repair_tile_idx ];
1735 0 : volatile ulong const * repair_metrics = fd_metrics_tile( repair->metrics );
1736 0 : ulong slot = repair_metrics[ MIDX( GAUGE, REPAIR, CATCHUP_SLOT ) ];
1737 0 : if( FD_LIKELY( !slot || ( gui->summary.slot_turbine!=ULONG_MAX && slot<=gui->summary.slot_turbine ) ) ) return;
1738 :
1739 0 : gui->summary.slot_turbine = slot;
1740 0 : fd_gui_printf_turbine_slot( gui );
1741 0 : fd_http_server_ws_broadcast( gui->http );
1742 0 : fd_gui_try_insert_run_length_slot( gui->summary.catch_up_turbine, FD_GUI_TURBINE_CATCH_UP_HISTORY_SZ, &gui->summary.catch_up_turbine_sz, slot );
1743 0 : }
1744 :
1745 : void
1746 6 : fd_gui_handle_repair_request( fd_gui_t * gui, ulong slot, ulong shred_idx, long tsorig, long now ) {
1747 6 : fd_gui_shred_event_append( gui, slot, shred_idx, FD_GUI_SLOT_SHRED_REPAIR_REQUEST, tsorig, now );
1748 6 : fd_gui_fec_event_append( gui, slot, shred_idx/FD_FEC_SHRED_CNT, FD_GUI_SLOT_SHRED_REPAIR_REQUEST, tsorig, now );
1749 6 : }
1750 :
1751 : static void
1752 0 : fd_gui_progcache_sample( fd_gui_t * gui ) {
1753 0 : fd_topo_t const * topo = gui->topo;
1754 :
1755 0 : ulong hits = 0UL;
1756 0 : ulong lookups = 0UL;
1757 :
1758 0 : for( ulong i=0UL; i<gui->summary.execrp_tile_cnt; i++ ) {
1759 0 : fd_topo_tile_t const * execrp = &topo->tiles[ fd_topo_find_tile( topo, "execrp", i ) ];
1760 0 : volatile ulong const * metrics = fd_metrics_tile( execrp->metrics );
1761 :
1762 0 : lookups += metrics[ MIDX( COUNTER, EXECRP, PROGCACHE_LOOKED_UP ) ];
1763 0 : hits += fd_metrics_enum_group_sum( metrics+MIDX( COUNTER, EXECRP, PROGCACHE_HIT ), FD_METRICS_ENUM_PROGCACHE_CLASS_G_ALL_MASK );
1764 0 : }
1765 :
1766 : /* The execrp tile writes lookups before hits in metrics_write, so
1767 : reading lookups first then hits here means we may observe the
1768 : new hits before the new lookups, giving hits > lookups
1769 : momentarily. Clamp to maintain the invariant hits <= lookups. */
1770 :
1771 0 : hits = fd_ulong_min( hits, lookups );
1772 :
1773 0 : ulong ring_idx = gui->summary.progcache_history_idx % FD_GUI_PROGCACHE_HISTORY_CNT;
1774 0 : ulong oldest_hits = gui->summary.progcache_hits_history [ ring_idx ];
1775 0 : ulong oldest_lookups = gui->summary.progcache_lookups_history[ ring_idx ];
1776 :
1777 0 : gui->summary.progcache_hits_history [ ring_idx ] = hits;
1778 0 : gui->summary.progcache_lookups_history[ ring_idx ] = lookups;
1779 0 : gui->summary.progcache_history_idx = gui->summary.progcache_history_idx + 1UL;
1780 :
1781 0 : ulong hits_1min = hits - oldest_hits;
1782 0 : ulong lookups_1min = lookups - oldest_lookups;
1783 0 : hits_1min = fd_ulong_min( hits_1min, lookups_1min );
1784 :
1785 0 : gui->summary.progcache_hits_1min = hits_1min;
1786 0 : gui->summary.progcache_lookups_1min = lookups_1min;
1787 0 : }
1788 :
1789 : long
1790 0 : fd_gui_next_deadline( fd_gui_t const * gui ) {
1791 0 : long due = gui->next_sample_1sec;
1792 0 : due = fd_long_min( due, gui->next_sample_200millis );
1793 0 : due = fd_long_min( due, gui->next_sample_100millis );
1794 0 : due = fd_long_min( due, gui->next_sample_50millis );
1795 0 : due = fd_long_min( due, gui->next_sample_40millis );
1796 0 : due = fd_long_min( due, gui->next_sample_25millis );
1797 0 : due = fd_long_min( due, gui->next_sample_10millis );
1798 0 : return due+1L; /* the samplers fire on now>next */
1799 0 : }
1800 :
1801 : int
1802 0 : fd_gui_poll( fd_gui_t * gui, long now ) {
1803 0 : if( FD_LIKELY( now>gui->next_sample_1sec ) ) {
1804 0 : for( ulong i=0UL; i<gui->tile_cnt; i++ ) {
1805 0 : fd_gui_hist_ts_append( gui, FD_GUI_HIST_TILE_TIMERS, &gui->summary.tile_timers_packed[ i ] );
1806 0 : }
1807 :
1808 0 : gui->next_sample_1sec += 1000L*1000L*1000L;
1809 0 : return 1;
1810 0 : }
1811 :
1812 0 : if( FD_LIKELY( now>gui->next_sample_200millis ) ) {
1813 0 : fd_gui_estimated_tps_snap( gui );
1814 0 : fd_gui_printf_estimated_tps( gui );
1815 0 : fd_http_server_ws_broadcast( gui->http );
1816 :
1817 0 : if( FD_LIKELY( gui->leader_begin_slot<=gui->leader_end_slot ) ) {
1818 0 : for( ulong i=0UL; i<gui->tile_cnt; i++ ) {
1819 0 : fd_gui_hist_ts_append( gui, FD_GUI_HIST_TILE_TIMERS, &gui->summary.tile_timers_packed[ i ] );
1820 0 : }
1821 0 : }
1822 :
1823 0 : gui->next_sample_200millis += 200L*1000L*1000L;
1824 0 : return 1;
1825 0 : }
1826 :
1827 0 : if( FD_LIKELY( now>gui->next_sample_100millis ) ) {
1828 0 : fd_gui_txn_waterfall_snap( gui, gui->summary.txn_waterfall_current );
1829 0 : fd_gui_printf_live_txn_waterfall( gui, gui->summary.txn_waterfall_reference, gui->summary.txn_waterfall_current, 0UL /* TODO: REAL NEXT LEADER SLOT */ );
1830 0 : fd_http_server_ws_broadcast( gui->http );
1831 :
1832 0 : if( FD_LIKELY( gui->leader_begin_slot>gui->leader_end_slot ) ) {
1833 0 : gui->summary.txn_waterfall_current->sample_time_nanos = now;
1834 0 : fd_gui_hist_ts_append( gui, FD_GUI_HIST_TXN_WATERFALL, gui->summary.txn_waterfall_current );
1835 0 : }
1836 :
1837 0 : fd_gui_network_stats_snap( gui, gui->summary.network_stats_current );
1838 0 : fd_gui_network_rate_max_update( gui, now );
1839 0 : fd_gui_printf_live_network_metrics( gui, gui->summary.network_stats_current );
1840 0 : fd_http_server_ws_broadcast( gui->http );
1841 :
1842 0 : *gui->summary.tile_stats_reference = *gui->summary.tile_stats_current;
1843 0 : fd_gui_tile_stats_snap( gui, gui->summary.txn_waterfall_current, gui->summary.tile_stats_current, now );
1844 0 : fd_gui_printf_live_tile_stats( gui, gui->summary.tile_stats_reference, gui->summary.tile_stats_current );
1845 0 : fd_http_server_ws_broadcast( gui->http );
1846 :
1847 0 : {
1848 0 : fd_gui_progcache_sample( gui );
1849 0 : fd_gui_printf_live_program_cache( gui );
1850 0 : fd_http_server_ws_broadcast( gui->http );
1851 :
1852 0 : *gui->summary.accounts_stats_reference = *gui->summary.accounts_stats_current;
1853 0 : fd_gui_accounts_stats_snap( gui, gui->summary.accounts_stats_current );
1854 0 : fd_gui_printf_accounts_stats( gui );
1855 0 : fd_http_server_ws_broadcast( gui->http );
1856 0 : gui->summary.accounts_stats_have_reference = 1;
1857 0 : }
1858 :
1859 0 : if( FD_UNLIKELY( gui->summary.boot_progress.phase!=FD_GUI_BOOT_PROGRESS_TYPE_RUNNING ) ) {
1860 0 : fd_gui_sample_catchup_slot( gui );
1861 0 : fd_gui_run_boot_progress( gui, now );
1862 0 : if( FD_UNLIKELY( memcmp( &gui->summary.boot_progress, &gui->summary.prev_boot_progress, sizeof(fd_gui_boot_progress_t) ) ) ) {
1863 0 : gui->summary.prev_boot_progress = gui->summary.boot_progress;
1864 0 : fd_gui_printf_boot_progress( gui );
1865 0 : fd_http_server_ws_broadcast( gui->http );
1866 0 : }
1867 0 : }
1868 :
1869 0 : ulong bundle_tile_idx = fd_topo_find_tile( gui->topo, "bundle", 0UL );
1870 0 : if( FD_LIKELY( bundle_tile_idx!=ULONG_MAX ) ) {
1871 0 : volatile ulong const * bundle_metrics = fd_metrics_tile( gui->topo->tiles[ bundle_tile_idx ].metrics );
1872 0 : int cur_state = (int)bundle_metrics[ MIDX( GAUGE, BUNDLE, CONN_STATE ) ];
1873 0 : if( FD_UNLIKELY( cur_state != gui->block_engine.status ) ) {
1874 0 : gui->block_engine.status = cur_state;
1875 0 : fd_gui_printf_block_engine( gui );
1876 0 : fd_http_server_ws_broadcast( gui->http );
1877 0 : }
1878 0 : }
1879 :
1880 0 : fd_gui_printf_health( gui );
1881 0 : fd_http_server_ws_broadcast( gui->http );
1882 :
1883 0 : if( FD_UNLIKELY( gui->epoch.missed_vote_history_dirty!=ULONG_MAX ) ) {
1884 0 : fd_gui_printf_missed_vote_history( gui, gui->epoch.missed_vote_history_dirty );
1885 0 : fd_http_server_ws_broadcast( gui->http );
1886 0 : gui->epoch.missed_vote_history_dirty = ULONG_MAX;
1887 0 : }
1888 :
1889 0 : gui->next_sample_100millis += 100L*1000L*1000L;
1890 0 : return 1;
1891 0 : }
1892 :
1893 0 : if( FD_LIKELY( now>gui->next_sample_50millis ) ) {
1894 0 : fd_gui_shred_flush( gui, now );
1895 0 : if( FD_LIKELY( !fd_gui_shred_window_is_empty( gui, gui->shreds.broadcast_watermark_ns, now-1L ) ) ) {
1896 0 : fd_gui_printf_shred_updates( gui, gui->shreds.broadcast_watermark_ns, now-1L );
1897 0 : fd_http_server_ws_broadcast( gui->http );
1898 0 : }
1899 0 : gui->shreds.broadcast_watermark_ns = now;
1900 :
1901 : /* We get the repair slot from the sampled metric after catching up
1902 : and from incoming shred data before catchup. This makes the
1903 : catchup progress bar look complete while also keeping the
1904 : overview slots vis correct. TODO: do this properly using frags
1905 : sent over a link */
1906 0 : if( FD_LIKELY( gui->summary.slot_caught_up!=ULONG_MAX ) ) fd_gui_sample_repair_slot( gui, now );
1907 :
1908 0 : if( FD_UNLIKELY( gui->snapsv.pending_cnt ) ) {
1909 0 : fd_gui_printf_snapshot_transfers( gui );
1910 0 : fd_http_server_ws_broadcast( gui->http );
1911 0 : gui->snapsv.pending_cnt = 0UL;
1912 0 : }
1913 :
1914 0 : gui->next_sample_50millis += 50L*1000L*1000L;
1915 0 : return 1;
1916 0 : }
1917 :
1918 0 : if( FD_LIKELY( now>gui->next_sample_40millis ) ) {
1919 0 : fd_gui_tile_timers_snap( gui, now );
1920 :
1921 0 : fd_gui_printf_live_tile_timers( gui );
1922 0 : fd_http_server_ws_broadcast( gui->http );
1923 :
1924 0 : fd_gui_printf_live_tile_metrics( gui );
1925 0 : fd_http_server_ws_broadcast( gui->http );
1926 :
1927 0 : if( FD_LIKELY( gui->leader_begin_slot>gui->leader_end_slot ) ) {
1928 0 : for( ulong i=0UL; i<gui->tile_cnt; i++ ) {
1929 0 : fd_gui_hist_ts_append( gui, FD_GUI_HIST_TILE_TIMERS, &gui->summary.tile_timers_packed[ i ] );
1930 0 : }
1931 0 : }
1932 :
1933 0 : gui->next_sample_40millis += 40L*1000L*1000L;
1934 0 : return 1;
1935 0 : }
1936 :
1937 0 : if( FD_LIKELY( now>gui->next_sample_25millis ) ) {
1938 0 : fd_gui_cpu_util_snap( gui, now );
1939 0 : gui->next_sample_25millis += 25L*1000L*1000L;
1940 0 : return 1;
1941 0 : }
1942 :
1943 0 : if( FD_LIKELY( now>gui->next_sample_10millis ) ) {
1944 0 : if( FD_UNLIKELY( gui->leader_begin_slot>gui->leader_end_slot ) ) fd_gui_scheduler_counts_snap( gui, now );
1945 :
1946 0 : fd_gui_printf_server_time_nanos( gui, now );
1947 0 : fd_http_server_ws_broadcast( gui->http );
1948 :
1949 : /* Lazy eviction must outpace ingest: ~1 ms of batches per tick */
1950 0 : long evict_end = fd_tickcount() + (long)( 1e6*gui->tick_per_ns );
1951 0 : for(;;) {
1952 0 : ulong archived = fd_gui_fec_archive( gui, 512UL );
1953 0 : int evicted = fd_gui_hist_evict_step( gui );
1954 0 : if( (!archived && !evicted) || fd_tickcount()>=evict_end ) break;
1955 0 : }
1956 :
1957 0 : gui->next_sample_10millis += 10L*1000L*1000L;
1958 0 : return 1;
1959 0 : }
1960 :
1961 0 : return 0;
1962 0 : }
1963 :
1964 : int
1965 : fd_gui_request_slot( fd_gui_t * gui,
1966 : ulong ws_conn_id,
1967 : ulong request_id,
1968 : char const * params,
1969 0 : ulong params_sz ) {
1970 0 : ulong _slot = 0UL; int has_slot = 0;
1971 0 : fd_jtok_t j[1]; fd_jtok_init( j, params, params_sz );
1972 0 : fd_jtok_str_t key;
1973 0 : fd_jtok_obj_enter( j );
1974 0 : while( fd_jtok_obj_next( j, &key ) ) {
1975 0 : if( fd_jtok_str_eq( &key, "slot" ) ) { fd_jtok_ulong( j, &_slot ); has_slot = 1; }
1976 0 : }
1977 0 : if( FD_UNLIKELY( fd_jtok_fini( j ) || !has_slot ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
1978 :
1979 0 : fd_gui_slot_t const * slot = fd_gui_slot_get_canon_safe( gui, _slot );
1980 0 : int known = slot && ( slot->skip!=FD_GUI_SKIP_STATUS_UNKNOWN || fd_gui_ag_slot_is_skip_notarized( gui, _slot ) );
1981 0 : if( FD_UNLIKELY( !known ) ) {
1982 0 : fd_gui_printf_null_query_response( gui->http, "slot", "query", request_id );
1983 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
1984 0 : return 0;
1985 0 : }
1986 :
1987 0 : fd_gui_printf_slot_request( gui, _slot, request_id, slot );
1988 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
1989 0 : return 0;
1990 0 : }
1991 :
1992 : int
1993 : fd_gui_request_slot_transactions( fd_gui_t * gui,
1994 : ulong ws_conn_id,
1995 : ulong request_id,
1996 : char const * params,
1997 0 : ulong params_sz ) {
1998 0 : ulong _slot = 0UL; int has_slot = 0;
1999 0 : fd_jtok_t j[1]; fd_jtok_init( j, params, params_sz );
2000 0 : fd_jtok_str_t key;
2001 0 : fd_jtok_obj_enter( j );
2002 0 : while( fd_jtok_obj_next( j, &key ) ) {
2003 0 : if( fd_jtok_str_eq( &key, "slot" ) ) { fd_jtok_ulong( j, &_slot ); has_slot = 1; }
2004 0 : }
2005 0 : if( FD_UNLIKELY( fd_jtok_fini( j ) || !has_slot ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2006 :
2007 0 : fd_gui_slot_t const * slot = fd_gui_slot_get_canon_safe( gui, _slot );
2008 0 : if( FD_UNLIKELY( !slot || slot->skip==FD_GUI_SKIP_STATUS_UNKNOWN ) ) {
2009 0 : fd_gui_printf_null_query_response( gui->http, "slot", "query_transactions", request_id );
2010 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
2011 0 : return 0;
2012 0 : }
2013 :
2014 0 : fd_gui_printf_slot_transactions_request( gui, _slot, request_id, slot );
2015 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
2016 0 : return 0;
2017 0 : }
2018 :
2019 : int
2020 : fd_gui_request_slot_detailed( fd_gui_t * gui,
2021 : ulong ws_conn_id,
2022 : ulong request_id,
2023 : char const * params,
2024 0 : ulong params_sz ) {
2025 0 : ulong _slot = 0UL; int has_slot = 0;
2026 0 : fd_jtok_t j[1]; fd_jtok_init( j, params, params_sz );
2027 0 : fd_jtok_str_t key;
2028 0 : fd_jtok_obj_enter( j );
2029 0 : while( fd_jtok_obj_next( j, &key ) ) {
2030 0 : if( fd_jtok_str_eq( &key, "slot" ) ) { fd_jtok_ulong( j, &_slot ); has_slot = 1; }
2031 0 : }
2032 0 : if( FD_UNLIKELY( fd_jtok_fini( j ) || !has_slot ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2033 :
2034 0 : fd_gui_slot_t const * slot = fd_gui_slot_get_canon_safe( gui, _slot );
2035 0 : int known = slot && ( slot->skip!=FD_GUI_SKIP_STATUS_UNKNOWN || fd_gui_ag_slot_is_skip_notarized( gui, _slot ) );
2036 0 : if( FD_UNLIKELY( !known ) ) {
2037 0 : fd_gui_printf_null_query_response( gui->http, "slot", "query_detailed", request_id );
2038 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
2039 0 : return 0;
2040 0 : }
2041 :
2042 0 : fd_gui_printf_slot_request_detailed( gui, _slot, request_id, slot );
2043 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
2044 0 : return 0;
2045 0 : }
2046 :
2047 : static inline ulong
2048 0 : fd_gui_slot_duration( fd_gui_t * gui, fd_gui_slot_t const * cur ) {
2049 0 : if( FD_UNLIKELY( cur->skip==FD_GUI_SKIP_STATUS_FINALIZED || cur->completed_time==LONG_MAX ) ) return ULONG_MAX;
2050 0 : fd_gui_slot_t const * prev = fd_gui_slot_get_any( gui, cur->slot-1UL );
2051 0 : long parent_completed_time = LONG_MAX;
2052 0 : if( FD_LIKELY( prev && prev->skip!=FD_GUI_SKIP_STATUS_FINALIZED ) ) parent_completed_time = prev->completed_time;
2053 0 : if( FD_UNLIKELY( parent_completed_time==LONG_MAX ) ) return ULONG_MAX;
2054 :
2055 0 : return (ulong)(cur->completed_time - parent_completed_time);
2056 0 : }
2057 :
2058 : /* All rankings are initialized / reset to ULONG_MAX. These sentinels
2059 : sort AFTER non-sentinel ranking entries. Equal slots are sorted by
2060 : oldest slot AFTER. Otherwise sort by value according to ranking
2061 : type. */
2062 0 : #define RANKING_BEFORE(a,b) fd_int_if( (a).slot==ULONG_MAX, 0, fd_int_if( (b).slot==ULONG_MAX, 1, fd_int_if( (a).value==(b).value, (a).slot>(b).slot, fd_int_if( (a).type==FD_GUI_SLOT_RANKING_TYPE_DESC, (a).value>(b).value, (a).value<(b).value ) ) ) )
2063 :
2064 : /* ranking_insert places e in the sorted top FD_GUI_SLOT_RANKINGS_SZ of
2065 : arr, or drops it if it sorts after the last entry. */
2066 :
2067 : static inline void
2068 : ranking_insert( fd_gui_slot_ranking_t * arr,
2069 0 : fd_gui_slot_ranking_t e ) {
2070 0 : if( FD_LIKELY( !RANKING_BEFORE( e, arr[ FD_GUI_SLOT_RANKINGS_SZ-1UL ] ) ) ) return;
2071 0 : ulong i = FD_GUI_SLOT_RANKINGS_SZ-1UL;
2072 0 : while( i && RANKING_BEFORE( e, arr[ i-1UL ] ) ) { arr[ i ] = arr[ i-1UL ]; i--; }
2073 0 : arr[ i ] = e;
2074 0 : }
2075 :
2076 : static inline void
2077 : fd_gui_try_insert_ranking( fd_gui_t * gui,
2078 : fd_gui_slot_rankings_t * rankings,
2079 0 : fd_gui_slot_t const * slot ) {
2080 0 : #define TRY_INSERT_SLOT( ranking_name, ranking_slot, ranking_value ) \
2081 0 : do { \
2082 0 : ranking_insert( rankings->FD_CONCAT2(largest_, ranking_name), (fd_gui_slot_ranking_t){ .slot = (ranking_slot), .value = (ranking_value), .type = FD_GUI_SLOT_RANKING_TYPE_DESC } ); \
2083 0 : ranking_insert( rankings->FD_CONCAT2(smallest_, ranking_name), (fd_gui_slot_ranking_t){ .slot = (ranking_slot), .value = (ranking_value), .type = FD_GUI_SLOT_RANKING_TYPE_ASC } ); \
2084 0 : } while (0)
2085 :
2086 0 : if( slot->skip==FD_GUI_SKIP_STATUS_FINALIZED ) {
2087 0 : TRY_INSERT_SLOT( skipped, slot->slot, slot->slot );
2088 0 : return;
2089 0 : }
2090 :
2091 0 : ulong dur = fd_gui_slot_duration( gui, slot );
2092 0 : if( FD_LIKELY( dur!=ULONG_MAX ) ) TRY_INSERT_SLOT( duration, slot->slot, dur );
2093 0 : TRY_INSERT_SLOT( tips, slot->slot, slot->tips );
2094 0 : TRY_INSERT_SLOT( fees, slot->slot, slot->priority_fee + slot->transaction_fee );
2095 0 : TRY_INSERT_SLOT( rewards, slot->slot, slot->tips + slot->priority_fee + slot->transaction_fee );
2096 0 : TRY_INSERT_SLOT( rewards_per_cu, slot->slot, slot->compute_units==0UL ? 0UL : (slot->tips + slot->priority_fee + slot->transaction_fee) / slot->compute_units );
2097 0 : TRY_INSERT_SLOT( compute_units, slot->slot, slot->compute_units );
2098 0 : #undef TRY_INSERT_SLOT
2099 0 : }
2100 :
2101 : static void
2102 0 : fd_gui_update_slot_rankings( fd_gui_t * gui ) {
2103 0 : if( FD_UNLIKELY( gui->summary.slot_caught_up==ULONG_MAX ) ) return;
2104 0 : ulong first_replay_slot = fd_gui_first_replay_slot( gui );
2105 0 : if( FD_UNLIKELY( first_replay_slot==ULONG_MAX ) ) return;
2106 0 : if( FD_UNLIKELY( gui->summary.slot_rooted==ULONG_MAX ) ) return;
2107 :
2108 0 : fd_gui_epoch_t * epoch = fd_gui_get_epoch_by_slot( gui, gui->summary.slot_rooted );
2109 0 : if( FD_UNLIKELY( !epoch ) ) return;
2110 :
2111 : /* No new slots since the last update */
2112 0 : if( FD_UNLIKELY( epoch->rankings_slot>gui->summary.slot_rooted ) ) return;
2113 :
2114 : /* Slots before first_replay_slot are unavailable. */
2115 0 : epoch->rankings_slot = fd_ulong_max( epoch->rankings_slot, first_replay_slot );
2116 :
2117 : /* Update the rankings. Only look through slots we haven't already. */
2118 0 : for( ulong s = gui->summary.slot_rooted; s>=epoch->rankings_slot; s--) {
2119 0 : fd_gui_slot_t const * slot = fd_gui_slot_get_canon_safe( gui, s );
2120 0 : if( FD_UNLIKELY( slot->skip==FD_GUI_SKIP_STATUS_UNKNOWN ) ) break;
2121 :
2122 0 : fd_gui_try_insert_ranking( gui, epoch->rankings, slot );
2123 0 : if( FD_UNLIKELY( slot->mine ) ) fd_gui_try_insert_ranking( gui, epoch->my_rankings, slot );
2124 0 : }
2125 :
2126 0 : epoch->rankings_slot = gui->summary.slot_rooted + 1UL;
2127 0 : }
2128 :
2129 : int
2130 : fd_gui_request_slot_rankings( fd_gui_t * gui,
2131 : ulong ws_conn_id,
2132 : ulong request_id,
2133 : char const * params,
2134 0 : ulong params_sz ) {
2135 0 : int mine = 0; int has_mine = 0;
2136 0 : fd_jtok_t j[1]; fd_jtok_init( j, params, params_sz );
2137 0 : fd_jtok_str_t key;
2138 0 : fd_jtok_obj_enter( j );
2139 0 : while( fd_jtok_obj_next( j, &key ) ) {
2140 0 : if( fd_jtok_str_eq( &key, "mine" ) ) { fd_jtok_bool( j, &mine ); has_mine = 1; }
2141 0 : }
2142 0 : if( FD_UNLIKELY( fd_jtok_fini( j ) || !has_mine ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2143 :
2144 0 : fd_gui_update_slot_rankings( gui );
2145 0 : fd_gui_printf_slot_rankings_request( gui, request_id, mine );
2146 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
2147 0 : return 0;
2148 0 : }
2149 :
2150 : /* fd_gui_jtok_parse_ns consumes a canonical nonnegative decimal string
2151 : into *out. Returns 0 on success, -1 for invalid values or values at
2152 : or above LONG_MAX. */
2153 :
2154 : static inline int
2155 : fd_gui_jtok_parse_ns( fd_jtok_t * j,
2156 204 : long * out ) {
2157 204 : char value[ 20UL ];
2158 204 : fd_jtok_cstr( j, value, sizeof(value) );
2159 204 : if( FD_UNLIKELY( fd_jtok_err( j ) ) ) return -1;
2160 :
2161 204 : ulong value_len = strlen( value );
2162 204 : if( FD_UNLIKELY( !value_len ) ) return -1;
2163 204 : if( FD_UNLIKELY( value_len>1UL && value[ 0 ]=='0' ) ) return -1;
2164 :
2165 1140 : for( ulong i=0UL; i<value_len; i++ ) {
2166 936 : if( FD_UNLIKELY( value[ i ]<'0' || value[ i ]>'9' ) ) return -1;
2167 936 : }
2168 :
2169 204 : long parsed = fd_cstr_to_long( value );
2170 204 : if( FD_UNLIKELY( parsed==LONG_MAX ) ) return -1;
2171 204 : *out = parsed;
2172 204 : return 0;
2173 204 : }
2174 :
2175 : static int
2176 : fd_gui_request_timeline( fd_gui_t * gui,
2177 : ulong ws_conn_id,
2178 : char const * key,
2179 : ulong id,
2180 : char const * params,
2181 102 : ulong params_sz ) {
2182 102 : long start_ns = 0L; int has_start = 0;
2183 102 : long end_ns = 0L; int has_end = 0;
2184 102 : char name[ 32UL ] = {0};
2185 102 : ulong tiles[ FD_TOPO_MAX_TILES ]; ulong tile_cnt = 0UL;
2186 102 : fd_jtok_t j[1]; fd_jtok_init( j, params, params_sz );
2187 102 : fd_jtok_str_t member;
2188 102 : fd_jtok_obj_enter( j );
2189 435 : while( fd_jtok_obj_next( j, &member ) ) {
2190 336 : if( fd_jtok_str_eq( &member, "start_ns" ) ) {
2191 102 : if( FD_UNLIKELY( fd_gui_jtok_parse_ns( j, &start_ns ) ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2192 102 : has_start = 1;
2193 234 : } else if( fd_jtok_str_eq( &member, "end_ns" ) ) {
2194 102 : if( FD_UNLIKELY( fd_gui_jtok_parse_ns( j, &end_ns ) ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2195 102 : has_end = 1;
2196 132 : } else if( fd_jtok_str_eq( &member, "granularity" ) ) {
2197 90 : fd_jtok_cstr( j, name, sizeof(name) );
2198 90 : } else if( fd_jtok_str_eq( &member, "tiles" ) ) {
2199 42 : fd_jtok_arr_enter( j );
2200 855 : while( fd_jtok_arr_next( j ) ) {
2201 816 : if( FD_UNLIKELY( tile_cnt>=FD_TOPO_MAX_TILES ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2202 813 : fd_jtok_ulong( j, &tiles[ tile_cnt++ ] );
2203 813 : }
2204 42 : }
2205 336 : }
2206 99 : if( FD_UNLIKELY( fd_jtok_fini( j ) || !has_start || !has_end || end_ns<=start_ns ) ) {
2207 12 : return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2208 12 : }
2209 87 : int err;
2210 87 : if( !strcmp( key, "query_slots" ) ) {
2211 0 : err = fd_gui_printf_timeline_query_slots( gui, start_ns, end_ns, id );
2212 87 : } else if( !strcmp( key, "query_events" ) ) {
2213 0 : err = fd_gui_printf_timeline_query_events( gui, start_ns, end_ns, id );
2214 87 : } else if( !strcmp( key, "query_shreds" ) ) {
2215 0 : if( !strcmp( name, "shred" ) ) err = fd_gui_printf_timeline_query_shreds( gui, start_ns, end_ns, id );
2216 0 : else if( !strcmp( name, "fec" ) ) err = fd_gui_printf_timeline_query_fec_events( gui, start_ns, end_ns, id );
2217 0 : else return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2218 87 : } else {
2219 87 : ulong g = 0UL;
2220 1008 : while( g<FD_GUI_TIMELINE_GRANULARITY_CNT && strcmp( name, fd_gui_timeline_granularities[ g ].name ) ) g++;
2221 87 : if( FD_UNLIKELY( g==FD_GUI_TIMELINE_GRANULARITY_CNT ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2222 54 : int stored;
2223 54 : ulong merge_cnt;
2224 54 : if( FD_UNLIKELY( fd_gui_timeline_tier( key, g, &stored, &merge_cnt ) ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2225 42 : ulong ns = fd_gui_timeline_granularity_ns( g );
2226 42 : ulong first = (ulong)start_ns / ns;
2227 42 : ulong reference = first*ns;
2228 42 : ulong count = ((ulong)end_ns-1UL)/ns - first + 1UL;
2229 42 : if( FD_UNLIKELY( count>FD_GUI_TIMELINE_QUERY_MAX_BUCKETS || count*ns>=(ulong)LONG_MAX-reference ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2230 30 : if( !strcmp( key, "query_agg_cpu" ) ) err = fd_gui_printf_timeline_query_agg_cpu( gui, name, g, (long)reference, count, tiles, tile_cnt, id );
2231 24 : else err = fd_gui_printf_timeline_query_agg( gui, key, name, g, (long)reference, count, id );
2232 30 : }
2233 30 : if( FD_UNLIKELY( err ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2234 27 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
2235 27 : return 0;
2236 27 : }
2237 :
2238 : int
2239 : fd_gui_ws_message( fd_gui_t * gui,
2240 : ulong ws_conn_id,
2241 : uchar const * data,
2242 102 : ulong data_len ) {
2243 102 : ulong id = 0UL; int has_id = 0;
2244 102 : fd_jtok_str_t topic = {0};
2245 102 : fd_jtok_str_t key = {0};
2246 102 : char const * params = NULL;
2247 102 : ulong params_sz = 0UL;
2248 :
2249 102 : fd_jtok_t j[1]; fd_jtok_init( j, data, data_len );
2250 102 : fd_jtok_str_t member;
2251 102 : fd_jtok_obj_enter( j );
2252 510 : while( fd_jtok_obj_next( j, &member ) ) {
2253 408 : if( fd_jtok_str_eq( &member, "id" ) ) { fd_jtok_ulong( j, &id ); has_id = 1; }
2254 306 : else if( fd_jtok_str_eq( &member, "topic" ) ) fd_jtok_str( j, &topic );
2255 204 : else if( fd_jtok_str_eq( &member, "key" ) ) fd_jtok_str( j, &key );
2256 102 : else if( fd_jtok_str_eq( &member, "params" ) ) {
2257 102 : if( FD_UNLIKELY( fd_jtok_peek( j )!=FD_JTOK_OBJ ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2258 102 : fd_jtok_raw( j, ¶ms, ¶ms_sz );
2259 102 : }
2260 408 : }
2261 102 : if( FD_UNLIKELY( fd_jtok_fini( j ) || !has_id || !topic.ptr || !key.ptr ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2262 :
2263 102 : if( FD_LIKELY( fd_jtok_str_eq( &topic, "slot" ) && fd_jtok_str_eq( &key, "query" ) ) ) {
2264 0 : if( FD_UNLIKELY( !params ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2265 0 : return fd_gui_request_slot( gui, ws_conn_id, id, params, params_sz );
2266 102 : } else if( FD_LIKELY( fd_jtok_str_eq( &topic, "slot" ) && fd_jtok_str_eq( &key, "query_detailed" ) ) ) {
2267 0 : if( FD_UNLIKELY( !params ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2268 0 : return fd_gui_request_slot_detailed( gui, ws_conn_id, id, params, params_sz );
2269 102 : } else if( FD_LIKELY( fd_jtok_str_eq( &topic, "slot" ) && fd_jtok_str_eq( &key, "query_transactions" ) ) ) {
2270 0 : if( FD_UNLIKELY( !params ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2271 0 : return fd_gui_request_slot_transactions( gui, ws_conn_id, id, params, params_sz );
2272 102 : } else if( FD_LIKELY( fd_jtok_str_eq( &topic, "slot" ) && fd_jtok_str_eq( &key, "query_rankings" ) ) ) {
2273 0 : if( FD_UNLIKELY( !params ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2274 0 : return fd_gui_request_slot_rankings( gui, ws_conn_id, id, params, params_sz );
2275 102 : } else if( FD_LIKELY( fd_jtok_str_eq( &topic, "timeline" ) &&
2276 102 : (fd_jtok_str_eq( &key, "query_shreds" ) ||
2277 102 : fd_jtok_str_eq( &key, "query_slots" ) ||
2278 102 : fd_jtok_str_eq( &key, "query_events" ) ||
2279 102 : fd_jtok_str_eq( &key, "query_agg_slots" ) ||
2280 102 : fd_jtok_str_eq( &key, "query_agg_shreds" ) ||
2281 102 : fd_jtok_str_eq( &key, "query_agg_compute" ) ||
2282 102 : fd_jtok_str_eq( &key, "query_agg_revenue" ) ||
2283 102 : fd_jtok_str_eq( &key, "query_agg_txn" ) ||
2284 102 : fd_jtok_str_eq( &key, "query_agg_cpu" )) ) ) {
2285 102 : if( FD_UNLIKELY( !params ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2286 102 : char name[ 32UL ];
2287 102 : if( FD_UNLIKELY( fd_jtok_str_decode( &key, name, sizeof(name) )<0L ) ) return FD_HTTP_SERVER_CONNECTION_CLOSE_BAD_REQUEST;
2288 102 : return fd_gui_request_timeline( gui, ws_conn_id, name, id, params, params_sz );
2289 102 : } else if( FD_LIKELY( fd_jtok_str_eq( &topic, "summary" ) && fd_jtok_str_eq( &key, "ping" ) ) ) {
2290 0 : fd_gui_printf_summary_ping( gui, id );
2291 0 : FD_TEST( !fd_http_server_ws_send( gui->http, ws_conn_id ) );
2292 0 : return 0;
2293 0 : }
2294 :
2295 0 : return FD_HTTP_SERVER_CONNECTION_CLOSE_UNKNOWN_METHOD;
2296 102 : }
2297 :
2298 : static inline uchar
2299 18 : slot_get_skip_status( fd_gui_t * gui, ulong _slot ) {
2300 18 : ulong tower_slot = gui->summary.slot_tower;
2301 18 : if( FD_UNLIKELY( tower_slot==ULONG_MAX || _slot>=tower_slot ) ) return FD_GUI_SKIP_STATUS_UNKNOWN;
2302 :
2303 6 : ulong const max_consecutive_skips = gui->max_consecutive_skips;
2304 :
2305 : /* Find the nearest landed canonical descendant and walk its lineage
2306 : down to obtain positive skip proof. */
2307 6 : ulong anchor_slot = ULONG_MAX;
2308 6 : ulong anchor_bank_seq = ULONG_MAX;
2309 6 : ulong search_hi = fd_ulong_min( _slot+max_consecutive_skips, tower_slot );
2310 6 : for( ulong s=_slot+1UL; s<=search_hi; s++ ) {
2311 6 : fd_gui_hist_kv_slot_iter_t it[ 1 ];
2312 : /* Equivocation-safe */
2313 6 : for( fd_gui_hist_kv_iter_begin( gui, it, FD_GUI_HIST_SLOT, s ); it->rec; fd_gui_hist_kv_iter_next( it ) ) {
2314 6 : fd_gui_slot_t const * rec = (fd_gui_slot_t const *)it->rec;
2315 6 : if( FD_LIKELY( rec->skip==FD_GUI_SKIP_STATUS_NOT_SKIPPED ) ) {
2316 6 : anchor_slot = s;
2317 6 : anchor_bank_seq = it->bank_seq;
2318 6 : break;
2319 6 : }
2320 6 : }
2321 6 : if( FD_UNLIKELY( anchor_slot!=ULONG_MAX ) ) break;
2322 6 : }
2323 6 : if( FD_UNLIKELY( anchor_slot==ULONG_MAX ) ) return FD_GUI_SKIP_STATUS_UNKNOWN; /* no descendant found */
2324 :
2325 : /* Walk the canonical fork back up. */
2326 6 : ulong cur_slot = anchor_slot;
2327 6 : ulong cur_bank_seq = anchor_bank_seq;
2328 6 : for( ulong steps=0UL; steps<max_consecutive_skips; steps++ ) {
2329 6 : fd_gui_hist_slot_key_t key;
2330 6 : key.slot = cur_slot; key.bank_seq = cur_bank_seq;
2331 6 : fd_gui_slot_t const * cmeta = (fd_gui_slot_t const *)fd_gui_hist_kv_get( gui, FD_GUI_HIST_SLOT, &key );
2332 6 : if( FD_UNLIKELY( !cmeta ) ) return FD_GUI_SKIP_STATUS_UNKNOWN; /* lineage broken / aged out */
2333 :
2334 6 : ulong parent_slot = cmeta->parent_slot;
2335 6 : ulong parent_bank_seq = cmeta->parent_bank_seq;
2336 6 : if( FD_UNLIKELY( parent_slot==ULONG_MAX ) ) return FD_GUI_SKIP_STATUS_UNKNOWN; /* Couldn't find _slot */
2337 6 : if( FD_LIKELY( parent_slot==_slot ) ) return FD_GUI_SKIP_STATUS_NOT_SKIPPED; /* _slot is on this lineage */
2338 6 : if( FD_LIKELY( parent_slot< _slot ) ) return FD_GUI_SKIP_STATUS_FINALIZED; /* lineage steps over _slot: skipped */
2339 0 : cur_slot = parent_slot;
2340 0 : cur_bank_seq = parent_bank_seq;
2341 0 : }
2342 0 : return FD_GUI_SKIP_STATUS_UNKNOWN;
2343 6 : }
2344 :
2345 : fd_gui_slot_t *
2346 27 : fd_gui_slot_get_canon_safe( fd_gui_t * gui, ulong _slot ) {
2347 27 : fd_gui_slot_t * slot = fd_gui_slot_get_canon( gui, _slot );
2348 :
2349 27 : if( FD_LIKELY( slot ) ) {
2350 9 : return slot;
2351 18 : } else {
2352 18 : uchar level = FD_GUI_SLOT_LEVEL_COMPLETED;
2353 18 : if( FD_LIKELY( gui->summary.slot_rooted!=ULONG_MAX && _slot<gui->summary.slot_rooted ) ) level = FD_GUI_SLOT_LEVEL_ROOTED;
2354 :
2355 18 : *gui->skipped_scratch = (fd_gui_slot_t){
2356 18 : .slot = _slot,
2357 18 : .bank_seq = ULONG_MAX,
2358 18 : .parent_bank_seq = ULONG_MAX,
2359 18 : .parent_slot = ULONG_MAX,
2360 18 : .vote_slot = ULONG_MAX,
2361 18 : .completed_time = LONG_MAX,
2362 18 : .parent_completed_time = LONG_MAX,
2363 18 : .max_compute_units= UINT_MAX,
2364 18 : .mine = (uchar)(fd_gui_slot_is_mine( gui, _slot ) & 1),
2365 18 : .skip = slot_get_skip_status( gui, _slot ),
2366 18 : .level = level,
2367 18 : .compute_units = UINT_MAX,
2368 18 : .transaction_fee = ULONG_MAX,
2369 18 : .priority_fee = ULONG_MAX,
2370 18 : .tips = ULONG_MAX,
2371 18 : .shred_cnt = UINT_MAX,
2372 18 : .is_voter = FD_GUI_IS_VOTER_UNKNOWN,
2373 18 : .vote_rewarded = fd_gui_slot_vote_rewarded_state( gui, _slot ),
2374 18 : .vote_count = fd_gui_slot_vote_count( gui, _slot ),
2375 18 : .vote_success = UINT_MAX,
2376 18 : .vote_failed = UINT_MAX,
2377 18 : .nonvote_success = UINT_MAX,
2378 18 : .nonvote_failed = UINT_MAX,
2379 18 : };
2380 18 : fd_gui_slot_set_voter_state( gui->skipped_scratch, fd_gui_slot_voter_state( gui, _slot ) );
2381 18 : return gui->skipped_scratch;
2382 18 : }
2383 27 : }
2384 :
2385 : static void
2386 0 : fd_gui_update_boot_epoch_duration( fd_gui_t * gui ) {
2387 0 : ulong prev = gui->summary.boot_progress.boot_target_slot_duration_nanos;
2388 :
2389 0 : ulong slot = fd_gui_boot_snapshot_slot( gui );
2390 0 : if( FD_LIKELY( slot!=ULONG_MAX ) ) {
2391 0 : fd_gui_epoch_t const * epoch = fd_gui_get_epoch_by_slot( gui, slot );
2392 0 : if( FD_LIKELY( epoch && epoch->target_slot_duration_ns>0L ) ) {
2393 0 : gui->summary.boot_progress.boot_target_slot_duration_nanos = (ulong)epoch->target_slot_duration_ns;
2394 0 : }
2395 0 : }
2396 :
2397 0 : if( FD_UNLIKELY( prev!=gui->summary.boot_progress.boot_target_slot_duration_nanos ) ) {
2398 0 : gui->summary.prev_boot_progress = gui->summary.boot_progress;
2399 0 : fd_gui_printf_boot_progress( gui );
2400 0 : fd_http_server_ws_broadcast( gui->http );
2401 0 : }
2402 0 : }
2403 :
2404 : void
2405 : fd_gui_handle_epoch_info( fd_gui_t * gui,
2406 : fd_epoch_info_msg_t const * epoch_info,
2407 0 : long now ) {
2408 0 : FD_TEST( epoch_info->staked_vote_cnt<=MAX_STAKE_WEIGHTS );
2409 0 : FD_TEST( epoch_info->slot_cnt<=MAX_SLOTS_PER_EPOCH );
2410 0 : FD_TEST( epoch_info->staked_vote_cnt );
2411 :
2412 0 : if( FD_UNLIKELY( !gui->epoch.has_epoch_schedule ) ) {
2413 0 : gui->epoch.epoch_schedule = epoch_info->epoch_schedule;
2414 0 : gui->epoch.has_epoch_schedule = 1;
2415 0 : }
2416 :
2417 0 : fd_vote_stake_weight_t const * stake_weights = fd_epoch_info_msg_stake_weights( epoch_info );
2418 0 : fd_memcpy( gui->epoch.stakes_scratch, stake_weights, epoch_info->staked_vote_cnt*sizeof(fd_vote_stake_weight_t) );
2419 :
2420 0 : fd_epoch_leaders_t * lsched = fd_epoch_leaders_join( fd_epoch_leaders_new( gui->epoch.lsched_scratch,
2421 0 : epoch_info->epoch,
2422 0 : epoch_info->start_slot,
2423 0 : epoch_info->slot_cnt,
2424 0 : epoch_info->staked_vote_cnt,
2425 0 : gui->epoch.stakes_scratch,
2426 0 : fd_epoch_leaders_use_geo_aware( &epoch_info->features, &epoch_info->epoch_schedule, epoch_info->epoch ) ) );
2427 0 : FD_TEST( lsched );
2428 :
2429 0 : int created = 0;
2430 0 : fd_gui_epoch_t * epoch = fd_gui_epoch_get_or_create( gui, epoch_info->epoch, &created );
2431 0 : FD_TEST( epoch );
2432 :
2433 0 : if( FD_LIKELY( created ) ) {
2434 0 : epoch->epoch = epoch_info->epoch;
2435 0 : epoch->start_slot = epoch_info->start_slot;
2436 0 : epoch->slot_cnt = epoch_info->slot_cnt;
2437 0 : epoch->start_time = LONG_MAX;
2438 0 : epoch->end_time = LONG_MAX;
2439 0 : epoch->my_total_slots = 0UL;
2440 0 : epoch->my_skipped_slots = 0UL;
2441 0 : epoch->rankings_slot = epoch_info->start_slot;
2442 0 : epoch->timeline_slot_lo_idx = ULONG_MAX;
2443 0 : epoch->timeline_slot_hi_idx = ULONG_MAX;
2444 0 : epoch->timeline_slot_min_start_ns = LONG_MAX;
2445 0 : epoch->timeline_slot_max_end_ns = LONG_MIN;
2446 0 : memset( epoch->timeline_slot_state, 0, sizeof(epoch->timeline_slot_state) );
2447 0 : memset( epoch->timeline_slot_shred_cnt, 0xFF, sizeof(epoch->timeline_slot_shred_cnt) );
2448 0 : memset( epoch->rankings, (int)(UINT_MAX), sizeof(epoch->rankings) );
2449 0 : memset( epoch->my_rankings, (int)(UINT_MAX), sizeof(epoch->my_rankings) );
2450 0 : memset( epoch->is_voter, FD_GUI_IS_VOTER_UNKNOWN, sizeof(epoch->is_voter) );
2451 0 : memset( epoch->skipped, 0, sizeof(epoch->skipped) );
2452 0 : memset( epoch->vote_rewarded, FD_GUI_VOTE_REWARDED_UNKNOWN, sizeof(epoch->vote_rewarded) );
2453 0 : memset( epoch->vote_count, UCHAR_MAX, sizeof(epoch->vote_count) );
2454 0 : epoch->epoch_schedule = epoch_info->epoch_schedule;
2455 0 : epoch->pub_cnt = lsched->pub_cnt;
2456 0 : epoch->stakes_cnt = epoch_info->staked_vote_cnt;
2457 0 : fd_memcpy( epoch->pub, lsched->pub, epoch->pub_cnt*sizeof(fd_pubkey_t) );
2458 0 : fd_memcpy( epoch->sched, lsched->sched, fd_ulong_min( lsched->sched_cnt, FD_GUI_EPOCH_SCHED_CNT )*sizeof(uint) );
2459 0 : fd_memcpy( epoch->stakes, gui->epoch.stakes_scratch, epoch->stakes_cnt*sizeof(fd_vote_stake_weight_t) );
2460 0 : }
2461 :
2462 0 : epoch->target_slot_duration_ns = (long)epoch_info->ns_per_slot;
2463 :
2464 0 : fd_epoch_leaders_delete( fd_epoch_leaders_leave( lsched ) );
2465 :
2466 0 : if( FD_UNLIKELY( gui->epoch.current_epoch==ULONG_MAX ) ) {
2467 0 : gui->epoch.current_epoch = epoch_info->epoch;
2468 0 : } else {
2469 0 : gui->epoch.current_epoch = fd_ulong_max( gui->epoch.current_epoch, epoch_info->epoch>0UL ? epoch_info->epoch-1UL : 0UL );
2470 0 : }
2471 :
2472 0 : epoch->start_time = now;
2473 0 : for( ulong i=0UL; i<fd_ulong_min( fd_ulong_sat_sub( epoch_info->start_slot, 1UL ), MAX_SLOTS_PER_EPOCH ); i++ ) {
2474 0 : fd_gui_slot_t const * slot = fd_gui_slot_get_any( gui, epoch_info->start_slot-i );
2475 0 : if( FD_UNLIKELY( !slot ) ) break;
2476 0 : else if( FD_UNLIKELY( slot->skip==FD_GUI_SKIP_STATUS_FINALIZED ) ) continue;
2477 0 : epoch->start_time = slot->parent_completed_time;
2478 0 : break;
2479 0 : }
2480 :
2481 0 : fd_gui_update_boot_epoch_duration( gui );
2482 :
2483 0 : fd_gui_printf_epoch( gui, epoch_info->epoch );
2484 0 : fd_http_server_ws_broadcast( gui->http );
2485 0 : }
2486 :
2487 : void
2488 : fd_gui_handle_shred( fd_gui_t * gui,
2489 : ulong slot,
2490 : ulong shred_idx,
2491 : ulong fec_set_idx,
2492 : int is_turbine,
2493 : long tsorig,
2494 27 : long now ) {
2495 27 : int was_sent = fd_gui_ephemeral_slots_contains( gui->summary.slots_max_turbine, FD_GUI_TURBINE_SLOT_HISTORY_SZ, slot );
2496 27 : if( FD_LIKELY( is_turbine ) ) fd_gui_try_insert_ephemeral_slot( gui->summary.slots_max_turbine, FD_GUI_TURBINE_SLOT_HISTORY_SZ, slot, tsorig );
2497 :
2498 : /* If we haven't caught up yet, update repair slot using received
2499 : shreds. This is not technically correct, but close enough and will
2500 : make the progress bar look correct. */
2501 27 : if( FD_UNLIKELY( !is_turbine && gui->summary.slot_caught_up==ULONG_MAX ) ) fd_gui_handle_repair_slot( gui, slot, tsorig );
2502 :
2503 27 : if( FD_UNLIKELY( !was_sent && is_turbine && slot!=gui->summary.slot_turbine ) ) {
2504 15 : gui->summary.slot_turbine = slot;
2505 :
2506 15 : fd_gui_printf_turbine_slot( gui );
2507 15 : fd_http_server_ws_broadcast( gui->http );
2508 :
2509 15 : gui->turbine_slots[ slot % FD_GUI_TURBINE_RECV_TIMESTAMPS ].slot = slot;
2510 15 : gui->turbine_slots[ slot % FD_GUI_TURBINE_RECV_TIMESTAMPS ].timestamp = tsorig;
2511 :
2512 15 : ulong duration_sum = 0UL;
2513 15 : ulong slot_cnt = 0UL;
2514 :
2515 11265 : for( ulong i=0UL; i<FD_GUI_TURBINE_RECV_TIMESTAMPS; i++ ) {
2516 11250 : fd_gui_turbine_slot_t * cur = &gui->turbine_slots[ i ];
2517 11250 : fd_gui_turbine_slot_t * prev = &gui->turbine_slots[ (i+FD_GUI_TURBINE_RECV_TIMESTAMPS-1UL) % FD_GUI_TURBINE_RECV_TIMESTAMPS ];
2518 11250 : if( FD_UNLIKELY( cur->slot==ULONG_MAX || prev->slot==ULONG_MAX || cur->slot!=prev->slot+1UL ) ) continue;
2519 :
2520 0 : long slot_duration = cur->timestamp - prev->timestamp;
2521 0 : duration_sum += (ulong)fd_long_max( slot_duration, 0UL );
2522 0 : slot_cnt++;
2523 0 : }
2524 :
2525 15 : if( FD_LIKELY( slot_cnt>0 ) ) {
2526 0 : gui->summary.estimated_slot_duration_nanos = (ulong)(duration_sum / slot_cnt);
2527 0 : fd_gui_printf_estimated_slot_duration_nanos( gui );
2528 0 : fd_http_server_ws_broadcast( gui->http );
2529 0 : }
2530 :
2531 15 : if( FD_UNLIKELY( gui->summary.slot_caught_up==ULONG_MAX ) ) fd_gui_try_insert_run_length_slot( gui->summary.catch_up_turbine, FD_GUI_TURBINE_CATCH_UP_HISTORY_SZ, &gui->summary.catch_up_turbine_sz, slot );
2532 15 : }
2533 :
2534 27 : uchar event = fd_uchar_if( is_turbine, FD_GUI_SLOT_SHRED_SHRED_RECEIVED_TURBINE, FD_GUI_SLOT_SHRED_SHRED_RECEIVED_REPAIR );
2535 27 : fd_gui_shred_event_append( gui, slot, shred_idx, event, tsorig, now );
2536 27 : fd_gui_fec_event_append( gui, slot, fec_set_idx/FD_FEC_SHRED_CNT, event, tsorig, now );
2537 27 : }
2538 :
2539 : void
2540 : fd_gui_handle_leader_fec( fd_gui_t * gui,
2541 : ulong slot,
2542 : ulong fec_shred_cnt,
2543 : int is_end_of_slot,
2544 : long tsorig,
2545 6 : long now ) {
2546 : /* Abandoned block detected */
2547 6 : if( FD_UNLIKELY( gui->shreds.leader_shred_slot!=slot ) ) {
2548 3 : gui->shreds.leader_shred_cnt = 0UL;
2549 3 : gui->shreds.leader_shred_slot = slot;
2550 3 : }
2551 :
2552 198 : for( ulong i=gui->shreds.leader_shred_cnt; i<gui->shreds.leader_shred_cnt+fec_shred_cnt; i++ ) {
2553 192 : fd_gui_shred_event_append( gui, slot, i, FD_GUI_SLOT_SHRED_SHRED_PUBLISHED, tsorig, now );
2554 : /* Every shred of a FEC set maps to the same FEC event. */
2555 192 : if( i==gui->shreds.leader_shred_cnt || !(i%FD_FEC_SHRED_CNT) ) {
2556 6 : fd_gui_fec_event_append( gui, slot, i/FD_FEC_SHRED_CNT, FD_GUI_SLOT_SHRED_SHRED_PUBLISHED, tsorig, now );
2557 6 : }
2558 192 : }
2559 6 : gui->shreds.leader_shred_cnt += fec_shred_cnt;
2560 6 : if( FD_UNLIKELY( is_end_of_slot ) ) gui->shreds.leader_shred_cnt = 0UL;
2561 6 : }
2562 :
2563 : void
2564 : fd_gui_handle_exec_txn_done( fd_gui_t * gui,
2565 : ulong slot,
2566 : ulong start_shred_idx,
2567 : ulong end_shred_idx,
2568 : long tsorig_ns FD_PARAM_UNUSED,
2569 : long tspub_ns,
2570 12000 : long now ) {
2571 : /* The frontend keeps the earliest exec done per shred: drop reports
2572 : that do not improve on the minimum seen so far. */
2573 12000 : ulong ring = slot%FD_GUI_EXEC_DONE_SLOT_CNT;
2574 12000 : long * ts = gui->exec_done.ts+ring*FD_SHRED_BLK_MAX;
2575 12000 : if( FD_UNLIKELY( gui->exec_done.slot[ ring ]!=slot ) ) {
2576 147 : gui->exec_done.slot[ ring ] = slot;
2577 2408595 : for( ulong i=0UL; i<FD_SHRED_BLK_MAX; i++ ) ts[ i ] = LONG_MAX;
2578 147 : }
2579 :
2580 12000 : ulong fec = ULONG_MAX;
2581 41553 : for( ulong i = start_shred_idx; i<end_shred_idx; i++ ) {
2582 : /*
2583 : We're leaving this state transition out due to its proximity to
2584 : FD_GUI_SLOT_SHRED_SHRED_REPLAY_EXEC_DONE, but if we ever wanted
2585 : to send this data to the frontend we could.
2586 :
2587 : fd_gui_shred_event_append( gui, slot, i, FD_GUI_SLOT_SHRED_SHRED_REPLAY_EXEC_START, tsorig_ns, now );
2588 : */
2589 :
2590 29553 : if( FD_LIKELY( i<FD_SHRED_BLK_MAX ) ) {
2591 29553 : if( FD_LIKELY( tspub_ns>=ts[ i ] ) ) continue;
2592 10599 : ts[ i ] = tspub_ns;
2593 10599 : }
2594 10599 : fd_gui_shred_event_append( gui, slot, i, FD_GUI_SLOT_SHRED_SHRED_REPLAY_EXEC_DONE, tspub_ns, now );
2595 : /* Every shred of a FEC set maps to the same FEC event, and all
2596 : carry the same timestamp, so one update per FEC set suffices. */
2597 10599 : if( fec!=i/FD_FEC_SHRED_CNT ) {
2598 5634 : fec = i/FD_FEC_SHRED_CNT;
2599 5634 : fd_gui_fec_event_append( gui, slot, fec, FD_GUI_SLOT_SHRED_SHRED_REPLAY_EXEC_DONE, tspub_ns, now );
2600 5634 : }
2601 10599 : }
2602 12000 : }
2603 :
2604 : static void
2605 : fd_gui_timeline_root_block( fd_gui_t * gui,
2606 : fd_gui_slot_t const * c,
2607 : ulong prev_rooted,
2608 : long now );
2609 :
2610 : static void
2611 : fd_gui_persist_slot_skip( fd_gui_t * gui,
2612 : ulong slot,
2613 72 : ulong bank_seq ) {
2614 72 : fd_gui_hist_kv_slot_iter_t it[ 1 ];
2615 126 : for( fd_gui_hist_kv_iter_begin( gui, it, FD_GUI_HIST_SLOT, slot ); it->rec; fd_gui_hist_kv_iter_next( it ) ) {
2616 54 : ((fd_gui_slot_t *)it->rec)->skip = fd_uchar_if( it->bank_seq==bank_seq, FD_GUI_SKIP_STATUS_NOT_SKIPPED, FD_GUI_SKIP_STATUS_FINALIZED );
2617 54 : }
2618 72 : }
2619 :
2620 : void
2621 : fd_gui_handle_root_advanced( fd_gui_t * gui,
2622 : ulong _slot,
2623 : ulong bank_seq,
2624 15 : long now ) {
2625 15 : fd_gui_slot_t * root = fd_gui_slot_get( gui, _slot, bank_seq );
2626 15 : if( FD_UNLIKELY( !root ) ) return;
2627 :
2628 : /* Rooting only ever advances. */
2629 15 : if( FD_UNLIKELY( gui->summary.slot_rooted!=ULONG_MAX && _slot<=gui->summary.slot_rooted ) ) return;
2630 :
2631 15 : ulong prev_rooted = gui->summary.slot_rooted;
2632 :
2633 15 : gui->summary.slot_rooted = _slot;
2634 : /* Slots below the root can no longer change, so their FEC events can
2635 : be archived. Close one slot behind the root so events for older
2636 : slots still queued on other inputs (which are polled independently
2637 : of replay_out) are not dropped. */
2638 15 : fd_gui_event_closed_slot_wmark_advance( gui, fd_ulong_sat_sub( _slot, 1UL ) );
2639 15 : fd_gui_printf_root_slot( gui );
2640 15 : fd_http_server_ws_broadcast( gui->http );
2641 :
2642 48 : for( ulong cslot=_slot, cbank_seq=bank_seq; ; ) {
2643 48 : fd_gui_slot_t * c = fd_gui_slot_get( gui, cslot, cbank_seq );
2644 48 : if( FD_UNLIKELY( !c || c->level>=FD_GUI_SLOT_LEVEL_ROOTED ) ) break;
2645 :
2646 42 : c->level = FD_GUI_SLOT_LEVEL_ROOTED;
2647 42 : fd_gui_persist_slot_skip( gui, cslot, cbank_seq );
2648 :
2649 42 : if( FD_UNLIKELY( c->finalization_kind==FD_GUI_AG_FINAL_NONE ) ) {
2650 42 : c->finalization_kind = FD_GUI_AG_FINAL_IMPLICIT;
2651 42 : }
2652 :
2653 42 : fd_gui_printf_slot( gui, cslot, c );
2654 42 : fd_http_server_ws_broadcast( gui->http );
2655 :
2656 42 : fd_gui_epoch_t * epoch = fd_gui_get_epoch_by_slot( gui, cslot );
2657 42 : if( FD_LIKELY( epoch ) ) {
2658 42 : ulong cidx = cslot - epoch->start_slot;
2659 42 : if( FD_LIKELY( cidx<epoch->slot_cnt ) ) {
2660 42 : if( FD_UNLIKELY( epoch->is_voter[ cidx ]!=FD_GUI_IS_VOTER_UNKNOWN ) )
2661 0 : fd_gui_slot_set_voter_state( c, epoch->is_voter[ cidx ] );
2662 42 : epoch->is_voter[ cidx ] = c->is_voter;
2663 42 : epoch->vote_count[ cidx ] = c->vote_count;
2664 :
2665 : /* This slot is on the rooted fork, so it was not skipped. */
2666 42 : epoch->skipped[ cidx ] = 0;
2667 42 : }
2668 42 : }
2669 :
2670 42 : ulong pslot = c->parent_slot, pseq = c->parent_bank_seq;
2671 42 : fd_gui_slot_t cc = *c; /* the timeline write below can evict c */
2672 42 : if( FD_UNLIKELY( pslot==ULONG_MAX || pslot>=cslot ) ) break;
2673 :
2674 : /* Record and republish newly rooted skipped slots. */
2675 63 : for( ulong s=pslot+1UL; s<cslot; s++ ) {
2676 30 : if( FD_UNLIKELY( prev_rooted!=ULONG_MAX && s<=prev_rooted ) ) continue; /* already rooted earlier */
2677 :
2678 30 : fd_gui_persist_slot_skip( gui, s, ULONG_MAX );
2679 :
2680 30 : fd_gui_epoch_t * sepoch = fd_gui_get_epoch_by_slot( gui, s );
2681 30 : if( FD_LIKELY( sepoch ) ) {
2682 30 : ulong sidx = s - sepoch->start_slot;
2683 30 : if( FD_LIKELY( sidx<sepoch->slot_cnt ) ) sepoch->skipped[ sidx ] = 1;
2684 30 : }
2685 :
2686 30 : if( FD_UNLIKELY( prev_rooted==ULONG_MAX ) ) continue;
2687 :
2688 9 : fd_gui_slot_t const * skipped = fd_gui_slot_get_canon_safe( gui, s );
2689 9 : if( FD_UNLIKELY( skipped->skip!=FD_GUI_SKIP_STATUS_FINALIZED ) ) continue;
2690 0 : fd_gui_printf_slot( gui, s, skipped );
2691 0 : fd_http_server_ws_broadcast( gui->http );
2692 0 : }
2693 :
2694 33 : fd_gui_timeline_root_block( gui, &cc, prev_rooted, now );
2695 :
2696 33 : cslot = pslot; cbank_seq = pseq;
2697 33 : }
2698 15 : }
2699 :
2700 : static fd_gui_ag_slot_t *
2701 : fd_gui_ag_slot_entry( fd_gui_t * gui,
2702 57 : ulong slot ) {
2703 : /* TODO: correctly handle equivocating slots */
2704 57 : fd_gui_ag_slot_t * ent = &gui->ag.slot[ slot % gui->ag.slot_cnt ];
2705 57 : if( FD_UNLIKELY( ent->slot!=slot ) ) {
2706 24 : ent->slot = slot;
2707 24 : memset( ent->block_id.uc, 0, sizeof(fd_hash_t) );
2708 24 : ent->bank_seq = ULONG_MAX;
2709 24 : ent->notarization_kind = FD_GUI_AG_NOTAR_NONE;
2710 24 : ent->finalization_kind = FD_GUI_AG_FINAL_NONE;
2711 24 : ent->skip = FD_GUI_SKIP_STATUS_UNKNOWN;
2712 24 : }
2713 57 : return ent;
2714 57 : }
2715 :
2716 : static int
2717 57 : fd_gui_ag_slot_has_proof( fd_gui_ag_slot_t const * ent ) {
2718 57 : return ent->notarization_kind!=FD_GUI_AG_NOTAR_NONE || ent->finalization_kind!=FD_GUI_AG_FINAL_NONE;
2719 57 : }
2720 :
2721 : static fd_gui_ag_slot_t *
2722 : fd_gui_ag_slot_for_certificate( fd_gui_t * gui,
2723 : ulong slot,
2724 0 : fd_hash_t const * block_id ) {
2725 0 : fd_gui_ag_slot_t * ent = fd_gui_ag_slot_entry( gui, slot );
2726 0 : if( FD_UNLIKELY( !fd_hash_eq( &ent->block_id, block_id ) ) ) {
2727 0 : ent->block_id = *block_id;
2728 0 : ent->bank_seq = ULONG_MAX;
2729 0 : ent->notarization_kind = FD_GUI_AG_NOTAR_NONE;
2730 0 : ent->finalization_kind = FD_GUI_AG_FINAL_NONE;
2731 0 : }
2732 0 : return ent;
2733 0 : }
2734 :
2735 : static void
2736 : fd_gui_ag_slot_publish( fd_gui_t * gui,
2737 57 : fd_gui_ag_slot_t const * ent ) {
2738 57 : if( FD_UNLIKELY( ent->bank_seq==ULONG_MAX ) ) return; /* not replayed yet, applied when it is */
2739 :
2740 57 : fd_gui_slot_t * slot = fd_gui_slot_get( gui, ent->slot, ent->bank_seq );
2741 57 : if( FD_UNLIKELY( !slot ) ) return;
2742 :
2743 57 : uchar notar = fd_uchar_if( ent->notarization_kind>slot->notarization_kind, ent->notarization_kind, slot->notarization_kind );
2744 57 : uchar final = fd_uchar_if( ent->finalization_kind>slot->finalization_kind, ent->finalization_kind, slot->finalization_kind );
2745 57 : uchar level = slot->level;
2746 :
2747 : /* Increase confirmation, but don't root yet since that's handled by
2748 : fd_gui_handle_root_advanced. */
2749 57 : if( FD_LIKELY( notar!=FD_GUI_AG_NOTAR_NONE || final!=FD_GUI_AG_FINAL_NONE ) ) {
2750 0 : level = fd_uchar_if( level<FD_GUI_SLOT_LEVEL_OPTIMISTICALLY_CONFIRMED, FD_GUI_SLOT_LEVEL_OPTIMISTICALLY_CONFIRMED, level );
2751 0 : }
2752 :
2753 57 : if( FD_LIKELY( notar==slot->notarization_kind && final==slot->finalization_kind && level==slot->level ) ) return;
2754 :
2755 0 : slot->notarization_kind = notar;
2756 0 : slot->finalization_kind = final;
2757 0 : slot->level = level;
2758 :
2759 0 : fd_gui_slot_t * canon = fd_gui_slot_get_canon( gui, ent->slot );
2760 0 : fd_gui_printf_slot( gui, ent->slot, fd_ptr_if( !!canon, canon, slot ) );
2761 0 : fd_http_server_ws_broadcast( gui->http );
2762 0 : }
2763 :
2764 : static void
2765 : fd_gui_ag_update_notarized_slot( fd_gui_t * gui,
2766 0 : ulong slot ) {
2767 0 : if( FD_LIKELY( gui->summary.slot_notarized!=ULONG_MAX && slot<=gui->summary.slot_notarized ) ) return;
2768 :
2769 0 : gui->summary.slot_notarized = slot;
2770 0 : fd_gui_printf_notarized_slot( gui );
2771 0 : fd_http_server_ws_broadcast( gui->http );
2772 0 : }
2773 :
2774 : void
2775 : fd_gui_ag_register_block( fd_gui_t * gui,
2776 : ulong slot,
2777 : fd_hash_t const * block_id,
2778 57 : ulong bank_seq ) {
2779 57 : if( FD_UNLIKELY( !block_id ) ) return;
2780 :
2781 57 : fd_gui_ag_slot_t * ent = fd_gui_ag_slot_entry( gui, slot );
2782 57 : if( FD_UNLIKELY( fd_gui_ag_slot_has_proof( ent ) && !fd_hash_eq( &ent->block_id, block_id ) ) ) return;
2783 :
2784 57 : ent->block_id = *block_id;
2785 57 : ent->bank_seq = bank_seq;
2786 57 : fd_gui_ag_slot_publish( gui, ent );
2787 57 : }
2788 :
2789 : void
2790 : fd_gui_handle_ag_notarized( fd_gui_t * gui,
2791 : ulong slot,
2792 : fd_hash_t const * block_id,
2793 0 : uchar notarization_kind ) {
2794 0 : if( FD_UNLIKELY( !block_id ) ) return;
2795 :
2796 0 : fd_gui_ag_slot_t * ent = fd_gui_ag_slot_for_certificate( gui, slot, block_id );
2797 0 : ent->notarization_kind = fd_uchar_if( notarization_kind>ent->notarization_kind, notarization_kind, ent->notarization_kind );
2798 0 : fd_gui_ag_slot_publish( gui, ent );
2799 0 : fd_gui_ag_update_notarized_slot( gui, slot );
2800 0 : }
2801 :
2802 : void
2803 : fd_gui_handle_ag_finalized( fd_gui_t * gui,
2804 : ulong slot,
2805 : fd_hash_t const * block_id,
2806 0 : uchar finalization_kind ) {
2807 0 : if( FD_UNLIKELY( !block_id ) ) return;
2808 :
2809 0 : fd_gui_ag_slot_t * ent = fd_gui_ag_slot_for_certificate( gui, slot, block_id );
2810 0 : ent->finalization_kind = fd_uchar_if( finalization_kind>ent->finalization_kind, finalization_kind, ent->finalization_kind );
2811 :
2812 : /* Finalization implies regular notarization. */
2813 0 : ent->notarization_kind = FD_GUI_AG_NOTAR_REGULAR;
2814 :
2815 0 : fd_gui_ag_slot_publish( gui, ent );
2816 0 : fd_gui_ag_update_notarized_slot( gui, slot );
2817 :
2818 0 : if( FD_LIKELY( gui->summary.slot_finalized==ULONG_MAX || slot>gui->summary.slot_finalized ) ) {
2819 0 : gui->summary.slot_finalized = slot;
2820 0 : fd_gui_printf_finalized_slot( gui );
2821 0 : fd_http_server_ws_broadcast( gui->http );
2822 0 : }
2823 0 : }
2824 :
2825 : void
2826 : fd_gui_handle_ag_skip_cert( fd_gui_t * gui,
2827 0 : ulong slot ) {
2828 :
2829 0 : fd_gui_ag_slot_t * ent = fd_gui_ag_slot_entry( gui, slot );
2830 0 : if( FD_LIKELY( ent->skip>=FD_GUI_SKIP_STATUS_NOTARIZED ) ) return;
2831 0 : ent->skip = FD_GUI_SKIP_STATUS_NOTARIZED;
2832 :
2833 0 : fd_gui_printf_slot( gui, slot, fd_gui_slot_get_canon_safe( gui, slot ) );
2834 0 : fd_http_server_ws_broadcast( gui->http );
2835 0 : fd_gui_ag_update_notarized_slot( gui, slot );
2836 0 : }
2837 :
2838 : void
2839 : fd_gui_handle_ag_leader( fd_gui_t * gui,
2840 0 : ulong parent_slot ) {
2841 0 : if( FD_UNLIKELY( gui->summary.slot_reset==parent_slot ) ) return;
2842 :
2843 0 : gui->summary.slot_reset = parent_slot;
2844 0 : fd_gui_printf_reset_slot( gui );
2845 0 : fd_http_server_ws_broadcast( gui->http );
2846 0 : }
2847 :
2848 : int
2849 : fd_gui_ag_slot_is_skip_notarized( fd_gui_t const * gui,
2850 9 : ulong slot ) {
2851 9 : if( FD_UNLIKELY( slot==ULONG_MAX ) ) return 0;
2852 :
2853 9 : fd_gui_ag_slot_t const * ent = &gui->ag.slot[ slot % gui->ag.slot_cnt ];
2854 9 : return ent->slot==slot && ent->skip>=FD_GUI_SKIP_STATUS_NOTARIZED;
2855 9 : }
2856 :
2857 : static void
2858 : fd_gui_handle_ag_reward( fd_gui_t * gui,
2859 : ulong slot,
2860 : int voted,
2861 57 : ushort voted_rank ) {
2862 :
2863 57 : uchar vote_rewarded = fd_uchar_if( !!voted, FD_GUI_VOTE_REWARDED_YES, FD_GUI_VOTE_REWARDED_NO );
2864 57 : uchar is_voter = fd_uchar_if( voted_rank!=USHORT_MAX, FD_GUI_IS_VOTER_YES, FD_GUI_IS_VOTER_NO );
2865 :
2866 57 : int epoch_changed = 0;
2867 57 : fd_gui_epoch_t * epoch = fd_gui_get_epoch_by_slot( gui, slot );
2868 57 : if( FD_LIKELY( epoch ) ) {
2869 6 : ulong idx = slot - epoch->start_slot;
2870 6 : if( FD_LIKELY( idx<epoch->slot_cnt && ( epoch->vote_rewarded[ idx ]!=vote_rewarded || epoch->is_voter[ idx ]!=is_voter ) ) ) {
2871 3 : int was_missed = epoch->vote_rewarded[ idx ]==FD_GUI_VOTE_REWARDED_NO && epoch->is_voter[ idx ]==FD_GUI_IS_VOTER_YES;
2872 3 : epoch_changed = 1;
2873 3 : epoch->vote_rewarded[ idx ] = vote_rewarded;
2874 3 : epoch->is_voter[ idx ] = is_voter;
2875 3 : int is_missed = vote_rewarded==FD_GUI_VOTE_REWARDED_NO && is_voter==FD_GUI_IS_VOTER_YES;
2876 :
2877 3 : if( FD_UNLIKELY( was_missed!=is_missed ) ) gui->epoch.missed_vote_history_dirty = epoch->epoch; /* coalesced into one broadcast per poll */
2878 3 : }
2879 6 : }
2880 :
2881 57 : fd_gui_slot_t * rec = fd_gui_slot_get_canon( gui, slot );
2882 57 : if( FD_UNLIKELY( !rec ) ) {
2883 57 : if( FD_UNLIKELY( epoch_changed ) ) {
2884 3 : fd_gui_slot_t const * skipped = fd_gui_slot_get_canon_safe( gui, slot );
2885 3 : if( FD_LIKELY( skipped->skip==FD_GUI_SKIP_STATUS_FINALIZED || fd_gui_ag_slot_is_skip_notarized( gui, slot ) ) ) {
2886 0 : fd_gui_printf_slot( gui, slot, skipped );
2887 0 : fd_http_server_ws_broadcast( gui->http );
2888 0 : }
2889 3 : }
2890 57 : return;
2891 57 : }
2892 :
2893 0 : int changed = rec->vote_rewarded!=vote_rewarded || rec->is_voter!=is_voter || epoch_changed;
2894 0 : rec->vote_rewarded = vote_rewarded;
2895 0 : fd_gui_slot_set_voter_state( rec, is_voter );
2896 0 : if( FD_UNLIKELY( !changed ) ) return;
2897 0 : fd_gui_printf_slot( gui, slot, rec );
2898 0 : fd_http_server_ws_broadcast( gui->http );
2899 0 : }
2900 :
2901 : fd_gui_timeline_granularity_t const fd_gui_timeline_granularities[ FD_GUI_TIMELINE_GRANULARITY_CNT ] = {
2902 : { "25ms", 25000000UL },
2903 : { "50ms", 50000000UL },
2904 : { "100ms", 100000000UL },
2905 : { "250ms", 250000000UL },
2906 : { "500ms", 500000000UL },
2907 : { "1s", 1000000000UL },
2908 : { "2s", 2000000000UL },
2909 : { "4s", 4000000000UL },
2910 : { "8s", 8000000000UL },
2911 : { "15s", 15000000000UL },
2912 : { "30s", 30000000000UL },
2913 : { "1m", 60000000000UL },
2914 : { "2m", 120000000000UL },
2915 : { "4m", 240000000000UL },
2916 : { "8m", 480000000000UL },
2917 : { "15m", 900000000000UL },
2918 : { "30m", 1800000000000UL },
2919 : { "1h", 3600000000000UL },
2920 : { "2h", 7200000000000UL },
2921 : { "4h", 14400000000000UL },
2922 : { "8h", 28800000000000UL },
2923 : { "12h", 43200000000000UL },
2924 : { "1d", 86400000000000UL }
2925 : };
2926 :
2927 : ulong const fd_gui_timeline_stored_granularity_ns[ FD_GUI_TIMELINE_STORED_GRANULARITY_CNT ] = {
2928 : [ FD_GUI_TIMELINE_GRANULARITY_25MS ] = 25000000UL,
2929 : [ FD_GUI_TIMELINE_GRANULARITY_250MS ] = 250000000UL,
2930 : [ FD_GUI_TIMELINE_GRANULARITY_2S ] = 2000000000UL,
2931 : [ FD_GUI_TIMELINE_GRANULARITY_15S ] = 15000000000UL,
2932 : [ FD_GUI_TIMELINE_GRANULARITY_2M ] = 120000000000UL,
2933 : [ FD_GUI_TIMELINE_GRANULARITY_15M ] = 900000000000UL,
2934 : [ FD_GUI_TIMELINE_GRANULARITY_2H ] = 7200000000000UL,
2935 : [ FD_GUI_TIMELINE_GRANULARITY_12H ] = 43200000000000UL
2936 : };
2937 :
2938 : /* Stored tiers available to each aggregate query. The shortest tier
2939 : is the query's minimum granularity. FD_GUI_TIMELINE_TIERS_DAY are
2940 : the tiers held by the day record. */
2941 :
2942 420 : #define FD_GUI_TIMELINE_TIERS_DAY ( (1UL<<FD_GUI_TIMELINE_GRANULARITY_250MS) | (1UL<<FD_GUI_TIMELINE_GRANULARITY_2S) | \
2943 420 : (1UL<<FD_GUI_TIMELINE_GRANULARITY_15S) | (1UL<<FD_GUI_TIMELINE_GRANULARITY_2M) | \
2944 420 : (1UL<<FD_GUI_TIMELINE_GRANULARITY_15M) | (1UL<<FD_GUI_TIMELINE_GRANULARITY_2H) | \
2945 420 : (1UL<<FD_GUI_TIMELINE_GRANULARITY_12H) )
2946 :
2947 : static ulong
2948 423 : fd_gui_timeline_tiers( char const * key ) {
2949 423 : if( !strcmp( key, "query_agg_cpu" ) ) return FD_GUI_TIMELINE_TIERS_DAY | (1UL<<FD_GUI_TIMELINE_GRANULARITY_25MS);
2950 294 : if( !strcmp( key, "query_agg_compute" ) ||
2951 294 : !strcmp( key, "query_agg_revenue" ) ||
2952 294 : !strcmp( key, "query_agg_txn" ) ||
2953 294 : !strcmp( key, "query_agg_shreds" ) ||
2954 294 : !strcmp( key, "query_agg_slots" ) ) return FD_GUI_TIMELINE_TIERS_DAY;
2955 3 : return 0UL;
2956 294 : }
2957 :
2958 : int
2959 : fd_gui_timeline_tier( char const * key,
2960 : ulong g,
2961 : int * stored,
2962 426 : ulong * merge_cnt ) {
2963 426 : if( FD_UNLIKELY( g>=FD_GUI_TIMELINE_GRANULARITY_CNT ) ) return -1;
2964 423 : ulong tiers = fd_gui_timeline_tiers( key );
2965 423 : if( FD_UNLIKELY( !tiers ) ) return -1;
2966 420 : ulong ns = fd_gui_timeline_granularity_ns( g );
2967 420 : if( FD_UNLIKELY( ns<fd_gui_timeline_stored_granularity_ns[ fd_ulong_find_lsb( tiers ) ] ) ) return -1;
2968 2121 : for( int t=(int)FD_GUI_TIMELINE_STORED_GRANULARITY_CNT-1; t>=0; t-- ) {
2969 2121 : if( !(tiers & (1UL<<t)) ) continue;
2970 2121 : ulong tier_ns = fd_gui_timeline_stored_granularity_ns[ t ];
2971 2121 : if( tier_ns>ns || ns%tier_ns ) continue;
2972 396 : *stored = t;
2973 396 : *merge_cnt = ns/tier_ns;
2974 396 : return 0;
2975 2121 : }
2976 0 : return -1;
2977 396 : }
2978 :
2979 : /* fd_gui_timeline_day_end_ns returns the end timestamp of the calendar
2980 : day day_idx. */
2981 :
2982 : static inline long
2983 417 : fd_gui_timeline_day_end_ns( ulong day_idx ) {
2984 417 : if( FD_UNLIKELY( day_idx>=(ulong)LONG_MAX/(ulong)FD_GUI_TIMELINE_DAY_NS ) ) return LONG_MAX;
2985 417 : return (long)((day_idx+1UL)*(ulong)FD_GUI_TIMELINE_DAY_NS);
2986 417 : }
2987 :
2988 : fd_gui_timeline_day_t *
2989 : fd_gui_timeline_day_get( fd_gui_t * gui,
2990 348 : ulong day_idx ) {
2991 348 : long end_time_ns = fd_gui_timeline_day_end_ns( day_idx );
2992 348 : if( FD_UNLIKELY( !gui->db || !gui->hist || end_time_ns==LONG_MAX ) ) return NULL;
2993 :
2994 348 : fd_gui_hist_iter_t it;
2995 348 : if( FD_UNLIKELY( fd_gui_hist_range_begin( gui, &it, FD_GUI_HIST_TIMELINE_DAY, end_time_ns, end_time_ns, NULL, NULL ) ) ) return NULL;
2996 348 : fd_gui_timeline_day_t * day = fd_gui_hist_range_next( &it ) ? (fd_gui_timeline_day_t *)it.rec : NULL;
2997 348 : fd_gui_hist_range_end( &it );
2998 348 : return day;
2999 348 : }
3000 :
3001 : /* fd_gui_timeline_cur_day returns the index of the newest day record
3002 : in the store, or ULONG_MAX if there is none. */
3003 :
3004 : static ulong
3005 36 : fd_gui_timeline_cur_day( fd_gui_t * gui ) {
3006 36 : long first, last;
3007 36 : if( FD_UNLIKELY( !fd_gui_store_ts_live_timestamp_bounds( gui->db, FD_GUI_HIST_TIMELINE_DAY, &first, &last ) ) ) return ULONG_MAX;
3008 6 : return (ulong)last/(ulong)FD_GUI_TIMELINE_DAY_NS-1UL;
3009 36 : }
3010 :
3011 : /* fd_gui_timeline_day_create_ok returns 1 if a new day record may be
3012 : created for day_idx, 0 otherwise. */
3013 :
3014 : static inline int
3015 : fd_gui_timeline_day_create_ok( ulong day_idx,
3016 : ulong cur_day,
3017 51 : long now ) {
3018 51 : if( FD_UNLIKELY( fd_gui_timeline_day_end_ns( day_idx )==LONG_MAX ) ) return 0;
3019 51 : if( FD_UNLIKELY( now<0L || day_idx>(ulong)now/(ulong)FD_GUI_TIMELINE_DAY_NS+1UL ) ) return 0;
3020 51 : return cur_day==ULONG_MAX || day_idx>cur_day;
3021 51 : }
3022 :
3023 : /* fd_gui_timeline_day_create returns the record for day_idx, creating
3024 : an empty one if it does not exist yet. Returns NULL if the
3025 : day cannot be created. */
3026 :
3027 : static fd_gui_timeline_day_t *
3028 : fd_gui_timeline_day_create( fd_gui_t * gui,
3029 : ulong day_idx,
3030 18 : long now ) {
3031 18 : long end_time_ns = fd_gui_timeline_day_end_ns( day_idx );
3032 18 : if( FD_UNLIKELY( !gui->db || !gui->hist || end_time_ns==LONG_MAX ) ) return NULL;
3033 18 : if( FD_UNLIKELY( !fd_gui_timeline_day_create_ok( day_idx, ULONG_MAX, now ) ) ) return NULL;
3034 :
3035 18 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_get( gui, day_idx );
3036 18 : if( day ) return day;
3037 18 : if( FD_UNLIKELY( !fd_gui_timeline_day_create_ok( day_idx, fd_gui_timeline_cur_day( gui ), now ) ) ) return NULL;
3038 :
3039 18 : fd_gui_timeline_day_t * seed = fd_gui_hist_ts_emplace( gui, FD_GUI_HIST_TIMELINE_DAY, end_time_ns );
3040 18 : if( FD_UNLIKELY( !seed ) ) return NULL;
3041 18 : memset( seed, 0xFF, sizeof(fd_gui_timeline_day_t) );
3042 :
3043 18 : seed->insert_time_ns = now;
3044 18 : seed->end_time_ns = end_time_ns;
3045 18 : return fd_gui_timeline_day_get( gui, day_idx );
3046 18 : }
3047 :
3048 : /* fd_gui_timeline_day_for_event returns the record for the day an event
3049 : belongs to, creating it if needed. Returns NULL if the day is unavailable. */
3050 :
3051 : static fd_gui_timeline_day_t *
3052 : fd_gui_timeline_day_for_event( fd_gui_t * gui,
3053 : ulong day_idx,
3054 93 : long now ) {
3055 93 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_get( gui, day_idx );
3056 93 : if( FD_LIKELY( day ) ) return day;
3057 18 : if( FD_UNLIKELY( !gui->db || !gui->hist ) ) return NULL;
3058 18 : ulong cur_day = fd_gui_timeline_cur_day( gui );
3059 18 : if( FD_UNLIKELY( day_idx && (cur_day==ULONG_MAX || day_idx>cur_day+1UL) ) ) {
3060 0 : fd_gui_timeline_day_create( gui, day_idx-1UL, now );
3061 0 : }
3062 18 : return fd_gui_timeline_day_create( gui, day_idx, now );
3063 18 : }
3064 :
3065 : /* fd_gui_timeline_count_add adds 1 to field in the bucket containing
3066 : ts_ns, at every stored granularity of day. */
3067 :
3068 : static void
3069 : fd_gui_timeline_count_add( fd_gui_timeline_day_t * day,
3070 : int field,
3071 39 : long ts_ns ) {
3072 39 : ulong day_ns = (ulong)ts_ns % (ulong)FD_GUI_TIMELINE_DAY_NS;
3073 312 : for( int g=FD_GUI_TIMELINE_GRANULARITY_250MS; g<(int)FD_GUI_TIMELINE_STORED_GRANULARITY_CNT; g++ ) {
3074 273 : fd_gui_timeline_field_accum( day, g, field, day_ns/fd_gui_timeline_stored_granularity_ns[ g ], 1UL );
3075 273 : }
3076 39 : }
3077 :
3078 : /* fd_gui_timeline_root_block records the timeline interval of newly
3079 : rooted block c and of the skipped slots between c and its parent.
3080 : Skipped slots at or below prev_rooted were recorded by an earlier
3081 : root. c must be a copy: creating day records can evict slot
3082 : records. */
3083 :
3084 : static void
3085 : fd_gui_timeline_root_block( fd_gui_t * gui,
3086 : fd_gui_slot_t const * c,
3087 : ulong prev_rooted,
3088 33 : long now ) {
3089 33 : long ct = c->completed_time;
3090 33 : long pt = c->parent_completed_time;
3091 33 : if( FD_UNLIKELY( ct<0L || ct==LONG_MAX || c->parent_slot>=c->slot ) ) return;
3092 33 : int have_pt = pt>=0L && pt<=ct;
3093 33 : ulong count = c->slot - c->parent_slot; /* slots advanced: count-1 skipped, then c */
3094 33 : ulong dur = fd_ulong_if( have_pt, (ulong)(ct-pt), 0UL );
3095 :
3096 96 : for( ulong k=1UL; k<=count; k++ ) {
3097 63 : ulong s = c->parent_slot + k;
3098 63 : if( prev_rooted!=ULONG_MAX && s<=prev_rooted ) continue;
3099 63 : fd_gui_epoch_t * epoch = fd_gui_get_epoch_by_slot( gui, s );
3100 63 : if( FD_UNLIKELY( !epoch || s<epoch->start_slot || s-epoch->start_slot>=fd_ulong_min( epoch->slot_cnt, MAX_SLOTS_PER_EPOCH ) ) ) continue;
3101 63 : ulong idx = s - epoch->start_slot;
3102 63 : uchar state = epoch->timeline_slot_state[ idx ];
3103 63 : uchar flags = (uchar)(FD_GUI_TIMELINE_SLOT_STATE_VALID | (state & FD_GUI_TIMELINE_SLOT_STATE_STARTED));
3104 63 : long first = (state & FD_GUI_TIMELINE_SLOT_STATE_STARTED) ? epoch->timeline_slot_first_shred_ns[ idx ] : LONG_MAX;
3105 :
3106 63 : if( k==count ) {
3107 : /* c landed: first shred arrival to replay completion. */
3108 33 : epoch->timeline_slot_start_ns[ idx ] = first;
3109 33 : epoch->timeline_slot_end_ns[ idx ] = ct;
3110 33 : epoch->timeline_slot_shred_cnt[ idx ] = c->shred_cnt;
3111 33 : epoch->timeline_slot_state[ idx ] = (uchar)(flags | (c->mine ? FD_GUI_TIMELINE_SLOT_STATE_MINE : 0U));
3112 33 : fd_gui_epoch_timeline_slot_note( epoch, idx );
3113 33 : continue;
3114 33 : }
3115 :
3116 : /* s was skipped. If a fork of it replayed, use the earliest
3117 : completion; otherwise give it an even share of the parent -> c
3118 : gap. */
3119 30 : long end_ns = LONG_MAX;
3120 30 : uint shred_cnt = UINT_MAX;
3121 30 : fd_gui_hist_kv_slot_iter_t it[ 1 ];
3122 42 : for( fd_gui_hist_kv_iter_begin( gui, it, FD_GUI_HIST_SLOT, s ); it->rec; fd_gui_hist_kv_iter_next( it ) ) {
3123 12 : fd_gui_slot_t const * fork = (fd_gui_slot_t const *)it->rec;
3124 12 : if( fork->completed_time>=0L && fork->completed_time<end_ns ) { end_ns = fork->completed_time; shred_cnt = fork->shred_cnt; }
3125 12 : }
3126 30 : int replayed = end_ns!=LONG_MAX;
3127 30 : long lo = pt + (long)(((uint128)(k-1UL)*dur)/count);
3128 30 : long hi = pt + (long)(((uint128)k*dur)/count);
3129 30 : epoch->timeline_slot_start_ns[ idx ] = replayed ? first : (have_pt ? lo : LONG_MAX);
3130 30 : epoch->timeline_slot_end_ns[ idx ] = replayed ? end_ns : (have_pt ? hi : LONG_MAX);
3131 30 : epoch->timeline_slot_shred_cnt[ idx ] = replayed ? shred_cnt : UINT_MAX;
3132 : /* Our block for s replayed but did not land. Uses the current
3133 : identity, like query_events. */
3134 30 : int mine = replayed && fd_gui_slot_is_mine( gui, s );
3135 30 : epoch->timeline_slot_state[ idx ] = (uchar)(flags | FD_GUI_TIMELINE_SLOT_STATE_SKIPPED | (mine ? FD_GUI_TIMELINE_SLOT_STATE_MINE : 0U));
3136 30 : fd_gui_epoch_timeline_slot_note( epoch, idx );
3137 :
3138 : /* Day aggregates last, since creating a day can evict records. A
3139 : skip with no parent time has no midpoint and is not counted. */
3140 30 : if( have_pt ) {
3141 30 : long mid = lo+(hi-lo)/2L;
3142 30 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_for_event( gui, (ulong)mid/(ulong)FD_GUI_TIMELINE_DAY_NS, now );
3143 30 : if( day ) fd_gui_timeline_count_add( day, FD_GUI_TIMELINE_FIELD_SKIPPED, mid );
3144 30 : }
3145 30 : if( mine ) {
3146 6 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_for_event( gui, (ulong)end_ns/(ulong)FD_GUI_TIMELINE_DAY_NS, now );
3147 6 : if( day ) fd_gui_timeline_count_add( day, FD_GUI_TIMELINE_FIELD_MINE_SKIPPED, end_ns );
3148 6 : }
3149 30 : }
3150 33 : }
3151 :
3152 :
3153 : void
3154 : fd_gui_timeline_handle_fec( fd_gui_t * gui,
3155 : ulong slot,
3156 : int published,
3157 : long timestamp_ns,
3158 : ulong turbine,
3159 : ulong repair,
3160 : ulong reconstructed,
3161 30 : long now ) {
3162 30 : if( FD_UNLIKELY( slot==ULONG_MAX || timestamp_ns<0L || timestamp_ns==LONG_MAX ||
3163 30 : turbine>2UL*FD_FEC_SHRED_CNT || repair>2UL*FD_FEC_SHRED_CNT ||
3164 30 : reconstructed>2UL*FD_FEC_SHRED_CNT ) ) return;
3165 12 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_for_event( gui, (ulong)timestamp_ns/(ulong)FD_GUI_TIMELINE_DAY_NS, now );
3166 12 : if( FD_UNLIKELY( !day ) ) return;
3167 12 : ulong day_ns = (ulong)timestamp_ns % (ulong)FD_GUI_TIMELINE_DAY_NS;
3168 96 : for( int g=FD_GUI_TIMELINE_GRANULARITY_250MS; g<(int)FD_GUI_TIMELINE_STORED_GRANULARITY_CNT; g++ ) {
3169 84 : ulong idx = day_ns / fd_gui_timeline_stored_granularity_ns[ g ];
3170 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_START_SLOT, idx, slot );
3171 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_END_SLOT, idx, slot );
3172 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_TURBINE, idx, turbine );
3173 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_REPAIR, idx, repair );
3174 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_RECONSTRUCTED, idx, reconstructed );
3175 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_PUBLISHED, idx, published ? 2UL*FD_FEC_SHRED_CNT : 0UL );
3176 84 : }
3177 12 : }
3178 :
3179 : /* fd_gui_timeline_duration_credit credits one block interval to the
3180 : buckets of one calendar day. The block interval is [parent,parent+gap)
3181 : and advances slot_units/FD_GUI_TIMELINE_SLOT_UNIT slots. [lo,hi) is the
3182 : part of the interval in this day. */
3183 :
3184 : static void
3185 : fd_gui_timeline_duration_credit( fd_gui_timeline_day_t * day,
3186 : ulong day_start,
3187 : ulong lo,
3188 : ulong hi,
3189 : ulong parent,
3190 : ulong gap,
3191 33 : ulong slot_units ) {
3192 : /* If gap*slot_units does not fit into ulong, the function shifts the
3193 : time offsets and gap right by the same amount. */
3194 33 : int sh = 0;
3195 69 : while( FD_UNLIKELY( (gap>>sh)>ULONG_MAX/slot_units ) ) sh++;
3196 29808 : #define SLOTS_AT(t) ( (((t)-parent)>>sh)*slot_units / (gap>>sh) )
3197 264 : for( int g=FD_GUI_TIMELINE_GRANULARITY_250MS; g<(int)FD_GUI_TIMELINE_STORED_GRANULARITY_CNT; g++ ) {
3198 231 : ulong w = fd_gui_timeline_stored_granularity_ns[ g ];
3199 15135 : for( ulong idx=(lo-day_start)/w; day_start+idx*w<hi; idx++ ) {
3200 14904 : ulong b0 = fd_ulong_max( lo, day_start+idx*w );
3201 14904 : ulong b1 = fd_ulong_min( hi, day_start+(idx+1UL)*w );
3202 14904 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_DURATION_WALL, idx, b1-b0 );
3203 14904 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_DURATION_SLOTS, idx, SLOTS_AT( b1 )-SLOTS_AT( b0 ) );
3204 14904 : }
3205 231 : }
3206 33 : #undef SLOTS_AT
3207 33 : }
3208 :
3209 : /* fd_gui_timeline_slot_duration spreads the slot progress of a replayed
3210 : block over the wall time since the completion of its parent. If the
3211 : day of the block completion does not exist, the function creates it.
3212 : It credits earlier days in the interval only if the store keeps them.
3213 : If a block advances more than gui->max_consecutive_skips slots, the
3214 : function credits only gui->max_consecutive_skips slots. The buckets
3215 : then show a slot duration that is too long, but the value is
3216 : finite. */
3217 :
3218 : static void
3219 : fd_gui_timeline_slot_duration( fd_gui_t * gui,
3220 : fd_gui_slot_t const * slot,
3221 57 : long now ) {
3222 57 : if( FD_UNLIKELY( slot->slot==ULONG_MAX || slot->parent_slot>=slot->slot ||
3223 57 : slot->parent_completed_time<0L || slot->parent_completed_time==LONG_MAX ||
3224 57 : slot->completed_time==LONG_MAX || slot->completed_time<=slot->parent_completed_time ) ) return;
3225 30 : if( FD_UNLIKELY( !gui->db || !gui->hist ) ) return;
3226 : /* Store operations can evict slot. After this point, use only local
3227 : copies. */
3228 30 : ulong parent = (ulong)slot->parent_completed_time;
3229 30 : ulong completed = (ulong)slot->completed_time;
3230 30 : ulong slot_units = fd_ulong_min( slot->slot-slot->parent_slot, gui->max_consecutive_skips )*FD_GUI_TIMELINE_SLOT_UNIT;
3231 30 : ulong last_day = (completed-1UL)/(ulong)FD_GUI_TIMELINE_DAY_NS;
3232 30 : if( FD_UNLIKELY( !fd_gui_timeline_day_for_event( gui, last_day, now ) ) ) return;
3233 :
3234 : /* Do not look up days that are older than the oldest retained day. */
3235 30 : long first, last;
3236 30 : if( FD_UNLIKELY( !fd_gui_store_ts_live_timestamp_bounds( gui->db, FD_GUI_HIST_TIMELINE_DAY, &first, &last ) ) ) return;
3237 30 : ulong first_day = fd_ulong_max( parent/(ulong)FD_GUI_TIMELINE_DAY_NS, (ulong)first/(ulong)FD_GUI_TIMELINE_DAY_NS-1UL );
3238 63 : for( ulong d=first_day; d<=last_day; d++ ) {
3239 33 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_get( gui, d );
3240 33 : if( FD_UNLIKELY( !day ) ) continue;
3241 33 : ulong day_start = d*(ulong)FD_GUI_TIMELINE_DAY_NS;
3242 33 : ulong lo = fd_ulong_max( parent, day_start );
3243 33 : ulong hi = fd_ulong_min( completed, day_start+(ulong)FD_GUI_TIMELINE_DAY_NS );
3244 33 : fd_gui_timeline_duration_credit( day, day_start, lo, hi, parent, completed-parent, slot_units );
3245 33 : }
3246 30 : }
3247 :
3248 : static void
3249 : fd_gui_timeline_handle_txn( fd_gui_t * gui,
3250 : ulong slot,
3251 : long timestamp_ns,
3252 : ulong compute_units,
3253 : ulong max_compute_units,
3254 : ulong transaction_fee,
3255 : ulong priority_fee,
3256 : ulong tips,
3257 : int txn_succeeded,
3258 12 : long now ) {
3259 12 : if( FD_UNLIKELY( slot==ULONG_MAX || timestamp_ns<0L || timestamp_ns==LONG_MAX ) ) return;
3260 12 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_for_event( gui, (ulong)timestamp_ns/(ulong)FD_GUI_TIMELINE_DAY_NS, now );
3261 12 : if( FD_UNLIKELY( !day ) ) return;
3262 12 : ulong day_ns = (ulong)timestamp_ns % (ulong)FD_GUI_TIMELINE_DAY_NS;
3263 96 : for( int g=FD_GUI_TIMELINE_GRANULARITY_250MS; g<(int)FD_GUI_TIMELINE_STORED_GRANULARITY_CNT; g++ ) {
3264 84 : ulong idx = day_ns / fd_gui_timeline_stored_granularity_ns[ g ];
3265 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_START_SLOT, idx, slot );
3266 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_END_SLOT, idx, slot );
3267 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_COMPUTE_UNITS, idx, compute_units );
3268 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_MAX_COMPUTE, idx, max_compute_units );
3269 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_TXN_FEES, idx, transaction_fee );
3270 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_PRIO_FEES, idx, priority_fee );
3271 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_TIPS, idx, tips );
3272 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_NONVOTE_SUCCESS, idx, !!txn_succeeded );
3273 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_NONVOTE_FAILED, idx, !txn_succeeded );
3274 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_VOTE_SUCCESS, idx, 0UL );
3275 84 : fd_gui_timeline_field_accum( day, g, FD_GUI_TIMELINE_FIELD_VOTE_FAILED, idx, 0UL );
3276 84 : }
3277 12 : }
3278 :
3279 : static int
3280 : fd_gui_timeline_mine_add( fd_gui_t * gui,
3281 : long timestamp_ns,
3282 3 : long now ) {
3283 3 : if( FD_UNLIKELY( timestamp_ns<0L || timestamp_ns==LONG_MAX ) ) return 0;
3284 3 : fd_gui_timeline_day_t * day = fd_gui_timeline_day_for_event( gui, (ulong)timestamp_ns/(ulong)FD_GUI_TIMELINE_DAY_NS, now );
3285 3 : if( FD_UNLIKELY( !day ) ) return 0;
3286 3 : fd_gui_timeline_count_add( day, FD_GUI_TIMELINE_FIELD_MINE, timestamp_ns );
3287 3 : return 1;
3288 3 : }
3289 :
3290 : fd_gui_timeline_tile_day_t *
3291 : fd_gui_timeline_tile_day_get( fd_gui_t * gui,
3292 : ulong day_idx,
3293 1590 : ulong tile_idx ) {
3294 1590 : if( FD_UNLIKELY( !gui->db || !gui->hist ) ) return NULL;
3295 1590 : fd_gui_hist_tile_day_key_t key = { .day_idx=day_idx, .tile_idx=tile_idx };
3296 1590 : return fd_gui_hist_kv_get( gui, FD_GUI_HIST_TIMELINE_TILE_DAY, &key );
3297 1590 : }
3298 :
3299 : int
3300 : fd_gui_timeline_tile_day_bounds( fd_gui_t * gui,
3301 : ulong * lo_day,
3302 42 : ulong * hi_day ) {
3303 42 : if( FD_UNLIKELY( !gui->db || !gui->hist ) ) return 0;
3304 42 : ulong lo = ULONG_MAX;
3305 42 : ulong hi = 0UL;
3306 42 : fd_gui_store_kv_scan_t it;
3307 42 : fd_gui_store_kv_scan_begin( gui->db, &it, FD_GUI_HIST_TIMELINE_TILE_DAY );
3308 147 : while( fd_gui_store_kv_scan_next( &it ) ) {
3309 105 : fd_gui_hist_tile_day_key_t const * key = it.rec; /* records start with their key */
3310 105 : lo = fd_ulong_min( lo, key->day_idx );
3311 105 : hi = fd_ulong_max( hi, key->day_idx );
3312 105 : }
3313 42 : if( lo==ULONG_MAX ) return 0;
3314 39 : *lo_day = lo;
3315 39 : *hi_day = hi;
3316 39 : return 1;
3317 42 : }
3318 :
3319 : /* fd_gui_timeline_tile_day_create creates the empty CPU record of
3320 : tile_idx for day_idx, which must not exist yet, under the same day
3321 : rules as the timeline day records. Returns NULL if the day is
3322 : unavailable. The ring's base regions hold today's and yesterday's
3323 : record for every tile, so today's records are never evicted (see
3324 : fd_gui_hist_base_regions). */
3325 :
3326 : static fd_gui_timeline_tile_day_t *
3327 : fd_gui_timeline_tile_day_create( fd_gui_t * gui,
3328 : ulong day_idx,
3329 : ulong tile_idx,
3330 15 : long now ) {
3331 15 : if( FD_UNLIKELY( !gui->db || !gui->hist ) ) return NULL;
3332 15 : ulong * cur_day = &gui->cpu_util.cur_day;
3333 15 : if( FD_UNLIKELY( *cur_day==ULONG_MAX ) ) {
3334 3 : ulong lo;
3335 3 : if( !fd_gui_timeline_tile_day_bounds( gui, &lo, cur_day ) ) *cur_day = ULONG_MAX;
3336 3 : }
3337 : /* Other tiles may still join the newest day; earlier days are closed. */
3338 15 : ulong closed_day = *cur_day==ULONG_MAX || !*cur_day ? ULONG_MAX : *cur_day-1UL;
3339 15 : if( FD_UNLIKELY( !fd_gui_timeline_day_create_ok( day_idx, closed_day, now ) ) ) return NULL;
3340 :
3341 15 : fd_gui_hist_tile_day_key_t key = { .day_idx=day_idx, .tile_idx=tile_idx };
3342 15 : fd_gui_timeline_tile_day_t * rec = fd_gui_hist_kv_get_or_create( gui, FD_GUI_HIST_TIMELINE_TILE_DAY, &key );
3343 15 : if( FD_UNLIKELY( !rec ) ) return NULL;
3344 : /* Creation can evict records, but never the newly reserved one. The
3345 : store sets the key; every other byte is written once. */
3346 15 : rec->insert_time_ns = now;
3347 15 : memset( rec->util_25ms, FD_GUI_CPU_UTIL_UNKNOWN, sizeof(rec->util_25ms) );
3348 15 : memset( rec->sum_250MS, 0, sizeof(fd_gui_timeline_tile_day_t)-offsetof( fd_gui_timeline_tile_day_t, sum_250MS ) );
3349 15 : *cur_day = fd_ulong_max( *cur_day==ULONG_MAX ? 0UL : *cur_day, day_idx );
3350 15 : return rec;
3351 15 : }
3352 :
3353 : void
3354 492 : fd_gui_cpu_util_snap( fd_gui_t * gui, long now ) {
3355 492 : if( FD_UNLIKELY( now<FD_GUI_CPU_UTIL_SAMPLE_NS ) ) return;
3356 492 : ulong slot = (ulong)now/(ulong)FD_GUI_CPU_UTIL_SAMPLE_NS - 1UL;
3357 492 : if( FD_UNLIKELY( gui->cpu_util.last_slot!=ULONG_MAX && slot<=gui->cpu_util.last_slot ) ) return;
3358 492 : gui->cpu_util.last_slot = slot;
3359 :
3360 492 : ulong start_ns = slot*(ulong)FD_GUI_CPU_UTIL_SAMPLE_NS;
3361 492 : ulong day_idx = start_ns/(ulong)FD_GUI_TIMELINE_DAY_NS;
3362 492 : ulong day_ns = start_ns%(ulong)FD_GUI_TIMELINE_DAY_NS;
3363 492 : ulong create_cnt = 0UL;
3364 22140 : for( ulong i=0UL; i<gui->tile_cnt; i++ ) {
3365 21648 : fd_topo_tile_t const * tile = &gui->topo->tiles[ i ];
3366 21648 : if( FD_UNLIKELY( !tile->metrics ) ) continue;
3367 984 : volatile ulong const * live = fd_metrics_tile( tile->metrics ) + MIDX( COUNTER, TILE, REGIME_DURATION_NANOS );
3368 984 : ulong timers[ FD_METRICS_ENUM_TILE_REGIME_CNT ];
3369 10824 : for( ulong j=0UL; j<FD_METRICS_ENUM_TILE_REGIME_CNT; j++ ) timers[ j ] = live[ j ];
3370 984 : ulong total = fd_metrics_enum_group_sum( timers, (1UL<<FD_METRICS_ENUM_TILE_REGIME_CNT)-1UL );
3371 984 : ulong idle = fd_metrics_enum_group_sum( timers, FD_METRICS_ENUM_TILE_REGIME_G_IDLE_MASK | FD_METRICS_ENUM_TILE_REGIME_G_BACKPRESSURE_MASK );
3372 984 : ulong dt = total - gui->cpu_util.total[ i ];
3373 984 : ulong di = idle - gui->cpu_util.idle [ i ];
3374 : /* A tile that has not published since the last sample keeps its
3375 : reference, so its next sample covers the whole gap. */
3376 984 : if( FD_UNLIKELY( !dt ) ) continue;
3377 741 : if( FD_UNLIKELY( !gui->cpu_util.total[ i ] ) ) {
3378 6 : gui->cpu_util.total[ i ] = total;
3379 6 : gui->cpu_util.idle [ i ] = idle;
3380 6 : continue;
3381 6 : }
3382 :
3383 : /* Creating a record writes several MiB, so a day rollover is
3384 : spread over ticks. */
3385 735 : fd_gui_timeline_tile_day_t * rec = fd_gui_timeline_tile_day_get( gui, day_idx, i );
3386 735 : if( FD_UNLIKELY( !rec ) ) {
3387 21 : if( FD_UNLIKELY( create_cnt>=FD_GUI_CPU_UTIL_CREATE_MAX ) ) continue;
3388 15 : create_cnt++;
3389 15 : rec = fd_gui_timeline_tile_day_create( gui, day_idx, i, now );
3390 15 : }
3391 729 : gui->cpu_util.total[ i ] = total;
3392 729 : gui->cpu_util.idle [ i ] = idle;
3393 729 : if( FD_UNLIKELY( !rec ) ) continue;
3394 729 : ulong busy = dt - fd_ulong_min( di, dt );
3395 729 : uchar util = (uchar)( ( busy*FD_GUI_CPU_UTIL_MAX + dt/2UL )/dt );
3396 729 : ulong idx = day_ns/(ulong)FD_GUI_CPU_UTIL_SAMPLE_NS;
3397 729 : if( FD_UNLIKELY( rec->util_25ms[ idx ]!=FD_GUI_CPU_UTIL_UNKNOWN ) ) continue; /* already sampled */
3398 729 : rec->util_25ms[ idx ] = util;
3399 729 : fd_gui_timeline_cpu_add( rec, day_ns, util );
3400 729 : }
3401 492 : }
3402 :
3403 : void
3404 : fd_gui_handle_genesis_hash( fd_gui_t * gui,
3405 0 : fd_hash_t const * msg ) {
3406 0 : FD_BASE58_ENCODE_32_BYTES( msg->uc, hash_cstr );
3407 0 : ulong cluster = fd_genesis_cluster_identify(hash_cstr);
3408 0 : char const * cluster_name = fd_genesis_cluster_name(cluster);
3409 :
3410 0 : if( FD_LIKELY( strcmp( gui->summary.cluster, cluster_name ) ) ) {
3411 0 : gui->summary.cluster = fd_genesis_cluster_name(cluster);
3412 0 : fd_gui_printf_cluster( gui );
3413 0 : fd_http_server_ws_broadcast( gui->http );
3414 0 : }
3415 0 : }
3416 :
3417 : void
3418 : fd_gui_handle_block_engine_update( fd_gui_t * gui,
3419 0 : fd_bundle_block_engine_update_t const * update ) {
3420 0 : gui->block_engine.has_block_engine = 1;
3421 :
3422 : /* copy strings and ensure null termination within bounds */
3423 0 : FD_TEST( fd_cstr_nlen( update->name, sizeof(gui->block_engine.name ) ) < sizeof(gui->block_engine.name ) );
3424 0 : FD_TEST( fd_cstr_nlen( update->url, sizeof(gui->block_engine.url ) ) < sizeof(gui->block_engine.url ) );
3425 0 : FD_TEST( fd_cstr_nlen( update->ip_cstr, sizeof(gui->block_engine.ip_cstr) ) < sizeof(gui->block_engine.ip_cstr) );
3426 0 : ulong name_len = fd_cstr_nlen( update->name, sizeof(gui->block_engine.name ) );
3427 0 : ulong url_len = fd_cstr_nlen( update->url, sizeof(gui->block_engine.url ) );
3428 0 : ulong ip_cstr_len = fd_cstr_nlen( update->ip_cstr, sizeof(gui->block_engine.ip_cstr) );
3429 0 : fd_memcpy( gui->block_engine.name, update->name, name_len+1UL );
3430 0 : fd_memcpy( gui->block_engine.url, update->url, url_len+1UL );
3431 0 : fd_memcpy( gui->block_engine.ip_cstr, update->ip_cstr, ip_cstr_len+1UL );
3432 :
3433 0 : fd_gui_printf_block_engine( gui );
3434 0 : fd_http_server_ws_broadcast( gui->http );
3435 0 : }
3436 :
3437 : void
3438 : fd_gui_handle_snapshot_update( fd_gui_t * gui,
3439 0 : fd_snapct_update_t const * msg ) {
3440 0 : FD_TEST( msg && fd_cstr_nlen( msg->read_path, 1 ) );
3441 :
3442 0 : ulong prev_slot = fd_gui_boot_snapshot_slot( gui );
3443 0 : if( msg->type==FD_SNAPCT_SNAPSHOT_TYPE_FULL ) {
3444 0 : gui->summary.boot_progress.loading_snapshot[ FD_GUI_BOOT_PROGRESS_INCREMENTAL_SNAPSHOT_IDX ].slot = ULONG_MAX;
3445 0 : gui->summary.boot_progress.loading_snapshot[ FD_GUI_BOOT_PROGRESS_INCREMENTAL_SNAPSHOT_IDX ].read_path[ 0 ] = '\0';
3446 0 : }
3447 :
3448 0 : ulong snapshot_idx = fd_ulong_if( msg->type==FD_SNAPCT_SNAPSHOT_TYPE_FULL, FD_GUI_BOOT_PROGRESS_FULL_SNAPSHOT_IDX, FD_GUI_BOOT_PROGRESS_INCREMENTAL_SNAPSHOT_IDX );
3449 :
3450 0 : char const * filename = strrchr( msg->read_path, '/' );
3451 :
3452 : /* Skip the '/' */
3453 0 : if( FD_LIKELY( filename ) ) filename++;
3454 0 : else filename = msg->read_path;
3455 :
3456 0 : if (msg->type == FD_SNAPCT_SNAPSHOT_TYPE_INCREMENTAL) {
3457 0 : ulong slot1, slot2;
3458 0 : if ( FD_LIKELY( sscanf( filename, "incremental-snapshot-%lu-%lu-", &slot1, &slot2 )==2 ) )
3459 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].slot = slot2;
3460 0 : else FD_LOG_ERR(("failed to scan filename: %s parsed from %s", filename, msg->read_path ));
3461 0 : } else if (msg->type == FD_SNAPCT_SNAPSHOT_TYPE_FULL) {
3462 0 : ulong slot1;
3463 0 : if ( FD_LIKELY( sscanf( filename, "snapshot-%lu-", &slot1 )==1 ) )
3464 0 : gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].slot = slot1;
3465 0 : else FD_LOG_ERR(("failed to scan filename: %s parsed from %s", filename, msg->read_path ));
3466 0 : }
3467 :
3468 0 : if( prev_slot!=fd_gui_boot_snapshot_slot( gui ) ) gui->summary.boot_progress.boot_target_slot_duration_nanos = ULONG_MAX;
3469 :
3470 0 : fd_cstr_printf_check( gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].read_path, sizeof(gui->summary.boot_progress.loading_snapshot[ snapshot_idx ].read_path), NULL, "%s", msg->read_path );
3471 0 : fd_gui_update_boot_epoch_duration( gui );
3472 0 : }
3473 :
3474 : void
3475 : fd_gui_handle_snapsv_update( fd_gui_t * gui,
3476 : ulong sig,
3477 : fd_snapsv_msg_t const * msg,
3478 : ulong sz,
3479 : int eom,
3480 0 : long now ) {
3481 0 : if( FD_UNLIKELY( sig!=FD_SNAPSV_MSG_SNAP || sz!=sizeof(fd_snapsv_msg_snap_t) ) ) return;
3482 0 : if( FD_UNLIKELY( gui->snapsv.pending_cnt>=FD_GUI_SNAPSV_PENDING_MAX ) ) return;
3483 0 : fd_gui_snapsv_pending_t * pending = &gui->snapsv.pending[ gui->snapsv.pending_cnt++ ];
3484 0 : pending->msg = msg->snap;
3485 0 : pending->sample_time_nanos = now;
3486 0 : pending->closed = eom;
3487 0 : }
3488 :
3489 : void
3490 : fd_gui_stage_snapshot_manifest( fd_gui_t * gui,
3491 0 : fd_snapshot_manifest_t const * manifest ) {
3492 0 : ulong attempt = 0UL;
3493 0 : for( ulong i=0UL; i<manifest->hard_fork_cnt; i++ ) {
3494 0 : if( FD_UNLIKELY( manifest->hard_forks[ i ].slot==manifest->slot ) ) {
3495 0 : attempt = manifest->hard_forks[ i ].cnt;
3496 0 : break;
3497 0 : }
3498 0 : }
3499 0 : gui->summary.boot_progress.wfs_attempt = attempt;
3500 0 : }
3501 :
3502 : static void
3503 : fd_gui_broadcast_skip_rate( fd_gui_t * gui,
3504 60 : ulong epoch ) {
3505 60 : fd_gui_epoch_t const * rec = fd_gui_epoch( gui, epoch );
3506 60 : if( FD_UNLIKELY( !rec ) ) return;
3507 :
3508 9 : ulong slot = epoch % 2UL;
3509 9 : if( FD_LIKELY( gui->summary.skip_rate[ slot ].epoch ==epoch
3510 9 : && gui->summary.skip_rate[ slot ].skipped==rec->my_skipped_slots
3511 9 : && gui->summary.skip_rate[ slot ].total ==rec->my_total_slots ) ) return;
3512 :
3513 3 : gui->summary.skip_rate[ slot ].epoch = epoch;
3514 3 : gui->summary.skip_rate[ slot ].skipped = rec->my_skipped_slots;
3515 3 : gui->summary.skip_rate[ slot ].total = rec->my_total_slots;
3516 :
3517 3 : fd_gui_printf_skip_rate( gui, epoch );
3518 3 : fd_http_server_ws_broadcast( gui->http );
3519 3 : }
3520 :
3521 : /* Returns 1 if the frontier was updated, and 0 otherwise. */
3522 :
3523 : static int
3524 57 : handle_tower_slot( fd_gui_t * gui, ulong reset_slot, ulong reset_bank_seq, long now FD_PARAM_UNUSED ) {
3525 57 : FD_TEST( reset_slot!=ULONG_MAX );
3526 :
3527 57 : ulong prev_reset_slot = gui->summary.slot_tower;
3528 57 : ulong prev_reset_bank_seq = gui->summary.slot_tower_bank_seq;
3529 :
3530 : /* Alpenglow drives this from replay completion rather than a
3531 : consensus-derived reset slot, so the record is not guaranteed. */
3532 57 : if( FD_UNLIKELY( !fd_gui_slot_get( gui, reset_slot, reset_bank_seq ) ) ) return 0;
3533 :
3534 : /* reset_slot has not changed */
3535 57 : if( FD_UNLIKELY( prev_reset_slot!=ULONG_MAX && reset_slot==prev_reset_slot && reset_bank_seq==prev_reset_bank_seq ) ) return 0;
3536 :
3537 : /* Alpenglow can complete a descendant before one of its ancestors.
3538 : Keep advertising the highest completed block on that fork. */
3539 27 : if( FD_UNLIKELY( prev_reset_slot!=ULONG_MAX && fd_gui_slot_is_ancestor( gui, reset_slot, reset_bank_seq, prev_reset_slot, prev_reset_bank_seq ) ) ) return 0;
3540 :
3541 27 : gui->summary.slot_tower = reset_slot;
3542 27 : gui->summary.slot_tower_bank_seq = reset_bank_seq;
3543 :
3544 27 : fd_gui_printf_completed_slot( gui );
3545 27 : fd_http_server_ws_broadcast( gui->http );
3546 :
3547 : /* ensure a history exists */
3548 27 : if( FD_UNLIKELY( prev_reset_slot==ULONG_MAX || gui->summary.slot_rooted==ULONG_MAX ) ) return 1;
3549 :
3550 : /* Switch forks. */
3551 27 : fd_gui_slot_t const * oc = fd_gui_slot_get( gui, prev_reset_slot, prev_reset_bank_seq );
3552 27 : fd_gui_slot_t const * nc = fd_gui_slot_get( gui, reset_slot, reset_bank_seq );
3553 30 : for( ulong slot=fd_ulong_max( gui->summary.slot_tower, prev_reset_slot ); slot>gui->summary.slot_rooted; slot-- ) {
3554 3 : while( oc && oc->slot>slot ) oc = fd_gui_slot_parent_get( gui, oc );
3555 3 : while( nc && nc->slot>slot ) nc = fd_gui_slot_parent_get( gui, nc );
3556 3 : ulong obank = oc && oc->slot==slot ? oc->bank_seq : ULONG_MAX;
3557 3 : ulong nbank = nc && nc->slot==slot ? nc->bank_seq : ULONG_MAX;
3558 :
3559 3 : int skipped_old = slot<=prev_reset_slot && fd_gui_slot_is_skipped( gui, gui->summary.slot_rooted, prev_reset_slot, prev_reset_bank_seq, slot );
3560 3 : int skipped_new = slot<=gui->summary.slot_tower && fd_gui_slot_is_skipped( gui, gui->summary.slot_rooted, gui->summary.slot_tower, reset_bank_seq, slot );
3561 3 : if( FD_LIKELY( skipped_old!=skipped_new ) ) {
3562 0 : fd_gui_epoch_t * epoch = fd_gui_get_epoch_by_slot( gui, slot );
3563 0 : if( FD_LIKELY( epoch && fd_gui_slot_is_mine( gui, slot ) ) ) {
3564 0 : if( skipped_new ) epoch->my_skipped_slots = fd_ulong_sat_add( epoch->my_skipped_slots, 1UL );
3565 0 : else epoch->my_skipped_slots = fd_ulong_sat_sub( epoch->my_skipped_slots, 1UL );
3566 0 : }
3567 0 : }
3568 :
3569 : /* Publish new/changed slots */
3570 3 : if( FD_LIKELY( skipped_old!=skipped_new || slot>prev_reset_slot || obank!=nbank ) ) {
3571 3 : fd_gui_printf_slot( gui, slot, fd_gui_slot_get_canon_safe( gui, slot ) );
3572 3 : fd_http_server_ws_broadcast( gui->http );
3573 3 : }
3574 :
3575 : /* Persist skip status */
3576 3 : fd_gui_slot_t * canon = fd_gui_slot_get_canon( gui, slot );
3577 3 : ulong canon_bank_seq = canon ? canon->bank_seq : ULONG_MAX; /* canon, if any, IS slot */
3578 3 : fd_gui_hist_kv_slot_iter_t it[ 1 ];
3579 6 : for( fd_gui_hist_kv_iter_begin( gui, it, FD_GUI_HIST_SLOT, slot ); it->rec; fd_gui_hist_kv_iter_next( it ) ) {
3580 3 : ((fd_gui_slot_t *)it->rec)->skip = fd_uchar_if( it->bank_seq==canon_bank_seq, FD_GUI_SKIP_STATUS_NOT_SKIPPED, FD_GUI_SKIP_STATUS_FINALIZED );
3581 3 : }
3582 3 : }
3583 :
3584 81 : for( ulong e=gui->epoch.current_epoch; e<=gui->epoch.current_epoch+1UL; e++ ) fd_gui_broadcast_skip_rate( gui, e );
3585 27 : return 1;
3586 27 : }
3587 :
3588 : static inline void
3589 : set_vote_state( fd_gui_t * gui,
3590 0 : int vote_state ) {
3591 0 : if( FD_UNLIKELY( gui->summary.vote_state!=vote_state ) ) {
3592 0 : gui->summary.vote_state = vote_state;
3593 0 : fd_gui_printf_vote_state( gui );
3594 0 : fd_http_server_ws_broadcast( gui->http );
3595 0 : }
3596 0 : }
3597 :
3598 : static long
3599 : fd_gui_tick_to_nanos( fd_gui_t const * gui,
3600 : long now,
3601 : long tick_now,
3602 99 : long tick ) {
3603 99 : if( tick==LONG_MAX ) return LONG_MAX;
3604 63 : return fd_long_sat_add( now, (long)((double)fd_long_sat_sub( tick, tick_now )/gui->tick_per_ns) );
3605 99 : }
3606 :
3607 : static void
3608 : fd_gui_record_replay_txn( fd_gui_t * gui,
3609 15 : fd_gui_store_replay_txn_t const * rec ) {
3610 15 : int landed = !!rec->is_committable;
3611 15 : int fees_paid = landed && rec->error_code!=5U && rec->error_code!=6U;
3612 15 : int tips_paid = landed && !rec->error_code;
3613 15 : ulong txn_fee = fees_paid ? rec->transaction_fee : 0UL;
3614 15 : ulong prio_fee = fees_paid ? rec->priority_fee : 0UL;
3615 15 : ulong tips = tips_paid ? rec->tips : 0UL;
3616 :
3617 15 : if( FD_LIKELY( landed ) ) fd_gui_timeline_handle_txn( gui, rec->slot, rec->commit_end_ns, rec->compute_units_consumed,
3618 12 : rec->block_compute_unit_limit, txn_fee, prio_fee,
3619 12 : tips, !rec->error_code, rec->insert_time_ns );
3620 15 : fd_gui_hist_ts_append( gui, FD_GUI_HIST_REPLAY_TXN, rec );
3621 15 : }
3622 :
3623 : void
3624 : fd_gui_handle_replay_txn( fd_gui_t * gui,
3625 : fd_replay_txn_executed_t const * txn,
3626 15 : long now ) {
3627 15 : if( FD_UNLIKELY( !gui->db || !gui->hist || txn->tick_sigverify_done==LONG_MAX || txn->tick_commit_end==LONG_MAX ) ) return;
3628 12 : long tick_now = fd_tickcount();
3629 12 : ulong requested = fd_pack_compute_cost( TXN( txn->txn ), txn->txn->payload, NULL, NULL, NULL, NULL, NULL );
3630 12 : fd_gui_store_replay_txn_t rec = {
3631 12 : .insert_time_ns = now,
3632 12 : .completion_time_ns = fd_gui_tick_to_nanos( gui, now, tick_now, fd_long_max( txn->tick_sigverify_done, txn->tick_commit_end ) ),
3633 12 : .block_compute_unit_limit = txn->max_compute_units,
3634 12 : .slot = txn->slot,
3635 12 : .txn_idx = txn->index_in_slot,
3636 12 : .txn_exec_idx = txn->exec_tile_idx,
3637 12 : .txn_sigverify_exec_idx = txn->sigverify_exec_tile_idx,
3638 12 : .txn_start_shred_idx = txn->txn->start_shred_idx,
3639 12 : .txn_end_shred_idx = txn->txn->end_shred_idx,
3640 12 : .sigverify_start_ns = fd_gui_tick_to_nanos( gui, now, tick_now, txn->tick_sigverify_disp ),
3641 12 : .sigverify_end_ns = fd_gui_tick_to_nanos( gui, now, tick_now, txn->tick_sigverify_done ),
3642 12 : .load_start_ns = fd_gui_tick_to_nanos( gui, now, tick_now, txn->tick_load_start ),
3643 12 : .check_start_ns = fd_gui_tick_to_nanos( gui, now, tick_now, txn->tick_check_start ),
3644 12 : .exec_start_ns = fd_gui_tick_to_nanos( gui, now, tick_now, txn->tick_exec_start ),
3645 12 : .commit_start_ns = fd_gui_tick_to_nanos( gui, now, tick_now, txn->tick_commit_start ),
3646 12 : .commit_end_ns = fd_gui_tick_to_nanos( gui, now, tick_now, txn->tick_commit_end ),
3647 12 : .transaction_fee = txn->transaction_fee,
3648 12 : .priority_fee = txn->priority_fee,
3649 12 : .tips = txn->tips,
3650 12 : .compute_units_requested = (uint)requested,
3651 12 : .compute_units_consumed = txn->compute_units_consumed,
3652 12 : .error_code = (uint)(-(long)txn->txn_err),
3653 12 : .is_committable = (uchar)!!txn->is_committable,
3654 12 : .is_fees_only = (uchar)!!txn->is_fees_only,
3655 12 : };
3656 12 : fd_memcpy( rec.signature, txn->txn->payload+TXN( txn->txn )->signature_off, FD_TXN_SIGNATURE_SZ );
3657 12 : fd_gui_record_replay_txn( gui, &rec );
3658 12 : }
3659 :
3660 : void
3661 : fd_gui_handle_replay_update( fd_gui_t * gui,
3662 : fd_replay_slot_completed_t const * slot_completed,
3663 57 : long now ) {
3664 57 : fd_gui_shred_event_slot_complete( gui, slot_completed->slot, slot_completed->completion_time_nanos, now );
3665 :
3666 57 : if( FD_LIKELY( gui->summary.slot_storage!=slot_completed->storage_slot ) ) {
3667 0 : gui->summary.slot_storage = slot_completed->storage_slot;
3668 0 : fd_gui_printf_storage_slot( gui );
3669 0 : fd_http_server_ws_broadcast( gui->http );
3670 0 : }
3671 :
3672 57 : if( FD_UNLIKELY( slot_completed->identity_balance!=ULONG_MAX && gui->summary.identity_account_balance!=slot_completed->identity_balance ) ) {
3673 0 : gui->summary.identity_account_balance = slot_completed->identity_balance;
3674 :
3675 0 : fd_gui_printf_identity_balance( gui );
3676 0 : fd_http_server_ws_broadcast( gui->http );
3677 0 : }
3678 :
3679 57 : if( FD_UNLIKELY( gui->summary.boot_progress.catching_up_first_replay_slot==ULONG_MAX ) ) {
3680 0 : gui->summary.boot_progress.catching_up_first_replay_slot = slot_completed->slot;
3681 0 : }
3682 :
3683 57 : fd_gui_slot_t * slot = fd_gui_slot_get_or_create( gui,
3684 57 : slot_completed->slot,
3685 57 : slot_completed->parent_slot,
3686 57 : slot_completed->bank_seq,
3687 57 : slot_completed->parent_bank_seq );
3688 57 : if( FD_UNLIKELY( !slot ) ) return; /* record could not be created / was evicted */
3689 :
3690 57 : slot->completed_time = slot_completed->completion_time_nanos;
3691 57 : slot->parent_slot = slot_completed->parent_slot;
3692 57 : slot->max_compute_units = fd_uint_if( slot_completed->cost_tracker.block_cost_limit==ULONG_MAX, slot->max_compute_units, (uint)slot_completed->cost_tracker.block_cost_limit );
3693 :
3694 57 : fd_gui_slot_t const * parent = fd_gui_slot_parent_get( gui, slot );
3695 57 : slot->parent_completed_time = parent ? parent->completed_time : LONG_MAX;
3696 :
3697 57 : fd_gui_timeline_slot_duration( gui, slot, now );
3698 57 : slot = fd_gui_slot_get( gui, slot_completed->slot, slot_completed->bank_seq );
3699 57 : if( FD_UNLIKELY( !slot ) ) return;
3700 :
3701 57 : ulong vote_slot;
3702 57 : if( FD_UNLIKELY( slot_completed->voted && slot_completed->slot>=FD_NUM_SLOTS_FOR_REWARD ) ) {
3703 0 : vote_slot = slot_completed->slot-FD_NUM_SLOTS_FOR_REWARD;
3704 57 : } else {
3705 57 : vote_slot = gui->summary.slot_voted; /* TODO: inherit from parent so it's fork-correct. Requires tracking identity changes to be correct. */
3706 57 : }
3707 :
3708 : /* A slot may already be notarized by the time we replay it. */
3709 57 : if( FD_LIKELY( slot->level<FD_GUI_SLOT_LEVEL_COMPLETED ) ) slot->level = FD_GUI_SLOT_LEVEL_COMPLETED;
3710 57 : slot->vote_failed = fd_uint_if( slot_completed->vote_failed==ULONG_MAX, slot->vote_failed, (uint)slot_completed->vote_failed );
3711 57 : slot->vote_success = fd_uint_if( slot_completed->vote_success==ULONG_MAX, slot->vote_success, (uint)slot_completed->vote_success );
3712 57 : slot->nonvote_success = fd_uint_if( slot_completed->nonvote_success==ULONG_MAX, slot->nonvote_success, (uint)slot_completed->nonvote_success );
3713 57 : slot->nonvote_failed = fd_uint_if( slot_completed->nonvote_failed==ULONG_MAX, slot->nonvote_failed, (uint)slot_completed->nonvote_failed );
3714 :
3715 57 : slot->transaction_fee = slot_completed->transaction_fee;
3716 57 : slot->priority_fee = slot_completed->priority_fee;
3717 57 : slot->tips = slot_completed->tips;
3718 57 : slot->compute_units = fd_uint_if( slot_completed->cost_tracker.block_cost==ULONG_MAX, slot->compute_units, (uint)slot_completed->cost_tracker.block_cost );
3719 57 : slot->shred_cnt = fd_uint_if( slot_completed->shred_cnt==ULONG_MAX, slot->shred_cnt, (uint)slot_completed->shred_cnt );
3720 57 : slot->vote_slot = vote_slot;
3721 57 : slot->block_hash = slot_completed->block_hash;
3722 :
3723 57 : fd_gui_epoch_t * epoch = fd_gui_get_epoch_by_slot( gui, slot_completed->slot );
3724 57 : if( FD_UNLIKELY( epoch && slot_completed->slot==epoch->start_slot+epoch->slot_cnt-1UL ) ) epoch->end_time = slot->completed_time;
3725 :
3726 57 : if( FD_UNLIKELY( slot->mine ) ) {
3727 6 : fd_gui_leader_slot_t * lmeta = fd_gui_slot_leader_get_or_create( gui, slot_completed->slot, slot_completed->bank_seq );
3728 6 : if( FD_LIKELY( lmeta ) ) lmeta->block_hash = slot_completed->block_hash;
3729 :
3730 6 : fd_gui_epoch_t const * epoch = fd_gui_get_epoch_by_slot( gui, slot_completed->slot );
3731 6 : if( FD_LIKELY( epoch ) ) fd_gui_broadcast_skip_rate( gui, epoch->epoch );
3732 6 : }
3733 :
3734 57 : slot = fd_gui_slot_get( gui, slot_completed->slot, slot_completed->bank_seq );
3735 57 : if( FD_UNLIKELY( !slot ) ) return;
3736 57 : if( slot->mine && !slot->timeline_mine_accounted ) {
3737 3 : int accounted = fd_gui_timeline_mine_add( gui, slot->completed_time, now );
3738 3 : slot = fd_gui_slot_get( gui, slot_completed->slot, slot_completed->bank_seq );
3739 3 : if( FD_UNLIKELY( !slot ) ) return;
3740 3 : slot->timeline_mine_accounted = (uchar)!!accounted;
3741 3 : }
3742 :
3743 : /* Set skip status based on the current canonical fork. */
3744 57 : fd_gui_slot_t * canon = fd_gui_slot_get_canon( gui, slot_completed->slot );
3745 57 : slot->skip = fd_uchar_if( canon && canon->bank_seq==slot_completed->bank_seq, FD_GUI_SKIP_STATUS_NOT_SKIPPED, FD_GUI_SKIP_STATUS_UNKNOWN );
3746 :
3747 : /* vote_count is keyed by the cert slot. The epoch copy is written
3748 : only on rooting, so it never holds a non-canonical bank's count. */
3749 57 : slot->vote_count = slot_completed->vote_count;
3750 :
3751 : /* fixes race if we just sample right after replay's SLOT_COMPLETE */
3752 57 : if( FD_LIKELY( gui->summary.slot_caught_up!=ULONG_MAX ) ) fd_gui_sample_repair_slot( gui, now );
3753 :
3754 : /* Update slot_turbine when we are leader. */
3755 57 : if( FD_UNLIKELY( gui->summary.slots_max_turbine[ 0 ].slot!=ULONG_MAX && slot_completed->slot > gui->summary.slots_max_turbine[ 0 ].slot ) ) {
3756 0 : fd_gui_try_insert_ephemeral_slot( gui->summary.slots_max_turbine, FD_GUI_TURBINE_SLOT_HISTORY_SZ, slot_completed->slot, now );
3757 0 : }
3758 :
3759 57 : int slot_turbine_hist_full = gui->summary.slots_max_turbine[ FD_GUI_TURBINE_SLOT_HISTORY_SZ-1UL ].slot!=ULONG_MAX;
3760 57 : if( FD_UNLIKELY( gui->summary.slot_caught_up==ULONG_MAX && slot_turbine_hist_full && gui->summary.slots_max_turbine[ 0 ].slot < (slot_completed->slot + 3UL) ) ) {
3761 0 : gui->summary.slot_caught_up = slot_completed->slot + 4UL;
3762 :
3763 0 : fd_gui_printf_slot_caught_up( gui );
3764 0 : fd_http_server_ws_broadcast( gui->http );
3765 0 : }
3766 :
3767 57 : if( FD_UNLIKELY( slot_completed->voted && slot_completed->slot>=FD_NUM_SLOTS_FOR_REWARD && ( gui->summary.slot_voted==ULONG_MAX || vote_slot>gui->summary.slot_voted ) ) ) {
3768 0 : gui->summary.slot_voted = vote_slot;
3769 0 : fd_gui_printf_vote_slot( gui );
3770 0 : fd_http_server_ws_broadcast( gui->http );
3771 0 : }
3772 :
3773 : /* Bind this bank only to certificates for the same block. */
3774 57 : fd_gui_ag_register_block( gui, slot_completed->slot, &slot_completed->block_id, slot_completed->bank_seq );
3775 :
3776 57 : if( FD_UNLIKELY( slot_completed->vote_balance!=ULONG_MAX && gui->summary.vote_account_balance!=slot_completed->vote_balance ) ) {
3777 0 : gui->summary.vote_account_balance = slot_completed->vote_balance;
3778 0 : fd_gui_printf_vote_balance( gui );
3779 0 : fd_http_server_ws_broadcast( gui->http );
3780 0 : }
3781 57 : if( FD_UNLIKELY( slot_completed->vote_commission!=USHORT_MAX && gui->summary.vote_commission!=slot_completed->vote_commission ) ) {
3782 0 : gui->summary.vote_commission = slot_completed->vote_commission;
3783 0 : fd_gui_printf_vote_commission( gui );
3784 0 : fd_http_server_ws_broadcast( gui->http );
3785 0 : }
3786 :
3787 57 : if( FD_LIKELY( slot_completed->slot>=FD_NUM_SLOTS_FOR_REWARD ) ) {
3788 57 : fd_gui_handle_ag_reward( gui, slot_completed->slot-FD_NUM_SLOTS_FOR_REWARD, slot_completed->voted, slot_completed->voted_rank );
3789 57 : }
3790 :
3791 57 : int frontier_updated = handle_tower_slot( gui, slot_completed->slot, slot_completed->bank_seq, now );
3792 :
3793 57 : if( FD_LIKELY( gui->summary.is_voting && slot_completed->slot>=FD_NUM_SLOTS_FOR_REWARD ) ) {
3794 0 : if( FD_UNLIKELY( slot_completed->voted_rank==USHORT_MAX ) ) {
3795 0 : set_vote_state( gui, FD_GUI_VOTE_STATE_NON_VOTING );
3796 0 : } else {
3797 0 : ulong s = gui->summary.slot_tower;
3798 0 : ulong voted = gui->summary.slot_voted;
3799 0 : int current = voted!=ULONG_MAX && fd_int_if( s>=128UL, voted+128UL>s, voted>0UL );
3800 0 : set_vote_state( gui, fd_int_if( current, FD_GUI_VOTE_STATE_VOTING, FD_GUI_VOTE_STATE_DELINQUENT ) );
3801 0 : }
3802 0 : }
3803 :
3804 57 : if( FD_UNLIKELY( frontier_updated && gui->summary.slot_estimated!=slot_completed->slot ) ) {
3805 24 : gui->summary.slot_estimated = slot_completed->slot;
3806 24 : fd_gui_printf_estimated_slot( gui );
3807 24 : fd_http_server_ws_broadcast( gui->http );
3808 24 : }
3809 57 : }
3810 :
3811 : void
3812 : fd_gui_became_leader( fd_gui_t * gui,
3813 : ulong _slot,
3814 : long start_time_nanos,
3815 : long end_time_nanos,
3816 : ulong max_compute_units,
3817 : ulong max_microblocks,
3818 15 : ulong bank_seq ) {
3819 15 : gui->leader_begin_slot = fd_ulong_max( gui->leader_begin_slot, _slot );
3820 :
3821 15 : fd_gui_leader_slot_t * lslot = fd_gui_slot_leader_get_or_create( gui, _slot, bank_seq );
3822 15 : if( FD_UNLIKELY( !lslot ) ) return;
3823 :
3824 15 : lslot->leader_start_time = fd_long_if( lslot->leader_start_time==LONG_MAX, start_time_nanos, lslot->leader_start_time );
3825 15 : lslot->leader_end_time = end_time_nanos;
3826 15 : lslot->max_microblocks = max_microblocks;
3827 15 : lslot->max_compute_units = max_compute_units;
3828 15 : if( FD_LIKELY( lslot->microblocks_upper_bound==UINT_MAX ) ) lslot->microblocks_upper_bound = (uint)max_microblocks;
3829 15 : }
3830 :
3831 : void
3832 : fd_gui_unbecame_leader( fd_gui_t * gui,
3833 : ulong _slot,
3834 21 : fd_done_packing_t const * done_packing ) {
3835 21 : gui->leader_end_slot = fd_ulong_max( gui->leader_end_slot, _slot ); /* may arrive before its became_leader */
3836 :
3837 21 : fd_gui_leader_slot_t * lslot = fd_gui_slot_leader_get_any( gui, _slot );
3838 21 : if( FD_UNLIKELY( !lslot ) ) return;
3839 18 : lslot->microblocks_upper_bound = (uint)done_packing->microblocks_in_slot;
3840 18 : fd_memcpy( lslot->scheduler_stats, done_packing, sizeof(fd_done_packing_t) );
3841 18 : lslot->unbecame_leader = 1;
3842 :
3843 18 : if( FD_LIKELY( !lslot->has_waterfall ) ) {
3844 15 : gui->leader_slot_pending = lslot->slot;
3845 15 : gui->leader_bank_seq_pending = lslot->bank_seq;
3846 15 : }
3847 18 : }
3848 :
3849 : void
3850 : fd_gui_done_draining( fd_gui_t * gui,
3851 9 : long now ) {
3852 9 : if( FD_UNLIKELY( gui->leader_slot_pending==ULONG_MAX ) ) return;
3853 :
3854 6 : fd_gui_leader_slot_t * lslot = fd_gui_slot_leader_get( gui, gui->leader_slot_pending, gui->leader_bank_seq_pending );
3855 6 : gui->leader_slot_pending = ULONG_MAX;
3856 6 : gui->leader_bank_seq_pending = ULONG_MAX;
3857 6 : if( FD_UNLIKELY( !lslot || lslot->has_waterfall ) ) return;
3858 :
3859 6 : fd_gui_txn_waterfall_t waterfall[ 1 ];
3860 6 : fd_gui_txn_waterfall_snap( gui, waterfall );
3861 6 : waterfall->sample_time_nanos = now;
3862 :
3863 6 : fd_memcpy( lslot->waterfall_reference, gui->summary.txn_waterfall_reference, sizeof(fd_gui_txn_waterfall_t) );
3864 6 : fd_memcpy( lslot->waterfall, waterfall, sizeof(fd_gui_txn_waterfall_t) );
3865 6 : lslot->has_waterfall = 1;
3866 :
3867 6 : fd_memcpy( gui->summary.txn_waterfall_reference, waterfall, sizeof(fd_gui_txn_waterfall_t) );
3868 6 : }
3869 :
3870 : void
3871 : fd_gui_microblock_execution_begin( fd_gui_t * gui,
3872 : long tspub_ns,
3873 : ulong _slot,
3874 : fd_txn_e_t * txns,
3875 : ulong txn_cnt,
3876 : uint microblock_idx,
3877 : ulong pack_txn_idx,
3878 : ulong bank_seq,
3879 15 : long now ) {
3880 15 : fd_gui_leader_slot_t * lslot = fd_gui_slot_leader_get_or_create( gui, _slot, bank_seq );
3881 15 : if( FD_UNLIKELY( !lslot ) ) return;
3882 :
3883 15 : lslot->leader_start_time = fd_long_if( lslot->leader_start_time==LONG_MAX, tspub_ns, lslot->leader_start_time );
3884 :
3885 30 : for( ulong i=0UL; i<txn_cnt; i++ ) {
3886 15 : fd_txn_p_t * txn_payload = txns[ i ].txnp;
3887 15 : fd_txn_t * txn = TXN( txn_payload );
3888 :
3889 15 : ulong sig_rewards = FD_PACK_FEE_PER_SIGNATURE * txn->signature_cnt;
3890 15 : ulong priority_rewards = ULONG_MAX;
3891 15 : ulong requested_execution_cus = ULONG_MAX;
3892 15 : ulong precompile_sigs = ULONG_MAX;
3893 15 : ulong requested_loaded_accounts_data_cost = ULONG_MAX;
3894 15 : ulong allocated_data = ULONG_MAX;
3895 15 : ulong cost_estimate = fd_pack_compute_cost( txn, txn_payload->payload, &requested_execution_cus, &priority_rewards, &precompile_sigs, &requested_loaded_accounts_data_cost, &allocated_data );
3896 15 : sig_rewards += FD_PACK_FEE_PER_SIGNATURE * precompile_sigs;
3897 15 : sig_rewards = sig_rewards * FD_PACK_TXN_FEE_BURN_PCT / 100UL;
3898 :
3899 15 : ulong txn_idx = pack_txn_idx + i;
3900 15 : uchar flags = (uchar)FD_GUI_TXN_FLAGS_STARTED;
3901 15 : flags |= (uchar)fd_uint_if( (txn_payload->flags & FD_TXN_P_FLAGS_BUNDLE) || (txn_payload->flags & FD_TXN_P_FLAGS_INITIALIZER_BUNDLE), FD_GUI_TXN_FLAGS_FROM_BUNDLE, 0U );
3902 :
3903 15 : fd_gui_store_txn_start_t rec = {
3904 15 : .slot = _slot,
3905 15 : .bank_seq = bank_seq,
3906 15 : .insert_time_ns = now,
3907 15 : .txn_idx = txn_idx,
3908 15 : .transaction_fee = sig_rewards,
3909 15 : .priority_fee = priority_rewards,
3910 15 : .timestamp_arrival_nanos = txn_payload->scheduler_arrival_time_nanos,
3911 15 : .microblock_start_ns = tspub_ns,
3912 15 : .compute_units_requested = (uint)(cost_estimate & 0x1FFFFFU),
3913 15 : .microblock_idx = microblock_idx,
3914 15 : .source_ipv4 = txn_payload->source_ipv4,
3915 15 : .source_tpu = txn_payload->source_tpu,
3916 15 : .flags = flags
3917 15 : };
3918 15 : fd_memcpy( rec.signature, txn_payload->payload + txn->signature_off, FD_SHA512_HASH_SZ );
3919 15 : if( FD_LIKELY( !fd_gui_hist_ts_append( gui, FD_GUI_HIST_TXN_START, &rec ) ) ) {
3920 9 : lslot = fd_gui_slot_leader_get( gui, _slot, bank_seq );
3921 9 : if( FD_LIKELY( lslot ) ) {
3922 9 : lslot->txn_insert_time_min_ns = fd_long_min( lslot->txn_insert_time_min_ns, now );
3923 9 : lslot->txn_insert_time_max_ns = fd_long_max( lslot->txn_insert_time_max_ns, now );
3924 9 : }
3925 9 : }
3926 15 : }
3927 :
3928 : /* At the moment, bank publishes at most 1 transaction per microblock,
3929 : even if it received microblocks with multiple transactions
3930 : (i.e. a bundle). This means that we need to calculate microblock
3931 : count here based on the transaction count. */
3932 15 : lslot = fd_gui_slot_leader_get( gui, _slot, bank_seq );
3933 15 : if( FD_LIKELY( lslot ) ) lslot->begin_microblocks += (uint)txn_cnt;
3934 15 : }
3935 :
3936 : static inline long
3937 15 : fd_gui_ns_dt_float_to_long( float dt ) {
3938 15 : return (long)((double)dt+0.5);
3939 15 : }
3940 :
3941 : /* fd_gui_record_leader_txn converts a transaction executed by the
3942 : leader pipeline into a replay record, so leader and replayed
3943 : transactions are served from the same store. */
3944 :
3945 : static void
3946 : fd_gui_record_leader_txn( fd_gui_t * gui,
3947 : fd_txn_p_t * txn_p,
3948 : ulong txn_idx,
3949 : ulong bank_idx,
3950 : ulong slot,
3951 : ulong block_compute_unit_limit,
3952 : fd_txn_ns_dt_t txn_ns_dt,
3953 : long exec_end_ticks,
3954 : ulong tips,
3955 : uint error_code,
3956 3 : long now ) {
3957 3 : ulong priority_fee = 0UL;
3958 3 : ulong precompile_sig_cnt = 0UL;
3959 3 : ulong requested = fd_pack_compute_cost( TXN( txn_p ), txn_p->payload, NULL,
3960 3 : &priority_fee, &precompile_sig_cnt, NULL, NULL );
3961 3 : long commit_end_ns = fd_gui_tick_to_nanos( gui, now, fd_tickcount(), exec_end_ticks );
3962 3 : long start_ns = fd_long_sat_sub( commit_end_ns, fd_gui_ns_dt_float_to_long( txn_ns_dt.commit_end ) );
3963 3 : fd_gui_store_replay_txn_t replay = {
3964 3 : .insert_time_ns = now,
3965 3 : .completion_time_ns = commit_end_ns,
3966 3 : .block_compute_unit_limit = block_compute_unit_limit,
3967 3 : .slot = slot,
3968 3 : .txn_idx = txn_idx, /* pack index, not position in the produced block */
3969 3 : .txn_exec_idx = bank_idx,
3970 3 : .txn_sigverify_exec_idx = ULONG_MAX,
3971 3 : .txn_start_shred_idx = UINT_MAX, /* execle's union holds pack_alloc, not shred indices */
3972 3 : .txn_end_shred_idx = UINT_MAX,
3973 3 : .sigverify_start_ns = LONG_MAX,
3974 3 : .sigverify_end_ns = LONG_MAX,
3975 3 : .load_start_ns = fd_long_sat_add( start_ns, fd_gui_ns_dt_float_to_long( txn_ns_dt.load_start ) ),
3976 3 : .check_start_ns = fd_long_sat_add( start_ns, fd_gui_ns_dt_float_to_long( txn_ns_dt.check_start ) ),
3977 3 : .exec_start_ns = fd_long_sat_add( start_ns, fd_gui_ns_dt_float_to_long( txn_ns_dt.exec_start ) ),
3978 3 : .commit_start_ns = fd_long_sat_add( start_ns, fd_gui_ns_dt_float_to_long( txn_ns_dt.commit_start ) ),
3979 3 : .commit_end_ns = commit_end_ns,
3980 3 : .transaction_fee = FD_PACK_FEE_PER_SIGNATURE*(TXN( txn_p )->signature_cnt+precompile_sig_cnt), /* before burn, like replay */
3981 3 : .priority_fee = priority_fee,
3982 3 : .tips = tips,
3983 3 : .compute_units_requested = (uint)requested,
3984 3 : .compute_units_consumed = txn_p->execle_cu.actual_consumed_cus,
3985 3 : .error_code = error_code,
3986 3 : .is_committable = 1U,
3987 3 : .is_fees_only = (uchar)!!(txn_p->flags & FD_TXN_P_FLAGS_FEES_ONLY),
3988 3 : };
3989 3 : fd_memcpy( replay.signature, txn_p->payload+TXN( txn_p )->signature_off, FD_TXN_SIGNATURE_SZ );
3990 3 : fd_gui_record_replay_txn( gui, &replay );
3991 3 : }
3992 :
3993 : void
3994 : fd_gui_microblock_execution_end( fd_gui_t * gui,
3995 : long tspub_ns,
3996 : ulong bank_idx,
3997 : ulong _slot,
3998 : ulong txn_cnt,
3999 : fd_txn_p_t * txns,
4000 : ulong pack_txn_idx,
4001 : fd_txn_ns_dt_t txn_ns_dt,
4002 : long exec_end_ticks,
4003 : ulong tips,
4004 : ulong bank_seq,
4005 21 : long now ) {
4006 21 : if( FD_UNLIKELY( 1UL!=txn_cnt ) ) FD_LOG_ERR(( "gui expects 1 txn per microblock from bank, found %lu", txn_cnt ));
4007 :
4008 21 : fd_gui_leader_slot_t * lslot = fd_gui_slot_leader_get_or_create( gui, _slot, bank_seq );
4009 21 : if( FD_UNLIKELY( !lslot ) ) return;
4010 :
4011 21 : lslot->leader_start_time = fd_long_if( lslot->leader_start_time==LONG_MAX, tspub_ns, lslot->leader_start_time );
4012 :
4013 21 : ulong block_compute_unit_limit = lslot->max_compute_units;
4014 42 : for( ulong i=0UL; i<txn_cnt; i++ ) {
4015 21 : fd_txn_p_t * txn_p = &txns[ i ];
4016 21 : ulong txn_idx = pack_txn_idx + i;
4017 :
4018 21 : uint error_code = (txn_p->flags>>24) & 0xFFU;
4019 21 : uchar flags = (uchar)FD_GUI_TXN_FLAGS_ENDED;
4020 21 : flags |= (uchar)fd_uint_if( !!(txn_p->flags & FD_TXN_P_FLAGS_EXECUTE_SUCCESS), FD_GUI_TXN_FLAGS_LANDED_IN_BLOCK, 0U );
4021 :
4022 21 : fd_gui_store_txn_end_t rec = {
4023 21 : .slot = _slot,
4024 21 : .bank_seq = bank_seq,
4025 21 : .insert_time_ns = now,
4026 21 : .txn_idx = txn_idx,
4027 21 : .timestamp_arrival_nanos = txn_p->scheduler_arrival_time_nanos,
4028 21 : .microblock_end_ns = tspub_ns,
4029 21 : .txn_ns_dt = txn_ns_dt,
4030 21 : .tips = tips,
4031 21 : .compute_units_consumed = (uint)(txn_p->execle_cu.actual_consumed_cus & 0x1FFFFFU),
4032 21 : .bank_idx = (uint)(bank_idx & 0x3FU),
4033 21 : .error_code = error_code,
4034 21 : .flags = flags
4035 21 : };
4036 21 : if( FD_LIKELY( !fd_gui_hist_ts_append( gui, FD_GUI_HIST_TXN_END, &rec ) ) ) {
4037 15 : lslot = fd_gui_slot_leader_get( gui, _slot, bank_seq );
4038 15 : if( FD_LIKELY( lslot ) ) {
4039 15 : lslot->txn_insert_time_min_ns = fd_long_min( lslot->txn_insert_time_min_ns, now );
4040 15 : lslot->txn_insert_time_max_ns = fd_long_max( lslot->txn_insert_time_max_ns, now );
4041 15 : }
4042 15 : }
4043 :
4044 21 : if( FD_LIKELY( gui->db && gui->hist && (txn_p->flags & FD_TXN_P_FLAGS_EXECUTE_SUCCESS) && exec_end_ticks!=LONG_MAX ) ) {
4045 3 : fd_gui_record_leader_txn( gui, txn_p, txn_idx, bank_idx, _slot, block_compute_unit_limit, txn_ns_dt, exec_end_ticks, tips, error_code, now );
4046 3 : }
4047 21 : }
4048 :
4049 21 : lslot = fd_gui_slot_leader_get( gui, _slot, bank_seq );
4050 21 : if( FD_LIKELY( lslot ) ) lslot->end_microblocks += (uint)txn_cnt;
4051 21 : }
|
