/** \file builtin.c Functions for executing builtin functions. How to add a new builtin function: 1). Create a function in builtin.c with the following signature: static int builtin_NAME( wchar_t ** args ) where NAME is the name of the builtin, and args is a zero-terminated list of arguments. 2). Add a line like { L"NAME", &builtin_NAME, N_(L"Bla bla bla") }, to the builtin_data variable. The description is used by the completion system. 3). Create a file doc_src/NAME.txt, containing the manual for the builtin in Doxygen-format. Check the other builtin manuals for proper syntax. 4). Add an entry to the BUILTIN_DOC_SRC variable of Makefile.in. Note that the entries should be sorted alphabetically! 5). Add an entry to the manual at the builtin-overview subsection. Note that the entries should be sorted alphabetically! 6). Use 'darcs add doc_src/NAME.txt' to start tracking changes to the documentation file. */ #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include "config.h" #include "fallback.h" #include "util.h" #include "wutil.h" #include "builtin.h" #include "function.h" #include "complete.h" #include "proc.h" #include "parser.h" #include "reader.h" #include "env.h" #include "common.h" #include "wgetopt.h" #include "sanity.h" #include "tokenizer.h" #include "builtin_help.h" #include "wildcard.h" #include "input_common.h" #include "input.h" #include "intern.h" #include "event.h" #include "signal.h" #include "translate.h" #include "halloc.h" #include "halloc_util.h" #include "parse_util.h" #include "expand.h" /** The default prompt for the read command */ #define DEFAULT_READ_PROMPT L"set_color green; echo read; set_color normal; echo \"> \"" /** The mode name to pass to history and input */ #define READ_MODE_NAME L"fish_read" /** The send stuff to foreground message */ #define FG_MSG _( L"Send job %d, '%ls' to foreground\n" ) typedef struct builtin_data { const wchar_t *name; int (*func)(wchar_t **argv); const wchar_t *desc; } builtin_data_t; /** Print modes for the jobs builtin */ enum { JOBS_DEFAULT, /**< Print lots of general info */ JOBS_PRINT_PID, /**< Print pid of each process in job */ JOBS_PRINT_COMMAND, /**< Print command name of each process in job */ JOBS_PRINT_GROUP, /**< Print group id of job */ } ; /** Table of all builtins */ static hash_table_t builtin; int builtin_out_redirect; int builtin_err_redirect; /* Buffers for storing the output of builtin functions */ string_buffer_t *sb_out=0, *sb_err=0; /** Stack containing builtin I/O for recursive builtin calls. */ static array_list_t io_stack; /** The file from which builtin functions should attempt to read, use instead of stdin. */ static int builtin_stdin; /** Table containing descriptions for all builtins */ static hash_table_t *desc=0; int builtin_count_args( wchar_t **argv ) { int argc = 1; while( argv[argc] != 0 ) { argc++; } return argc; } void builtin_wperror( const wchar_t *s) { if( s != 0 ) { sb_append2( sb_err, s, L": ", (void *)0 ); } char *err = strerror( errno ); wchar_t *werr = str2wcs( err ); if( werr ) { sb_append2( sb_err, werr, L"\n", (void *)0 ); free( werr ); } } /* Here follows the definition of all builtin commands. The function names are all on the form builtin_NAME where NAME is the name of the builtin. so the function name for the builtin 'jobs' is 'builtin_jobs'. Two builtins, 'command' and 'builtin' are not defined here as they are part of the parser. (They are not parsed as commands, instead they only slightly alter the parser state) */ void builtin_print_help( wchar_t *cmd, string_buffer_t *b ) { const char *h; if( b == sb_err ) { sb_append( sb_err, parser_current_line() ); } h = builtin_help_get( cmd ); if( !h ) return; wchar_t *str = str2wcs(builtin_help_get( cmd )); if( str ) { sb_append( b, str ); free( str ); } } /** The bind builtin, used for setting character sequences */ static int builtin_bind( wchar_t **argv ) { int i; int argc=builtin_count_args( argv ); woptind=0; const static struct woption long_options[] = { { L"set-mode", required_argument, 0, 'M' } , { 0, 0, 0, 0 } } ; while( 1 ) { int opt_index = 0; int opt = wgetopt_long( argc, argv, L"M:", long_options, &opt_index ); if( opt == -1 ) break; switch( opt ) { case 0: if(long_options[opt_index].flag != 0) break; sb_printf( sb_err, BUILTIN_ERR_UNKNOWN, argv[0], long_options[opt_index].name ); builtin_print_help( argv[0], sb_err ); return 1; case 'M': input_set_mode( woptarg ); break; case '?': builtin_print_help( argv[0], sb_err ); return 1; } } for( i=woptind; inext; free( eb ); } else { block_t *block=current_block; event_block_t *eb = malloc( sizeof( event_block_t ) ); if( !eb ) die_mem(); eb->type = type; switch( scope ) { case LOCAL: { if( !block->outer ) block=0; break; } case GLOBAL: { block=0; } case UNSET: { while( block && block->type != FUNCTION_CALL ) block = block->outer; } } if( block ) { eb->next = block->first_event_block; block->first_event_block = eb; halloc_register( block, eb ); } else { eb->next = global_event_block; global_event_block=eb; } } return 0; } /** The builtin builtin, used for given builtins precedence over functions. Mostly handled by the parser. All this code does is some additional operational modes, such as printing a list of all builtins. */ static int builtin_builtin( wchar_t **argv ) { int argc=builtin_count_args( argv ); int list=0; woptind=0; const static struct woption long_options[] = { { L"names", no_argument, 0, 'n' } , { L"help", no_argument, 0, 'h' } , { 0, 0, 0, 0 } } ; while( 1 ) { int opt_index = 0; int opt = wgetopt_long( argc, argv, L"nh", long_options, &opt_index ); if( opt == -1 ) break; switch( opt ) { case 0: if(long_options[opt_index].flag != 0) break; sb_printf( sb_err, BUILTIN_ERR_UNKNOWN, argv[0], long_options[opt_index].name ); builtin_print_help( argv[0], sb_err ); return 1; case 'h': builtin_print_help( argv[0], sb_err ); return 0; case 'n': list=1; break; case '?': builtin_print_help( argv[0], sb_err ); return 1; } } if( list ) { array_list_t names; wchar_t **names_arr; int i; al_init( &names ); builtin_get_names( &names ); names_arr = list_to_char_arr( &names ); qsort( names_arr, al_get_count( &names ), sizeof(wchar_t *), (int (*)(const void *, const void *))&wcsfilecmp ); for( i=0; itype ) { case EVENT_SIGNAL: { sb_printf( sb_out, L" --on-signal %ls", sig2wcs( next->param1.signal ) ); break; } case EVENT_VARIABLE: { sb_printf( sb_out, L" --on-variable %ls", next->param1.variable ); break; } case EVENT_EXIT: { if( next->param1.pid > 0 ) sb_printf( sb_out, L" --on-process-exit %d", next->param1.pid ); else sb_printf( sb_out, L" --on-job-exit %d", -next->param1.pid ); break; } case EVENT_JOB_ID: { job_t *j = job_get( next->param1.job_id ); if( j ) sb_printf( sb_out, L" --on-job-exit %d", j->pgid ); break; } } } al_destroy( &ev ); sb_append2( sb_out, L"\n\t", def, L"\nend\n\n", (void *)0); } /** The functions builtin, used for listing and erasing functions. */ static int builtin_functions( wchar_t **argv ) { int i; int erase=0; wchar_t *desc=0; array_list_t names; wchar_t **names_arr; int argc=builtin_count_args( argv ); int list=0; int show_hidden=0; int res = 0; woptind=0; const static struct woption long_options[] = { { L"erase", no_argument, 0, 'e' } , { L"description", required_argument, 0, 'd' } , { L"names", no_argument, 0, 'n' } , { L"all", no_argument, 0, 'a' } , { 0, 0, 0, 0 } } ; while( 1 ) { int opt_index = 0; int opt = wgetopt_long( argc, argv, L"ed:na", long_options, &opt_index ); if( opt == -1 ) break; switch( opt ) { case 0: if(long_options[opt_index].flag != 0) break; sb_printf( sb_err, BUILTIN_ERR_UNKNOWN, argv[0], long_options[opt_index].name ); builtin_print_help( argv[0], sb_err ); return 1; case 'e': erase=1; break; case 'd': desc=woptarg; break; case 'n': list=1; break; case 'a': show_hidden=1; break; case '?': builtin_print_help( argv[0], sb_err ); return 1; } } /* Erase, desc and list are mutually exclusive */ if( (erase + (desc!=0) + list) > 1 ) { sb_printf( sb_err, _( L"%ls: Invalid combination of options\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); return 1; } if( erase ) { int i; for( i=woptind; itype = EVENT_SIGNAL; e->param1.signal = sig; e->function_name=0; al_push( events, e ); break; } case 'v': { event_t *e; if( !wcsvarname( woptarg ) ) { sb_printf( sb_err, _( L"%ls: Invalid variable name '%ls'\n" ), argv[0], woptarg ); res=1; break; } e = halloc( current_block, sizeof(event_t)); if( !e ) die_mem(); e->type = EVENT_VARIABLE; e->param1.variable = halloc_wcsdup( current_block, woptarg ); e->function_name=0; al_push( events, e ); break; } case 'j': case 'p': { pid_t pid; wchar_t *end; event_t *e; e = halloc( current_block, sizeof(event_t)); if( !e ) die_mem(); if( ( opt == 'j' ) && ( wcscasecmp( woptarg, L"caller" ) == 0 ) ) { int job_id = -1; if( is_subshell ) { block_t *b = current_block; while( b && (b->type != SUBST) ) b = b->outer; if( b ) { b=b->outer; } if( b->job ) { job_id = b->job->job_id; } } if( job_id == -1 ) { sb_printf( sb_err, _( L"%ls: Cannot find calling job for event handler\n" ), argv[0] ); res=1; } else { e->type = EVENT_JOB_ID; e->param1.job_id = job_id; } } else { errno = 0; pid = wcstol( woptarg, &end, 10 ); if( errno || !end || *end ) { sb_printf( sb_err, _( L"%ls: Invalid process id %ls\n" ), argv[0], woptarg ); res=1; break; } e->type = EVENT_EXIT; e->param1.pid = (opt=='j'?-1:1)*abs(pid); } if( res ) { free( e ); } else { e->function_name=0; al_push( events, e ); } break; } case '?': builtin_print_help( argv[0], sb_err ); res = 1; break; } } if( !res ) { if( argc-woptind != 1 ) { sb_printf( sb_err, _( L"%ls: Expected one argument, got %d\n" ), argv[0], argc-woptind ); res=1; } else if( !(is_binding?wcsbindingname( argv[woptind] ) : wcsvarname( argv[woptind] ) )) { sb_printf( sb_err, _( L"%ls: Illegal function name '%ls'\n" ), argv[0], argv[woptind] ); res=1; } else if( parser_is_reserved(argv[woptind] ) ) { sb_printf( sb_err, _( L"%ls: The name '%ls' is reserved,\nand can not be used as a function name\n" ), argv[0], argv[woptind] ); res=1; } } if( res ) { int i; array_list_t names; wchar_t **names_arr; int chars=0; // builtin_print_help( argv[0], sb_err ); const wchar_t *cfa = _( L"Current functions are: " ); sb_append( sb_err, cfa ); chars += wcslen( cfa ); al_init( &names ); function_get_names( &names, 0 ); names_arr = list_to_char_arr( &names ); qsort( names_arr, al_get_count( &names ), sizeof(wchar_t *), (int (*)(const void *, const void *))&wcsfilecmp ); for( i=0; i common_get_width() ) { chars = 0; sb_append(sb_err, L"\n" ); } sb_append2( sb_err, nxt, L" ", (void *)0 ); } free( names_arr ); al_destroy( &names ); sb_append( sb_err, L"\n" ); parser_pop_block(); parser_push_block( FAKE ); } else { current_block->param1.function_name=halloc_wcsdup( current_block, argv[woptind]); current_block->param2.function_description=desc?halloc_wcsdup( current_block, desc):0; current_block->param3.function_is_binding = is_binding; current_block->param4.function_events = events; for( i=0; ifunction_name = current_block->param1.function_name; } } current_block->tok_pos = parser_get_pos(); current_block->skip = 1; return 0; } /** The random builtin. For generating random numbers. */ static int builtin_random( wchar_t **argv ) { static int seeded=0; int argc = builtin_count_args( argv ); woptind=0; const static struct woption long_options[] = { { L"help", no_argument, 0, 'h' } , { 0, 0, 0, 0 } } ; while( 1 ) { int opt_index = 0; int opt = wgetopt_long( argc, argv, L"h", long_options, &opt_index ); if( opt == -1 ) break; switch( opt ) { case 0: if(long_options[opt_index].flag != 0) break; sb_printf( sb_err, BUILTIN_ERR_UNKNOWN, argv[0], long_options[opt_index].name ); builtin_print_help( argv[0], sb_err ); return 1; case 'h': builtin_print_help( argv[0], sb_err ); break; case '?': builtin_print_help( argv[0], sb_err ); return 1; } } switch( argc-woptind ) { case 0: { if( !seeded ) { seeded=1; srand( time( 0 ) ); } sb_printf( sb_out, L"%d\n", rand()%32767 ); break; } case 1: { int foo; wchar_t *end=0; errno=0; foo = wcstol( argv[woptind], &end, 10 ); if( errno || *end ) { sb_printf( sb_err, _( L"%ls: Seed value '%ls' is not a valid number\n" ), argv[0], argv[woptind] ); return 1; } seeded=1; srand( foo ); break; } default: { sb_printf( sb_err, _( L"%ls: Expected zero or one argument, got %d\n" ), argv[0], argc-woptind ); builtin_print_help( argv[0], sb_err ); return 1; } } return 0; } /** The read builtin. Reads from stdin and stores the values in environment variables. */ static int builtin_read( wchar_t **argv ) { wchar_t *buff=0; int i, argc = builtin_count_args( argv ); wchar_t *ifs; int place = ENV_USER; wchar_t *nxt; wchar_t *prompt = DEFAULT_READ_PROMPT; wchar_t *commandline = L""; woptind=0; while( 1 ) { const static struct woption long_options[] = { { L"export", no_argument, 0, 'x' } , { L"global", no_argument, 0, 'g' } , { L"local", no_argument, 0, 'l' } , { L"universal", no_argument, 0, 'U' } , { L"unexport", no_argument, 0, 'u' } , { L"prompt", required_argument, 0, 'p' } , { L"command", required_argument, 0, 'c' } , { 0, 0, 0, 0 } } ; int opt_index = 0; int opt = wgetopt_long( argc, argv, L"xglUup:c:", long_options, &opt_index ); if( opt == -1 ) break; switch( opt ) { case 0: if(long_options[opt_index].flag != 0) break; sb_printf( sb_err, BUILTIN_ERR_UNKNOWN, argv[0], long_options[opt_index].name ); builtin_print_help( argv[0], sb_err ); return 1; case L'x': place |= ENV_EXPORT; break; case L'g': place |= ENV_GLOBAL; break; case L'l': place |= ENV_LOCAL; break; case L'U': place |= ENV_UNIVERSAL; break; case L'u': place |= ENV_UNEXPORT; break; case L'p': prompt = woptarg; break; case L'c': commandline = woptarg; break; case L'?': builtin_print_help( argv[0], sb_err ); return 1; } } if( ( place & ENV_UNEXPORT ) && ( place & ENV_EXPORT ) ) { sb_printf( sb_err, BUILTIN_ERR_EXPUNEXP, argv[0], parser_current_line() ); builtin_print_help( argv[0], sb_err ); return 1; } if( (place&ENV_LOCAL?1:0) + (place & ENV_GLOBAL?1:0) + (place & ENV_UNIVERSAL?1:0) > 1) { sb_printf( sb_err, BUILTIN_ERR_GLOCAL, argv[0], parser_current_line() ); builtin_print_help( argv[0], sb_err ); return 1; } if( woptind == argc ) { sb_printf( sb_err, BUILTIN_ERR_MISSING, argv[0] ); sb_append2( sb_err, parser_current_line(), L"\n", (void *)0 ); builtin_print_help( argv[0], sb_err ); return 1; } /* Verify all variable names */ for( i=woptind; iparam1.source_dest = fn_intern; parse_util_set_argv( argv+2); res = reader_read( fd ); parser_pop_block(); if( res ) { sb_printf( sb_err, _( L"%ls: Error while reading file '%ls'\n" ), argv[0], argv[1] ); } /* Do not close fd after calling reader_read. reader_read automatically closes it before calling eval. */ reader_pop_current_filename(); } return res; } /** Make the specified job the first job of the job list. Moving jobs around in the list makes the list reflect the order in which the jobs were used. */ static void make_first( job_t *j ) { job_t *prev=0; job_t *curr; for( curr = first_job; curr != j; curr = curr->next ) { prev=curr; } if( curr == j ) { if( prev == 0 ) return; else { prev->next = curr->next; curr->next = first_job; first_job = curr; } } } /** Builtin for putting a job in the foreground */ static int builtin_fg( wchar_t **argv ) { job_t *j; if( argv[1] == 0 ) { /* Select last constructed job (I.e. first job in the job que) that is possible to put in the foreground */ for( j=first_job; j; j=j->next ) { if( j->constructed && (!job_is_completed(j)) && ( (job_is_stopped(j) || !j->fg) && (j->job_control))) break; } if( !j ) { sb_printf( sb_err, _( L"%ls: There are no suitable jobs\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); } } else if( argv[2] != 0 ) { /* Specifying what more than one job to put to the foreground is a syntax error, we still try to locate the job argv[1], since we want to know if this is an ambigous job specification or if this is an malformed job id */ int pid = wcstol( argv[1], 0, 10 ); j = job_get_from_pid( pid ); if( j != 0 ) { sb_printf( sb_err, _( L"%ls: Ambiguous job\n" ), argv[0] ); } else { sb_printf( sb_err, _( L"%ls: '%ls' is not a job\n" ), argv[0], argv[1] ); } builtin_print_help( argv[0], sb_err ); j=0; } else { int pid = abs(wcstol( argv[1], 0, 10 )); j = job_get_from_pid( pid ); if( !j ) { sb_printf( sb_err, _( L"%ls: No suitable job: %d\n" ), argv[0], pid ); builtin_print_help( argv[0], sb_err ); } if( !j->job_control ) { sb_printf( sb_err, _( L"%ls: Can't put job %d, '%ls' to foreground because it is not under job control\n" ), argv[0], pid, j->command ); builtin_print_help( argv[0], sb_err ); j=0; } } if( j ) { if( builtin_err_redirect ) { sb_printf( sb_err, FG_MSG, j->job_id, j->command ); } else { /* If we aren't redirecting, send output to real stderr, since stuff in sb_err won't get printed until the command finishes. */ fwprintf( stderr, FG_MSG, j->job_id, j->command ); } wchar_t *ft = tok_first( j->command ); if( ft != 0 ) env_set( L"_", ft, ENV_EXPORT ); free(ft); reader_write_title(); make_first( j ); j->fg=1; job_continue( j, job_is_stopped(j) ); } return j != 0; } /** Helper function for builtin_bg() */ static int send_to_bg( job_t *j, const wchar_t *name ) { if( j == 0 ) { sb_printf( sb_err, _( L"%ls: Unknown job '%ls'\n" ), L"bg", name ); builtin_print_help( L"bg", sb_err ); return 1; } else if( !j->job_control ) { sb_printf( sb_err, _( L"%ls: Can't put job %d, '%ls' to background because it is not under job control\n" ), L"bg", j->job_id, j->command ); builtin_print_help( L"bg", sb_err ); return 1; } else { sb_printf( sb_err, _(L"Send job %d '%ls' to background\n"), j->job_id, j->command ); } make_first( j ); j->fg=0; job_continue( j, job_is_stopped(j) ); return 0; } /** Builtin for putting a job in the background */ static int builtin_bg( wchar_t **argv ) { int res = 0; if( argv[1] == 0 ) { job_t *j; for( j=first_job; j; j=j->next ) { if( job_is_stopped(j) && j->job_control && (!job_is_completed(j)) ) break; } if( !j ) { sb_printf( sb_err, _( L"%ls: There are no suitable jobs\n" ), argv[0] ); res = 1; } else { res = send_to_bg( j, _(L"(default)" ) ); } } else { for( argv++; !res && *argv != 0; argv++ ) { int pid = wcstol( *argv, 0, 10 ); res |= send_to_bg( job_get_from_pid( pid ), *argv); } } return res; } #ifdef HAVE__PROC_SELF_STAT /** Calculates the cpu usage (in percent) of the specified job. */ static int cpu_use( job_t *j ) { double u=0; process_t *p; for( p=j->first_process; p; p=p->next ) { struct timeval t; int jiffies; gettimeofday( &t, 0 ); jiffies = proc_get_jiffies( p ); double t1 = 1000000.0*p->last_time.tv_sec+p->last_time.tv_usec; double t2 = 1000000.0*t.tv_sec+t.tv_usec; /* fwprintf( stderr, L"t1 %f t2 %f p1 %d p2 %d\n", t1, t2, jiffies, p->last_jiffies ); */ u += ((double)(jiffies-p->last_jiffies))/(t2-t1); } return u*1000000; } #endif /** Print information about the specified job */ static void builtin_jobs_print( job_t *j, int mode, int header ) { process_t *p; switch( mode ) { case JOBS_DEFAULT: { if( header ) { /* Print table header before first job */ sb_append( sb_out, _( L"Job\tGroup\t" )); #ifdef HAVE__PROC_SELF_STAT sb_append( sb_out, _( L"CPU\t" ) ); #endif sb_append( sb_out, _( L"State\tCommand\n" ) ); } sb_printf( sb_out, L"%d\t%d\t", j->job_id, j->pgid ); #ifdef HAVE__PROC_SELF_STAT sb_printf( sb_out, L"%d%%\t", cpu_use(j) ); #endif sb_append2( sb_out, job_is_stopped(j)?_(L"stopped"):_(L"running"), L"\t", j->command, L"\n", (void *)0 ); break; } case JOBS_PRINT_GROUP: { if( header ) { /* Print table header before first job */ sb_append( sb_out, _( L"Group\n" )); } sb_printf( sb_out, L"%d\n", j->pgid ); break; } case JOBS_PRINT_PID: { if( header ) { /* Print table header before first job */ sb_append( sb_out, _( L"Procces\n" )); } for( p=j->first_process; p; p=p->next ) { sb_printf( sb_out, L"%d\n", p->pid ); } break; } case JOBS_PRINT_COMMAND: { if( header ) { /* Print table header before first job */ sb_append( sb_out, _( L"Command\n" )); } for( p=j->first_process; p; p=p->next ) { sb_printf( sb_out, L"%ls\n", p->argv[0] ); } break; } } } /** Builtin for printing running jobs */ static int builtin_jobs( wchar_t **argv ) { int argc=0; int found=0; int mode=JOBS_DEFAULT; int print_last = 0; job_t *j; argc = builtin_count_args( argv ); woptind=0; while( 1 ) { const static struct woption long_options[] = { { L"pid", no_argument, 0, 'p' } , { L"command", no_argument, 0, 'c' } , { L"group", no_argument, 0, 'g' } , { L"last", no_argument, 0, 'l' } , { 0, 0, 0, 0 } } ; int opt_index = 0; int opt = wgetopt_long( argc, argv, L"pclg", long_options, &opt_index ); if( opt == -1 ) break; switch( opt ) { case 0: if(long_options[opt_index].flag != 0) break; sb_printf( sb_err, BUILTIN_ERR_UNKNOWN, argv[0], long_options[opt_index].name ); sb_append( sb_err, parser_current_line() ); // builtin_print_help( argv[0], sb_err ); return 1; case 'p': mode=JOBS_PRINT_PID; break; case 'c': mode=JOBS_PRINT_COMMAND; break; case 'g': mode=JOBS_PRINT_GROUP; break; case 'l': { print_last = 1; break; } case '?': // builtin_print_help( argv[0], sb_err ); return 1; } } /* Do not babble if not interactive */ if( builtin_out_redirect ) { found=1; } if( print_last ) { /* Ignore unconstructed jobs, i.e. ourself. */ for( j=first_job; j; j=j->next ) { if( j->constructed ) { builtin_jobs_print( j, mode, !found ); return 0; } } } else { if( woptind < argc ) { int i; found = 1; for( i=woptind; inext ) { /* Ignore unconstructed jobs, i.e. ourself. */ if( j->constructed /*&& j->skip_notification*/ ) { builtin_jobs_print( j, mode, !found ); found = 1; } } } } if( !found ) { sb_printf( sb_out, _( L"%ls: There are no jobs\n" ), argv[0] ); } return 0; } /** Builtin for looping over a list */ static int builtin_for( wchar_t **argv ) { int argc = builtin_count_args( argv ); int res=1; if( argc < 3) { sb_printf( sb_err, _( L"%ls: Expected at least two arguments, got %d\n"), argc , argv[0] ); builtin_print_help( argv[0], sb_err ); } else if ( !wcsvarname(argv[1]) ) { sb_printf( sb_err, _( L"%ls: '%ls' is not a valid variable name\n" ), argv[0], argv[1] ); builtin_print_help( argv[0], sb_err ); } else if (wcscmp( argv[2], L"in") != 0 ) { sb_printf( sb_err, _( L"%ls: Second argument must be 'in'\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); } else { res=0; } if( res ) { parser_push_block( FAKE ); } else { parser_push_block( FOR ); al_init( ¤t_block->param2.for_vars); int i; current_block->tok_pos = parser_get_pos(); current_block->param1.for_variable = halloc_wcsdup( current_block, argv[1] ); for( i=argc-1; i>3; i-- ) { al_push( ¤t_block->param2.for_vars, halloc_wcsdup( current_block, argv[ i ] ) ); } halloc_register( current_block, current_block->param2.for_vars.arr ); if( argc > 3 ) { env_set( current_block->param1.for_variable, argv[3], ENV_LOCAL ); } else { current_block->skip=1; } } return res; } /** The begin builtin. Creates a nex block. */ static int builtin_begin( wchar_t **argv ) { parser_push_block( BEGIN ); current_block->tok_pos = parser_get_pos(); return 0; } /** Builtin for ending a block of code, such as a for-loop or an if statement. The end command is whare a lot of the block-level magic happens. */ static int builtin_end( wchar_t **argv ) { if( !current_block->outer ) { sb_printf( sb_err, _( L"%ls: Not inside of block\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); return 1; } else { /** By default, 'end' kills the current block scope. But if we are rewinding a loop, this should be set to false, so that variables in the current loop scope won't die between laps. */ int kill_block = 1; switch( current_block->type ) { case WHILE: { /* If this is a while loop, we rewind the loop unless it's the last lap, in which case we continue. */ if( !( current_block->skip && (current_block->loop_status != LOOP_CONTINUE ))) { current_block->loop_status = LOOP_NORMAL; current_block->skip = 0; kill_block = 0; parser_set_pos( current_block->tok_pos); current_block->param1.while_state = WHILE_TEST_AGAIN; } break; } case IF: case SUBST: case BEGIN: /* Nothing special happens at the end of these. The scope just ends. */ break; case FOR: { /* set loop variable to next element, and rewind to the beginning of the block. */ if( current_block->loop_status == LOOP_BREAK ) { al_truncate( ¤t_block->param2.for_vars, 0 ); } if( al_get_count( ¤t_block->param2.for_vars ) ) { wchar_t *val = (wchar_t *)al_pop( ¤t_block->param2.for_vars ); env_set( current_block->param1.for_variable, val, ENV_LOCAL); current_block->loop_status = LOOP_NORMAL; current_block->skip = 0; kill_block = 0; parser_set_pos( current_block->tok_pos ); /* fwprintf( stderr, L"jump to %d\n", current_block->tok_pos ); */ } break; } case FUNCTION_DEF: { /** Copy the text from the beginning of the function until the end command and use as the new definition for the specified function */ wchar_t *def = wcsndup( parser_get_buffer()+current_block->tok_pos, parser_get_job_pos()-current_block->tok_pos ); //fwprintf( stderr, L"Function: %ls\n", def ); if( !is_interactive || !parser_test( def, 1 ) ) { function_add( current_block->param1.function_name, def, current_block->param2.function_description, current_block->param4.function_events, current_block->param3.function_is_binding ); } free(def); } break; } if( kill_block ) { parser_pop_block(); } /* If everything goes ok, return status of last command to execute. */ return proc_get_last_status(); } } /** Builtin for executing commands if an if statement is false */ static int builtin_else( wchar_t **argv ) { if( current_block == 0 || current_block->type != IF || current_block->param1.if_state != 1) { sb_printf( sb_err, _( L"%ls: Not inside of 'if' block\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); return 1; } else { current_block->param1.if_state++; current_block->skip = !current_block->skip; env_pop(); env_push(0); } /* If everything goes ok, return status of last command to execute. */ return proc_get_last_status(); } /** This function handles both the 'continue' and the 'break' builtins that are used for loop control. */ static int builtin_break_continue( wchar_t **argv ) { int is_break = (wcscmp(argv[0],L"break")==0); int argc = builtin_count_args( argv ); block_t *b = current_block; if( argc != 1 ) { sb_printf( sb_err, BUILTIN_ERR_UNKNOWN, argv[0], argv[1] ); builtin_print_help( argv[0], sb_err ); return 1; } while( (b != 0) && ( b->type != WHILE) && (b->type != FOR ) ) { b = b->outer; } if( b == 0 ) { sb_printf( sb_err, _( L"%ls: Not inside of loop\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); return 1; } b = current_block; while( ( b->type != WHILE) && (b->type != FOR ) ) { b->skip=1; b = b->outer; } b->skip=1; b->loop_status = is_break?LOOP_BREAK:LOOP_CONTINUE; return 0; } /** Function for handling the \c return builtin */ static int builtin_return( wchar_t **argv ) { int argc = builtin_count_args( argv ); int status = 0; block_t *b = current_block; switch( argc ) { case 1: break; case 2: { wchar_t *end; errno = 0; status = wcstol(argv[1],&end,10); if( errno || *end != 0) { sb_printf( sb_err, _( L"%ls: Argument '%ls' must be an integer\n" ), argv[0], argv[1] ); builtin_print_help( argv[0], sb_err ); return 1; } // fwprintf( stderr, L"Return with status %d\n", status ); break; } default: sb_printf( sb_err, _( L"%ls: Too many arguments\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); return 1; } while( (b != 0) && ( b->type != FUNCTION_CALL) ) { b = b->outer; } if( b == 0 ) { sb_printf( sb_err, _( L"%ls: Not inside of function\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); return 1; } b = current_block; while( ( b->type != FUNCTION_CALL)) { b->skip=1; b = b->outer; } b->skip=1; // proc_set_last_status( status ); return status; } /** Builtin for executing one of several blocks of commands depending on the value of an argument. */ static int builtin_switch( wchar_t **argv ) { int res=0; int argc = builtin_count_args( argv ); if( argc != 2 ) { sb_printf( sb_err, _( L"%ls: Expected exactly one argument, got %d\n" ), argv[0], argc-1 ); builtin_print_help( argv[0], sb_err ); res=1; parser_push_block( FAKE ); } else { parser_push_block( SWITCH ); current_block->param1.switch_value = halloc_wcsdup( current_block, argv[1]); current_block->skip=1; current_block->param2.switch_taken=0; } return res; } /** Builtin used together with the switch builtin for conditional execution */ static int builtin_case( wchar_t **argv ) { int argc = builtin_count_args( argv ); int i; wchar_t *unescaped=0; if( current_block->type != SWITCH ) { sb_printf( sb_err, _( L"%ls: 'case' command while not in switch block\n" ), argv[0] ); builtin_print_help( argv[0], sb_err ); return 1; } current_block->skip = 1; if( current_block->param2.switch_taken ) { return 0; } for( i=1; iparam1.switch_value, unescaped ) ) { current_block->skip = 0; current_block->param2.switch_taken = 1; break; } } free( unescaped ); return 0; } /* END OF BUILTIN COMMANDS Below are functions for handling the builtin commands */ const static builtin_data_t builtin_data[]= { { L"exit", &builtin_exit, N_( L"Exit the shell" ) } , { L"block", &builtin_block, N_( L"Temporarily block delivery of events" ) } , { L"builtin", &builtin_builtin, N_( L"Run a builtin command instead of a function" ) } , { L"cd", &builtin_cd, N_( L"Change working directory" ) } , { L"function", &builtin_function, N_( L"Define a new function" ) } , { L"functions", &builtin_functions, N_( L"List or remove functions" ) } , { L"complete", &builtin_complete, N_( L"Edit command specific completions" ) } , { L"end", &builtin_end, N_( L"End a block of commands" ) } , { L"else", &builtin_else, N_( L"Evaluate block if condition is false" ) } , { L"eval", &builtin_eval, N_( L"Evaluate parameters as a command" ) } , { L"for", &builtin_for, N_( L"Perform a set of commands multiple times" ) } , { L".", &builtin_source, N_( L"Evaluate contents of file" ) } , { L"set", &builtin_set, N_( L"Handle environment variables" ) } , { L"fg", &builtin_fg, N_( L"Send job to foreground" ) } , { L"bg", &builtin_bg, N_( L"Send job to background" ) } , { L"jobs", &builtin_jobs, N_( L"Print currently running jobs" ) } , { L"read", &builtin_read, N_( L"Read a line of input into variables" ) } , { L"break", &builtin_break_continue, N_( L"Stop the innermost loop" ) } , { L"continue", &builtin_break_continue, N_( L"Skip the rest of the current lap of the innermost loop" ) } , { L"return", &builtin_return, N_( L"Stop the currently evaluated function" ) } , { L"commandline", &builtin_commandline, N_( L"Set or get the commandline" ) } , { L"switch", &builtin_switch, N_( L"Conditionally execute a block of commands" ) } , { L"case", &builtin_case, N_( L"Conditionally execute a block of commands" ) } , { L"bind", &builtin_bind, N_( L"Handle fish key bindings" ) } , { L"random", &builtin_random, N_( L"Generate random number" ) } , { L"status", &builtin_status, N_( L"Return status information about fish" ) } , { L"ulimit", &builtin_ulimit, N_( L"Set or get the shells resource usage limits" ) } , /* Builtins that are handled directly by the parser. They are bound to a noop function only so that they show up in the listings of builtin commands, etc.. */ { L"command", &builtin_generic, N_( L"Run a program instead of a function or builtin" ) } , { L"if", &builtin_generic, N_( L"Evaluate block if condition is true" ) } , { L"while", &builtin_generic, N_( L"Perform a command multiple times" ) } , { L"not", &builtin_generic, N_( L"Negate exit status of job" ) } , { L"and", &builtin_generic, N_( L"Execute command if previous command suceeded" ) } , { L"or", &builtin_generic, N_( L"Execute command if previous command failed" ) } , { L"exec", &builtin_generic, N_( L"Run command in current process" ) } , { L"begin", &builtin_begin, N_( L"Create a block of code" ) } , /* This is not a builtin, but fish handles it's help display internally. So some ugly special casing to make sure 'count -h' displays the help for count, but 'count (echo -h)' does not. */ { L"count", &builtin_generic, 0 } , { 0, 0, 0 } } ; void builtin_init() { int i; al_init( &io_stack ); hash_init( &builtin, &hash_wcs_func, &hash_wcs_cmp ); for( i=0; builtin_data[i].name; i++ ) { hash_put( &builtin, builtin_data[i].name, builtin_data[i].func ); intern_static( builtin_data[i].name ); } builtin_help_init(); } void builtin_destroy() { if( desc ) { hash_destroy( desc ); free( desc ); desc=0; } al_destroy( &io_stack ); hash_destroy( &builtin ); builtin_help_destroy(); } int builtin_exists( wchar_t *cmd ) { /* Count is not a builtin, but it's help is handled internally by fish, so it is in the hash_table_t. */ if( wcscmp( cmd, L"count" )==0) return 0; return (hash_get(&builtin, cmd) != 0 ); } /** Return true if the specified builtin should handle it's own help, false otherwise. */ static int internal_help( wchar_t *cmd ) { if( wcscmp( cmd, L"for" ) == 0 || wcscmp( cmd, L"while" ) == 0 || wcscmp( cmd, L"function" ) == 0 || wcscmp( cmd, L"if" ) == 0 || wcscmp( cmd, L"end" ) == 0 || wcscmp( cmd, L"switch" ) == 0 ) return 1; return 0; } int builtin_run( wchar_t **argv ) { int (*cmd)(wchar_t **argv)=0; cmd = hash_get( &builtin, argv[0] ); if( argv[1] != 0 && !internal_help(argv[0]) ) { if( argv[2] == 0 && (parser_is_help( argv[1], 0 ) ) ) { builtin_print_help( argv[0], sb_out ); return 0; } } if( cmd != 0 ) { int status; status = cmd(argv); // fwprintf( stderr, L"Builtin: Set status of %ls to %d\n", argv[0], status ); return status; } else { debug( 0, _( L"Unknown builtin '%ls'" ), argv[0] ); } return 1; } void builtin_get_names( array_list_t *list ) { hash_get_keys( &builtin, list ); } const wchar_t *builtin_get_desc( const wchar_t *b ) { if( !desc ) { int i; desc = malloc( sizeof( hash_table_t ) ); if( !desc) return 0; hash_init( desc, &hash_wcs_func, &hash_wcs_cmp ); for( i=0; builtin_data[i].name; i++ ) { hash_put( desc, builtin_data[i].name, builtin_data[i].desc ); } } return _( hash_get( desc, b )); } void builtin_push_io( int in) { if( builtin_stdin != -1 ) { al_push( &io_stack, (void *)(long)builtin_stdin ); al_push( &io_stack, sb_out ); al_push( &io_stack, sb_err ); } builtin_stdin = in; sb_out = malloc(sizeof(string_buffer_t)); sb_err = malloc(sizeof(string_buffer_t)); sb_init( sb_out ); sb_init( sb_err ); } void builtin_pop_io() { builtin_stdin = 0; sb_destroy( sb_out ); sb_destroy( sb_err ); free( sb_out); free(sb_err); if( al_get_count( &io_stack ) >0 ) { sb_err = (string_buffer_t *)al_pop( &io_stack ); sb_out = (string_buffer_t *)al_pop( &io_stack ); builtin_stdin = (int)(long)al_pop( &io_stack ); } else { sb_out = sb_err = 0; builtin_stdin = 0; } }