LCOV - code coverage report
Current view: top level - app/shared_dev/commands - dev.c (source / functions) Hit Total Coverage
Test: cov.lcov Lines: 0 160 0.0 %
Date: 2025-07-01 05:00:49 Functions: 0 7 0.0 %

          Line data    Source code
       1             : #define _GNU_SOURCE
       2             : 
       3             : #include "../../platform/fd_sys_util.h"
       4             : #include "../../shared/genesis_hash.h"
       5             : #include "../../shared/commands/configure/configure.h"
       6             : #include "../../shared/commands/run/run.h"
       7             : #include "../../shared/commands/monitor/monitor.h"
       8             : 
       9             : #include <stdio.h>
      10             : #include <unistd.h>
      11             : #include <sched.h>
      12             : #include <fcntl.h>
      13             : #include <pthread.h>
      14             : #include <sys/wait.h>
      15             : 
      16             : fd_topo_run_tile_t
      17             : fdctl_tile_run( fd_topo_tile_t const * tile );
      18             : 
      19             : void
      20             : dev_cmd_args( int *    pargc,
      21             :               char *** pargv,
      22           0 :               args_t * args ) {
      23           0 :   args->dev.parent_pipefd = -1;
      24           0 :   args->dev.monitor = fd_env_strip_cmdline_contains( pargc, pargv, "--monitor" );
      25           0 :   args->dev.no_configure = fd_env_strip_cmdline_contains( pargc, pargv, "--no-configure" );
      26           0 :   args->dev.no_init_workspaces = fd_env_strip_cmdline_contains( pargc, pargv, "--no-init-workspaces" );
      27           0 :   args->dev.no_agave = fd_env_strip_cmdline_contains( pargc, pargv, "--no-agave"  ) ||
      28           0 :                        fd_env_strip_cmdline_contains( pargc, pargv, "--no-solana" );
      29           0 :   const char * debug_tile = fd_env_strip_cmdline_cstr( pargc, pargv, "--debug-tile", NULL, NULL );
      30           0 :   if( FD_UNLIKELY( debug_tile ) )
      31           0 :     strncpy( args->dev.debug_tile, debug_tile, sizeof( args->dev.debug_tile ) - 1 );
      32           0 : }
      33             : 
      34             : void
      35             : dev_cmd_perm( args_t *         args,
      36             :               fd_cap_chk_t *   chk,
      37           0 :               config_t const * config ) {
      38           0 :   if( FD_LIKELY( !args->dev.no_configure ) ) {
      39           0 :     args_t configure_args = {
      40           0 :       .configure.command = CONFIGURE_CMD_INIT,
      41           0 :     };
      42           0 :     for( ulong i=0UL; STAGES[ i ]; i++ )
      43           0 :       configure_args.configure.stages[ i ] = STAGES[ i ];
      44           0 :     configure_cmd_perm( &configure_args, chk, config );
      45           0 :   }
      46             : 
      47           0 :   run_cmd_perm( NULL, chk, config );
      48           0 : }
      49             : 
      50             : pid_t firedancer_pid, monitor_pid;
      51             : extern char fd_log_private_path[ 1024 ]; /* empty string on start */
      52             : 
      53           0 : #define FD_LOG_ERR_NOEXIT(a) do { long _fd_log_msg_now = fd_log_wallclock(); fd_log_private_1( 4, _fd_log_msg_now, __FILE__, __LINE__, __func__, fd_log_private_0 a ); } while(0)
      54             : 
      55             : extern int * fd_log_private_shared_lock;
      56             : 
      57             : static void
      58           0 : parent_signal( int sig ) {
      59           0 :   if( FD_LIKELY( firedancer_pid ) ) kill( firedancer_pid, SIGINT );
      60           0 :   if( FD_LIKELY( monitor_pid ) )    kill( monitor_pid, SIGKILL );
      61             : 
      62             :   /* Same hack as in run.c, see comments there. */
      63           0 :   int lock = 0;
      64           0 :   fd_log_private_shared_lock = &lock;
      65             : 
      66           0 :   if( -1!=fd_log_private_logfile_fd() ) FD_LOG_ERR_NOEXIT(( "Received signal %s\nLog at \"%s\"", fd_io_strsignal( sig ), fd_log_private_path ));
      67           0 :   else                                  FD_LOG_ERR_NOEXIT(( "Received signal %s",                fd_io_strsignal( sig ) ));
      68             : 
      69           0 :   if( FD_LIKELY( sig==SIGINT ) ) fd_sys_util_exit_group( 128+SIGINT );
      70           0 :   else                           fd_sys_util_exit_group( 0          );
      71           0 : }
      72             : 
      73             : static void
      74           0 : install_parent_signals( void ) {
      75           0 :   struct sigaction sa = {
      76           0 :     .sa_handler = parent_signal,
      77           0 :     .sa_flags   = 0,
      78           0 :   };
      79           0 :   if( FD_UNLIKELY( sigaction( SIGTERM, &sa, NULL ) ) )
      80           0 :     FD_LOG_ERR(( "sigaction(SIGTERM) failed (%i-%s)", errno, fd_io_strerror( errno ) ));
      81           0 :   if( FD_UNLIKELY( sigaction( SIGINT, &sa, NULL ) ) )
      82           0 :     FD_LOG_ERR(( "sigaction(SIGINT) failed (%i-%s)", errno, fd_io_strerror( errno ) ));
      83           0 : }
      84             : 
      85             : void
      86           0 : update_config_for_dev( fd_config_t * config ) {
      87             :   /* Automatically compute the shred version from genesis if it
      88             :      exists and we don't know it.  If it doesn't exist, we'll keep it
      89             :      set to zero and get from gossip. */
      90           0 :   char genesis_path[ PATH_MAX ];
      91           0 :   FD_TEST( fd_cstr_printf_check( genesis_path, PATH_MAX, NULL, "%s/genesis.bin", config->paths.ledger ) );
      92           0 :   ushort shred_version = compute_shred_version( genesis_path, NULL );
      93           0 :   for( ulong i=0UL; i<config->layout.shred_tile_count; i++ ) {
      94           0 :     ulong shred_id = fd_topo_find_tile( &config->topo, "shred", i );
      95           0 :     if( FD_UNLIKELY( shred_id==ULONG_MAX ) ) FD_LOG_ERR(( "could not find shred tile %lu", i ));
      96           0 :     fd_topo_tile_t * shred = &config->topo.tiles[ shred_id ];
      97           0 :     if( FD_LIKELY( shred->shred.expected_shred_version==(ushort)0 ) ) {
      98           0 :       shred->shred.expected_shred_version = shred_version;
      99           0 :     }
     100           0 :   }
     101           0 :   ulong store_id = fd_topo_find_tile( &config->topo, "storei", 0 );
     102           0 :   if( FD_UNLIKELY( store_id!=ULONG_MAX ) ) {
     103           0 :     fd_topo_tile_t * storei = &config->topo.tiles[ store_id ];
     104           0 :     if( FD_LIKELY( storei->store_int.expected_shred_version==(ushort)0 ) ) {
     105           0 :       storei->store_int.expected_shred_version = shred_version;
     106           0 :     }
     107           0 :   }
     108           0 : }
     109             : 
     110             : /* Run Firedancer entirely in a single process for development and
     111             :    debugging convenience. */
     112             : 
     113             : static void
     114             : run_firedancer_threaded( config_t * config,
     115             :                          int        init_workspaces,
     116           0 :                          void ( * agave_main )( config_t const * ) ) {
     117           0 :   install_parent_signals();
     118             : 
     119           0 :   fd_topo_print_log( 0, &config->topo );
     120             : 
     121           0 :   run_firedancer_init( config, init_workspaces );
     122           0 :   fdctl_setup_netns( config, 1 );
     123             : 
     124           0 :   if( FD_UNLIKELY( config->development.debug_tile ) ) {
     125           0 :     fd_log_private_shared_lock[ 1 ] = 1;
     126           0 :   }
     127             : 
     128             :   /* This is kind of a hack, but we have to join all the workspaces as read-write
     129             :      if we are running things threaded.  The reason is that if one of the earlier
     130             :      tiles maps it in as read-only, later tiles will reuse the same cached shmem
     131             :      join (the key is only on shmem name, when it should be (name, mode)). */
     132             : 
     133           0 :   if( 0==strcmp( config->net.provider, "xdp" ) ) {
     134           0 :     fd_xdp_fds_t fds = fd_topo_install_xdp( &config->topo, config->net.bind_address_parsed );
     135           0 :     (void)fds;
     136           0 :   }
     137             : 
     138           0 :   fd_topo_join_workspaces( &config->topo, FD_SHMEM_JOIN_MODE_READ_WRITE );
     139           0 :   fd_topo_run_single_process( &config->topo, 2, config->uid, config->gid, fdctl_tile_run, NULL );
     140             : 
     141           0 :   if( FD_UNLIKELY( agave_main && !config->development.no_agave ) ) {
     142           0 :     agave_main( config );
     143           0 :   }
     144             : 
     145             :   /* None of the threads will ever exit, they just abort the process, so sleep forever. */
     146           0 :   for(;;) pause();
     147           0 : }
     148             : 
     149             : void
     150             : dev_cmd_fn( args_t *   args,
     151             :             config_t * config,
     152           0 :             void ( * agave_main )( config_t const * ) ) {
     153           0 :   if( FD_LIKELY( !args->dev.no_configure ) ) {
     154           0 :     args_t configure_args = {
     155           0 :       .configure.command = CONFIGURE_CMD_INIT,
     156           0 :     };
     157           0 :     for( ulong i=0UL; STAGES[ i ]; i++ )
     158           0 :       configure_args.configure.stages[ i ] = STAGES[ i ];
     159           0 :     configure_cmd_fn( &configure_args, config );
     160           0 :   }
     161             : 
     162           0 :   update_config_for_dev( config );
     163           0 :   if( FD_UNLIKELY( args->dev.no_agave ) ) config->development.no_agave = 1;
     164             : 
     165           0 :   if( FD_UNLIKELY( strcmp( "", args->dev.debug_tile ) ) ) {
     166           0 :     if( FD_LIKELY( config->development.sandbox ) ) {
     167           0 :       FD_LOG_WARNING(( "disabling sandbox to debug tile `%s`", args->dev.debug_tile ));
     168           0 :       config->development.sandbox = 0;
     169           0 :     }
     170             : 
     171           0 :     if( !strcmp( args->dev.debug_tile, "solana" ) ||
     172           0 :         !strcmp( args->dev.debug_tile, "agave" ) ) {
     173           0 :       config->development.debug_tile = UINT_MAX; /* Sentinel value representing Agave */
     174           0 :     } else {
     175           0 :       ulong tile_id = fd_topo_find_tile( &config->topo, args->dev.debug_tile, 0UL );
     176           0 :       if( FD_UNLIKELY( tile_id==ULONG_MAX ) ) FD_LOG_ERR(( "--debug-tile `%s` not present in topology", args->dev.debug_tile ));
     177           0 :       config->development.debug_tile = 1U+(uint)tile_id;
     178           0 :     }
     179           0 :   }
     180             : 
     181           0 :   if( FD_LIKELY( !args->dev.monitor ) ) {
     182           0 :     if( FD_LIKELY( !config->development.no_clone ) ) run_firedancer( config, args->dev.parent_pipefd, !args->dev.no_init_workspaces );
     183           0 :     else                                             run_firedancer_threaded( config , !args->dev.no_init_workspaces, agave_main );
     184           0 :   } else {
     185           0 :     install_parent_signals();
     186             : 
     187           0 :     int pipefd[2];
     188           0 :     if( FD_UNLIKELY( pipe2( pipefd, O_NONBLOCK ) ) ) FD_LOG_ERR(( "pipe2() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     189           0 :     initialize_workspaces(config);
     190           0 :     firedancer_pid = fork();
     191           0 :     if( !firedancer_pid ) {
     192           0 :       if( FD_UNLIKELY( close( pipefd[0] ) ) ) FD_LOG_ERR(( "close() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     193           0 :       if( FD_UNLIKELY( dup2( pipefd[1], STDERR_FILENO ) == -1 ) )
     194           0 :         FD_LOG_ERR(( "dup2() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     195           0 :       if( FD_UNLIKELY( close( pipefd[1] ) ) ) FD_LOG_ERR(( "close() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     196           0 :       if( FD_UNLIKELY( setenv( "RUST_LOG_STYLE", "always", 1 ) ) ) /* otherwise RUST_LOG will not be colorized to the pipe */
     197           0 :         FD_LOG_ERR(( "setenv() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     198           0 :       if( FD_LIKELY( !config->development.no_clone ) ) run_firedancer( config, -1, 0 );
     199           0 :       else                                             run_firedancer_threaded( config , 0, agave_main );
     200           0 :     } else {
     201           0 :       if( FD_UNLIKELY( close( pipefd[1] ) ) ) FD_LOG_ERR(( "close() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     202           0 :     }
     203             : 
     204           0 :     args_t monitor_args;
     205           0 :     int argc = 0;
     206           0 :     char * argv[] = { NULL };
     207           0 :     char ** pargv = (char**)argv;
     208           0 :     monitor_cmd_args( &argc, &pargv, &monitor_args );
     209           0 :     monitor_args.monitor.drain_output_fd = pipefd[0];
     210             : 
     211           0 :     monitor_pid = fork();
     212           0 :     if( !monitor_pid ) monitor_cmd_fn( &monitor_args, config );
     213           0 :     if( FD_UNLIKELY( close( pipefd[0] ) ) ) FD_LOG_ERR(( "close() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     214             : 
     215           0 :     int wstatus;
     216           0 :     pid_t exited_pid = wait4( -1, &wstatus, (int)__WALL, NULL );
     217           0 :     if( FD_UNLIKELY( exited_pid == -1 ) ) FD_LOG_ERR(( "wait4() failed (%i-%s)", errno, fd_io_strerror( errno ) ));
     218             : 
     219           0 :     char * exited_child = exited_pid == firedancer_pid ? "firedancer" : exited_pid == monitor_pid ? "monitor" : "unknown";
     220           0 :     int exit_code = 0;
     221           0 :     if( FD_UNLIKELY( !WIFEXITED( wstatus ) ) ) {
     222           0 :       FD_LOG_ERR(( "%s exited unexpectedly with signal %d (%s)", exited_child, WTERMSIG( wstatus ), fd_io_strsignal( WTERMSIG( wstatus ) ) ));
     223           0 :       exit_code = WTERMSIG( wstatus );
     224           0 :     } else {
     225           0 :       FD_LOG_ERR(( "%s exited unexpectedly with code %d", exited_child, WEXITSTATUS( wstatus ) ));
     226           0 :       if( FD_UNLIKELY( exited_pid == monitor_pid && !WEXITSTATUS( wstatus ) ) ) exit_code = EXIT_FAILURE;
     227           0 :       else exit_code = WEXITSTATUS( wstatus );
     228           0 :     }
     229             : 
     230           0 :     if( FD_UNLIKELY( exited_pid == monitor_pid ) ) {
     231           0 :       if( FD_UNLIKELY( kill( firedancer_pid, SIGKILL ) ) )
     232           0 :         FD_LOG_ERR(( "failed to kill all processes (%i-%s)", errno, fd_io_strerror( errno ) ));
     233           0 :     } else {
     234           0 :       if( FD_UNLIKELY( kill( monitor_pid, SIGKILL ) ) )
     235           0 :         FD_LOG_ERR(( "failed to kill all processes (%i-%s)", errno, fd_io_strerror( errno ) ));
     236           0 :     }
     237           0 :     fd_sys_util_exit_group( exit_code );
     238           0 :   }
     239           0 : }

Generated by: LCOV version 1.14