| /* vi: set sw=4 ts=4: */ |
| /* |
| * Minix shell port for busybox |
| * |
| * This version of the Minix shell was adapted for use in busybox |
| * by Erik Andersen <andersen@codepoet.org> |
| * |
| * - backtick expansion did not work properly |
| * Jonas Holmberg <jonas.holmberg@axis.com> |
| * Robert Schwebel <r.schwebel@pengutronix.de> |
| * Erik Andersen <andersen@codepoet.org> |
| * |
| * Licensed under GPLv2 or later, see file LICENSE in this tarball for details. |
| */ |
| |
| #include <setjmp.h> |
| #include <sys/times.h> |
| #include "busybox.h" |
| |
| extern char **environ; |
| |
| |
| /*#define MSHDEBUG 1*/ |
| |
| #ifdef MSHDEBUG |
| int mshdbg = MSHDEBUG; |
| |
| #define DBGPRINTF(x) if(mshdbg>0)printf x |
| #define DBGPRINTF0(x) if(mshdbg>0)printf x |
| #define DBGPRINTF1(x) if(mshdbg>1)printf x |
| #define DBGPRINTF2(x) if(mshdbg>2)printf x |
| #define DBGPRINTF3(x) if(mshdbg>3)printf x |
| #define DBGPRINTF4(x) if(mshdbg>4)printf x |
| #define DBGPRINTF5(x) if(mshdbg>5)printf x |
| #define DBGPRINTF6(x) if(mshdbg>6)printf x |
| #define DBGPRINTF7(x) if(mshdbg>7)printf x |
| #define DBGPRINTF8(x) if(mshdbg>8)printf x |
| #define DBGPRINTF9(x) if(mshdbg>9)printf x |
| |
| int mshdbg_rc = 0; |
| |
| #define RCPRINTF(x) if(mshdbg_rc)printf x |
| |
| #else |
| |
| #define DBGPRINTF(x) |
| #define DBGPRINTF0(x) ((void)0) |
| #define DBGPRINTF1(x) ((void)0) |
| #define DBGPRINTF2(x) ((void)0) |
| #define DBGPRINTF3(x) ((void)0) |
| #define DBGPRINTF4(x) ((void)0) |
| #define DBGPRINTF5(x) ((void)0) |
| #define DBGPRINTF6(x) ((void)0) |
| #define DBGPRINTF7(x) ((void)0) |
| #define DBGPRINTF8(x) ((void)0) |
| #define DBGPRINTF9(x) ((void)0) |
| |
| #define RCPRINTF(x) ((void)0) |
| |
| #endif /* MSHDEBUG */ |
| |
| |
| #if ENABLE_FEATURE_EDITING_FANCY_PROMPT |
| # define DEFAULT_ROOT_PROMPT "\\u:\\w> " |
| # define DEFAULT_USER_PROMPT "\\u:\\w$ " |
| #else |
| # define DEFAULT_ROOT_PROMPT "# " |
| # define DEFAULT_USER_PROMPT "$ " |
| #endif |
| |
| |
| /* -------- sh.h -------- */ |
| /* |
| * shell |
| */ |
| |
| #define LINELIM 2100 |
| #define NPUSH 8 /* limit to input nesting */ |
| |
| #undef NOFILE |
| #define NOFILE 20 /* Number of open files */ |
| #define NUFILE 10 /* Number of user-accessible files */ |
| #define FDBASE 10 /* First file usable by Shell */ |
| |
| /* |
| * values returned by wait |
| */ |
| #define WAITSIG(s) ((s)&0177) |
| #define WAITVAL(s) (((s)>>8)&0377) |
| #define WAITCORE(s) (((s)&0200)!=0) |
| |
| /* |
| * library and system definitions |
| */ |
| typedef void xint; /* base type of jmp_buf, for not broken compilers */ |
| |
| /* |
| * shell components |
| */ |
| |
| #define QUOTE 0200 |
| |
| #define NOBLOCK ((struct op *)NULL) |
| #define NOWORD ((char *)NULL) |
| #define NOWORDS ((char **)NULL) |
| #define NOPIPE ((int *)NULL) |
| |
| |
| /* |
| * redirection |
| */ |
| struct ioword { |
| short io_unit; /* unit affected */ |
| short io_flag; /* action (below) */ |
| char *io_name; /* file name */ |
| }; |
| |
| #define IOREAD 1 /* < */ |
| #define IOHERE 2 /* << (here file) */ |
| #define IOWRITE 4 /* > */ |
| #define IOCAT 8 /* >> */ |
| #define IOXHERE 16 /* ${}, ` in << */ |
| #define IODUP 32 /* >&digit */ |
| #define IOCLOSE 64 /* >&- */ |
| |
| #define IODEFAULT (-1) /* token for default IO unit */ |
| |
| |
| /* |
| * Description of a command or an operation on commands. |
| * Might eventually use a union. |
| */ |
| struct op { |
| int type; /* operation type, see below */ |
| char **words; /* arguments to a command */ |
| struct ioword **ioact; /* IO actions (eg, < > >>) */ |
| struct op *left; |
| struct op *right; |
| char *str; /* identifier for case and for */ |
| }; |
| |
| #define TCOM 1 /* command */ |
| #define TPAREN 2 /* (c-list) */ |
| #define TPIPE 3 /* a | b */ |
| #define TLIST 4 /* a [&;] b */ |
| #define TOR 5 /* || */ |
| #define TAND 6 /* && */ |
| #define TFOR 7 |
| #define TDO 8 |
| #define TCASE 9 |
| #define TIF 10 |
| #define TWHILE 11 |
| #define TUNTIL 12 |
| #define TELIF 13 |
| #define TPAT 14 /* pattern in case */ |
| #define TBRACE 15 /* {c-list} */ |
| #define TASYNC 16 /* c & */ |
| /* Added to support "." file expansion */ |
| #define TDOT 17 |
| |
| /* Strings for names to make debug easier */ |
| #ifdef MSHDEBUG |
| static const char *const T_CMD_NAMES[] = { |
| "PLACEHOLDER", |
| "TCOM", |
| "TPAREN", |
| "TPIPE", |
| "TLIST", |
| "TOR", |
| "TAND", |
| "TFOR", |
| "TDO", |
| "TCASE", |
| "TIF", |
| "TWHILE", |
| "TUNTIL", |
| "TELIF", |
| "TPAT", |
| "TBRACE", |
| "TASYNC", |
| "TDOT", |
| }; |
| #endif |
| |
| /* |
| * actions determining the environment of a process |
| */ |
| #define BIT(i) (1<<(i)) |
| #define FEXEC BIT(0) /* execute without forking */ |
| |
| #define AREASIZE (90000) |
| |
| /* |
| * flags to control evaluation of words |
| */ |
| #define DOSUB 1 /* interpret $, `, and quotes */ |
| #define DOBLANK 2 /* perform blank interpretation */ |
| #define DOGLOB 4 /* interpret [?* */ |
| #define DOKEY 8 /* move words with `=' to 2nd arg. list */ |
| #define DOTRIM 16 /* trim resulting string */ |
| |
| #define DOALL (DOSUB|DOBLANK|DOGLOB|DOKEY|DOTRIM) |
| |
| |
| /* PROTOTYPES */ |
| static int newfile(char *s); |
| |
| |
| struct brkcon { |
| jmp_buf brkpt; |
| struct brkcon *nextlev; |
| }; |
| |
| |
| /* |
| * flags: |
| * -e: quit on error |
| * -k: look for name=value everywhere on command line |
| * -n: no execution |
| * -t: exit after reading and executing one command |
| * -v: echo as read |
| * -x: trace |
| * -u: unset variables net diagnostic |
| */ |
| static char flags['z' - 'a' + 1]; |
| /* this looks weird, but is OK ... we index flag with 'a'...'z' */ |
| static char *flag = flags - 'a'; |
| |
| static char *null; /* null value for variable */ |
| static int intr; /* interrupt pending */ |
| |
| static char *trap[_NSIG + 1]; |
| static char ourtrap[_NSIG + 1]; |
| static int trapset; /* trap pending */ |
| |
| static int heedint; /* heed interrupt signals */ |
| |
| static int yynerrs; /* yacc */ |
| |
| static char line[LINELIM]; |
| static char *elinep; |
| |
| #if ENABLE_FEATURE_EDITING |
| static char *current_prompt; |
| static line_input_t *line_input_state; |
| #endif |
| |
| static int areanum; /* current allocation area */ |
| |
| |
| /* |
| * other functions |
| */ |
| static const char *rexecve(char *c, char **v, char **envp); |
| static char *evalstr(char *cp, int f); |
| static char *putn(int n); |
| static char *unquote(char *as); |
| static int rlookup(char *n); |
| static struct wdblock *glob(char *cp, struct wdblock *wb); |
| static int my_getc(int ec); |
| static int subgetc(char ec, int quoted); |
| static char **makenv(int all, struct wdblock *wb); |
| static char **eval(char **ap, int f); |
| static int setstatus(int s); |
| static int waitfor(int lastpid, int canintr); |
| |
| static void onintr(int s); /* SIGINT handler */ |
| |
| static int newenv(int f); |
| static void quitenv(void); |
| static void next(int f); |
| static void setdash(void); |
| static void onecommand(void); |
| static void runtrap(int i); |
| |
| |
| /* -------- area stuff -------- */ |
| |
| #define REGSIZE sizeof(struct region) |
| #define GROWBY (256) |
| /* #define SHRINKBY (64) */ |
| #undef SHRINKBY |
| #define FREE (32767) |
| #define BUSY (0) |
| #define ALIGN (sizeof(int)-1) |
| |
| |
| struct region { |
| struct region *next; |
| int area; |
| }; |
| |
| |
| /* -------- grammar stuff -------- */ |
| typedef union { |
| char *cp; |
| char **wp; |
| int i; |
| struct op *o; |
| } YYSTYPE; |
| |
| #define WORD 256 |
| #define LOGAND 257 |
| #define LOGOR 258 |
| #define BREAK 259 |
| #define IF 260 |
| #define THEN 261 |
| #define ELSE 262 |
| #define ELIF 263 |
| #define FI 264 |
| #define CASE 265 |
| #define ESAC 266 |
| #define FOR 267 |
| #define WHILE 268 |
| #define UNTIL 269 |
| #define DO 270 |
| #define DONE 271 |
| #define IN 272 |
| /* Added for "." file expansion */ |
| #define DOT 273 |
| |
| #define YYERRCODE 300 |
| |
| /* flags to yylex */ |
| #define CONTIN 01 /* skip new lines to complete command */ |
| |
| static struct op *pipeline(int cf); |
| static struct op *andor(void); |
| static struct op *c_list(void); |
| static int synio(int cf); |
| static void musthave(int c, int cf); |
| static struct op *simple(void); |
| static struct op *nested(int type, int mark); |
| static struct op *command(int cf); |
| static struct op *dogroup(int onlydone); |
| static struct op *thenpart(void); |
| static struct op *elsepart(void); |
| static struct op *caselist(void); |
| static struct op *casepart(void); |
| static char **pattern(void); |
| static char **wordlist(void); |
| static struct op *list(struct op *t1, struct op *t2); |
| static struct op *block(int type, struct op *t1, struct op *t2, char **wp); |
| static struct op *newtp(void); |
| static struct op *namelist(struct op *t); |
| static char **copyw(void); |
| static void word(char *cp); |
| static struct ioword **copyio(void); |
| static struct ioword *io(int u, int f, char *cp); |
| static int yylex(int cf); |
| static int collect(int c, int c1); |
| static int dual(int c); |
| static void diag(int ec); |
| static char *tree(unsigned size); |
| |
| /* -------- var.h -------- */ |
| |
| struct var { |
| char *value; |
| char *name; |
| struct var *next; |
| char status; |
| }; |
| |
| #define COPYV 1 /* flag to setval, suggesting copy */ |
| #define RONLY 01 /* variable is read-only */ |
| #define EXPORT 02 /* variable is to be exported */ |
| #define GETCELL 04 /* name & value space was got with getcell */ |
| |
| static int yyparse(void); |
| |
| static int execute(struct op *t, int *pin, int *pout, int act); |
| |
| |
| #define AFID_NOBUF (~0) |
| #define AFID_ID 0 |
| |
| |
| /* -------- io.h -------- */ |
| /* io buffer */ |
| struct iobuf { |
| unsigned id; /* buffer id */ |
| char buf[512]; /* buffer */ |
| char *bufp; /* pointer into buffer */ |
| char *ebufp; /* pointer to end of buffer */ |
| }; |
| |
| /* possible arguments to an IO function */ |
| struct ioarg { |
| const char *aword; |
| char **awordlist; |
| int afile; /* file descriptor */ |
| unsigned afid; /* buffer id */ |
| long afpos; /* file position */ |
| struct iobuf *afbuf; /* buffer for this file */ |
| }; |
| |
| /* an input generator's state */ |
| struct io { |
| int (*iofn) (struct ioarg *, struct io *); |
| struct ioarg *argp; |
| int peekc; |
| char prev; /* previous character read by readc() */ |
| char nlcount; /* for `'s */ |
| char xchar; /* for `'s */ |
| char task; /* reason for pushed IO */ |
| }; |
| |
| #define XOTHER 0 /* none of the below */ |
| #define XDOLL 1 /* expanding ${} */ |
| #define XGRAVE 2 /* expanding `'s */ |
| #define XIO 3 /* file IO */ |
| |
| /* in substitution */ |
| #define INSUB() (e.iop->task == XGRAVE || e.iop->task == XDOLL) |
| |
| static struct ioarg temparg = { 0, 0, 0, AFID_NOBUF, 0 }; /* temporary for PUSHIO */ |
| static struct ioarg ioargstack[NPUSH]; |
| static struct io iostack[NPUSH]; |
| static struct iobuf sharedbuf = { AFID_NOBUF }; |
| static struct iobuf mainbuf = { AFID_NOBUF }; |
| static unsigned bufid = AFID_ID; /* buffer id counter */ |
| |
| #define PUSHIO(what,arg,gen) ((temparg.what = (arg)), pushio(&temparg,(gen))) |
| #define RUN(what,arg,gen) ((temparg.what = (arg)), run(&temparg,(gen))) |
| |
| |
| /* |
| * parsing & execution environment |
| */ |
| static struct env { |
| char *linep; |
| struct io *iobase; |
| struct io *iop; |
| xint *errpt; /* void * */ |
| int iofd; |
| struct env *oenv; |
| } e; |
| |
| |
| /* |
| * input generators for IO structure |
| */ |
| static int nlchar(struct ioarg *ap); |
| static int strchar(struct ioarg *ap); |
| static int qstrchar(struct ioarg *ap); |
| static int filechar(struct ioarg *ap); |
| static int herechar(struct ioarg *ap); |
| static int linechar(struct ioarg *ap); |
| static int gravechar(struct ioarg *ap, struct io *iop); |
| static int qgravechar(struct ioarg *ap, struct io *iop); |
| static int dolchar(struct ioarg *ap); |
| static int wdchar(struct ioarg *ap); |
| static void scraphere(void); |
| static void freehere(int area); |
| static void gethere(void); |
| static void markhere(char *s, struct ioword *iop); |
| static int herein(char *hname, int xdoll); |
| static int run(struct ioarg *argp, int (*f) (struct ioarg *)); |
| |
| |
| static int eofc(void); |
| static int readc(void); |
| static void unget(int c); |
| static void ioecho(char c); |
| |
| |
| /* |
| * IO control |
| */ |
| static void pushio(struct ioarg *argp, int (*f) (struct ioarg *)); |
| static int remap(int fd); |
| static int openpipe(int *pv); |
| static void closepipe(int *pv); |
| static struct io *setbase(struct io *ip); |
| |
| /* -------- word.h -------- */ |
| |
| #define NSTART 16 /* default number of words to allow for initially */ |
| |
| struct wdblock { |
| short w_bsize; |
| short w_nword; |
| /* bounds are arbitrary */ |
| char *w_words[1]; |
| }; |
| |
| static struct wdblock *addword(char *wd, struct wdblock *wb); |
| static struct wdblock *newword(int nw); |
| static char **getwords(struct wdblock *wb); |
| |
| /* -------- misc stuff -------- */ |
| |
| static int forkexec(struct op *t, int *pin, int *pout, int act, char **wp); |
| static int iosetup(struct ioword *iop, int pipein, int pipeout); |
| static void brkset(struct brkcon *bc); |
| static int dolabel(struct op *t); |
| static int dohelp(struct op *t); |
| static int dochdir(struct op *t); |
| static int doshift(struct op *t); |
| static int dologin(struct op *t); |
| static int doumask(struct op *t); |
| static int doexec(struct op *t); |
| static int dodot(struct op *t); |
| static int dowait(struct op *t); |
| static int doread(struct op *t); |
| static int doeval(struct op *t); |
| static int dotrap(struct op *t); |
| static int getsig(char *s); |
| static void setsig(int n, sighandler_t f); |
| static int getn(char *as); |
| static int dobreak(struct op *t); |
| static int docontinue(struct op *t); |
| static int brkcontin(char *cp, int val); |
| static int doexit(struct op *t); |
| static int doexport(struct op *t); |
| static int doreadonly(struct op *t); |
| static void rdexp(char **wp, void (*f) (struct var *), int key); |
| static void badid(char *s); |
| static int doset(struct op *t); |
| static void varput(char *s, int out); |
| static int dotimes(struct op *t); |
| static int expand(const char *cp, struct wdblock **wbp, int f); |
| static char *blank(int f); |
| static int dollar(int quoted); |
| static int grave(int quoted); |
| static void globname(char *we, char *pp); |
| static char *generate(char *start1, char *end1, char *middle, char *end); |
| static int anyspcl(struct wdblock *wb); |
| static int xstrcmp(char *p1, char *p2); |
| static void glob0(char *a0, unsigned a1, int a2, |
| int (*a3) (char *, char *)); |
| static void readhere(char **name, char *s, int ec); |
| static void pushio(struct ioarg *argp, int (*f) (struct ioarg *)); |
| static int xxchar(struct ioarg *ap); |
| |
| struct here { |
| char *h_tag; |
| int h_dosub; |
| struct ioword *h_iop; |
| struct here *h_next; |
| }; |
| |
| static const char * const signame[] = { |
| "Signal 0", |
| "Hangup", |
| NULL, /* interrupt */ |
| "Quit", |
| "Illegal instruction", |
| "Trace/BPT trap", |
| "Abort", |
| "Bus error", |
| "Floating Point Exception", |
| "Killed", |
| "SIGUSR1", |
| "SIGSEGV", |
| "SIGUSR2", |
| NULL, /* broken pipe */ |
| "Alarm clock", |
| "Terminated", |
| }; |
| |
| #define NSIGNAL (sizeof(signame)/sizeof(signame[0])) |
| |
| struct res { |
| const char *r_name; |
| int r_val; |
| }; |
| static const struct res restab[] = { |
| {"for", FOR}, |
| {"case", CASE}, |
| {"esac", ESAC}, |
| {"while", WHILE}, |
| {"do", DO}, |
| {"done", DONE}, |
| {"if", IF}, |
| {"in", IN}, |
| {"then", THEN}, |
| {"else", ELSE}, |
| {"elif", ELIF}, |
| {"until", UNTIL}, |
| {"fi", FI}, |
| {";;", BREAK}, |
| {"||", LOGOR}, |
| {"&&", LOGAND}, |
| {"{", '{'}, |
| {"}", '}'}, |
| {".", DOT}, |
| {0, 0}, |
| }; |
| |
| |
| struct builtincmd { |
| const char *name; |
| int (*builtinfunc) (struct op * t); |
| }; |
| static const struct builtincmd builtincmds[] = { |
| {".", dodot}, |
| {":", dolabel}, |
| {"break", dobreak}, |
| {"cd", dochdir}, |
| {"continue", docontinue}, |
| {"eval", doeval}, |
| {"exec", doexec}, |
| {"exit", doexit}, |
| {"export", doexport}, |
| {"help", dohelp}, |
| {"login", dologin}, |
| {"newgrp", dologin}, |
| {"read", doread}, |
| {"readonly", doreadonly}, |
| {"set", doset}, |
| {"shift", doshift}, |
| {"times", dotimes}, |
| {"trap", dotrap}, |
| {"umask", doumask}, |
| {"wait", dowait}, |
| {0, 0} |
| }; |
| |
| static struct op *scantree(struct op *); |
| static struct op *dowholefile(int, int); |
| |
| |
| /* Globals */ |
| static char **dolv; |
| static int dolc; |
| static int exstat; |
| static char gflg; |
| static int interactive; /* Is this an interactive shell */ |
| static int execflg; |
| static int multiline; /* \n changed to ; */ |
| static struct op *outtree; /* result from parser */ |
| static xint *failpt; |
| static xint *errpt; |
| static struct brkcon *brklist; |
| static int isbreak; |
| static struct wdblock *wdlist; |
| static struct wdblock *iolist; |
| static char *trap[_NSIG + 1]; |
| static char ourtrap[_NSIG + 1]; |
| static int trapset; /* trap pending */ |
| |
| #ifdef MSHDEBUG |
| static struct var *mshdbg_var; |
| #endif |
| static struct var *vlist; /* dictionary */ |
| static struct var *homedir; /* home directory */ |
| static struct var *prompt; /* main prompt */ |
| static struct var *cprompt; /* continuation prompt */ |
| static struct var *path; /* search path for commands */ |
| static struct var *shell; /* shell to interpret command files */ |
| static struct var *ifs; /* field separators */ |
| |
| static int areanum; /* current allocation area */ |
| static int intr; |
| static int inparse; |
| static char *null = (char*)""; |
| static int heedint = 1; |
| static void (*qflag) (int) = SIG_IGN; |
| static int startl; |
| static int peeksym; |
| static int nlseen; |
| static int iounit = IODEFAULT; |
| static YYSTYPE yylval; |
| static char *elinep = line + sizeof(line) - 5; |
| |
| |
| static struct here *inhere; /* list of hear docs while parsing */ |
| static struct here *acthere; /* list of active here documents */ |
| static struct region *areabot; /* bottom of area */ |
| static struct region *areatop; /* top of area */ |
| static struct region *areanxt; /* starting point of scan */ |
| static void *brktop; |
| static void *brkaddr; |
| |
| static struct env e = { |
| line, /* linep: char ptr */ |
| iostack, /* iobase: struct io ptr */ |
| iostack - 1, /* iop: struct io ptr */ |
| (xint *) NULL, /* errpt: void ptr for errors? */ |
| FDBASE, /* iofd: file desc */ |
| (struct env *) NULL /* oenv: struct env ptr */ |
| }; |
| |
| #ifdef MSHDEBUG |
| void print_t(struct op *t) |
| { |
| DBGPRINTF(("T: t=%p, type %s, words=%p, IOword=%p\n", t, |
| T_CMD_NAMES[t->type], t->words, t->ioact)); |
| |
| if (t->words) { |
| DBGPRINTF(("T: W1: %s", t->words[0])); |
| } |
| } |
| |
| void print_tree(struct op *head) |
| { |
| if (head == NULL) { |
| DBGPRINTF(("PRINT_TREE: no tree\n")); |
| return; |
| } |
| |
| DBGPRINTF(("NODE: %p, left %p, right %p\n", head, head->left, |
| head->right)); |
| |
| if (head->left) |
| print_tree(head->left); |
| |
| if (head->right) |
| print_tree(head->right); |
| } |
| #endif /* MSHDEBUG */ |
| |
| |
| /* |
| * IO functions |
| */ |
| static void prs(const char *s) |
| { |
| if (*s) |
| write(2, s, strlen(s)); |
| } |
| |
| static void prn(unsigned u) |
| { |
| prs(itoa(u)); |
| } |
| |
| static void echo(char **wp) |
| { |
| int i; |
| |
| prs("+"); |
| for (i = 0; wp[i]; i++) { |
| if (i) |
| prs(" "); |
| prs(wp[i]); |
| } |
| prs("\n"); |
| } |
| |
| static void closef(int i) |
| { |
| if (i > 2) |
| close(i); |
| } |
| |
| static void closeall(void) |
| { |
| int u; |
| |
| for (u = NUFILE; u < NOFILE;) |
| close(u++); |
| } |
| |
| |
| /* fail but return to process next command */ |
| static void fail(void) ATTRIBUTE_NORETURN; |
| static void fail(void) |
| { |
| longjmp(failpt, 1); |
| /* NOTREACHED */ |
| } |
| |
| /* abort shell (or fail in subshell) */ |
| static void leave(void) ATTRIBUTE_NORETURN; |
| static void leave(void) |
| { |
| DBGPRINTF(("LEAVE: leave called!\n")); |
| |
| if (execflg) |
| fail(); |
| scraphere(); |
| freehere(1); |
| runtrap(0); |
| _exit(exstat); |
| /* NOTREACHED */ |
| } |
| |
| static void warn(const char *s) |
| { |
| if (*s) { |
| prs(s); |
| exstat = -1; |
| } |
| prs("\n"); |
| if (flag['e']) |
| leave(); |
| } |
| |
| static void err(const char *s) |
| { |
| warn(s); |
| if (flag['n']) |
| return; |
| if (!interactive) |
| leave(); |
| if (e.errpt) |
| longjmp(e.errpt, 1); |
| closeall(); |
| e.iop = e.iobase = iostack; |
| } |
| |
| |
| /* -------- area.c -------- */ |
| |
| /* |
| * All memory between (char *)areabot and (char *)(areatop+1) is |
| * exclusively administered by the area management routines. |
| * It is assumed that sbrk() and brk() manipulate the high end. |
| */ |
| |
| #define sbrk(X) ({ \ |
| void * __q = (void *)-1; \ |
| if (brkaddr + (int)(X) < brktop) { \ |
| __q = brkaddr; \ |
| brkaddr += (int)(X); \ |
| } \ |
| __q; \ |
| }) |
| |
| static void initarea(void) |
| { |
| brkaddr = xmalloc(AREASIZE); |
| brktop = brkaddr + AREASIZE; |
| |
| while ((long) sbrk(0) & ALIGN) |
| sbrk(1); |
| areabot = (struct region *) sbrk(REGSIZE); |
| |
| areabot->next = areabot; |
| areabot->area = BUSY; |
| areatop = areabot; |
| areanxt = areabot; |
| } |
| |
| static char *getcell(unsigned nbytes) |
| { |
| int nregio; |
| struct region *p, *q; |
| int i; |
| |
| if (nbytes == 0) { |
| puts("getcell(0)"); |
| abort(); |
| } |
| /* silly and defeats the algorithm */ |
| /* |
| * round upwards and add administration area |
| */ |
| nregio = (nbytes + (REGSIZE - 1)) / REGSIZE + 1; |
| p = areanxt; |
| for (;;) { |
| if (p->area > areanum) { |
| /* |
| * merge free cells |
| */ |
| while ((q = p->next)->area > areanum && q != areanxt) |
| p->next = q->next; |
| /* |
| * exit loop if cell big enough |
| */ |
| if (q >= p + nregio) |
| goto found; |
| } |
| p = p->next; |
| if (p == areanxt) |
| break; |
| } |
| i = nregio >= GROWBY ? nregio : GROWBY; |
| p = (struct region *) sbrk(i * REGSIZE); |
| if (p == (struct region *) -1) |
| return NULL; |
| p--; |
| if (p != areatop) { |
| puts("not contig"); |
| abort(); /* allocated areas are contiguous */ |
| } |
| q = p + i; |
| p->next = q; |
| p->area = FREE; |
| q->next = areabot; |
| q->area = BUSY; |
| areatop = q; |
| found: |
| /* |
| * we found a FREE area big enough, pointed to by 'p', and up to 'q' |
| */ |
| areanxt = p + nregio; |
| if (areanxt < q) { |
| /* |
| * split into requested area and rest |
| */ |
| if (areanxt + 1 > q) { |
| puts("OOM"); |
| abort(); /* insufficient space left for admin */ |
| } |
| areanxt->next = q; |
| areanxt->area = FREE; |
| p->next = areanxt; |
| } |
| p->area = areanum; |
| return (char *) (p + 1); |
| } |
| |
| static void freecell(char *cp) |
| { |
| struct region *p; |
| |
| p = (struct region *) cp; |
| if (p != NULL) { |
| p--; |
| if (p < areanxt) |
| areanxt = p; |
| p->area = FREE; |
| } |
| } |
| #define DELETE(obj) freecell((char *)obj) |
| |
| static void freearea(int a) |
| { |
| struct region *p, *top; |
| |
| top = areatop; |
| for (p = areabot; p != top; p = p->next) |
| if (p->area >= a) |
| p->area = FREE; |
| } |
| |
| static void setarea(char *cp, int a) |
| { |
| struct region *p; |
| |
| p = (struct region *) cp; |
| if (p != NULL) |
| (p - 1)->area = a; |
| } |
| |
| static int getarea(char *cp) |
| { |
| return ((struct region *) cp - 1)->area; |
| } |
| |
| static void garbage(void) |
| { |
| struct region *p, *q, *top; |
| |
| top = areatop; |
| for (p = areabot; p != top; p = p->next) { |
| if (p->area > areanum) { |
| while ((q = p->next)->area > areanum) |
| p->next = q->next; |
| areanxt = p; |
| } |
| } |
| #ifdef SHRINKBY |
| if (areatop >= q + SHRINKBY && q->area > areanum) { |
| brk((char *) (q + 1)); |
| q->next = areabot; |
| q->area = BUSY; |
| areatop = q; |
| } |
| #endif |
| } |
| |
| static char *space(int n) |
| { |
| char *cp; |
| |
| cp = getcell(n); |
| if (cp == NULL) |
| err("out of string space"); |
| return cp; |
| } |
| |
| static char *strsave(const char *s, int a) |
| { |
| char *cp; |
| |
| cp = space(strlen(s) + 1); |
| if (cp == NULL) { |
| // FIXME: I highly doubt this is good. |
| return (char*)""; |
| } |
| setarea(cp, a); |
| strcpy(cp, s); |
| return cp; |
| } |
| |
| |
| /* -------- var.c -------- */ |
| |
| static int eqname(const char *n1, const char *n2) |
| { |
| for (; *n1 != '=' && *n1 != '\0'; n1++) |
| if (*n2++ != *n1) |
| return 0; |
| return *n2 == '\0' || *n2 == '='; |
| } |
| |
| static const char *findeq(const char *cp) |
| { |
| while (*cp != '\0' && *cp != '=') |
| cp++; |
| return cp; |
| } |
| |
| /* |
| * Find the given name in the dictionary |
| * and return its value. If the name was |
| * not previously there, enter it now and |
| * return a null value. |
| */ |
| static struct var *lookup(const char *n) |
| { |
| // FIXME: dirty hack |
| static struct var dummy; |
| |
| struct var *vp; |
| const char *cp; |
| char *xp; |
| int c; |
| |
| if (isdigit(*n)) { |
| dummy.name = (char*)n; |
| for (c = 0; isdigit(*n) && c < 1000; n++) |
| c = c * 10 + *n - '0'; |
| dummy.status = RONLY; |
| dummy.value = (c <= dolc ? dolv[c] : null); |
| return &dummy; |
| } |
| |
| for (vp = vlist; vp; vp = vp->next) |
| if (eqname(vp->name, n)) |
| return vp; |
| |
| cp = findeq(n); |
| vp = (struct var *) space(sizeof(*vp)); |
| if (vp == 0 || (vp->name = space((int) (cp - n) + 2)) == 0) { |
| dummy.name = dummy.value = (char*)""; |
| return &dummy; |
| } |
| |
| xp = vp->name; |
| while ((*xp = *n++) != '\0' && *xp != '=') |
| xp++; |
| *xp++ = '='; |
| *xp = '\0'; |
| setarea((char *) vp, 0); |
| setarea((char *) vp->name, 0); |
| vp->value = null; |
| vp->next = vlist; |
| vp->status = GETCELL; |
| vlist = vp; |
| return vp; |
| } |
| |
| /* |
| * if name is not NULL, it must be |
| * a prefix of the space `val', |
| * and end with `='. |
| * this is all so that exporting |
| * values is reasonably painless. |
| */ |
| static void nameval(struct var *vp, const char *val, const char *name) |
| { |
| const char *cp; |
| char *xp; |
| int fl; |
| |
| if (vp->status & RONLY) { |
| xp = vp->name; |
| while (*xp && *xp != '=') |
| putc(*xp++, stderr); |
| err(" is read-only"); |
| return; |
| } |
| fl = 0; |
| if (name == NULL) { |
| xp = space(strlen(vp->name) + strlen(val) + 2); |
| if (xp == NULL) |
| return; |
| /* make string: name=value */ |
| setarea(xp, 0); |
| name = xp; |
| cp = vp->name; |
| while ((*xp = *cp++) != '\0' && *xp != '=') |
| xp++; |
| *xp++ = '='; |
| strcpy(xp, val); |
| val = xp; |
| fl = GETCELL; |
| } |
| if (vp->status & GETCELL) |
| freecell(vp->name); /* form new string `name=value' */ |
| vp->name = (char*)name; |
| vp->value = (char*)val; |
| vp->status |= fl; |
| } |
| |
| /* |
| * give variable at `vp' the value `val'. |
| */ |
| static void setval(struct var *vp, const char *val) |
| { |
| nameval(vp, val, NULL); |
| } |
| |
| static void export(struct var *vp) |
| { |
| vp->status |= EXPORT; |
| } |
| |
| static void ronly(struct var *vp) |
| { |
| if (isalpha(vp->name[0]) || vp->name[0] == '_') /* not an internal symbol */ |
| vp->status |= RONLY; |
| } |
| |
| static int isassign(const char *s) |
| { |
| unsigned char c; |
| DBGPRINTF7(("ISASSIGN: enter, s=%s\n", s)); |
| |
| /* no isalpha() - we shouldn't use locale */ |
| c = *s; |
| if (c != '_' |
| && (unsigned)((c|0x20) - 'a') > 25 /* not letter */ |
| ) { |
| return 0; |
| } |
| while (1) { |
| c = *++s; |
| if (c == '\0') |
| return 0; |
| if (c == '=') |
| return 1; |
| c |= 0x20; /* lowercase letters, doesn't affect numbers */ |
| if (c != '_' |
| && (unsigned)(c - '0') > 9 /* not number */ |
| && (unsigned)(c - 'a') > 25 /* not letter */ |
| ) { |
| return 0; |
| } |
| } |
| } |
| |
| static int assign(const char *s, int cf) |
| { |
| const char *cp; |
| struct var *vp; |
| |
| DBGPRINTF7(("ASSIGN: enter, s=%s, cf=%d\n", s, cf)); |
| |
| if (!isalpha(*s) && *s != '_') |
| return 0; |
| for (cp = s; *cp != '='; cp++) |
| if (*cp == '\0' || (!isalnum(*cp) && *cp != '_')) |
| return 0; |
| vp = lookup(s); |
| nameval(vp, ++cp, cf == COPYV ? NULL : s); |
| if (cf != COPYV) |
| vp->status &= ~GETCELL; |
| return 1; |
| } |
| |
| static int checkname(char *cp) |
| { |
| DBGPRINTF7(("CHECKNAME: enter, cp=%s\n", cp)); |
| |
| if (!isalpha(*cp++) && *(cp - 1) != '_') |
| return 0; |
| while (*cp) |
| if (!isalnum(*cp++) && *(cp - 1) != '_') |
| return 0; |
| return 1; |
| } |
| |
| static void putvlist(int f, int out) |
| { |
| struct var *vp; |
| |
| for (vp = vlist; vp; vp = vp->next) { |
| if (vp->status & f && (isalpha(*vp->name) || *vp->name == '_')) { |
| if (vp->status & EXPORT) |
| write(out, "export ", 7); |
| if (vp->status & RONLY) |
| write(out, "readonly ", 9); |
| write(out, vp->name, (int) (findeq(vp->name) - vp->name)); |
| write(out, "\n", 1); |
| } |
| } |
| } |
| |
| |
| /* |
| * trap handling |
| */ |
| static void sig(int i) |
| { |
| trapset = i; |
| signal(i, sig); |
| } |
| |
| static void runtrap(int i) |
| { |
| char *trapstr; |
| |
| trapstr = trap[i]; |
| if (trapstr == NULL) |
| return; |
| |
| if (i == 0) |
| trap[i] = NULL; |
| |
| RUN(aword, trapstr, nlchar); |
| } |
| |
| |
| static void setdash(void) |
| { |
| char *cp; |
| int c; |
| char m['z' - 'a' + 1]; |
| |
| cp = m; |
| for (c = 'a'; c <= 'z'; c++) |
| if (flag[c]) |
| *cp++ = c; |
| *cp = '\0'; |
| setval(lookup("-"), m); |
| } |
| |
| static int newfile(char *s) |
| { |
| int f; |
| |
| DBGPRINTF7(("NEWFILE: opening %s\n", s)); |
| |
| f = 0; |
| if (NOT_LONE_DASH(s)) { |
| DBGPRINTF(("NEWFILE: s is %s\n", s)); |
| f = open(s, 0); |
| if (f < 0) { |
| prs(s); |
| err(": cannot open"); |
| return 1; |
| } |
| } |
| |
| next(remap(f)); |
| return 0; |
| } |
| |
| |
| struct op *scantree(struct op *head) |
| { |
| struct op *dotnode; |
| |
| if (head == NULL) |
| return NULL; |
| |
| if (head->left != NULL) { |
| dotnode = scantree(head->left); |
| if (dotnode) |
| return dotnode; |
| } |
| |
| if (head->right != NULL) { |
| dotnode = scantree(head->right); |
| if (dotnode) |
| return dotnode; |
| } |
| |
| if (head->words == NULL) |
| return NULL; |
| |
| DBGPRINTF5(("SCANTREE: checking node %p\n", head)); |
| |
| if ((head->type != TDOT) && LONE_CHAR(head->words[0], '.')) { |
| DBGPRINTF5(("SCANTREE: dot found in node %p\n", head)); |
| return head; |
| } |
| |
| return NULL; |
| } |
| |
| |
| static void onecommand(void) |
| { |
| int i; |
| jmp_buf m1; |
| |
| DBGPRINTF(("ONECOMMAND: enter, outtree=%p\n", outtree)); |
| |
| while (e.oenv) |
| quitenv(); |
| |
| areanum = 1; |
| freehere(areanum); |
| freearea(areanum); |
| garbage(); |
| wdlist = 0; |
| iolist = 0; |
| e.errpt = 0; |
| e.linep = line; |
| yynerrs = 0; |
| multiline = 0; |
| inparse = 1; |
| intr = 0; |
| execflg = 0; |
| |
| failpt = m1; |
| setjmp(failpt); /* Bruce Evans' fix */ |
| failpt = m1; |
| if (setjmp(failpt) || yyparse() || intr) { |
| DBGPRINTF(("ONECOMMAND: this is not good.\n")); |
| |
| while (e.oenv) |
| quitenv(); |
| scraphere(); |
| if (!interactive && intr) |
| leave(); |
| inparse = 0; |
| intr = 0; |
| return; |
| } |
| |
| inparse = 0; |
| brklist = 0; |
| intr = 0; |
| execflg = 0; |
| |
| if (!flag['n']) { |
| DBGPRINTF(("ONECOMMAND: calling execute, t=outtree=%p\n", |
| outtree)); |
| execute(outtree, NOPIPE, NOPIPE, 0); |
| } |
| |
| if (!interactive && intr) { |
| execflg = 0; |
| leave(); |
| } |
| |
| i = trapset; |
| if (i != 0) { |
| trapset = 0; |
| runtrap(i); |
| } |
| } |
| |
| static int newenv(int f) |
| { |
| struct env *ep; |
| |
| DBGPRINTF(("NEWENV: f=%d (indicates quitenv and return)\n", f)); |
| |
| if (f) { |
| quitenv(); |
| return 1; |
| } |
| |
| ep = (struct env *) space(sizeof(*ep)); |
| if (ep == NULL) { |
| while (e.oenv) |
| quitenv(); |
| fail(); |
| } |
| *ep = e; |
| e.oenv = ep; |
| e.errpt = errpt; |
| |
| return 0; |
| } |
| |
| static void quitenv(void) |
| { |
| struct env *ep; |
| int fd; |
| |
| DBGPRINTF(("QUITENV: e.oenv=%p\n", e.oenv)); |
| |
| ep = e.oenv; |
| if (ep != NULL) { |
| fd = e.iofd; |
| e = *ep; |
| /* should close `'d files */ |
| DELETE(ep); |
| while (--fd >= e.iofd) |
| close(fd); |
| } |
| } |
| |
| /* |
| * Is character c in s? |
| */ |
| static int any(int c, const char *s) |
| { |
| while (*s) |
| if (*s++ == c) |
| return 1; |
| return 0; |
| } |
| |
| /* |
| * Is any character from s1 in s2? |
| */ |
| static int anys(const char *s1, const char *s2) |
| { |
| while (*s1) |
| if (any(*s1++, s2)) |
| return 1; |
| return 0; |
| } |
| |
| static char *putn(int n) |
| { |
| return itoa(n); |
| } |
| |
| static void next(int f) |
| { |
| PUSHIO(afile, f, filechar); |
| } |
| |
| static void onintr(int s) /* ANSI C requires a parameter */ |
| { |
| signal(SIGINT, onintr); |
| intr = 1; |
| if (interactive) { |
| if (inparse) { |
| prs("\n"); |
| fail(); |
| } |
| } else if (heedint) { |
| execflg = 0; |
| leave(); |
| } |
| } |
| |
| |
| /* -------- gmatch.c -------- */ |
| /* |
| * int gmatch(string, pattern) |
| * char *string, *pattern; |
| * |
| * Match a pattern as in sh(1). |
| */ |
| |
| #define CMASK 0377 |
| #define QUOTE 0200 |
| #define QMASK (CMASK&~QUOTE) |
| #define NOT '!' /* might use ^ */ |
| |
| static const char *cclass(const char *p, int sub) |
| { |
| int c, d, not, found; |
| |
| not = (*p == NOT); |
| if (not != 0) |
| p++; |
| found = not; |
| do { |
| if (*p == '\0') |
| return NULL; |
| c = *p & CMASK; |
| if (p[1] == '-' && p[2] != ']') { |
| d = p[2] & CMASK; |
| p++; |
| } else |
| d = c; |
| if (c == sub || (c <= sub && sub <= d)) |
| found = !not; |
| } while (*++p != ']'); |
| return found ? p + 1 : NULL; |
| } |
| |
| static int gmatch(const char *s, const char *p) |
| { |
| int sc, pc; |
| |
| if (s == NULL || p == NULL) |
| return 0; |
| |
| while ((pc = *p++ & CMASK) != '\0') { |
| sc = *s++ & QMASK; |
| switch (pc) { |
| case '[': |
| p = cclass(p, sc); |
| if (p == NULL) |
| return 0; |
| break; |
| |
| case '?': |
| if (sc == 0) |
| return 0; |
| break; |
| |
| case '*': |
| s--; |
| do { |
| if (*p == '\0' || gmatch(s, p)) |
| return 1; |
| } while (*s++ != '\0'); |
| return 0; |
| |
| default: |
| if (sc != (pc & ~QUOTE)) |
| return 0; |
| } |
| } |
| return *s == '\0'; |
| } |
| |
| |
| /* -------- csyn.c -------- */ |
| /* |
| * shell: syntax (C version) |
| */ |
| |
| static void yyerror(const char *s) ATTRIBUTE_NORETURN; |
| static void yyerror(const char *s) |
| { |
| yynerrs++; |
| if (interactive && e.iop <= iostack) { |
| multiline = 0; |
| while (eofc() == 0 && yylex(0) != '\n'); |
| } |
| err(s); |
| fail(); |
| } |
| |
| static void zzerr(void) ATTRIBUTE_NORETURN; |
| static void zzerr(void) |
| { |
| yyerror("syntax error"); |
| } |
| |
| int yyparse(void) |
| { |
| DBGPRINTF7(("YYPARSE: enter...\n")); |
| |
| startl = 1; |
| peeksym = 0; |
| yynerrs = 0; |
| outtree = c_list(); |
| musthave('\n', 0); |
| return (yynerrs != 0); |
| } |
| |
| static struct op *pipeline(int cf) |
| { |
| struct op *t, *p; |
| int c; |
| |
| DBGPRINTF7(("PIPELINE: enter, cf=%d\n", cf)); |
| |
| t = command(cf); |
| |
| DBGPRINTF9(("PIPELINE: t=%p\n", t)); |
| |
| if (t != NULL) { |
| while ((c = yylex(0)) == '|') { |
| p = command(CONTIN); |
| if (p == NULL) { |
| DBGPRINTF8(("PIPELINE: error!\n")); |
| zzerr(); |
| } |
| |
| if (t->type != TPAREN && t->type != TCOM) { |
| /* shell statement */ |
| t = block(TPAREN, t, NOBLOCK, NOWORDS); |
| } |
| |
| t = block(TPIPE, t, p, NOWORDS); |
| } |
| peeksym = c; |
| } |
| |
| DBGPRINTF7(("PIPELINE: returning t=%p\n", t)); |
| return t; |
| } |
| |
| static struct op *andor(void) |
| { |
| struct op *t, *p; |
| int c; |
| |
| DBGPRINTF7(("ANDOR: enter...\n")); |
| |
| t = pipeline(0); |
| |
| DBGPRINTF9(("ANDOR: t=%p\n", t)); |
| |
| if (t != NULL) { |
| while ((c = yylex(0)) == LOGAND || c == LOGOR) { |
| p = pipeline(CONTIN); |
| if (p == NULL) { |
| DBGPRINTF8(("ANDOR: error!\n")); |
| zzerr(); |
| } |
| |
| t = block(c == LOGAND ? TAND : TOR, t, p, NOWORDS); |
| } /* WHILE */ |
| |
| peeksym = c; |
| } |
| |
| DBGPRINTF7(("ANDOR: returning t=%p\n", t)); |
| return t; |
| } |
| |
| static struct op *c_list(void) |
| { |
| struct op *t, *p; |
| int c; |
| |
| DBGPRINTF7(("C_LIST: enter...\n")); |
| |
| t = andor(); |
| |
| if (t != NULL) { |
| peeksym = yylex(0); |
| if (peeksym == '&') |
| t = block(TASYNC, t, NOBLOCK, NOWORDS); |
| |
| while ((c = yylex(0)) == ';' || c == '&' |
| || (multiline && c == '\n')) { |
| |
| p = andor(); |
| if (p== NULL) |
| return t; |
| |
| peeksym = yylex(0); |
| if (peeksym == '&') |
| p = block(TASYNC, p, NOBLOCK, NOWORDS); |
| |
| t = list(t, p); |
| } /* WHILE */ |
| |
| peeksym = c; |
| } |
| /* IF */ |
| DBGPRINTF7(("C_LIST: returning t=%p\n", t)); |
| return t; |
| } |
| |
| static int synio(int cf) |
| { |
| struct ioword *iop; |
| int i; |
| int c; |
| |
| DBGPRINTF7(("SYNIO: enter, cf=%d\n", cf)); |
| |
| c = yylex(cf); |
| if (c != '<' && c != '>') { |
| peeksym = c; |
| return 0; |
| } |
| |
| i = yylval.i; |
| musthave(WORD, 0); |
| iop = io(iounit, i, yylval.cp); |
| iounit = IODEFAULT; |
| |
| if (i & IOHERE) |
| markhere(yylval.cp, iop); |
| |
| DBGPRINTF7(("SYNIO: returning 1\n")); |
| return 1; |
| } |
| |
| static void musthave(int c, int cf) |
| { |
| peeksym = yylex(cf); |
| if (peeksym != c) { |
| DBGPRINTF7(("MUSTHAVE: error!\n")); |
| zzerr(); |
| } |
| |
| peeksym = 0; |
| } |
| |
| static struct op *simple(void) |
| { |
| struct op *t; |
| |
| t = NULL; |
| for (;;) { |
| switch (peeksym = yylex(0)) { |
| case '<': |
| case '>': |
| (void) synio(0); |
| break; |
| |
| case WORD: |
| if (t == NULL) { |
| t = newtp(); |
| t->type = TCOM; |
| } |
| peeksym = 0; |
| word(yylval.cp); |
| break; |
| |
| default: |
| return t; |
| } |
| } |
| } |
| |
| static struct op *nested(int type, int mark) |
| { |
| struct op *t; |
| |
| DBGPRINTF3(("NESTED: enter, type=%d, mark=%d\n", type, mark)); |
| |
| multiline++; |
| t = c_list(); |
| musthave(mark, 0); |
| multiline--; |
| return block(type, t, NOBLOCK, NOWORDS); |
| } |
| |
| static struct op *command(int cf) |
| { |
| struct op *t; |
| struct wdblock *iosave; |
| int c; |
| |
| DBGPRINTF(("COMMAND: enter, cf=%d\n", cf)); |
| |
| iosave = iolist; |
| iolist = NULL; |
| |
| if (multiline) |
| cf |= CONTIN; |
| |
| while (synio(cf)) |
| cf = 0; |
| |
| c = yylex(cf); |
| |
| switch (c) { |
| default: |
| peeksym = c; |
| t = simple(); |
| if (t == NULL) { |
| if (iolist == NULL) |
| return NULL; |
| t = newtp(); |
| t->type = TCOM; |
| } |
| break; |
| |
| case '(': |
| t = nested(TPAREN, ')'); |
| break; |
| |
| case '{': |
| t = nested(TBRACE, '}'); |
| break; |
| |
| case FOR: |
| t = newtp(); |
| t->type = TFOR; |
| musthave(WORD, 0); |
| startl = 1; |
| t->str = yylval.cp; |
| multiline++; |
| t->words = wordlist(); |
| c = yylex(0); |
| if (c != '\n' && c != ';') |
| peeksym = c; |
| t->left = dogroup(0); |
| multiline--; |
| break; |
| |
| case WHILE: |
| case UNTIL: |
| multiline++; |
| t = newtp(); |
| t->type = c == WHILE ? TWHILE : TUNTIL; |
| t->left = c_list(); |
| t->right = dogroup(1); |
| t->words = NULL; |
| multiline--; |
| break; |
| |
| case CASE: |
| t = newtp(); |
| t->type = TCASE; |
| musthave(WORD, 0); |
| t->str = yylval.cp; |
| startl++; |
| multiline++; |
| musthave(IN, CONTIN); |
| startl++; |
| |
| t->left = caselist(); |
| |
| musthave(ESAC, 0); |
| multiline--; |
| break; |
| |
| case IF: |
| multiline++; |
| t = newtp(); |
| t->type = TIF; |
| t->left = c_list(); |
| t->right = thenpart(); |
| musthave(FI, 0); |
| multiline--; |
| break; |
| |
| case DOT: |
| t = newtp(); |
| t->type = TDOT; |
| |
| musthave(WORD, 0); /* gets name of file */ |
| DBGPRINTF7(("COMMAND: DOT clause, yylval.cp is %s\n", yylval.cp)); |
| |
| word(yylval.cp); /* add word to wdlist */ |
| word(NOWORD); /* terminate wdlist */ |
| t->words = copyw(); /* dup wdlist */ |
| break; |
| |
| } |
| |
| while (synio(0)); |
| |
| t = namelist(t); |
| iolist = iosave; |
| |
| DBGPRINTF(("COMMAND: returning %p\n", t)); |
| |
| return t; |
| } |
| |
| static struct op *dowholefile(int type, int mark) |
| { |
| struct op *t; |
| |
| DBGPRINTF(("DOWHOLEFILE: enter, type=%d, mark=%d\n", type, mark)); |
| |
| multiline++; |
| t = c_list(); |
| multiline--; |
| t = block(type, t, NOBLOCK, NOWORDS); |
| DBGPRINTF(("DOWHOLEFILE: return t=%p\n", t)); |
| return t; |
| } |
| |
| static struct op *dogroup(int onlydone) |
| { |
| int c; |
| struct op *mylist; |
| |
| c = yylex(CONTIN); |
| if (c == DONE && onlydone) |
| return NULL; |
| if (c != DO) |
| zzerr(); |
| mylist = c_list(); |
| musthave(DONE, 0); |
| return mylist; |
| } |
| |
| static struct op *thenpart(void) |
| { |
| int c; |
| struct op *t; |
| |
| c = yylex(0); |
| if (c != THEN) { |
| peeksym = c; |
| return NULL; |
| } |
| t = newtp(); |
| t->type = 0; |
| t->left = c_list(); |
| if (t->left == NULL) |
| zzerr(); |
| t->right = elsepart(); |
| return t; |
| } |
| |
| static struct op *elsepart(void) |
| { |
| int c; |
| struct op *t; |
| |
| switch (c = yylex(0)) { |
| case ELSE: |
| t = c_list(); |
| if (t == NULL) |
| zzerr(); |
| return t; |
| |
| case ELIF: |
| t = newtp(); |
| t->type = TELIF; |
| t->left = c_list(); |
| t->right = thenpart(); |
| return t; |
| |
| default: |
| peeksym = c; |
| return NULL; |
| } |
| } |
| |
| static struct op *caselist(void) |
| { |
| struct op *t; |
| |
| t = NULL; |
| while ((peeksym = yylex(CONTIN)) != ESAC) { |
| DBGPRINTF(("CASELIST, doing yylex, peeksym=%d\n", peeksym)); |
| t = list(t, casepart()); |
| } |
| |
| DBGPRINTF(("CASELIST, returning t=%p\n", t)); |
| return t; |
| } |
| |
| static struct op *casepart(void) |
| { |
| struct op *t; |
| |
| DBGPRINTF7(("CASEPART: enter...\n")); |
| |
| t = newtp(); |
| t->type = TPAT; |
| t->words = pattern(); |
| musthave(')', 0); |
| t->left = c_list(); |
| peeksym = yylex(CONTIN); |
| if (peeksym != ESAC) |
| musthave(BREAK, CONTIN); |
| |
| DBGPRINTF7(("CASEPART: made newtp(TPAT, t=%p)\n", t)); |
| |
| return t; |
| } |
| |
| static char **pattern(void) |
| { |
| int c, cf; |
| |
| cf = CONTIN; |
| do { |
| musthave(WORD, cf); |
| word(yylval.cp); |
| cf = 0; |
| c = yylex(0); |
| } while (c == '|'); |
| peeksym = c; |
| word(NOWORD); |
| |
| return copyw(); |
| } |
| |
| static char **wordlist(void) |
| { |
| int c; |
| |
| c = yylex(0); |
| if (c != IN) { |
| peeksym = c; |
| return NULL; |
| } |
| startl = 0; |
| while ((c = yylex(0)) == WORD) |
| word(yylval.cp); |
| word(NOWORD); |
| peeksym = c; |
| return copyw(); |
| } |
| |
| /* |
| * supporting functions |
| */ |
| static struct op *list(struct op *t1, struct op *t2) |
| { |
| DBGPRINTF7(("LIST: enter, t1=%p, t2=%p\n", t1, t2)); |
| |
| if (t1 == NULL) |
| return t2; |
| if (t2 == NULL) |
| return t1; |
| |
| return block(TLIST, t1, t2, NOWORDS); |
| } |
| |
| static struct op *block(int type, struct op *t1, struct op *t2, char **wp) |
| { |
| struct op *t; |
| |
| DBGPRINTF7(("BLOCK: enter, type=%d (%s)\n", type, T_CMD_NAMES[type])); |
| |
| t = newtp(); |
| t->type = type; |
| t->left = t1; |
| t->right = t2; |
| t->words = wp; |
| |
| DBGPRINTF7(("BLOCK: inserted %p between %p and %p\n", t, t1, |
| t2)); |
| |
| return t; |
| } |
| |
| /* See if given string is a shell multiline (FOR, IF, etc) */ |
| static int rlookup(char *n) |
| { |
| const struct res *rp; |
| |
| DBGPRINTF7(("RLOOKUP: enter, n is %s\n", n)); |
| |
| for (rp = restab; rp->r_name; rp++) |
| if (strcmp(rp->r_name, n) == 0) { |
| DBGPRINTF7(("RLOOKUP: match, returning %d\n", rp->r_val)); |
| return rp->r_val; /* Return numeric code for shell multiline */ |
| } |
| |
| DBGPRINTF7(("RLOOKUP: NO match, returning 0\n")); |
| return 0; /* Not a shell multiline */ |
| } |
| |
| static struct op *newtp(void) |
| { |
| struct op *t; |
| |
| t = (struct op *) tree(sizeof(*t)); |
| t->type = 0; |
| t->words = NULL; |
| t->ioact = NULL; |
| t->left = NULL; |
| t->right = NULL; |
| t->str = NULL; |
| |
| DBGPRINTF3(("NEWTP: allocated %p\n", t)); |
| |
| return t; |
| } |
| |
| static struct op *namelist(struct op *t) |
| { |
| |
| DBGPRINTF7(("NAMELIST: enter, t=%p, type %s, iolist=%p\n", t, |
| T_CMD_NAMES[t->type], iolist)); |
| |
| if (iolist) { |
| iolist = addword((char *) NULL, iolist); |
| t->ioact = copyio(); |
| } else |
| t->ioact = NULL; |
| |
| if (t->type != TCOM) { |
| if (t->type != TPAREN && t->ioact != NULL) { |
| t = block(TPAREN, t, NOBLOCK, NOWORDS); |
| t->ioact = t->left->ioact; |
| t->left->ioact = NULL; |
| } |
| return t; |
| } |
| |
| word(NOWORD); |
| t->words = copyw(); |
| |
| return t; |
| } |
| |
| static char **copyw(void) |
| { |
| char **wd; |
| |
| wd = getwords(wdlist); |
| wdlist = 0; |
| return wd; |
| } |
| |
| static void word(char *cp) |
| { |
| wdlist = addword(cp, wdlist); |
| } |
| |
| static struct ioword **copyio(void) |
| { |
| struct ioword **iop; |
| |
| iop = (struct ioword **) getwords(iolist); |
| iolist = 0; |
| return iop; |
| } |
| |
| static struct ioword *io(int u, int f, char *cp) |
| { |
| struct ioword *iop; |
| |
| iop = (struct ioword *) tree(sizeof(*iop)); |
| iop->io_unit = u; |
| iop->io_flag = f; |
| iop->io_name = cp; |
| iolist = addword((char *) iop, iolist); |
| return iop; |
| } |
| |
| static int yylex(int cf) |
| { |
| int c, c1; |
| int atstart; |
| |
| c = peeksym; |
| if (c > 0) { |
| peeksym = 0; |
| if (c == '\n') |
| startl = 1; |
| return c; |
| } |
| |
| nlseen = 0; |
| atstart = startl; |
| startl = 0; |
| yylval.i = 0; |
| e.linep = line; |
| |
| /* MALAMO */ |
| line[LINELIM - 1] = '\0'; |
| |
| loop: |
| while ((c = my_getc(0)) == ' ' || c == '\t') /* Skip whitespace */ |
| ; |
| |
| switch (c) { |
| default: |
| if (any(c, "0123456789")) { |
| c1 = my_getc(0); |
| unget(c1); |
| if (c1 == '<' || c1 == '>') { |
| iounit = c - '0'; |
| goto loop; |
| } |
| *e.linep++ = c; |
| c = c1; |
| } |
| break; |
| |
| case '#': /* Comment, skip to next newline or End-of-string */ |
| while ((c = my_getc(0)) != '\0' && c != '\n'); |
| unget(c); |
| goto loop; |
| |
| case 0: |
| DBGPRINTF5(("YYLEX: return 0, c=%d\n", c)); |
| return c; |
| |
| case '$': |
| DBGPRINTF9(("YYLEX: found $\n")); |
| *e.linep++ = c; |
| c = my_getc(0); |
| if (c == '{') { |
| c = collect(c, '}'); |
| if (c != '\0') |
| return c; |
| goto pack; |
| } |
| break; |
| |
| case '`': |
| case '\'': |
| case '"': |
| c = collect(c, c); |
| if (c != '\0') |
| return c; |
| goto pack; |
| |
| case '|': |
| case '&': |
| case ';': |
| startl = 1; |
| /* If more chars process them, else return NULL char */ |
| c1 = dual(c); |
| if (c1 != '\0') |
| return c1; |
| return c; |
| |
| case '^': |
| startl = 1; |
| return '|'; |
| case '>': |
| case '<': |
| diag(c); |
| return c; |
| |
| case '\n': |
| nlseen++; |
| gethere(); |
| startl = 1; |
| if (multiline || cf & CONTIN) { |
| if (interactive && e.iop <= iostack) { |
| #if ENABLE_FEATURE_EDITING |
| current_prompt = cprompt->value; |
| #else |
| prs(cprompt->value); |
| #endif |
| } |
| if (cf & CONTIN) |
| goto loop; |
| } |
| return c; |
| |
| case '(': |
| case ')': |
| startl = 1; |
| return c; |
| } |
| |
| unget(c); |
| |
| pack: |
| while ((c = my_getc(0)) != '\0' && !any(c, "`$ '\"\t;&<>()|^\n")) { |
| if (e.linep >= elinep) |
| err("word too long"); |
| else |
| *e.linep++ = c; |
| }; |
| |
| unget(c); |
| |
| if (any(c, "\"'`$")) |
| goto loop; |
| |
| *e.linep++ = '\0'; |
| |
| if (atstart) { |
| c = rlookup(line); |
| if (c != 0) { |
| startl = 1; |
| return c; |
| } |
| } |
| |
| yylval.cp = strsave(line, areanum); |
| return WORD; |
| } |
| |
| |
| static int collect(int c, int c1) |
| { |
| char s[2]; |
| |
| DBGPRINTF8(("COLLECT: enter, c=%d, c1=%d\n", c, c1)); |
| |
| *e.linep++ = c; |
| while ((c = my_getc(c1)) != c1) { |
| if (c == 0) { |
| unget(c); |
| s[0] = c1; |
| s[1] = 0; |
| prs("no closing "); |
| yyerror(s); |
| return YYERRCODE; |
| } |
| if (interactive && c == '\n' && e.iop <= iostack) { |
| #if ENABLE_FEATURE_EDITING |
| current_prompt = cprompt->value; |
| #else |
| prs(cprompt->value); |
| #endif |
| } |
| *e.linep++ = c; |
| } |
| |
| *e.linep++ = c; |
| |
| DBGPRINTF8(("COLLECT: return 0, line is %s\n", line)); |
| |
| return 0; |
| } |
| |
| /* "multiline commands" helper func */ |
| /* see if next 2 chars form a shell multiline */ |
| static int dual(int c) |
| { |
| char s[3]; |
| char *cp = s; |
| |
| DBGPRINTF8(("DUAL: enter, c=%d\n", c)); |
| |
| *cp++ = c; /* c is the given "peek" char */ |
| *cp++ = my_getc(0); /* get next char of input */ |
| *cp = '\0'; /* add EOS marker */ |
| |
| c = rlookup(s); /* see if 2 chars form a shell multiline */ |
| if (c == 0) |
| unget(*--cp); /* String is not a shell multiline, put peek char back */ |
| |
| return c; /* String is multiline, return numeric multiline (restab) code */ |
| } |
| |
| static void diag(int ec) |
| { |
| int c; |
| |
| DBGPRINTF8(("DIAG: enter, ec=%d\n", ec)); |
| |
| c = my_getc(0); |
| if (c == '>' || c == '<') { |
| if (c != ec) |
| zzerr(); |
| yylval.i = (ec == '>' ? IOWRITE | IOCAT : IOHERE); |
| c = my_getc(0); |
| } else |
| yylval.i = (ec == '>' ? IOWRITE : IOREAD); |
| if (c != '&' || yylval.i == IOHERE) |
| unget(c); |
| else |
| yylval.i |= IODUP; |
| } |
| |
| static char *tree(unsigned size) |
| { |
| char *t; |
| |
| t = getcell(size); |
| if (t == NULL) { |
| DBGPRINTF2(("TREE: getcell(%d) failed!\n", size)); |
| prs("command line too complicated\n"); |
| fail(); |
| /* NOTREACHED */ |
| } |
| return t; |
| } |
| |
| |
| /* VARARGS1 */ |
| /* ARGSUSED */ |
| |
| /* -------- exec.c -------- */ |
| |
| static struct op **find1case(struct op *t, const char *w) |
| { |
| struct op *t1; |
| struct op **tp; |
| char **wp; |
| char *cp; |
| |
| if (t == NULL) { |
| DBGPRINTF3(("FIND1CASE: enter, t==NULL, returning.\n")); |
| return NULL; |
| } |
| |
| DBGPRINTF3(("FIND1CASE: enter, t->type=%d (%s)\n", t->type, |
| T_CMD_NAMES[t->type])); |
| |
| if (t->type == TLIST) { |
| tp = find1case(t->left, w); |
| if (tp != NULL) { |
| DBGPRINTF3(("FIND1CASE: found one to the left, returning tp=%p\n", tp)); |
| return tp; |
| } |
| t1 = t->right; /* TPAT */ |
| } else |
| t1 = t; |
| |
| for (wp = t1->words; *wp;) { |
| cp = evalstr(*wp++, DOSUB); |
| if (cp && gmatch(w, cp)) { |
| DBGPRINTF3(("FIND1CASE: returning &t1->left= %p.\n", |
| &t1->left)); |
| return &t1->left; |
| } |
| } |
| |
| DBGPRINTF(("FIND1CASE: returning NULL\n")); |
| return NULL; |
| } |
| |
| static struct op *findcase(struct op *t, const char *w) |
| { |
| struct op **tp; |
| |
| tp = find1case(t, w); |
| return tp != NULL ? *tp : NULL; |
| } |
| |
| /* |
| * execute tree |
| */ |
| |
| static int execute(struct op *t, int *pin, int *pout, int act) |
| { |
| struct op *t1; |
| volatile int i, rv, a; |
| const char *cp; |
| char **wp, **wp2; |
| struct var *vp; |
| struct op *outtree_save; |
| struct brkcon bc; |
| |
| #if __GNUC__ |
| /* Avoid longjmp clobbering */ |
| (void) ℘ |
| #endif |
| |
| if (t == NULL) { |
| DBGPRINTF4(("EXECUTE: enter, t==null, returning.\n")); |
| return 0; |
| } |
| |
| DBGPRINTF(("EXECUTE: t=%p, t->type=%d (%s), t->words is %s\n", t, |
| t->type, T_CMD_NAMES[t->type], |
| ((t->words == NULL) ? "NULL" : t->words[0]))); |
| |
| rv = 0; |
| a = areanum++; |
| wp = (wp2 = t->words) != NULL |
| ? eval(wp2, t->type == TCOM ? DOALL : DOALL & ~DOKEY) |
| : NULL; |
| |
| switch (t->type) { |
| case TDOT: |
| DBGPRINTF3(("EXECUTE: TDOT\n")); |
| |
| outtree_save = outtree; |
| |
| newfile(evalstr(t->words[0], DOALL)); |
| |
| t->left = dowholefile(TLIST, 0); |
| t->right = NULL; |
| |
| outtree = outtree_save; |
| |
| if (t->left) |
| rv = execute(t->left, pin, pout, 0); |
| if (t->right) |
| rv = execute(t->right, pin, pout, 0); |
| break; |
| |
| case TPAREN: |
| rv = execute(t->left, pin, pout, 0); |
| break; |
| |
| case TCOM: |
| rv = forkexec(t, pin, pout, act, wp); |
| break; |
| |
| case TPIPE: |
| { |
| int pv[2]; |
| |
| rv = openpipe(pv); |
| if (rv < 0) |
| break; |
| pv[0] = remap(pv[0]); |
| pv[1] = remap(pv[1]); |
| (void) execute(t->left, pin, pv, 0); |
| rv = execute(t->right, pv, pout, 0); |
| } |
| break; |
| |
| case TLIST: |
| (void) execute(t->left, pin, pout, 0); |
| rv = execute(t->right, pin, pout, 0); |
| break; |
| |
| case TASYNC: |
| { |
| int hinteractive = interactive; |
| |
| DBGPRINTF7(("EXECUTE: TASYNC clause, calling vfork()...\n")); |
| |
| i = vfork(); |
| if (i == 0) { /* child */ |
| signal(SIGINT, SIG_IGN); |
| signal(SIGQUIT, SIG_IGN); |
| if (interactive) |
| signal(SIGTERM, SIG_DFL); |
| interactive = 0; |
| if (pin == NULL) { |
| close(0); |
| open(bb_dev_null, 0); |
| } |
| _exit(execute(t->left, pin, pout, FEXEC)); |
| } |
| interactive = hinteractive; |
| if (i != -1) { |
| setval(lookup("!"), putn(i)); |
| if (pin != NULL) |
| closepipe(pin); |
| if (interactive) { |
| prs(putn(i)); |
| prs("\n"); |
| } |
| } else |
| rv = -1; |
| setstatus(rv); |
| } |
| break; |
| |
| case TOR: |
| case TAND: |
| rv = execute(t->left, pin, pout, 0); |
| t1 = t->right; |
| if (t1 != NULL && (rv == 0) == (t->type == TAND)) |
| rv = execute(t1, pin, pout, 0); |
| break; |
| |
| case TFOR: |
| if (wp == NULL) { |
| wp = dolv + 1; |
| i = dolc; |
| if (i < 0) |
| i = 0; |
| } else { |
| i = -1; |
| while (*wp++ != NULL); |
| } |
| vp = lookup(t->str); |
| while (setjmp(bc.brkpt)) |
| if (isbreak) |
| goto broken; |
| brkset(&bc); |
| for (t1 = t->left; i-- && *wp != NULL;) { |
| setval(vp, *wp++); |
| rv = execute(t1, pin, pout, 0); |
| } |
| brklist = brklist->nextlev; |
| break; |
| |
| case TWHILE: |
| case TUNTIL: |
| while (setjmp(bc.brkpt)) |
| if (isbreak) |
| goto broken; |
| brkset(&bc); |
| t1 = t->left; |
| while ((execute(t1, pin, pout, 0) == 0) == (t->type == TWHILE)) |
| rv = execute(t->right, pin, pout, 0); |
| brklist = brklist->nextlev; |
| break; |
| |
| case TIF: |
| case TELIF: |
| if (t->right != NULL) { |
| rv = !execute(t->left, pin, pout, 0) ? |
| execute(t->right->left, pin, pout, 0) : |
| execute(t->right->right, pin, pout, 0); |
| } |
| break; |
| |
| case TCASE: |
| cp = evalstr(t->str, DOSUB | DOTRIM); |
| if (cp == NULL) |
| cp = ""; |
| |
| DBGPRINTF7(("EXECUTE: TCASE, t->str is %s, cp is %s\n", |
| ((t->str == NULL) ? "NULL" : t->str), |
| ((cp == NULL) ? "NULL" : cp))); |
| |
| t1 = findcase(t->left, cp); |
| if (t1 != NULL) { |
| DBGPRINTF7(("EXECUTE: TCASE, calling execute(t=%p, t1=%p)...\n", t, t1)); |
| rv = execute(t1, pin, pout, 0); |
| DBGPRINTF7(("EXECUTE: TCASE, back from execute(t=%p, t1=%p)...\n", t, t1)); |
| } |
| break; |
| |
| case TBRACE: |
| /* |
| iopp = t->ioact; |
| if (i) |
| while (*iopp) |
| if (iosetup(*iopp++, pin!=NULL, pout!=NULL)) { |
| rv = -1; |
| break; |
| } |
| */ |
| if (rv >= 0) { |
| t1 = t->left; |
| if (t1) { |
| rv = execute(t1, pin, pout, 0); |
| } |
| } |
| break; |
| |
| }; |
| |
| broken: |
| t->words = wp2; |
| isbreak = 0; |
| freehere(areanum); |
| freearea(areanum); |
| areanum = a; |
| if (interactive && intr) { |
| closeall(); |
| fail(); |
| } |
| |
| i = trapset; |
| if (i != 0) { |
| trapset = 0; |
| runtrap(i); |
| } |
| |
| DBGPRINTF(("EXECUTE: returning from t=%p, rv=%d\n", t, rv)); |
| return rv; |
| } |
| |
| typedef int (*builtin_func_ptr)(struct op *); |
| |
| static builtin_func_ptr inbuilt(const char *s) { |
| const struct builtincmd *bp; |
| |
| for (bp = builtincmds; bp->name != NULL; bp++) |
| if (strcmp(bp->name, s) == 0) |
| return bp->builtinfunc; |
| |
| return NULL; |
| } |
| |
| static int forkexec(struct op *t, int *pin, int *pout, int act, char **wp) |
| { |
| pid_t newpid; |
| int i, rv; |
| builtin_func_ptr shcom = NULL; |
| int f; |
| const char *cp = NULL; |
| struct ioword **iopp; |
| int resetsig; |
| char **owp; |
| int forked = 0; |
| |
| int *hpin = pin; |
| int *hpout = pout; |
| char *hwp; |
| int hinteractive; |
| int hintr; |
| struct brkcon *hbrklist; |
| int hexecflg; |
| |
| #if __GNUC__ |
| /* Avoid longjmp clobbering */ |
| (void) &pin; |
| (void) &pout; |
| (void) ℘ |
| (void) &shcom; |
| (void) &cp; |
| (void) &resetsig; |
| (void) &owp; |
| #endif |
| |
| DBGPRINTF(("FORKEXEC: t=%p, pin %p, pout %p, act %d\n", t, pin, |
| pout, act)); |
| DBGPRINTF7(("FORKEXEC: t->words is %s\n", |
| ((t->words == NULL) ? "NULL" : t->words[0]))); |
| |
| owp = wp; |
| resetsig = 0; |
| rv = -1; /* system-detected error */ |
| if (t->type == TCOM) { |
| while (*wp++ != NULL); |
| cp = *wp; |
| |
| /* strip all initial assignments */ |
| /* not correct wrt PATH=yyy command etc */ |
| if (flag['x']) { |
| DBGPRINTF9(("FORKEXEC: echo'ing, cp=%p, wp=%p, owp=%p\n", |
| cp, wp, owp)); |
| echo(cp ? wp : owp); |
| } |
| |
| if (cp == NULL && t->ioact == NULL) { |
| while ((cp = *owp++) != NULL && assign(cp, COPYV)) |
| /**/; |
| DBGPRINTF(("FORKEXEC: returning setstatus()\n")); |
| return setstatus(0); |
| } |
| if (cp != NULL) { |
| shcom = inbuilt(cp); |
| } |
| } |
| |
| t->words = wp; |
| f = act; |
| |
| DBGPRINTF(("FORKEXEC: shcom %p, f&FEXEC 0x%x, owp %p\n", shcom, |
| f & FEXEC, owp)); |
| |
| if (shcom == NULL && (f & FEXEC) == 0) { |
| /* Save values in case the child process alters them */ |
| hpin = pin; |
| hpout = pout; |
| hwp = *wp; |
| hinteractive = interactive; |
| hintr = intr; |
| hbrklist = brklist; |
| hexecflg = execflg; |
| |
| DBGPRINTF3(("FORKEXEC: calling vfork()...\n")); |
| |
| newpid = vfork(); |
| |
| if (newpid == -1) { |
| DBGPRINTF(("FORKEXEC: ERROR, cannot vfork()!\n")); |
| return -1; |
| } |
| |
| if (newpid > 0) { /* Parent */ |
| /* Restore values */ |
| pin = hpin; |
| pout = hpout; |
| *wp = hwp; |
| interactive = hinteractive; |
| intr = hintr; |
| brklist = hbrklist; |
| execflg = hexecflg; |
| /* moved up |
| if (i == -1) |
| return rv; |
| */ |
| if (pin != NULL) |
| closepipe(pin); |
| |
| return (pout == NULL ? setstatus(waitfor(newpid, 0)) : 0); |
| } |
| |
| /* Must be the child process, pid should be 0 */ |
| DBGPRINTF(("FORKEXEC: child process, shcom=%p\n", shcom)); |
| |
| if (interactive) { |
| signal(SIGINT, SIG_IGN); |
| signal(SIGQUIT, SIG_IGN); |
| resetsig = 1; |
| } |
| interactive = 0; |
| intr = 0; |
| forked = 1; |
| brklist = 0; |
| execflg = 0; |
| } |
| |
| if (owp != NULL) |
| while ((cp = *owp++) != NULL && assign(cp, COPYV)) |
| if (shcom == NULL) |
| export(lookup(cp)); |
| |
| #ifdef COMPIPE |
| if ((pin != NULL || pout != NULL) && shcom != NULL && shcom != doexec) { |
| err("piping to/from shell builtins not yet done"); |
| if (forked) |
| _exit(-1); |
| return -1; |
| } |
| #endif |
| |
| if (pin != NULL) { |
| dup2(pin[0], 0); |
| closepipe(pin); |
| } |
| if (pout != NULL) { |
| dup2(pout[1], 1); |
| closepipe(pout); |
| } |
| |
| iopp = t->ioact; |
| if (iopp != NULL) { |
| if (shcom != NULL && shcom != doexec) { |
| prs(cp); |
| err(": cannot redirect shell command"); |
| if (forked) |
| _exit(-1); |
| return -1; |
| } |
| while (*iopp) |
| if (iosetup(*iopp++, pin != NULL, pout != NULL)) { |
| if (forked) |
| _exit(rv); |
| return rv; |
| } |
| } |
| |
| if (shcom) { |
| i = setstatus((*shcom) (t)); |
| if (forked) |
| _exit(i); |
| DBGPRINTF(("FORKEXEC: returning i=%d\n", i)); |
| return i; |
| } |
| |
| /* should use FIOCEXCL */ |
| for (i = FDBASE; i < NOFILE; i++) |
| close(i); |
| if (resetsig) { |
| signal(SIGINT, SIG_DFL); |
| signal(SIGQUIT, SIG_DFL); |
| } |
| |
| if (t->type == TPAREN) |
| _exit(execute(t->left, NOPIPE, NOPIPE, FEXEC)); |
| if (wp[0] == NULL) |
| _exit(0); |
| |
| cp = rexecve(wp[0], wp, makenv(0, NULL)); |
| prs(wp[0]); |
| prs(": "); |
| err(cp); |
| if (!execflg) |
| trap[0] = NULL; |
| |
| DBGPRINTF(("FORKEXEC: calling leave(), pid=%d\n", newpid)); |
| |
| leave(); |
| /* NOTREACHED */ |
| _exit(1); |
| } |
| |
| /* |
| * 0< 1> are ignored as required |
| * within pipelines. |
| */ |
| static int iosetup(struct ioword *iop, int pipein, int pipeout) |
| { |
| int u = -1; |
| char *cp = NULL; |
| const char *msg; |
| |
| DBGPRINTF(("IOSETUP: iop %p, pipein %i, pipeout %i\n", iop, |
| pipein, pipeout)); |
| |
| if (iop->io_unit == IODEFAULT) /* take default */ |
| iop->io_unit = iop->io_flag & (IOREAD | IOHERE) ? 0 : 1; |
| |
| if (pipein && iop->io_unit == 0) |
| return 0; |
| |
| if (pipeout && iop->io_unit == 1) |
| return 0; |
| |
| msg = iop->io_flag & (IOREAD | IOHERE) ? "open" : "create"; |
| if ((iop->io_flag & IOHERE) == 0) { |
| cp = iop->io_name; /* huh?? */ |
| cp = evalstr(cp, DOSUB | DOTRIM); |
| if (cp == NULL) |
| return 1; |
| } |
| |
| if (iop->io_flag & IODUP) { |
| if (cp[1] || (!isdigit(*cp) && *cp != '-')) { |
| prs(cp); |
| err(": illegal >& argument"); |
| return 1; |
| } |
| if (*cp == '-') |
| iop->io_flag = IOCLOSE; |
| iop->io_flag &= ~(IOREAD | IOWRITE); |
| } |
| switch (iop->io_flag) { |
| case IOREAD: |
| u = open(cp, 0); |
| break; |
| |
| case IOHERE: |
| case IOHERE | IOXHERE: |
| u = herein(iop->io_name, iop->io_flag & IOXHERE); |
| cp = (char*)"here file"; |
| break; |
| |
| case IOWRITE | IOCAT: |
| u = open(cp, 1); |
| if (u >= 0) { |
| lseek(u, (long) 0, SEEK_END); |
| break; |
| } |
| case IOWRITE: |
| u = creat(cp, 0666); |
| break; |
| |
| case IODUP: |
| u = dup2(*cp - '0', iop->io_unit); |
| break; |
| |
| case IOCLOSE: |
| close(iop->io_unit); |
| return 0; |
| } |
| if (u < 0) { |
| prs(cp); |
| prs(": cannot "); |
| warn(msg); |
| return 1; |
| } |
| if (u != iop->io_unit) { |
| dup2(u, iop->io_unit); |
| close(u); |
| } |
| return 0; |
| } |
| |
| /* |
| * Enter a new loop level (marked for break/continue). |
| */ |
| static void brkset(struct brkcon *bc) |
| { |
| bc->nextlev = brklist; |
| brklist = bc; |
| } |
| |
| /* |
| * Wait for the last process created. |
| * Print a message for each process found |
| * that was killed by a signal. |
| * Ignore interrupt signals while waiting |
| * unless `canintr' is true. |
| */ |
| static int waitfor(int lastpid, int canintr) |
| { |
| int pid, rv; |
| int s; |
| int oheedint = heedint; |
| |
| heedint = 0; |
| rv = 0; |
| do { |
| pid = wait(&s); |
| if (pid == -1) { |
| if (errno != EINTR || canintr) |
| break; |
| } else { |
| rv = WAITSIG(s); |
| if (rv != 0) { |
| if (rv < NSIGNAL) { |
| if (signame[rv] != NULL) { |
| if (pid != lastpid) { |
| prn(pid); |
| prs(": "); |
| } |
| prs(signame[rv]); |
| } |
| } else { |
| if (pid != lastpid) { |
| prn(pid); |
| prs(": "); |
| } |
| prs("Signal "); |
| prn(rv); |
| prs(" "); |
| } |
| if (WAITCORE(s)) |
| prs(" - core dumped"); |
| if (rv >= NSIGNAL || signame[rv]) |
| prs("\n"); |
| rv = -1; |
| } else |
| rv = WAITVAL(s); |
| } |
| } while (pid != lastpid); |
| heedint = oheedint; |
| if (intr) { |
| if (interactive) { |
| if (canintr) |
| intr = 0; |
| } else { |
| if (exstat == 0) |
| exstat = rv; |
| onintr(0); |
| } |
| } |
| return rv; |
| } |
| |
| static int setstatus(int s) |
| { |
| exstat = s; |
| setval(lookup("?"), putn(s)); |
| return s; |
| } |
| |
| /* |
| * PATH-searching interface to execve. |
| * If getenv("PATH") were kept up-to-date, |
| * execvp might be used. |
| */ |
| static const char *rexecve(char *c, char **v, char **envp) |
| { |
| int i; |
| const char *sp; |
| char *tp; |
| int eacces = 0, asis = 0; |
| char *name = c; |
| |
| if (ENABLE_FEATURE_SH_STANDALONE_SHELL) { |
| optind = 1; |
| if (find_applet_by_name(name)) { |
| /* We have to exec here since we vforked. Running |
| * run_applet_by_name() won't work and bad things |
| * will happen. */ |
| execve(CONFIG_BUSYBOX_EXEC_PATH, v, envp); |
| } |
| } |
| |
| DBGPRINTF(("REXECVE: c=%p, v=%p, envp=%p\n", c, v, envp)); |
| |
| sp = any('/', c) ? "" : path->value; |
| asis = (*sp == '\0'); |
| while (asis || *sp != '\0') { |
| asis = 0; |
| tp = e.linep; |
| for (; *sp != '\0'; tp++) { |
| *tp = *sp++; |
| if (*tp == ':') { |
| asis = (*sp == '\0'); |
| break; |
| } |
| } |
| if (tp != e.linep) |
| *tp++ = '/'; |
| for (i = 0; (*tp++ = c[i++]) != '\0';); |
| |
| DBGPRINTF3(("REXECVE: e.linep is %s\n", e.linep)); |
| |
| execve(e.linep, v, envp); |
| |
| switch (errno) { |
| case ENOEXEC: |
| *v = e.linep; |
| tp = *--v; |
| *v = e.linep; |
| execve(DEFAULT_SHELL, v, envp); |
| *v = tp; |
| return "no Shell"; |
| |
| case ENOMEM: |
| return (char *) bb_msg_memory_exhausted; |
| |
| case E2BIG: |
| return "argument list too long"; |
| |
| case EACCES: |
| eacces++; |
| break; |
| } |
| } |
| return errno == ENOENT ? "not found" : "cannot execute"; |
| } |
| |
| /* |
| * Run the command produced by generator `f' |
| * applied to stream `arg'. |
| */ |
| static int run(struct ioarg *argp, int (*f) (struct ioarg *)) |
| { |
| struct op *otree; |
| struct wdblock *swdlist; |
| struct wdblock *siolist; |
| jmp_buf ev, rt; |
| xint *ofail; |
| int rv; |
| |
| #if __GNUC__ |
| /* Avoid longjmp clobbering */ |
| (void) &rv; |
| #endif |
| |
| DBGPRINTF(("RUN: enter, areanum %d, outtree %p, failpt %p\n", |
| areanum, outtree, failpt)); |
| |
| areanum++; |
| swdlist = wdlist; |
| siolist = iolist; |
| otree = outtree; |
| ofail = failpt; |
| rv = -1; |
| |
| errpt = ev; |
| if (newenv(setjmp(errpt)) == 0) { |
| wdlist = 0; |
| iolist = 0; |
| pushio(argp, f); |
| e.iobase = e.iop; |
| yynerrs = 0; |
| failpt = rt; |
| if (setjmp(failpt) == 0 && yyparse() == 0) |
| rv = execute(outtree, NOPIPE, NOPIPE, 0); |
| quitenv(); |
| } else { |
| DBGPRINTF(("RUN: error from newenv()!\n")); |
| } |
| |
| wdlist = swdlist; |
| iolist = siolist; |
| failpt = ofail; |
| outtree = otree; |
| freearea(areanum--); |
| |
| return rv; |
| } |
| |
| /* -------- do.c -------- */ |
| |
| /* |
| * built-in commands: doX |
| */ |
| |
| static int dohelp(struct op *t) |
| { |
| int col; |
| const struct builtincmd *x; |
| |
| puts("\nBuilt-in commands:\n" |
| "-------------------"); |
| |
| for (col = 0, x = builtincmds; x->builtinfunc != NULL; x++) { |
| if (!x->name) |
| continue; |
| col += printf("%s%s", ((col == 0) ? "\t" : " "), x->name); |
| if (col > 60) { |
| puts(""); |
| col = 0; |
| } |
| } |
| #if ENABLE_FEATURE_SH_STANDALONE_SHELL |
| { |
| int i; |
| const struct BB_applet *applet; |
| |
| for (i = 0, applet = applets; i < NUM_APPLETS; applet++, i++) { |
| if (!applet->name) |
| continue; |
| |
| col += printf("%s%s", ((col == 0) ? "\t" : " "), applet->name); |
| if (col > 60) { |
| puts(""); |
| col = 0; |
| } |
| } |
| } |
| #endif |
| puts("\n"); |
| return EXIT_SUCCESS; |
| } |
| |
| |
| |
| static int dolabel(struct op *t) |
| { |
| return 0; |
| } |
| |
| static int dochdir(struct op *t) |
| { |
| const char *cp, *er; |
| |
| cp = t->words[1]; |
| if (cp == NULL) { |
| cp = homedir->value; |
| if (cp == NULL) |
| er = ": no home directory"; |
| } else if (chdir(cp) < 0) |
| er = ": bad directory"; |
| else |
| return 0; |
| prs(cp != NULL ? cp : "cd"); |
| err(er); |
| return 1; |
| } |
| |
| static int doshift(struct op *t) |
| { |
| int n; |
| |
| n = t->words[1] ? getn(t->words[1]) : 1; |
| if (dolc < n) { |
| err("nothing to shift"); |
| return 1; |
| } |
| dolv[n] = dolv[0]; |
| dolv += n; |
| dolc -= n; |
| setval(lookup("#"), putn(dolc)); |
| return 0; |
| } |
| |
| /* |
| * execute login and newgrp directly |
| */ |
| static int dologin(struct op *t) |
| { |
| const char *cp; |
| |
| if (interactive) { |
| signal(SIGINT, SIG_DFL); |
| signal(SIGQUIT, SIG_DFL); |
| } |
| cp = rexecve(t->words[0], t->words, makenv(0, NULL)); |
| prs(t->words[0]); |
| prs(": "); |
| err(cp); |
| return 1; |
| } |
| |
| static int doumask(struct op *t) |
| { |
| int i, n; |
| char *cp; |
| |
| cp = t->words[1]; |
| if (cp == NULL) { |
| i = umask(0); |
| umask(i); |
| for (n = 3 * 4; (n -= 3) >= 0;) |
| putc('0' + ((i >> n) & 07), stderr); |
| putc('\n', stderr); |
| } else { |
| /* huh??? '8','9' are not allowed! */ |
| for (n = 0; *cp >= '0' && *cp <= '9'; cp++) |
| n = n * 8 + (*cp - '0'); |
| umask(n); |
| } |
| return 0; |
| } |
| |
| static int doexec(struct op *t) |
| { |
| int i; |
| jmp_buf ex; |
| xint *ofail; |
| |
| t->ioact = NULL; |
| for (i = 0; (t->words[i] = t->words[i + 1]) != NULL; i++); |
| if (i == 0) |
| return 1; |
| execflg = 1; |
| ofail = failpt; |
| failpt = ex; |
| if (setjmp(failpt) == 0) |
| execute(t, NOPIPE, NOPIPE, FEXEC); |
| failpt = ofail; |
| execflg = 0; |
| return 1; |
| } |
| |
| static int dodot(struct op *t) |
| { |
| int i; |
| const char *sp; |
| char *tp; |
| char *cp; |
| int maltmp; |
| |
| DBGPRINTF(("DODOT: enter, t=%p, tleft %p, tright %p, e.linep is %s\n", t, t->left, t->right, ((e.linep == NULL) ? "NULL" : e.linep))); |
| |
| cp = t->words[1]; |
| if (cp == NULL) { |
| DBGPRINTF(("DODOT: bad args, ret 0\n")); |
| return 0; |
| } |
| DBGPRINTF(("DODOT: cp is %s\n", cp)); |
| |
| sp = any('/', cp) ? ":" : path->value; |
| |
| DBGPRINTF(("DODOT: sp is %s, e.linep is %s\n", |
| ((sp == NULL) ? "NULL" : sp), |
| ((e.linep == NULL) ? "NULL" : e.linep))); |
| |
| while (*sp) { |
| tp = e.linep; |
| while (*sp && (*tp = *sp++) != ':') |
| tp++; |
| if (tp != e.linep) |
| *tp++ = '/'; |
| |
| for (i = 0; (*tp++ = cp[i++]) != '\0';); |
| |
| /* Original code */ |
| i = open(e.linep, 0); |
| if (i >= 0) { |
| exstat = 0; |
| maltmp = remap(i); |
| DBGPRINTF(("DODOT: remap=%d, exstat=%d, e.iofd %d, i %d, e.linep is %s\n", maltmp, exstat, e.iofd, i, e.linep)); |
| |
| next(maltmp); /* Basically a PUSHIO */ |
| |
| DBGPRINTF(("DODOT: returning exstat=%d\n", exstat)); |
| |
| return exstat; |
| } |
| } /* while */ |
| |
| prs(cp); |
| err(": not found"); |
| |
| return -1; |
| } |
| |
| static int dowait(struct op *t) |
| { |
| int i; |
| char *cp; |
| |
| cp = t->words[1]; |
| if (cp != NULL) { |
| i = getn(cp); |
| if (i == 0) |
| return 0; |
| } else |
| i = -1; |
| setstatus(waitfor(i, 1)); |
| return 0; |
| } |
| |
| static int doread(struct op *t) |
| { |
| char *cp, **wp; |
| int nb = 0; |
| int nl = 0; |
| |
| if (t->words[1] == NULL) { |
| err("Usage: read name ..."); |
| return 1; |
| } |
| for (wp = t->words + 1; *wp; wp++) { |
| for (cp = e.linep; !nl && cp < elinep - 1; cp++) { |
| nb = read(0, cp, sizeof(*cp)); |
| if (nb != sizeof(*cp)) |
| break; |
| nl = (*cp == '\n'); |
| if (nl || (wp[1] && any(*cp, ifs->value))) |
| break; |
| } |
| *cp = '\0'; |
| if (nb <= 0) |
| break; |
| setval(lookup(*wp), e.linep); |
| } |
| return nb <= 0; |
| } |
| |
| static int doeval(struct op *t) |
| { |
| return RUN(awordlist, t->words + 1, wdchar); |
| } |
| |
| static int dotrap(struct op *t) |
| { |
| int n, i; |
| int resetsig; |
| |
| if (t->words[1] == NULL) { |
| for (i = 0; i <= _NSIG; i++) |
| if (trap[i]) { |
| prn(i); |
| prs(": "); |
| prs(trap[i]); |
| prs("\n"); |
| } |
| return 0; |
| } |
| resetsig = isdigit(*t->words[1]); |
| for (i = resetsig ? 1 : 2; t->words[i] != NULL; ++i) { |
| n = getsig(t->words[i]); |
| freecell(trap[n]); |
| trap[n] = 0; |
| if (!resetsig) { |
| if (*t->words[1] != '\0') { |
| trap[n] = strsave(t->words[1], 0); |
| setsig(n, sig); |
| } else |
| setsig(n, SIG_IGN); |
| } else { |
| if (interactive) { |
| if (n == SIGINT) |
| setsig(n, onintr); |
| else |
| setsig(n, n == SIGQUIT ? SIG_IGN : SIG_DFL); |
| } else |
| setsig(n, SIG_DFL); |
| } |
| } |
| return 0; |
| } |
| |
| static int getsig(char *s) |
| { |
| int n; |
| |
| n = getn(s); |
| if (n < 0 || n > _NSIG) { |
| err("trap: bad signal number"); |
| n = 0; |
| } |
| return n; |
| } |
| |
| static void setsig(int n, sighandler_t f) |
| { |
| if (n == 0) |
| return; |
| if (signal(n, SIG_IGN) != SIG_IGN || ourtrap[n]) { |
| ourtrap[n] = 1; |
| signal(n, f); |
| } |
| } |
| |
| static int getn(char *as) |
| { |
| char *s; |
| int n, m; |
| |
| s = as; |
| m = 1; |
| if (*s == '-') { |
| m = -1; |
| s++; |
| } |
| for (n = 0; isdigit(*s); s++) |
| n = (n * 10) + (*s - '0'); |
| if (*s) { |
| prs(as); |
| err(": bad number"); |
| } |
| return n * m; |
| } |
| |
| static int dobreak(struct op *t) |
| { |
| return brkcontin(t->words[1], 1); |
| } |
| |
| static int docontinue(struct op *t) |
| { |
| return brkcontin(t->words[1], 0); |
| } |
| |
| static int brkcontin(char *cp, int val) |
| { |
| struct brkcon *bc; |
| int nl; |
| |
| nl = cp == NULL ? 1 : getn(cp); |
| if (nl <= 0) |
| nl = 999; |
| do { |
| bc = brklist; |
| if (bc == NULL) |
| break; |
| brklist = bc->nextlev; |
| } while (--nl); |
| if (nl) { |
| err("bad break/continue level"); |
| return 1; |
| } |
| isbreak = val; |
| longjmp(bc->brkpt, 1); |
| /* NOTREACHED */ |
| } |
| |
| static int doexit(struct op *t) |
| { |
| char *cp; |
| |
| execflg = 0; |
| cp = t->words[1]; |
| if (cp != NULL) |
| setstatus(getn(cp)); |
| |
| DBGPRINTF(("DOEXIT: calling leave(), t=%p\n", t)); |
| |
| leave(); |
| /* NOTREACHED */ |
| return 0; |
| } |
| |
| static int doexport(struct op *t) |
| { |
| rdexp(t->words + 1, export, EXPORT); |
| return 0; |
| } |
| |
| static int doreadonly(struct op *t) |
| { |
| rdexp(t->words + 1, ronly, RONLY); |
| return 0; |
| } |
| |
| static void rdexp(char **wp, void (*f) (struct var *), int key) |
| { |
| DBGPRINTF6(("RDEXP: enter, wp=%p, func=%p, key=%d\n", wp, f, key)); |
| DBGPRINTF6(("RDEXP: *wp=%s\n", *wp)); |
| |
| if (*wp != NULL) { |
| for (; *wp != NULL; wp++) { |
| if (isassign(*wp)) { |
| char *cp; |
| |
| assign(*wp, COPYV); |
| for (cp = *wp; *cp != '='; cp++); |
| *cp = '\0'; |
| } |
| if (checkname(*wp)) |
| (*f) (lookup(*wp)); |
| else |
| badid(*wp); |
| } |
| } else |
| putvlist(key, 1); |
| } |
| |
| static void badid(char *s) |
| { |
| prs(s); |
| err(": bad identifier"); |
| } |
| |
| static int doset(struct op *t) |
| { |
| struct var *vp; |
| char *cp; |
| int n; |
| |
| cp = t->words[1]; |
| if (cp == NULL) { |
| for (vp = vlist; vp; vp = vp->next) |
| varput(vp->name, 1); |
| return 0; |
| } |
| if (*cp == '-') { |
| /* bad: t->words++; */ |
| for (n = 0; (t->words[n] = t->words[n + 1]) != NULL; n++); |
| if (*++cp == 0) |
| flag['x'] = flag['v'] = 0; |
| else { |
| for (; *cp; cp++) { |
| switch (*cp) { |
| case 'e': |
| if (!interactive) |
| flag['e']++; |
| break; |
| |
| default: |
| if (*cp >= 'a' && *cp <= 'z') |
| flag[(int) *cp]++; |
| break; |
| } |
| } |
| } |
| setdash(); |
| } |
| if (t->words[1]) { |
| t->words[0] = dolv[0]; |
| for (n = 1; t->words[n]; n++) |
| setarea((char *) t->words[n], 0); |
| dolc = n - 1; |
| dolv = t->words; |
| setval(lookup("#"), putn(dolc)); |
| setarea((char *) (dolv - 1), 0); |
| } |
| return 0; |
| } |
| |
| static void varput(char *s, int out) |
| { |
| if (isalnum(*s) || *s == '_') { |
| write(out, s, strlen(s)); |
| write(out, "\n", 1); |
| } |
| } |
| |
| |
| /* |
| * Copyright (c) 1999 Herbert Xu <herbert@debian.org> |
| * This file contains code for the times builtin. |
| */ |
| static int dotimes(struct op *t) |
| { |
| struct tms buf; |
| long clk_tck = sysconf(_SC_CLK_TCK); |
| |
| times(&buf); |
| printf("%dm%fs %dm%fs\n%dm%fs %dm%fs\n", |
| (int) (buf.tms_utime / clk_tck / 60), |
| ((double) buf.tms_utime) / clk_tck, |
| (int) (buf.tms_stime / clk_tck / 60), |
| ((double) buf.tms_stime) / clk_tck, |
| (int) (buf.tms_cutime / clk_tck / 60), |
| ((double) buf.tms_cutime) / clk_tck, |
| (int) (buf.tms_cstime / clk_tck / 60), |
| ((double) buf.tms_cstime) / clk_tck); |
| return 0; |
| } |
| |
| |
| /* -------- eval.c -------- */ |
| |
| /* |
| * ${} |
| * `command` |
| * blank interpretation |
| * quoting |
| * glob |
| */ |
| |
| static char **eval(char **ap, int f) |
| { |
| struct wdblock *wb; |
| char **wp; |
| char **wf; |
| jmp_buf ev; |
| |
| #if __GNUC__ |
| /* Avoid longjmp clobbering */ |
| (void) ℘ |
| (void) ≈ |
| #endif |
| |
| DBGPRINTF4(("EVAL: enter, f=%d\n", f)); |
| |
| wp = NULL; |
| wb = NULL; |
| wf = NULL; |
| errpt = ev; |
| if (newenv(setjmp(errpt)) == 0) { |
| while (*ap && isassign(*ap)) |
| expand(*ap++, &wb, f & ~DOGLOB); |
| if (flag['k']) { |
| for (wf = ap; *wf; wf++) { |
| if (isassign(*wf)) |
| expand(*wf, &wb, f & ~DOGLOB); |
| } |
| } |
| for (wb = addword((char *) 0, wb); *ap; ap++) { |
| if (!flag['k'] || !isassign(*ap)) |
| expand(*ap, &wb, f & ~DOKEY); |
| } |
| wb = addword((char *) 0, wb); |
| wp = getwords(wb); |
| quitenv(); |
| } else |
| gflg = 1; |
| |
| return gflg ? (char **) NULL : wp; |
| } |
| |
| |
| /* |
| * Make the exported environment from the exported |
| * names in the dictionary. Keyword assignments |
| * will already have been done. |
| */ |
| static char **makenv(int all, struct wdblock *wb) |
| { |
| struct var *vp; |
| |
| DBGPRINTF5(("MAKENV: enter, all=%d\n", all)); |
| |
| for (vp = vlist; vp; vp = vp->next) |
| if (all || vp->status & EXPORT) |
| wb = addword(vp->name, wb); |
| wb = addword((char *) 0, wb); |
| return getwords(wb); |
| } |
| |
| static int expand(const char *cp, struct wdblock **wbp, int f) |
| { |
| jmp_buf ev; |
| char *xp; |
| |
| #if __GNUC__ |
| /* Avoid longjmp clobbering */ |
| (void) &cp; |
| #endif |
| |
| DBGPRINTF3(("EXPAND: enter, f=%d\n", f)); |
| |
| gflg = 0; |
| |
| if (cp == NULL) |
| return 0; |
| |
| if (!anys("$`'\"", cp) && !anys(ifs->value, cp) |
| && ((f & DOGLOB) == 0 || !anys("[*?", cp)) |
| ) { |
| xp = strsave(cp, areanum); |
| if (f & DOTRIM) |
| unquote(xp); |
| *wbp = addword(xp, *wbp); |
| return 1; |
| } |
| errpt = ev; |
| if (newenv(setjmp(errpt)) == 0) { |
| PUSHIO(aword, cp, strchar); |
| e.iobase = e.iop; |
| while ((xp = blank(f)) && gflg == 0) { |
| e.linep = xp; |
| xp = strsave(xp, areanum); |
| if ((f & DOGLOB) == 0) { |
| if (f & DOTRIM) |
| unquote(xp); |
| *wbp = addword(xp, *wbp); |
| } else |
| *wbp = glob(xp, *wbp); |
| } |
| quitenv(); |
| } else |
| gflg = 1; |
| return gflg == 0; |
| } |
| |
| static char *evalstr(char *cp, int f) |
| { |
| struct wdblock *wb; |
| |
| DBGPRINTF6(("EVALSTR: enter, cp=%p, f=%d\n", cp, f)); |
| |
| wb = NULL; |
| if (expand(cp, &wb, f)) { |
| if (wb == NULL || wb->w_nword == 0 |
| || (cp = wb->w_words[0]) == NULL |
| ) { |
| // TODO: I suspect that |
| // char *evalstr(char *cp, int f) is actually |
| // const char *evalstr(const char *cp, int f)! |
| cp = (char*)""; |
| } |
| DELETE(wb); |
| } else |
| cp = NULL; |
| return cp; |
| } |
| |
| |
| /* |
| * Blank interpretation and quoting |
| */ |
| static char *blank(int f) |
| { |
| int c, c1; |
| char *sp; |
| int scanequals, foundequals; |
| |
| DBGPRINTF3(("BLANK: enter, f=%d\n", f)); |
| |
| sp = e.linep; |
| scanequals = f & DOKEY; |
| foundequals = 0; |
| |
| loop: |
| c = subgetc('"', foundequals); |
| switch (c) { |
| case 0: |
| if (sp == e.linep) |
| return 0; |
| *e.linep++ = 0; |
| return sp; |
| |
| default: |
| if (f & DOBLANK && any(c, ifs->value)) |
| goto loop; |
| break; |
| |
| case '"': |
| case '\'': |
| scanequals = 0; |
| if (INSUB()) |
| break; |
| for (c1 = c; (c = subgetc(c1, 1)) != c1;) { |
| if (c == 0) |
| break; |
| if (c == '\'' || !any(c, "$`\"")) |
| c |= QUOTE; |
| *e.linep++ = c; |
| } |
| c = 0; |
| } |
| unget(c); |
| if (!isalpha(c) && c != '_') |
| scanequals = 0; |
| for (;;) { |
| c = subgetc('"', foundequals); |
| if (c == 0 || |
| f & (DOBLANK && any(c, ifs->value)) || |
| (!INSUB() && any(c, "\"'"))) { |
| scanequals = 0; |
| unget(c); |
| if (any(c, "\"'")) |
| goto loop; |
| break; |
| } |
| if (scanequals) { |
| if (c == '=') { |
| foundequals = 1; |
| scanequals = 0; |
| } else if (!isalnum(c) && c != '_') |
| scanequals = 0; |
| } |
| *e.linep++ = c; |
| } |
| *e.linep++ = 0; |
| return sp; |
| } |
| |
| /* |
| * Get characters, substituting for ` and $ |
| */ |
| static int subgetc(char ec, int quoted) |
| { |
| char c; |
| |
| DBGPRINTF3(("SUBGETC: enter, quoted=%d\n", quoted)); |
| |
| again: |
| c = my_getc(ec); |
| if (!INSUB() && ec != '\'') { |
| if (c == '`') { |
| if (grave(quoted) == 0) |
| return 0; |
| e.iop->task = XGRAVE; |
| goto again; |
| } |
| if (c == '$') { |
| c = dollar(quoted); |
| if (c == 0) { |
| e.iop->task = XDOLL; |
| goto again; |
| } |
| } |
| } |
| return c; |
| } |
| |
| /* |
| * Prepare to generate the string returned by ${} substitution. |
| */ |
| static int dollar(int quoted) |
| { |
| int otask; |
| struct io *oiop; |
| char *dolp; |
| char *s, c, *cp = NULL; |
| struct var *vp; |
| |
| DBGPRINTF3(("DOLLAR: enter, quoted=%d\n", quoted)); |
| |
| c = readc(); |
| s = e.linep; |
| if (c != '{') { |
| *e.linep++ = c; |
| if (isalpha(c) || c == '_') { |
| while ((c = readc()) != 0 && (isalnum(c) || c == '_')) |
| if (e.linep < elinep) |
| *e.linep++ = c; |
| unget(c); |
| } |
| c = 0; |
| } else { |
| oiop = e.iop; |
| otask = e.iop->task; |
| |
| e.iop->task = XOTHER; |
| while ((c = subgetc('"', 0)) != 0 && c != '}' && c != '\n') |
| if (e.linep < elinep) |
| *e.linep++ = c; |
| if (oiop == e.iop) |
| e.iop->task = otask; |
| if (c != '}') { |
| err("unclosed ${"); |
| gflg++; |
| return c; |
| } |
| } |
| if (e.linep >= elinep) { |
| err("string in ${} too long"); |
| gflg++; |
| e.linep -= 10; |
| } |
| *e.linep = 0; |
| if (*s) |
| for (cp = s + 1; *cp; cp++) |
| if (any(*cp, "=-+?")) { |
| c = *cp; |
| *cp++ = 0; |
| break; |
| } |
| if (s[1] == 0 && (*s == '*' || *s == '@')) { |
| if (dolc > 1) { |
| /* currently this does not distinguish $* and $@ */ |
| /* should check dollar */ |
| e.linep = s; |
| PUSHIO(awordlist, dolv + 1, dolchar); |
| return 0; |
| } else { /* trap the nasty ${=} */ |
| s[0] = '1'; |
| s[1] = '\0'; |
| } |
| } |
| vp = lookup(s); |
| dolp = vp->value; |
| if (dolp == null) { |
| switch (c) { |
| case '=': |
| if (isdigit(*s)) { |
| err("cannot use ${...=...} with $n"); |
| gflg++; |
| break; |
| } |
| setval(vp, cp); |
| dolp = vp->value; |
| break; |
| |
| case '-': |
| dolp = strsave(cp, areanum); |
| break; |
| |
| case '?': |
| if (*cp == 0) { |
| prs("missing value for "); |
| err(s); |
| } else |
| err(cp); |
| gflg++; |
| break; |
| } |
| } else if (c == '+') |
| dolp = strsave(cp, areanum); |
| if (flag['u'] && dolp == null) { |
| prs("unset variable: "); |
| err(s); |
| gflg++; |
| } |
| e.linep = s; |
| PUSHIO(aword, dolp, quoted ? qstrchar : strchar); |
| return 0; |
| } |
| |
| /* |
| * Run the command in `...` and read its output. |
| */ |
| |
| static int grave(int quoted) |
| { |
| const char *cp; |
| int i; |
| int j; |
| int pf[2]; |
| static char child_cmd[LINELIM]; |
| const char *src; |
| char *dest; |
| int count; |
| int ignore; |
| int ignore_once; |
| char *argument_list[4]; |
| struct wdblock *wb = NULL; |
| |
| #if __GNUC__ |
| /* Avoid longjmp clobbering */ |
| (void) &cp; |
| #endif |
| |
| for (cp = e.iop->argp->aword; *cp != '`'; cp++) { |
| if (*cp == 0) { |
| err("no closing `"); |
| return 0; |
| } |
| } |
| |
| /* string copy with dollar expansion */ |
| src = e.iop->argp->aword; |
| dest = child_cmd; |
| count = 0; |
| ignore = 0; |
| ignore_once = 0; |
| while ((*src != '`') && (count < LINELIM)) { |
| if (*src == '\'') |
| ignore = !ignore; |
| if (*src == '\\') |
| ignore_once = 1; |
| if (*src == '$' && !ignore && !ignore_once) { |
| struct var *vp; |
| char var_name[LINELIM]; |
| char alt_value[LINELIM]; |
| int var_index = 0; |
| int alt_index = 0; |
| char operator = 0; |
| int braces = 0; |
| char *value; |
| |
| src++; |
| if (*src == '{') { |
| braces = 1; |
| src++; |
| } |
| |
| var_name[var_index++] = *src++; |
| while (isalnum(*src) || *src=='_') |
| var_name[var_index++] = *src++; |
| var_name[var_index] = 0; |
| |
| if (braces) { |
| switch (*src) { |
| case '}': |
| break; |
| case '-': |
| case '=': |
| case '+': |
| case '?': |
| operator = * src; |
| break; |
| default: |
| err("unclosed ${\n"); |
| return 0; |
| } |
| if (operator) { |
| src++; |
| while (*src && (*src != '}')) { |
| alt_value[alt_index++] = *src++; |
| } |
| alt_value[alt_index] = 0; |
| if (*src != '}') { |
| err("unclosed ${\n"); |
| return 0; |
| } |
| } |
| src++; |
| } |
| |
| if (isalpha(*var_name)) { |
| /* let subshell handle it instead */ |
| |
| char *namep = var_name; |
| |
| *dest++ = '$'; |
| if (braces) |
| *dest++ = '{'; |
| while (*namep) |
| *dest++ = *namep++; |
| if (operator) { |
| char *altp = alt_value; |
| *dest++ = operator; |
| while (*altp) |
| *dest++ = *altp++; |
| } |
| if (braces) |
| *dest++ = '}'; |
| |
| wb = addword(lookup(var_name)->name, wb); |
| } else { |
| /* expand */ |
| |
| vp = lookup(var_name); |
| if (vp->value != null) |
| value = (operator == '+') ? |
| alt_value : vp->value; |
| else if (operator == '?') { |
| err(alt_value); |
| return 0; |
| } else if (alt_index && (operator != '+')) { |
| value = alt_value; |
| if (operator == '=') |
| setval(vp, value); |
| } else |
| continue; |
| |
| while (*value && (count < LINELIM)) { |
| *dest++ = *value++; |
| count++; |
| } |
| } |
| } else { |
| *dest++ = *src++; |
| count++; |
| ignore_once = 0; |
| } |
| } |
| *dest = '\0'; |
| |
| if (openpipe(pf) < 0) |
| return 0; |
| |
| while ((i = vfork()) == -1 && errno == EAGAIN); |
| |
| DBGPRINTF3(("GRAVE: i is %p\n", io)); |
| |
| if (i < 0) { |
| closepipe(pf); |
| err((char *) bb_msg_memory_exhausted); |
| return 0; |
| } |
| if (i != 0) { |
| waitpid(i, NULL, 0); |
| e.iop->argp->aword = ++cp; |
| close(pf[1]); |
| PUSHIO(afile, remap(pf[0]), |
| (int (*)(struct ioarg *)) ((quoted) ? qgravechar : gravechar)); |
| return 1; |
| } |
| /* allow trapped signals */ |
| /* XXX - Maybe this signal stuff should go as well? */ |
| for (j = 0; j <= _NSIG; j++) |
| if (ourtrap[j] && signal(j, SIG_IGN) != SIG_IGN) |
| signal(j, SIG_DFL); |
| |
| dup2(pf[1], 1); |
| closepipe(pf); |
| |
| argument_list[0] = (char *) DEFAULT_SHELL; |
| argument_list[1] = (char *) "-c"; |
| argument_list[2] = child_cmd; |
| argument_list[3] = NULL; |
| |
| cp = rexecve(argument_list[0], argument_list, makenv(1, wb)); |
| prs(argument_list[0]); |
| prs(": "); |
| err(cp); |
| _exit(1); |
| } |
| |
| |
| static char *unquote(char *as) |
| { |
| char *s; |
| |
| s = as; |
| if (s != NULL) |
| while (*s) |
| *s++ &= ~QUOTE; |
| return as; |
| } |
| |
| /* -------- glob.c -------- */ |
| |
| /* |
| * glob |
| */ |
| |
| #define scopy(x) strsave((x), areanum) |
| #define BLKSIZ 512 |
| #define NDENT ((BLKSIZ+sizeof(struct dirent)-1)/sizeof(struct dirent)) |
| |
| static struct wdblock *cl, *nl; |
| static char spcl[] = "[?*"; |
| |
| static struct wdblock *glob(char *cp, struct wdblock *wb) |
| { |
| int i; |
| char *pp; |
| |
| if (cp == 0) |
| return wb; |
| i = 0; |
| for (pp = cp; *pp; pp++) |
| if (any(*pp, spcl)) |
| i++; |
| else if (!any(*pp & ~QUOTE, spcl)) |
| *pp &= ~QUOTE; |
| if (i != 0) { |
| for (cl = addword(scopy(cp), NULL); anyspcl(cl); cl = nl) { |
| nl = newword(cl->w_nword * 2); |
| for (i = 0; i < cl->w_nword; i++) { /* for each argument */ |
| for (pp = cl->w_words[i]; *pp; pp++) |
| if (any(*pp, spcl)) { |
| globname(cl->w_words[i], pp); |
| break; |
| } |
| if (*pp == '\0') |
| nl = addword(scopy(cl->w_words[i]), nl); |
| } |
| for (i = 0; i < cl->w_nword; i++) |
| DELETE(cl->w_words[i]); |
| DELETE(cl); |
| } |
| for (i = 0; i < cl->w_nword; i++) |
| unquote(cl->w_words[i]); |
| glob0((char *) cl->w_words, cl->w_nword, sizeof(char *), xstrcmp); |
| if (cl->w_nword) { |
| for (i = 0; i < cl->w_nword; i++) |
| wb = addword(cl->w_words[i], wb); |
| DELETE(cl); |
| return wb; |
| } |
| } |
| wb = addword(unquote(cp), wb); |
| return wb; |
| } |
| |
| static void globname(char *we, char *pp) |
| { |
| char *np, *cp; |
| char *name, *gp, *dp; |
| int k; |
| DIR *dirp; |
| struct dirent *de; |
| char dname[NAME_MAX + 1]; |
| struct stat dbuf; |
| |
| for (np = we; np != pp; pp--) |
| if (pp[-1] == '/') |
| break; |
| for (dp = cp = space((int) (pp - np) + 3); np < pp;) |
| *cp++ = *np++; |
| *cp++ = '.'; |
| *cp = '\0'; |
| for (gp = cp = space(strlen(pp) + 1); *np && *np != '/';) |
| *cp++ = *np++; |
| *cp = '\0'; |
| dirp = opendir(dp); |
| if (dirp == 0) { |
| DELETE(dp); |
| DELETE(gp); |
| return; |
| } |
| dname[NAME_MAX] = '\0'; |
| while ((de = readdir(dirp)) != NULL) { |
| /* XXX Hmmm... What this could be? (abial) */ |
| /* |
| if (ent[j].d_ino == 0) |
| continue; |
| */ |
| strncpy(dname, de->d_name, NAME_MAX); |
| if (dname[0] == '.') |
| if (*gp != '.') |
| continue; |
| for (k = 0; k < NAME_MAX; k++) |
| if (any(dname[k], spcl)) |
| dname[k] |= QUOTE; |
| if (gmatch(dname, gp)) { |
| name = generate(we, pp, dname, np); |
| if (*np && !anys(np, spcl)) { |
| if (stat(name, &dbuf)) { |
| DELETE(name); |
| continue; |
| } |
| } |
| nl = addword(name, nl); |
| } |
| } |
| closedir(dirp); |
| DELETE(dp); |
| DELETE(gp); |
| } |
| |
| /* |
| * generate a pathname as below. |
| * start..end1 / middle end |
| * the slashes come for free |
| */ |
| static char *generate(char *start1, char *end1, char *middle, char *end) |
| { |
| char *p; |
| char *op, *xp; |
| |
| p = op = space((int)(end1 - start1) + strlen(middle) + strlen(end) + 2); |
| for (xp = start1; xp != end1;) |
| *op++ = *xp++; |
| for (xp = middle; (*op++ = *xp++) != '\0';); |
| op--; |
| for (xp = end; (*op++ = *xp++) != '\0';); |
| return p; |
| } |
| |
| static int anyspcl(struct wdblock *wb) |
| { |
| int i; |
| char **wd; |
| |
| wd = wb->w_words; |
| for (i = 0; i < wb->w_nword; i++) |
| if (anys(spcl, *wd++)) |
| return 1; |
| return 0; |
| } |
| |
| static int xstrcmp(char *p1, char *p2) |
| { |
| return strcmp(*(char **) p1, *(char **) p2); |
| } |
| |
| |
| /* -------- word.c -------- */ |
| |
| static struct wdblock *newword(int nw) |
| { |
| struct wdblock *wb; |
| |
| wb = (struct wdblock *) space(sizeof(*wb) + nw * sizeof(char *)); |
| wb->w_bsize = nw; |
| wb->w_nword = 0; |
| return wb; |
| } |
| |
| static struct wdblock *addword(char *wd, struct wdblock *wb) |
| { |
| struct wdblock *wb2; |
| int nw; |
| |
| if (wb == NULL) |
| wb = newword(NSTART); |
| nw = wb->w_nword; |
| if (nw >= wb->w_bsize) { |
| wb2 = newword(nw * 2); |
| memcpy((char *) wb2->w_words, (char *) wb->w_words, |
| nw * sizeof(char *)); |
| wb2->w_nword = nw; |
| DELETE(wb); |
| wb = wb2; |
| } |
| wb->w_words[wb->w_nword++] = wd; |
| return wb; |
| } |
| |
| static |
| char **getwords(struct wdblock *wb) |
| { |
| char **wd; |
| int nb; |
| |
| if (wb == NULL) |
| return NULL; |
| if (wb->w_nword == 0) { |
| DELETE(wb); |
| return NULL; |
| } |
| wd = (char **) space(nb = sizeof(*wd) * wb->w_nword); |
| memcpy((char *) wd, (char *) wb->w_words, nb); |
| DELETE(wb); /* perhaps should done by caller */ |
| return wd; |
| } |
| |
| static int (*func) (char *, char *); |
| static int globv; |
| |
| static void glob3(char *i, char *j, char *k) |
| { |
| char *index1, *index2, *index3; |
| int c; |
| int m; |
| |
| m = globv; |
| index1 = i; |
| index2 = j; |
| index3 = k; |
| do { |
| c = *index1; |
| *index1++ = *index3; |
| *index3++ = *index2; |
| *index2++ = c; |
| } while (--m); |
| } |
| |
| static void glob2(char *i, char *j) |
| { |
| char *index1, *index2, c; |
| int m; |
| |
| m = globv; |
| index1 = i; |
| index2 = j; |
| do { |
| c = *index1; |
| *index1++ = *index2; |
| *index2++ = c; |
| } while (--m); |
| } |
| |
| static void glob1(char *base, char *lim) |
| { |
| char *i, *j; |
| int v2; |
| char *lptr, *hptr; |
| int c; |
| unsigned n; |
| |
| v2 = globv; |
| |
| top: |
| n = (int) (lim - base); |
| if (n <= v2) |
| return; |
| n = v2 * (n / (2 * v2)); |
| hptr = lptr = base + n; |
| i = base; |
| j = lim - v2; |
| for (;;) { |
| if (i < lptr) { |
| c = (*func) (i, lptr); |
| if (c == 0) { |
| lptr -= v2; |
| glob2(i, lptr); |
| continue; |
| } |
| if (c < 0) { |
| i += v2; |
| continue; |
| } |
| } |
| |
| begin: |
| if (j > hptr) { |
| c = (*func) (hptr, j); |
| if (c == 0) { |
| hptr += v2; |
| glob2(hptr, j); |
| goto begin; |
| } |
| if (c > 0) { |
| if (i == lptr) { |
| hptr += v2; |
| glob3(i, hptr, j); |
| i = (lptr += v2); |
| goto begin; |
| } |
| glob2(i, j); |
| j -= v2; |
| i += v2; |
| continue; |
| } |
| j -= v2; |
| goto begin; |
| } |
| |
| |
| if (i == lptr) { |
| if (lptr - base >= lim - hptr) { |
| glob1(hptr + v2, lim); |
| lim = lptr; |
| } else { |
| glob1(base, lptr); |
| base = hptr + v2; |
| } |
| goto top; |
| } |
| |
| lptr -= v2; |
| glob3(j, lptr, i); |
| j = (hptr -= v2); |
| } |
| } |
| |
| static void glob0(char *a0, unsigned a1, int a2, int (*a3) (char *, char *)) |
| { |
| func = a3; |
| globv = a2; |
| glob1(a0, a0 + a1 * a2); |
| } |
| |
| |
| /* -------- io.c -------- */ |
| |
| /* |
| * shell IO |
| */ |
| |
| static int my_getc(int ec) |
| { |
| int c; |
| |
| if (e.linep > elinep) { |
| while ((c = readc()) != '\n' && c); |
| err("input line too long"); |
| gflg++; |
| return c; |
| } |
| c = readc(); |
| if ((ec != '\'') && (ec != '`') && (e.iop->task != XGRAVE)) { |
| if (c == '\\') { |
| c = readc(); |
| if (c == '\n' && ec != '\"') |
| return my_getc(ec); |
| c |= QUOTE; |
| } |
| } |
| return c; |
| } |
| |
| static void unget(int c) |
| { |
| if (e.iop >= e.iobase) |
| e.iop->peekc = c; |
| } |
| |
| static int eofc(void) |
| { |
| return e.iop < e.iobase || (e.iop->peekc == 0 && e.iop->prev == 0); |
| } |
| |
| static int readc(void) |
| { |
| int c; |
| |
| RCPRINTF(("READC: e.iop %p, e.iobase %p\n", e.iop, e.iobase)); |
| |
| for (; e.iop >= e.iobase; e.iop--) { |
| RCPRINTF(("READC: e.iop %p, peekc 0x%x\n", e.iop, e.iop->peekc)); |
| c = e.iop->peekc; |
| if (c != '\0') { |
| e.iop->peekc = 0; |
| return c; |
| } |
| if (e.iop->prev != 0) { |
| c = (*e.iop->iofn)(e.iop->argp, e.iop); |
| if (c != '\0') { |
| if (c == -1) { |
| e.iop++; |
| continue; |
| } |
| if (e.iop == iostack) |
| ioecho(c); |
| e.iop->prev = c; |
| return e.iop->prev; |
| } |
| if (e.iop->task == XIO && e.iop->prev != '\n') { |
| e.iop->prev = 0; |
| if (e.iop == iostack) |
| ioecho('\n'); |
| return '\n'; |
| } |
| } |
| if (e.iop->task == XIO) { |
| if (multiline) { |
| e.iop->prev = 0; |
| return e.iop->prev; |
| } |
| if (interactive && e.iop == iostack + 1) { |
| #if ENABLE_FEATURE_EDITING |
| current_prompt = prompt->value; |
| #else |
| prs(prompt->value); |
| #endif |
| } |
| } |
| } /* FOR */ |
| |
| if (e.iop >= iostack) { |
| RCPRINTF(("READC: return 0, e.iop %p\n", e.iop)); |
| return 0; |
| } |
| |
| DBGPRINTF(("READC: leave()...\n")); |
| leave(); |
| |
| /* NOTREACHED */ |
| return 0; |
| } |
| |
| static void ioecho(char c) |
| { |
| if (flag['v']) |
| write(2, &c, sizeof c); |
| } |
| |
| |
| static void pushio(struct ioarg *argp, int (*fn) (struct ioarg *)) |
| { |
| DBGPRINTF(("PUSHIO: argp %p, argp->afid 0x%x, e.iop %p\n", argp, |
| argp->afid, e.iop)); |
| |
| /* Set env ptr for io source to next array spot and check for array overflow */ |
| if (++e.iop >= &iostack[NPUSH]) { |
| e.iop--; |
| err("Shell input nested too deeply"); |
| gflg++; |
| return; |
| } |
| |
| /* We did not overflow the NPUSH array spots so setup data structs */ |
| |
| e.iop->iofn = (int (*)(struct ioarg *, struct io *)) fn; /* Store data source func ptr */ |
| |
| if (argp->afid != AFID_NOBUF) |
| e.iop->argp = argp; |
| else { |
| |
| e.iop->argp = ioargstack + (e.iop - iostack); /* MAL - index into stack */ |
| *e.iop->argp = *argp; /* copy data from temp area into stack spot */ |
| |
| /* MAL - mainbuf is for 1st data source (command line?) and all nested use a single shared buffer? */ |
| |
| if (e.iop == &iostack[0]) |
| e.iop->argp->afbuf = &mainbuf; |
| else |
| e.iop->argp->afbuf = &sharedbuf; |
| |
| /* MAL - if not a termimal AND (commandline OR readable file) then give it a buffer id? */ |
| /* This line appears to be active when running scripts from command line */ |
| if ((isatty(e.iop->argp->afile) == 0) |
| && (e.iop == &iostack[0] |
| || lseek(e.iop->argp->afile, 0L, SEEK_CUR) != -1)) { |
| if (++bufid == AFID_NOBUF) /* counter rollover check, AFID_NOBUF = 11111111 */ |
| bufid = AFID_ID; /* AFID_ID = 0 */ |
| |
| e.iop->argp->afid = bufid; /* assign buffer id */ |
| } |
| |
| DBGPRINTF(("PUSHIO: iostack %p, e.iop %p, afbuf %p\n", |
| iostack, e.iop, e.iop->argp->afbuf)); |
| DBGPRINTF(("PUSHIO: mbuf %p, sbuf %p, bid %d, e.iop %p\n", |
| &mainbuf, &sharedbuf, bufid, e.iop)); |
| |
| } |
| |
| e.iop->prev = ~'\n'; |
| e.iop->peekc = 0; |
| e.iop->xchar = 0; |
| e.iop->nlcount = 0; |
| |
| if (fn == filechar || fn == linechar) |
| e.iop->task = XIO; |
| else if (fn == (int (*)(struct ioarg *)) gravechar |
| || fn == (int (*)(struct ioarg *)) qgravechar) |
| e.iop->task = XGRAVE; |
| else |
| e.iop->task = XOTHER; |
| } |
| |
| static struct io *setbase(struct io *ip) |
| { |
| struct io *xp; |
| |
| xp = e.iobase; |
| e.iobase = ip; |
| return xp; |
| } |
| |
| /* |
| * Input generating functions |
| */ |
| |
| /* |
| * Produce the characters of a string, then a newline, then EOF. |
| */ |
| static int nlchar(struct ioarg *ap) |
| { |
| int c; |
| |
| if (ap->aword == NULL) |
| return 0; |
| c = *ap->aword++; |
| if (c == 0) { |
| ap->aword = NULL; |
| return '\n'; |
| } |
| return c; |
| } |
| |
| /* |
| * Given a list of words, produce the characters |
| * in them, with a space after each word. |
| */ |
| static int wdchar(struct ioarg *ap) |
| { |
| char c; |
| char **wl; |
| |
| wl = ap->awordlist; |
| if (wl == NULL) |
| return 0; |
| if (*wl != NULL) { |
| c = *(*wl)++; |
| if (c != 0) |
| return c & 0177; |
| ap->awordlist++; |
| return ' '; |
| } |
| ap->awordlist = NULL; |
| return '\n'; |
| } |
| |
| /* |
| * Return the characters of a list of words, |
| * producing a space between them. |
| */ |
| static int dolchar(struct ioarg *ap) |
| { |
| char *wp; |
| |
| wp = *ap->awordlist++; |
| if (wp != NULL) { |
| PUSHIO(aword, wp, *ap->awordlist == NULL ? strchar : xxchar); |
| return -1; |
| } |
| return 0; |
| } |
| |
| static int xxchar(struct ioarg *ap) |
| { |
| int c; |
| |
| if (ap->aword == NULL) |
| return 0; |
| c = *ap->aword++; |
| if (c == '\0') { |
| ap->aword = NULL; |
| return ' '; |
| } |
| return c; |
| } |
| |
| /* |
| * Produce the characters from a single word (string). |
| */ |
| static int strchar(struct ioarg *ap) |
| { |
| if (ap->aword == NULL) |
| return 0; |
| return *ap->aword++; |
| } |
| |
| /* |
| * Produce quoted characters from a single word (string). |
| */ |
| static int qstrchar(struct ioarg *ap) |
| { |
| int c; |
| |
| if (ap->aword == NULL) |
| return 0; |
| c = *ap->aword++; |
| if (c) |
| c |= QUOTE; |
| return c; |
| } |
| |
| /* |
| * Return the characters from a file. |
| */ |
| static int filechar(struct ioarg *ap) |
| { |
| int i; |
| char c; |
| struct iobuf *bp = ap->afbuf; |
| |
| if (ap->afid != AFID_NOBUF) { |
| i = (ap->afid != bp->id); |
| if (i || bp->bufp == bp->ebufp) { |
| if (i) |
| lseek(ap->afile, ap->afpos, SEEK_SET); |
| |
| i = safe_read(ap->afile, bp->buf, sizeof(bp->buf)); |
| if (i <= 0) { |
| closef(ap->afile); |
| return 0; |
| } |
| |
| bp->id = ap->afid; |
| bp->bufp = bp->buf; |
| bp->ebufp = bp->bufp + i; |
| } |
| |
| ap->afpos++; |
| return *bp->bufp++ & 0177; |
| } |
| #if ENABLE_FEATURE_EDITING |
| if (interactive && isatty(ap->afile)) { |
| static char mycommand[BUFSIZ]; |
| static int position = 0, size = 0; |
| |
| while (size == 0 || position >= size) { |
| read_line_input(current_prompt, mycommand, BUFSIZ, line_input_state); |
| size = strlen(mycommand); |
| position = 0; |
| } |
| c = mycommand[position]; |
| position++; |
| return c; |
| } |
| #endif |
| i = safe_read(ap->afile, &c, sizeof(c)); |
| return i == sizeof(c) ? (c & 0x7f) : (closef(ap->afile), 0); |
| } |
| |
| /* |
| * Return the characters from a here temp file. |
| */ |
| static int herechar(struct ioarg *ap) |
| { |
| char c; |
| |
| if (read(ap->afile, &c, sizeof(c)) != sizeof(c)) { |
| close(ap->afile); |
| c = '\0'; |
| } |
| return c; |
| } |
| |
| /* |
| * Return the characters produced by a process (`...`). |
| * Quote them if required, and remove any trailing newline characters. |
| */ |
| static int gravechar(struct ioarg *ap, struct io *iop) |
| { |
| int c; |
| |
| c = qgravechar(ap, iop) & ~QUOTE; |
| if (c == '\n') |
| c = ' '; |
| return c; |
| } |
| |
| static int qgravechar(struct ioarg *ap, struct io *iop) |
| { |
| int c; |
| |
| DBGPRINTF3(("QGRAVECHAR: enter, ap=%p, iop=%p\n", ap, iop)); |
| |
| if (iop->xchar) { |
| if (iop->nlcount) { |
| iop->nlcount--; |
| return '\n' | QUOTE; |
| } |
| c = iop->xchar; |
| iop->xchar = 0; |
| } else if ((c = filechar(ap)) == '\n') { |
| iop->nlcount = 1; |
| while ((c = filechar(ap)) == '\n') |
| iop->nlcount++; |
| iop->xchar = c; |
| if (c == 0) |
| return c; |
| iop->nlcount--; |
| c = '\n'; |
| } |
| return c != 0 ? c | QUOTE : 0; |
| } |
| |
| /* |
| * Return a single command (usually the first line) from a file. |
| */ |
| static int linechar(struct ioarg *ap) |
| { |
| int c; |
| |
| c = filechar(ap); |
| if (c == '\n') { |
| if (!multiline) { |
| closef(ap->afile); |
| ap->afile = -1; /* illegal value */ |
| } |
| } |
| return c; |
| } |
| |
| /* |
| * remap fd into Shell's fd space |
| */ |
| static int remap(int fd) |
| { |
| int i; |
| int map[NOFILE]; |
| int newfd; |
| |
| DBGPRINTF(("REMAP: fd=%d, e.iofd=%d\n", fd, e.iofd)); |
| |
| if (fd < e.iofd) { |
| for (i = 0; i < NOFILE; i++) |
| map[i] = 0; |
| |
| do { |
| map[fd] = 1; |
| newfd = dup(fd); |
| fd = newfd; |
| } while (fd >= 0 && fd < e.iofd); |
| |
| for (i = 0; i < NOFILE; i++) |
| if (map[i]) |
| close(i); |
| |
| if (fd < 0) |
| err("too many files open in shell"); |
| } |
| |
| return fd; |
| } |
| |
| static int openpipe(int *pv) |
| { |
| int i; |
| |
| i = pipe(pv); |
| if (i < 0) |
| err("can't create pipe - try again"); |
| return i; |
| } |
| |
| static void closepipe(int *pv) |
| { |
| if (pv != NULL) { |
| close(*pv++); |
| close(*pv); |
| } |
| } |
| |
| |
| /* -------- here.c -------- */ |
| |
| /* |
| * here documents |
| */ |
| |
| static void markhere(char *s, struct ioword *iop) |
| { |
| struct here *h, *lh; |
| |
| DBGPRINTF7(("MARKHERE: enter, s=%p\n", s)); |
| |
| h = (struct here *) space(sizeof(struct here)); |
| if (h == NULL) |
| return; |
| |
| h->h_tag = evalstr(s, DOSUB); |
| if (h->h_tag == 0) |
| return; |
| |
| h->h_iop = iop; |
| iop->io_name = 0; |
| h->h_next = NULL; |
| if (inhere == 0) |
| inhere = h; |
| else { |
| for (lh = inhere; lh != NULL; lh = lh->h_next) { |
| if (lh->h_next == 0) { |
| lh->h_next = h; |
| break; |
| } |
| } |
| } |
| iop->io_flag |= IOHERE | IOXHERE; |
| for (s = h->h_tag; *s; s++) { |
| if (*s & QUOTE) { |
| iop->io_flag &= ~IOXHERE; |
| *s &= ~QUOTE; |
| } |
| } |
| h->h_dosub = iop->io_flag & IOXHERE; |
| } |
| |
| static void gethere(void) |
| { |
| struct here *h, *hp; |
| |
| DBGPRINTF7(("GETHERE: enter...\n")); |
| |
| /* Scan here files first leaving inhere list in place */ |
| for (hp = h = inhere; h != NULL; hp = h, h = h->h_next) |
| readhere(&h->h_iop->io_name, h->h_tag, h->h_dosub ? 0 : '\''); |
| |
| /* Make inhere list active - keep list intact for scraphere */ |
| if (hp != NULL) { |
| hp->h_next = acthere; |
| acthere = inhere; |
| inhere = NULL; |
| } |
| } |
| |
| static void readhere(char **name, char *s, int ec) |
| { |
| int tf; |
| char tname[30] = ".msh_XXXXXX"; |
| int c; |
| jmp_buf ev; |
| char myline[LINELIM + 1]; |
| char *thenext; |
| |
| DBGPRINTF7(("READHERE: enter, name=%p, s=%p\n", name, s)); |
| |
| tf = mkstemp(tname); |
| if (tf < 0) |
| return; |
| |
| *name = strsave(tname, areanum); |
| errpt = ev; |
| if (newenv(setjmp(errpt)) != 0) |
| unlink(tname); |
| else { |
| pushio(e.iop->argp, (int (*)(struct ioarg *)) e.iop->iofn); |
| e.iobase = e.iop; |
| for (;;) { |
| if (interactive && e.iop <= iostack) { |
| #if ENABLE_FEATURE_EDITING |
| current_prompt = cprompt->value; |
| #else |
| prs(cprompt->value); |
| #endif |
| } |
| thenext = myline; |
| while ((c = my_getc(ec)) != '\n' && c) { |
| if (ec == '\'') |
| c &= ~QUOTE; |
| if (thenext >= &myline[LINELIM]) { |
| c = 0; |
| break; |
| } |
| *thenext++ = c; |
| } |
| *thenext = 0; |
| if (strcmp(s, myline) == 0 || c == 0) |
| break; |
| *thenext++ = '\n'; |
| write(tf, myline, (int) (thenext - myline)); |
| } |
| if (c == 0) { |
| prs("here document `"); |
| prs(s); |
| err("' unclosed"); |
| } |
| quitenv(); |
| } |
| close(tf); |
| } |
| |
| /* |
| * open here temp file. |
| * if unquoted here, expand here temp file into second temp file. |
| */ |
| static int herein(char *hname, int xdoll) |
| { |
| int hf; |
| int tf; |
| |
| #if __GNUC__ |
| /* Avoid longjmp clobbering */ |
| (void) &tf; |
| #endif |
| if (hname == NULL) |
| return -1; |
| |
| DBGPRINTF7(("HEREIN: hname is %s, xdoll=%d\n", hname, xdoll)); |
| |
| hf = open(hname, 0); |
| if (hf < 0) |
| return -1; |
| |
| if (xdoll) { |
| char c; |
| char tname[30] = ".msh_XXXXXX"; |
| jmp_buf ev; |
| |
| tf = mkstemp(tname); |
| if (tf < 0) |
| return -1; |
| errpt = ev; |
| if (newenv(setjmp(errpt)) == 0) { |
| PUSHIO(afile, hf, herechar); |
| setbase(e.iop); |
| while ((c = subgetc(0, 0)) != 0) { |
| c &= ~QUOTE; |
| write(tf, &c, sizeof c); |
| } |
| quitenv(); |
| } else |
| unlink(tname); |
| close(tf); |
| tf = open(tname, 0); |
| unlink(tname); |
| return tf; |
| } |
| return hf; |
| } |
| |
| static void scraphere(void) |
| { |
| struct here *h; |
| |
| DBGPRINTF7(("SCRAPHERE: enter...\n")); |
| |
| for (h = inhere; h != NULL; h = h->h_next) { |
| if (h->h_iop && h->h_iop->io_name) |
| unlink(h->h_iop->io_name); |
| } |
| inhere = NULL; |
| } |
| |
| /* unlink here temp files before a freearea(area) */ |
| static void freehere(int area) |
| { |
| struct here *h, *hl; |
| |
| DBGPRINTF6(("FREEHERE: enter, area=%d\n", area)); |
| |
| hl = NULL; |
| for (h = acthere; h != NULL; h = h->h_next) |
| if (getarea((char *) h) >= area) { |
| if (h->h_iop->io_name != NULL) |
| unlink(h->h_iop->io_name); |
| if (hl == NULL) |
| acthere = h->h_next; |
| else |
| hl->h_next = h->h_next; |
| } else |
| hl = h; |
| } |
| |
| |
| /* -------- sh.c -------- */ |
| /* |
| * shell |
| */ |
| |
| int msh_main(int argc, char **argv); |
| int msh_main(int argc, char **argv) |
| { |
| int f; |
| char *s; |
| int cflag; |
| char *name, **ap; |
| int (*iof) (struct ioarg *); |
| |
| #if ENABLE_FEATURE_EDITING |
| line_input_state = new_line_input_t(FOR_SHELL); |
| #endif |
| |
| DBGPRINTF(("MSH_MAIN: argc %d, environ %p\n", argc, environ)); |
| |
| initarea(); |
| ap = environ; |
| if (ap != NULL) { |
| while (*ap) |
| assign(*ap++, !COPYV); |
| for (ap = environ; *ap;) |
| export(lookup(*ap++)); |
| } |
| closeall(); |
| areanum = 1; |
| |
| shell = lookup("SHELL"); |
| if (shell->value == null) |
| setval(shell, (char *)DEFAULT_SHELL); |
| export(shell); |
| |
| homedir = lookup("HOME"); |
| if (homedir->value == null) |
| setval(homedir, "/"); |
| export(homedir); |
| |
| setval(lookup("$"), putn(getpid())); |
| |
| path = lookup("PATH"); |
| if (path->value == null) { |
| if (geteuid() == 0) |
| setval(path, "/sbin:/bin:/usr/sbin:/usr/bin"); |
| else |
| setval(path, "/bin:/usr/bin"); |
| } |
| export(path); |
| |
| ifs = lookup("IFS"); |
| if (ifs->value == null) |
| setval(ifs, " \t\n"); |
| |
| #ifdef MSHDEBUG |
| mshdbg_var = lookup("MSHDEBUG"); |
| if (mshdbg_var->value == null) |
| setval(mshdbg_var, "0"); |
| #endif |
| |
| prompt = lookup("PS1"); |
| #if ENABLE_FEATURE_EDITING_FANCY_PROMPT |
| if (prompt->value == null) |
| #endif |
| setval(prompt, DEFAULT_USER_PROMPT); |
| if (geteuid() == 0) { |
| setval(prompt, DEFAULT_ROOT_PROMPT); |
| prompt->status &= ~EXPORT; |
| } |
| cprompt = lookup("PS2"); |
| #if ENABLE_FEATURE_EDITING_FANCY_PROMPT |
| if (cprompt->value == null) |
| #endif |
| setval(cprompt, "> "); |
| |
| iof = filechar; |
| cflag = 0; |
| name = *argv++; |
| if (--argc >= 1) { |
| if (argv[0][0] == '-' && argv[0][1] != '\0') { |
| for (s = argv[0] + 1; *s; s++) |
| switch (*s) { |
| case 'c': |
| prompt->status &= ~EXPORT; |
| cprompt->status &= ~EXPORT; |
| setval(prompt, ""); |
| setval(cprompt, ""); |
| cflag = 1; |
| if (--argc > 0) |
| PUSHIO(aword, *++argv, iof = nlchar); |
| break; |
| |
| case 'q': |
| qflag = SIG_DFL; |
| break; |
| |
| case 's': |
| /* standard input */ |
| break; |
| |
| case 't': |
| prompt->status &= ~EXPORT; |
| setval(prompt, ""); |
| iof = linechar; |
| break; |
| |
| case 'i': |
| interactive++; |
| default: |
| if (*s >= 'a' && *s <= 'z') |
| flag[(int) *s]++; |
| } |
| } else { |
| argv--; |
| argc++; |
| } |
| |
| if (iof == filechar && --argc > 0) { |
| setval(prompt, ""); |
| setval(cprompt, ""); |
| prompt->status &= ~EXPORT; |
| cprompt->status &= ~EXPORT; |
| |
| /* Shell is non-interactive, activate printf-based debug */ |
| #ifdef MSHDEBUG |
| mshdbg = (int) (((char) (mshdbg_var->value[0])) - '0'); |
| if (mshdbg < 0) |
| mshdbg = 0; |
| #endif |
| DBGPRINTF(("MSH_MAIN: calling newfile()\n")); |
| |
| name = *++argv; |
| if (newfile(name)) |
| exit(1); /* Exit on error */ |
| } |
| } |
| |
| setdash(); |
| |
| /* This won't be true if PUSHIO has been called, say from newfile() above */ |
| if (e.iop < iostack) { |
| PUSHIO(afile, 0, iof); |
| if (isatty(0) && isatty(1) && !cflag) { |
| interactive++; |
| #if !ENABLE_FEATURE_SH_EXTRA_QUIET |
| #ifdef MSHDEBUG |
| printf("\n\n%s Built-in shell (msh with debug)\n", BB_BANNER); |
| #else |
| printf("\n\n%s Built-in shell (msh)\n", BB_BANNER); |
| #endif |
| printf("Enter 'help' for a list of built-in commands.\n\n"); |
| #endif |
| } |
| } |
| |
| signal(SIGQUIT, qflag); |
| if (name && name[0] == '-') { |
| interactive++; |
| f = open(".profile", 0); |
| if (f >= 0) |
| next(remap(f)); |
| f = open("/etc/profile", 0); |
| if (f >= 0) |
| next(remap(f)); |
| } |
| if (interactive) |
| signal(SIGTERM, sig); |
| |
| if (signal(SIGINT, SIG_IGN) != SIG_IGN) |
| signal(SIGINT, onintr); |
| dolv = argv; |
| dolc = argc; |
| dolv[0] = name; |
| if (dolc > 1) { |
| for (ap = ++argv; --argc > 0;) { |
| *ap = *argv++; |
| if (assign(*ap, !COPYV)) { |
| dolc--; /* keyword */ |
| } else { |
| ap++; |
| } |
| } |
| } |
| setval(lookup("#"), putn((--dolc < 0) ? (dolc = 0) : dolc)); |
| |
| DBGPRINTF(("MSH_MAIN: begin FOR loop, interactive %d, e.iop %p, iostack %p\n", interactive, e.iop, iostack)); |
| |
| for (;;) { |
| if (interactive && e.iop <= iostack) { |
| #if ENABLE_FEATURE_EDITING |
| current_prompt = prompt->value; |
| #else |
| prs(prompt->value); |
| #endif |
| } |
| onecommand(); |
| /* Ensure that getenv("PATH") stays current */ |
| setenv("PATH", path->value, 1); |
| } |
| |
| DBGPRINTF(("MSH_MAIN: returning.\n")); |
| } |
| |
| |
| /* |
| * Copyright (c) 1987,1997, Prentice Hall |
| * All rights reserved. |
| * |
| * Redistribution and use of the MINIX operating system in source and |
| * binary forms, with or without modification, are permitted provided |
| * that the following conditions are met: |
| * |
| * Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * |
| * Redistributions in binary form must reproduce the above |
| * copyright notice, this list of conditions and the following |
| * disclaimer in the documentation and/or other materials provided |
| * with the distribution. |
| * |
| * Neither the name of Prentice Hall nor the names of the software |
| * authors or contributors may be used to endorse or promote |
| * products derived from this software without specific prior |
| * written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS, AUTHORS, AND |
| * CONTRIBUTORS ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, |
| * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF |
| * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL PRENTICE HALL OR ANY AUTHORS OR CONTRIBUTORS BE |
| * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR |
| * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF |
| * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR |
| * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, |
| * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE |
| * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, |
| * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| * |
| */ |