exec.c revision 1.5 1 1.5 hubertf /* $NetBSD: exec.c,v 1.5 1999/10/20 15:09:59 hubertf Exp $ */
2 1.2 tls
3 1.1 jtc /*
4 1.1 jtc * execute command tree
5 1.1 jtc */
6 1.1 jtc
7 1.1 jtc #include "sh.h"
8 1.1 jtc #include "c_test.h"
9 1.1 jtc #include <ctype.h>
10 1.1 jtc #include "ksh_stat.h"
11 1.1 jtc
12 1.1 jtc /* Does ps4 get parameter substitutions done? */
13 1.1 jtc #ifdef KSH
14 1.1 jtc # define PS4_SUBSTITUTE(s) substitute((s), 0)
15 1.1 jtc #else
16 1.1 jtc # define PS4_SUBSTITUTE(s) (s)
17 1.1 jtc #endif /* KSH */
18 1.1 jtc
19 1.1 jtc static int comexec ARGS((struct op *t, struct tbl *volatile tp, char **ap,
20 1.1 jtc int volatile flags));
21 1.1 jtc static void scriptexec ARGS((struct op *tp, char **ap));
22 1.1 jtc static int call_builtin ARGS((struct tbl *tp, char **wp));
23 1.1 jtc static int iosetup ARGS((struct ioword *iop, struct tbl *tp));
24 1.5 hubertf static int herein ARGS((const char *content, int sub));
25 1.1 jtc #ifdef KSH
26 1.1 jtc static char *do_selectargs ARGS((char **ap, bool_t print_menu));
27 1.1 jtc #endif /* KSH */
28 1.1 jtc #ifdef KSH
29 1.1 jtc static int dbteste_isa ARGS((Test_env *te, Test_meta meta));
30 1.1 jtc static const char *dbteste_getopnd ARGS((Test_env *te, Test_op op,
31 1.1 jtc int do_eval));
32 1.1 jtc static int dbteste_eval ARGS((Test_env *te, Test_op op, const char *opnd1,
33 1.1 jtc const char *opnd2, int do_eval));
34 1.1 jtc static void dbteste_error ARGS((Test_env *te, int offset, const char *msg));
35 1.1 jtc #endif /* KSH */
36 1.1 jtc #ifdef OS2
37 1.2 tls static int search_access1 ARGS((const char *path, int mode, int *errnop));
38 1.1 jtc #endif /* OS2 */
39 1.1 jtc
40 1.1 jtc
41 1.1 jtc /*
42 1.1 jtc * handle systems that don't have F_SETFD
43 1.1 jtc */
44 1.1 jtc #ifndef F_SETFD
45 1.1 jtc # ifndef MAXFD
46 1.1 jtc # define MAXFD 64
47 1.1 jtc # endif
48 1.1 jtc /* a bit field would be smaller, but this will work */
49 1.1 jtc static char clexec_tab[MAXFD+1];
50 1.1 jtc #endif
51 1.1 jtc
52 1.1 jtc /*
53 1.1 jtc * we now use this function always.
54 1.1 jtc */
55 1.1 jtc int
56 1.1 jtc fd_clexec(fd)
57 1.1 jtc int fd;
58 1.1 jtc {
59 1.1 jtc #ifndef F_SETFD
60 1.1 jtc if (fd >= 0 && fd < sizeof(clexec_tab)) {
61 1.1 jtc clexec_tab[fd] = 1;
62 1.1 jtc return 0;
63 1.1 jtc }
64 1.1 jtc return -1;
65 1.1 jtc #else
66 1.1 jtc return fcntl(fd, F_SETFD, 1);
67 1.1 jtc #endif
68 1.1 jtc }
69 1.1 jtc
70 1.1 jtc
71 1.1 jtc /*
72 1.1 jtc * execute command tree
73 1.1 jtc */
74 1.1 jtc int
75 1.1 jtc execute(t, flags)
76 1.1 jtc struct op * volatile t;
77 1.1 jtc volatile int flags; /* if XEXEC don't fork */
78 1.1 jtc {
79 1.1 jtc int i;
80 1.1 jtc volatile int rv = 0;
81 1.1 jtc int pv[2];
82 1.1 jtc char ** volatile ap;
83 1.1 jtc char *s, *cp;
84 1.1 jtc struct ioword **iowp;
85 1.1 jtc struct tbl *tp = NULL;
86 1.1 jtc
87 1.1 jtc if (t == NULL)
88 1.1 jtc return 0;
89 1.1 jtc
90 1.1 jtc /* Is this the end of a pipeline? If so, we want to evaluate the
91 1.1 jtc * command arguments
92 1.1 jtc bool_t eval_done = FALSE;
93 1.1 jtc if ((flags&XFORK) && !(flags&XEXEC) && (flags&XPCLOSE)) {
94 1.1 jtc eval_done = TRUE;
95 1.1 jtc tp = eval_execute_args(t, &ap);
96 1.1 jtc }
97 1.1 jtc */
98 1.1 jtc if ((flags&XFORK) && !(flags&XEXEC) && t->type != TPIPE)
99 1.5 hubertf return exchild(t, flags & ~XTIME, -1); /* run in sub-process */
100 1.1 jtc
101 1.1 jtc newenv(E_EXEC);
102 1.1 jtc if (trap)
103 1.1 jtc runtraps(0);
104 1.1 jtc
105 1.1 jtc if (t->type == TCOM) {
106 1.1 jtc /* Clear subst_exstat before argument expansion. Used by
107 1.5 hubertf * null commands (see comexec() and c_eval()) and by c_set().
108 1.1 jtc */
109 1.1 jtc subst_exstat = 0;
110 1.1 jtc
111 1.5 hubertf current_lineno = t->lineno; /* for $LINENO */
112 1.5 hubertf
113 1.1 jtc /* POSIX says expand command words first, then redirections,
114 1.1 jtc * and assignments last..
115 1.1 jtc */
116 1.1 jtc ap = eval(t->args, t->u.evalflags | DOBLANK | DOGLOB | DOTILDE);
117 1.5 hubertf if (flags & XTIME)
118 1.5 hubertf /* Allow option parsing (bizarre, but POSIX) */
119 1.5 hubertf timex_hook(t, &ap);
120 1.1 jtc if (Flag(FXTRACE) && ap[0]) {
121 1.1 jtc shf_fprintf(shl_out, "%s",
122 1.1 jtc PS4_SUBSTITUTE(str_val(global("PS4"))));
123 1.1 jtc for (i = 0; ap[i]; i++)
124 1.1 jtc shf_fprintf(shl_out, "%s%s", ap[i],
125 1.1 jtc ap[i + 1] ? space : newline);
126 1.1 jtc shf_flush(shl_out);
127 1.1 jtc }
128 1.1 jtc if (ap[0])
129 1.1 jtc tp = findcom(ap[0], FC_BI|FC_FUNC);
130 1.1 jtc }
131 1.5 hubertf flags &= ~XTIME;
132 1.1 jtc
133 1.1 jtc if (t->ioact != NULL || t->type == TPIPE || t->type == TCOPROC) {
134 1.1 jtc e->savefd = (short *) alloc(sizeofN(short, NUFILE), ATEMP);
135 1.1 jtc /* initialize to not redirected */
136 1.1 jtc memset(e->savefd, 0, sizeofN(short, NUFILE));
137 1.1 jtc }
138 1.1 jtc
139 1.1 jtc /* do redirection, to be restored in quitenv() */
140 1.1 jtc if (t->ioact != NULL)
141 1.1 jtc for (iowp = t->ioact; *iowp != NULL; iowp++) {
142 1.1 jtc if (iosetup(*iowp, tp) < 0) {
143 1.1 jtc exstat = rv = 1;
144 1.1 jtc /* Redirection failures for special commands
145 1.1 jtc * cause (non-interactive) shell to exit.
146 1.1 jtc */
147 1.1 jtc if (tp && tp->type == CSHELL
148 1.1 jtc && (tp->flag & SPEC_BI))
149 1.1 jtc errorf(null);
150 1.1 jtc /* Deal with FERREXIT, quitenv(), etc. */
151 1.1 jtc goto Break;
152 1.1 jtc }
153 1.1 jtc }
154 1.1 jtc
155 1.1 jtc switch(t->type) {
156 1.1 jtc case TCOM:
157 1.1 jtc rv = comexec(t, tp, ap, flags);
158 1.1 jtc break;
159 1.1 jtc
160 1.1 jtc case TPAREN:
161 1.1 jtc rv = execute(t->left, flags|XFORK);
162 1.1 jtc break;
163 1.1 jtc
164 1.1 jtc case TPIPE:
165 1.1 jtc flags |= XFORK;
166 1.1 jtc flags &= ~XEXEC;
167 1.1 jtc e->savefd[0] = savefd(0, 0);
168 1.1 jtc (void) ksh_dup2(e->savefd[0], 0, FALSE); /* stdin of first */
169 1.1 jtc e->savefd[1] = savefd(1, 0);
170 1.1 jtc while (t->type == TPIPE) {
171 1.1 jtc openpipe(pv);
172 1.1 jtc (void) ksh_dup2(pv[1], 1, FALSE); /* stdout of curr */
173 1.1 jtc /* Let exchild() close pv[0] in child
174 1.1 jtc * (if this isn't done, commands like
175 1.1 jtc * (: ; cat /etc/termcap) | sleep 1
176 1.1 jtc * will hang forever).
177 1.1 jtc */
178 1.1 jtc exchild(t->left, flags|XPIPEO|XCCLOSE, pv[0]);
179 1.1 jtc (void) ksh_dup2(pv[0], 0, FALSE); /* stdin of next */
180 1.1 jtc closepipe(pv);
181 1.1 jtc flags |= XPIPEI;
182 1.1 jtc t = t->right;
183 1.1 jtc }
184 1.1 jtc restfd(1, e->savefd[1]); /* stdout of last */
185 1.1 jtc e->savefd[1] = 0; /* no need to re-restore this */
186 1.1 jtc /* Let exchild() close 0 in parent, after fork, before wait */
187 1.1 jtc i = exchild(t, flags|XPCLOSE, 0);
188 1.1 jtc if (!(flags&XBGND) && !(flags&XXCOM))
189 1.1 jtc rv = i;
190 1.1 jtc break;
191 1.1 jtc
192 1.1 jtc case TLIST:
193 1.1 jtc while (t->type == TLIST) {
194 1.1 jtc execute(t->left, flags & XERROK);
195 1.1 jtc t = t->right;
196 1.1 jtc }
197 1.1 jtc rv = execute(t, flags & XERROK);
198 1.1 jtc break;
199 1.1 jtc
200 1.1 jtc #ifdef KSH
201 1.1 jtc case TCOPROC:
202 1.1 jtc {
203 1.1 jtc # ifdef JOB_SIGS
204 1.1 jtc sigset_t omask;
205 1.1 jtc # endif /* JOB_SIGS */
206 1.1 jtc
207 1.1 jtc # ifdef JOB_SIGS
208 1.1 jtc /* Block sigchild as we are using things changed in the
209 1.1 jtc * signal handler
210 1.1 jtc */
211 1.1 jtc sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
212 1.1 jtc e->type = E_ERRH;
213 1.1 jtc i = ksh_sigsetjmp(e->jbuf, 0);
214 1.1 jtc if (i) {
215 1.1 jtc sigprocmask(SIG_SETMASK, &omask, (sigset_t *) 0);
216 1.1 jtc quitenv();
217 1.1 jtc unwind(i);
218 1.1 jtc /*NOTREACHED*/
219 1.1 jtc }
220 1.1 jtc # endif /* JOB_SIGS */
221 1.1 jtc /* Already have a (live) co-process? */
222 1.1 jtc if (coproc.job && coproc.write >= 0)
223 1.1 jtc errorf("coprocess already exists");
224 1.1 jtc
225 1.1 jtc /* Can we re-use the existing co-process pipe? */
226 1.1 jtc coproc_cleanup(TRUE);
227 1.1 jtc
228 1.1 jtc /* do this before opening pipes, in case these fail */
229 1.1 jtc e->savefd[0] = savefd(0, 0);
230 1.1 jtc e->savefd[1] = savefd(1, 0);
231 1.1 jtc
232 1.1 jtc openpipe(pv);
233 1.1 jtc ksh_dup2(pv[0], 0, FALSE);
234 1.1 jtc close(pv[0]);
235 1.1 jtc coproc.write = pv[1];
236 1.1 jtc coproc.job = (void *) 0;
237 1.1 jtc
238 1.1 jtc if (coproc.readw >= 0)
239 1.1 jtc ksh_dup2(coproc.readw, 1, FALSE);
240 1.1 jtc else {
241 1.1 jtc openpipe(pv);
242 1.1 jtc coproc.read = pv[0];
243 1.1 jtc ksh_dup2(pv[1], 1, FALSE);
244 1.1 jtc coproc.readw = pv[1]; /* closed before first read */
245 1.1 jtc coproc.njobs = 0;
246 1.1 jtc /* create new coprocess id */
247 1.1 jtc ++coproc.id;
248 1.1 jtc }
249 1.1 jtc # ifdef JOB_SIGS
250 1.1 jtc sigprocmask(SIG_SETMASK, &omask, (sigset_t *) 0);
251 1.1 jtc e->type = E_EXEC; /* no more need for error handler */
252 1.1 jtc # endif /* JOB_SIGS */
253 1.1 jtc
254 1.1 jtc /* exchild() closes coproc.* in child after fork,
255 1.1 jtc * will also increment coproc.njobs when the
256 1.1 jtc * job is actually created.
257 1.1 jtc */
258 1.1 jtc flags &= ~XEXEC;
259 1.1 jtc exchild(t->left, flags|XBGND|XFORK|XCOPROC|XCCLOSE,
260 1.1 jtc coproc.readw);
261 1.1 jtc break;
262 1.1 jtc }
263 1.1 jtc #endif /* KSH */
264 1.1 jtc
265 1.1 jtc case TASYNC:
266 1.1 jtc /* XXX non-optimal, I think - "(foo &)", forks for (),
267 1.1 jtc * forks again for async... parent should optimize
268 1.1 jtc * this to "foo &"...
269 1.1 jtc */
270 1.1 jtc rv = execute(t->left, (flags&~XEXEC)|XBGND|XFORK);
271 1.1 jtc break;
272 1.1 jtc
273 1.1 jtc case TOR:
274 1.1 jtc case TAND:
275 1.1 jtc rv = execute(t->left, XERROK);
276 1.1 jtc if (t->right != NULL && (rv == 0) == (t->type == TAND))
277 1.1 jtc rv = execute(t->right, flags & XERROK);
278 1.1 jtc else
279 1.1 jtc flags |= XERROK;
280 1.1 jtc break;
281 1.1 jtc
282 1.1 jtc case TBANG:
283 1.1 jtc rv = !execute(t->right, XERROK);
284 1.1 jtc break;
285 1.1 jtc
286 1.1 jtc #ifdef KSH
287 1.1 jtc case TDBRACKET:
288 1.1 jtc {
289 1.1 jtc Test_env te;
290 1.1 jtc
291 1.1 jtc te.flags = TEF_DBRACKET;
292 1.1 jtc te.pos.wp = t->args;
293 1.1 jtc te.isa = dbteste_isa;
294 1.1 jtc te.getopnd = dbteste_getopnd;
295 1.1 jtc te.eval = dbteste_eval;
296 1.1 jtc te.error = dbteste_error;
297 1.1 jtc
298 1.1 jtc rv = test_parse(&te);
299 1.1 jtc break;
300 1.1 jtc }
301 1.1 jtc #endif /* KSH */
302 1.1 jtc
303 1.1 jtc case TFOR:
304 1.1 jtc #ifdef KSH
305 1.1 jtc case TSELECT:
306 1.1 jtc {
307 1.1 jtc volatile bool_t is_first = TRUE;
308 1.1 jtc #endif /* KSH */
309 1.1 jtc ap = (t->vars != NULL) ?
310 1.1 jtc eval(t->vars, DOBLANK|DOGLOB|DOTILDE)
311 1.1 jtc : e->loc->argv + 1;
312 1.1 jtc e->type = E_LOOP;
313 1.1 jtc while (1) {
314 1.1 jtc i = ksh_sigsetjmp(e->jbuf, 0);
315 1.1 jtc if (!i)
316 1.1 jtc break;
317 1.1 jtc if ((e->flags&EF_BRKCONT_PASS)
318 1.1 jtc || (i != LBREAK && i != LCONTIN))
319 1.1 jtc {
320 1.1 jtc quitenv();
321 1.1 jtc unwind(i);
322 1.1 jtc } else if (i == LBREAK) {
323 1.1 jtc rv = 0;
324 1.1 jtc goto Break;
325 1.1 jtc }
326 1.1 jtc }
327 1.1 jtc rv = 0; /* in case of a continue */
328 1.1 jtc if (t->type == TFOR) {
329 1.1 jtc while (*ap != NULL) {
330 1.5 hubertf setstr(global(t->str), *ap++, KSH_UNWIND_ERROR);
331 1.1 jtc rv = execute(t->left, flags & XERROK);
332 1.1 jtc }
333 1.1 jtc }
334 1.1 jtc #ifdef KSH
335 1.1 jtc else { /* TSELECT */
336 1.1 jtc for (;;) {
337 1.1 jtc if (!(cp = do_selectargs(ap, is_first))) {
338 1.1 jtc rv = 1;
339 1.1 jtc break;
340 1.1 jtc }
341 1.1 jtc is_first = FALSE;
342 1.5 hubertf setstr(global(t->str), cp, KSH_UNWIND_ERROR);
343 1.1 jtc rv = execute(t->left, flags & XERROK);
344 1.1 jtc }
345 1.1 jtc }
346 1.1 jtc }
347 1.1 jtc #endif /* KSH */
348 1.1 jtc break;
349 1.1 jtc
350 1.1 jtc case TWHILE:
351 1.1 jtc case TUNTIL:
352 1.1 jtc e->type = E_LOOP;
353 1.1 jtc while (1) {
354 1.1 jtc i = ksh_sigsetjmp(e->jbuf, 0);
355 1.1 jtc if (!i)
356 1.1 jtc break;
357 1.1 jtc if ((e->flags&EF_BRKCONT_PASS)
358 1.1 jtc || (i != LBREAK && i != LCONTIN))
359 1.1 jtc {
360 1.1 jtc quitenv();
361 1.1 jtc unwind(i);
362 1.1 jtc } else if (i == LBREAK) {
363 1.1 jtc rv = 0;
364 1.1 jtc goto Break;
365 1.1 jtc }
366 1.1 jtc }
367 1.1 jtc rv = 0; /* in case of a continue */
368 1.1 jtc while ((execute(t->left, XERROK) == 0) == (t->type == TWHILE))
369 1.1 jtc rv = execute(t->right, flags & XERROK);
370 1.1 jtc break;
371 1.1 jtc
372 1.1 jtc case TIF:
373 1.1 jtc case TELIF:
374 1.1 jtc if (t->right == NULL)
375 1.1 jtc break; /* should be error */
376 1.1 jtc rv = execute(t->left, XERROK) == 0 ?
377 1.1 jtc execute(t->right->left, flags & XERROK) :
378 1.1 jtc execute(t->right->right, flags & XERROK);
379 1.1 jtc break;
380 1.1 jtc
381 1.1 jtc case TCASE:
382 1.1 jtc cp = evalstr(t->str, DOTILDE);
383 1.1 jtc for (t = t->left; t != NULL && t->type == TPAT; t = t->right)
384 1.1 jtc for (ap = t->vars; *ap; ap++)
385 1.1 jtc if ((s = evalstr(*ap, DOTILDE|DOPAT))
386 1.1 jtc && gmatch(cp, s, FALSE))
387 1.1 jtc goto Found;
388 1.1 jtc break;
389 1.1 jtc Found:
390 1.1 jtc rv = execute(t->left, flags & XERROK);
391 1.1 jtc break;
392 1.1 jtc
393 1.1 jtc case TBRACE:
394 1.1 jtc rv = execute(t->left, flags & XERROK);
395 1.1 jtc break;
396 1.1 jtc
397 1.1 jtc case TFUNCT:
398 1.1 jtc rv = define(t->str, t);
399 1.1 jtc break;
400 1.1 jtc
401 1.1 jtc case TTIME:
402 1.5 hubertf /* Clear XEXEC so nested execute() call doesn't exit
403 1.5 hubertf * (allows "ls -l | time grep foo").
404 1.5 hubertf */
405 1.5 hubertf rv = timex(t, flags & ~XEXEC);
406 1.1 jtc break;
407 1.1 jtc
408 1.1 jtc case TEXEC: /* an eval'd TCOM */
409 1.1 jtc s = t->args[0];
410 1.1 jtc ap = makenv();
411 1.1 jtc #ifndef F_SETFD
412 1.1 jtc for (i = 0; i < sizeof(clexec_tab); i++)
413 1.1 jtc if (clexec_tab[i]) {
414 1.1 jtc close(i);
415 1.1 jtc clexec_tab[i] = 0;
416 1.1 jtc }
417 1.1 jtc #endif
418 1.1 jtc restoresigs();
419 1.2 tls cleanup_proc_env();
420 1.5 hubertf /* XINTACT bit is for OS2 */
421 1.5 hubertf ksh_execve(t->str, t->args, ap, (flags & XINTACT) ? 1 : 0);
422 1.1 jtc if (errno == ENOEXEC)
423 1.1 jtc scriptexec(t, ap);
424 1.1 jtc else
425 1.1 jtc errorf("%s: %s", s, strerror(errno));
426 1.1 jtc }
427 1.1 jtc Break:
428 1.1 jtc exstat = rv;
429 1.1 jtc
430 1.1 jtc quitenv(); /* restores IO */
431 1.4 mycroft if ((flags&XEXEC)) {
432 1.5 hubertf unwind(LEXIT); /* exit child */
433 1.4 mycroft /* NOTREACHED */
434 1.4 mycroft }
435 1.1 jtc if (rv != 0 && !(flags & XERROK)) {
436 1.1 jtc if (Flag(FERREXIT))
437 1.1 jtc unwind(LERROR);
438 1.1 jtc trapsig(SIGERR_);
439 1.1 jtc }
440 1.1 jtc return rv;
441 1.1 jtc }
442 1.1 jtc
443 1.1 jtc /*
444 1.1 jtc * execute simple command
445 1.1 jtc */
446 1.1 jtc
447 1.1 jtc static int
448 1.1 jtc comexec(t, tp, ap, flags)
449 1.1 jtc struct op *t;
450 1.1 jtc struct tbl *volatile tp;
451 1.1 jtc register char **ap;
452 1.1 jtc int volatile flags;
453 1.1 jtc {
454 1.1 jtc int i;
455 1.1 jtc int rv = 0;
456 1.1 jtc register char *cp;
457 1.1 jtc register char **lastp;
458 1.1 jtc static struct op texec; /* Must be static (XXX but why?) */
459 1.1 jtc int type_flags;
460 1.1 jtc int keepasn_ok;
461 1.1 jtc int fcflags = FC_BI|FC_FUNC|FC_PATH;
462 1.3 christos #ifdef __GNUC__
463 1.3 christos (void) &rv;
464 1.3 christos #endif
465 1.1 jtc
466 1.5 hubertf #ifdef KSH
467 1.1 jtc /* snag the last argument for $_ XXX not the same as at&t ksh,
468 1.1 jtc * which only seems to set $_ after a newline (but not in
469 1.1 jtc * functions/dot scripts, but in interactive and scipt) -
470 1.1 jtc * perhaps save last arg here and set it in shell()?.
471 1.1 jtc */
472 1.5 hubertf if (Flag(FTALKING) && *(lastp = ap)) {
473 1.1 jtc while (*++lastp)
474 1.1 jtc ;
475 1.5 hubertf /* setstr() can't fail here */
476 1.5 hubertf setstr(typeset("_", LOCAL, 0, INTEGER, 0), *--lastp,
477 1.5 hubertf KSH_RETURN_ERROR);
478 1.1 jtc }
479 1.5 hubertf #endif /* KSH */
480 1.1 jtc
481 1.1 jtc /* Deal with the shell builtins builtin, exec and command since
482 1.1 jtc * they can be followed by other commands. This must be done before
483 1.1 jtc * we know if we should create a local block, which must be done
484 1.1 jtc * before we can do a path search (in case the assignments change
485 1.1 jtc * PATH).
486 1.1 jtc * Odd cases:
487 1.1 jtc * FOO=bar exec > /dev/null FOO is kept but not exported
488 1.1 jtc * FOO=bar exec foobar FOO is exported
489 1.1 jtc * FOO=bar command exec > /dev/null FOO is neither kept nor exported
490 1.1 jtc * FOO=bar command FOO is neither kept nor exported
491 1.1 jtc * PATH=... foobar use new PATH in foobar search
492 1.1 jtc */
493 1.1 jtc keepasn_ok = 1;
494 1.1 jtc while (tp && tp->type == CSHELL) {
495 1.1 jtc fcflags = FC_BI|FC_FUNC|FC_PATH;/* undo effects of command */
496 1.1 jtc if (tp->val.f == c_builtin) {
497 1.1 jtc if ((cp = *++ap) == NULL) {
498 1.1 jtc tp = NULL;
499 1.1 jtc break;
500 1.1 jtc }
501 1.1 jtc tp = findcom(cp, FC_BI);
502 1.1 jtc if (tp == NULL)
503 1.1 jtc errorf("builtin: %s: not a builtin", cp);
504 1.1 jtc continue;
505 1.1 jtc } else if (tp->val.f == c_exec) {
506 1.1 jtc if (ap[1] == NULL)
507 1.1 jtc break;
508 1.1 jtc ap++;
509 1.1 jtc flags |= XEXEC;
510 1.1 jtc } else if (tp->val.f == c_command) {
511 1.1 jtc int optc, saw_p = 0;
512 1.1 jtc
513 1.1 jtc /* Ugly dealing with options in two places (here and
514 1.1 jtc * in c_command(), but such is life)
515 1.1 jtc */
516 1.1 jtc ksh_getopt_reset(&builtin_opt, 0);
517 1.1 jtc while ((optc = ksh_getopt(ap, &builtin_opt, ":p"))
518 1.1 jtc == 'p')
519 1.1 jtc saw_p = 1;
520 1.1 jtc if (optc != EOF)
521 1.1 jtc break; /* command -vV or something */
522 1.1 jtc /* don't look for functions */
523 1.1 jtc fcflags = FC_BI|FC_PATH;
524 1.1 jtc if (saw_p) {
525 1.1 jtc if (Flag(FRESTRICTED)) {
526 1.1 jtc warningf(TRUE,
527 1.1 jtc "command -p: restricted");
528 1.1 jtc rv = 1;
529 1.1 jtc goto Leave;
530 1.1 jtc }
531 1.1 jtc fcflags |= FC_DEFPATH;
532 1.1 jtc }
533 1.1 jtc ap += builtin_opt.optind;
534 1.2 tls /* POSIX says special builtins lose their status
535 1.1 jtc * if accessed using command.
536 1.1 jtc */
537 1.1 jtc keepasn_ok = 0;
538 1.1 jtc if (!ap[0]) {
539 1.1 jtc /* ensure command with no args exits with 0 */
540 1.1 jtc subst_exstat = 0;
541 1.1 jtc break;
542 1.1 jtc }
543 1.1 jtc } else
544 1.1 jtc break;
545 1.1 jtc tp = findcom(ap[0], fcflags & (FC_BI|FC_FUNC));
546 1.1 jtc }
547 1.1 jtc if (keepasn_ok && (!ap[0] || (tp && (tp->flag & KEEPASN))))
548 1.1 jtc type_flags = 0;
549 1.1 jtc else {
550 1.1 jtc /* create new variable/function block */
551 1.1 jtc newblock();
552 1.1 jtc /* ksh functions don't keep assignments, POSIX functions do. */
553 1.1 jtc if (keepasn_ok && tp && tp->type == CFUNC
554 1.1 jtc && !(tp->flag & FKSH))
555 1.1 jtc type_flags = 0;
556 1.1 jtc else
557 1.1 jtc type_flags = LOCAL|LOCAL_COPY|EXPORT;
558 1.1 jtc }
559 1.1 jtc if (Flag(FEXPORT))
560 1.1 jtc type_flags |= EXPORT;
561 1.1 jtc for (i = 0; t->vars[i]; i++) {
562 1.1 jtc cp = evalstr(t->vars[i], DOASNTILDE);
563 1.1 jtc if (Flag(FXTRACE)) {
564 1.1 jtc if (i == 0)
565 1.1 jtc shf_fprintf(shl_out, "%s",
566 1.1 jtc PS4_SUBSTITUTE(str_val(global("PS4"))));
567 1.1 jtc shf_fprintf(shl_out, "%s%s", cp,
568 1.1 jtc t->vars[i + 1] ? space : newline);
569 1.1 jtc if (!t->vars[i + 1])
570 1.1 jtc shf_flush(shl_out);
571 1.1 jtc }
572 1.1 jtc typeset(cp, type_flags, 0, 0, 0);
573 1.1 jtc }
574 1.1 jtc
575 1.1 jtc if ((cp = *ap) == NULL) {
576 1.1 jtc rv = subst_exstat;
577 1.1 jtc goto Leave;
578 1.1 jtc } else if (!tp) {
579 1.1 jtc if (Flag(FRESTRICTED) && ksh_strchr_dirsep(cp)) {
580 1.1 jtc warningf(TRUE, "%s: restricted", cp);
581 1.1 jtc rv = 1;
582 1.1 jtc goto Leave;
583 1.1 jtc }
584 1.1 jtc tp = findcom(cp, fcflags);
585 1.1 jtc }
586 1.1 jtc
587 1.1 jtc switch (tp->type) {
588 1.1 jtc case CSHELL: /* shell built-in */
589 1.1 jtc rv = call_builtin(tp, ap);
590 1.1 jtc break;
591 1.1 jtc
592 1.1 jtc case CFUNC: /* function call */
593 1.1 jtc {
594 1.1 jtc volatile int old_xflag;
595 1.1 jtc volatile Tflag old_inuse;
596 1.1 jtc const char *volatile old_kshname;
597 1.1 jtc
598 1.1 jtc if (!(tp->flag & ISSET)) {
599 1.1 jtc struct tbl *ftp;
600 1.1 jtc
601 1.1 jtc if (!tp->u.fpath) {
602 1.1 jtc if (tp->u2.errno_) {
603 1.1 jtc warningf(TRUE,
604 1.1 jtc "%s: can't find function definition file - %s",
605 1.1 jtc cp, strerror(tp->u2.errno_));
606 1.1 jtc rv = 126;
607 1.1 jtc } else {
608 1.1 jtc warningf(TRUE,
609 1.1 jtc "%s: can't find function definition file", cp);
610 1.1 jtc rv = 127;
611 1.1 jtc }
612 1.1 jtc break;
613 1.1 jtc }
614 1.1 jtc if (include(tp->u.fpath, 0, (char **) 0, 0) < 0) {
615 1.1 jtc warningf(TRUE,
616 1.1 jtc "%s: can't open function definition file %s - %s",
617 1.1 jtc cp, tp->u.fpath, strerror(errno));
618 1.1 jtc rv = 127;
619 1.1 jtc break;
620 1.1 jtc }
621 1.1 jtc if (!(ftp = findfunc(cp, hash(cp), FALSE))
622 1.1 jtc || !(ftp->flag & ISSET))
623 1.1 jtc {
624 1.1 jtc warningf(TRUE,
625 1.1 jtc "%s: function not defined by %s",
626 1.1 jtc cp, tp->u.fpath);
627 1.1 jtc rv = 127;
628 1.1 jtc break;
629 1.1 jtc }
630 1.1 jtc tp = ftp;
631 1.1 jtc }
632 1.1 jtc
633 1.1 jtc /* ksh functions set $0 to function name, POSIX functions leave
634 1.1 jtc * $0 unchanged.
635 1.1 jtc */
636 1.1 jtc old_kshname = kshname;
637 1.1 jtc if (tp->flag & FKSH)
638 1.1 jtc kshname = ap[0];
639 1.5 hubertf else
640 1.5 hubertf ap[0] = (char *) kshname;
641 1.1 jtc e->loc->argv = ap;
642 1.1 jtc for (i = 0; *ap++ != NULL; i++)
643 1.1 jtc ;
644 1.1 jtc e->loc->argc = i - 1;
645 1.5 hubertf /* ksh-style functions handle getopts sanely,
646 1.5 hubertf * bourne/posix functions are insane...
647 1.5 hubertf */
648 1.5 hubertf if (tp->flag & FKSH) {
649 1.5 hubertf e->loc->flags |= BF_DOGETOPTS;
650 1.5 hubertf e->loc->getopts_state = user_opt;
651 1.5 hubertf getopts_reset(1);
652 1.5 hubertf }
653 1.1 jtc
654 1.1 jtc old_xflag = Flag(FXTRACE);
655 1.1 jtc Flag(FXTRACE) = tp->flag & TRACE ? TRUE : FALSE;
656 1.1 jtc
657 1.1 jtc old_inuse = tp->flag & FINUSE;
658 1.1 jtc tp->flag |= FINUSE;
659 1.1 jtc
660 1.1 jtc e->type = E_FUNC;
661 1.1 jtc i = ksh_sigsetjmp(e->jbuf, 0);
662 1.1 jtc if (i == 0) {
663 1.1 jtc /* seems odd to pass XERROK here, but at&t ksh does */
664 1.1 jtc exstat = execute(tp->val.t, flags & XERROK);
665 1.1 jtc i = LRETURN;
666 1.1 jtc }
667 1.1 jtc kshname = old_kshname;
668 1.1 jtc Flag(FXTRACE) = old_xflag;
669 1.1 jtc tp->flag = (tp->flag & ~FINUSE) | old_inuse;
670 1.1 jtc /* Were we deleted while executing? If so, free the execution
671 1.1 jtc * tree. todo: Unfortunately, the table entry is never re-used
672 1.1 jtc * until the lookup table is expanded.
673 1.1 jtc */
674 1.1 jtc if ((tp->flag & (FDELETE|FINUSE)) == FDELETE) {
675 1.1 jtc if (tp->flag & ALLOC) {
676 1.1 jtc tp->flag &= ~ALLOC;
677 1.1 jtc tfree(tp->val.t, tp->areap);
678 1.1 jtc }
679 1.1 jtc tp->flag = 0;
680 1.1 jtc }
681 1.1 jtc switch (i) {
682 1.1 jtc case LRETURN:
683 1.1 jtc case LERROR:
684 1.1 jtc rv = exstat;
685 1.1 jtc break;
686 1.1 jtc case LINTR:
687 1.1 jtc case LEXIT:
688 1.1 jtc case LLEAVE:
689 1.1 jtc case LSHELL:
690 1.1 jtc quitenv();
691 1.1 jtc unwind(i);
692 1.1 jtc /*NOTREACHED*/
693 1.1 jtc default:
694 1.1 jtc quitenv();
695 1.1 jtc internal_errorf(1, "CFUNC %d", i);
696 1.1 jtc }
697 1.1 jtc break;
698 1.1 jtc }
699 1.1 jtc
700 1.1 jtc case CEXEC: /* executable command */
701 1.1 jtc case CTALIAS: /* tracked alias */
702 1.1 jtc if (!(tp->flag&ISSET)) {
703 1.1 jtc /* errno_ will be set if the named command was found
704 1.1 jtc * but could not be executed (permissions, no execute
705 1.1 jtc * bit, directory, etc). Print out a (hopefully)
706 1.1 jtc * useful error message and set the exit status to 126.
707 1.1 jtc */
708 1.1 jtc if (tp->u2.errno_) {
709 1.1 jtc warningf(TRUE, "%s: cannot execute - %s", cp,
710 1.1 jtc strerror(tp->u2.errno_));
711 1.1 jtc rv = 126; /* POSIX */
712 1.1 jtc } else {
713 1.1 jtc warningf(TRUE, "%s: not found", cp);
714 1.1 jtc rv = 127;
715 1.1 jtc }
716 1.1 jtc break;
717 1.1 jtc }
718 1.1 jtc
719 1.5 hubertf #ifdef KSH
720 1.1 jtc /* set $_ to program's full path */
721 1.5 hubertf /* setstr() can't fail here */
722 1.5 hubertf setstr(typeset("_", LOCAL|EXPORT, 0, INTEGER, 0), tp->val.s,
723 1.5 hubertf KSH_RETURN_ERROR);
724 1.5 hubertf #endif /* KSH */
725 1.1 jtc
726 1.1 jtc if (flags&XEXEC) {
727 1.1 jtc j_exit();
728 1.1 jtc if (!(flags&XBGND) || Flag(FMONITOR)) {
729 1.1 jtc setexecsig(&sigtraps[SIGINT], SS_RESTORE_ORIG);
730 1.1 jtc setexecsig(&sigtraps[SIGQUIT], SS_RESTORE_ORIG);
731 1.1 jtc }
732 1.1 jtc }
733 1.1 jtc
734 1.1 jtc /* to fork we set up a TEXEC node and call execute */
735 1.1 jtc texec.type = TEXEC;
736 1.1 jtc texec.left = t; /* for tprint */
737 1.1 jtc texec.str = tp->val.s;
738 1.1 jtc texec.args = ap;
739 1.1 jtc rv = exchild(&texec, flags, -1);
740 1.1 jtc break;
741 1.1 jtc }
742 1.1 jtc Leave:
743 1.1 jtc if (flags & XEXEC) {
744 1.1 jtc exstat = rv;
745 1.1 jtc unwind(LLEAVE);
746 1.1 jtc }
747 1.1 jtc return rv;
748 1.1 jtc }
749 1.1 jtc
750 1.1 jtc static void
751 1.1 jtc scriptexec(tp, ap)
752 1.1 jtc register struct op *tp;
753 1.1 jtc register char **ap;
754 1.1 jtc {
755 1.1 jtc char *shell;
756 1.1 jtc
757 1.1 jtc shell = str_val(global(EXECSHELL_STR));
758 1.1 jtc if (shell && *shell)
759 1.1 jtc shell = search(shell, path, X_OK, (int *) 0);
760 1.1 jtc if (!shell || !*shell)
761 1.1 jtc shell = EXECSHELL;
762 1.1 jtc
763 1.1 jtc *tp->args-- = tp->str;
764 1.1 jtc #ifdef SHARPBANG
765 1.1 jtc {
766 1.1 jtc char buf[LINE];
767 1.1 jtc register char *cp;
768 1.1 jtc register int fd, n;
769 1.1 jtc
770 1.1 jtc buf[0] = '\0';
771 1.1 jtc if ((fd = open(tp->str, O_RDONLY)) >= 0) {
772 1.1 jtc if ((n = read(fd, buf, LINE - 1)) > 0)
773 1.1 jtc buf[n] = '\0';
774 1.1 jtc (void) close(fd);
775 1.1 jtc }
776 1.1 jtc if ((buf[0] == '#' && buf[1] == '!' && (cp = &buf[2]))
777 1.1 jtc # ifdef OS2
778 1.1 jtc || (strncmp(buf, "extproc", 7) == 0 && isspace(buf[7])
779 1.1 jtc && (cp = &buf[7]))
780 1.1 jtc # endif /* OS2 */
781 1.1 jtc )
782 1.1 jtc {
783 1.1 jtc while (*cp && (*cp == ' ' || *cp == '\t'))
784 1.1 jtc cp++;
785 1.1 jtc if (*cp && *cp != '\n') {
786 1.1 jtc char *a0 = cp, *a1 = (char *) 0;
787 1.1 jtc # ifdef OS2
788 1.1 jtc char *a2 = cp;
789 1.1 jtc # endif /* OS2 */
790 1.1 jtc
791 1.1 jtc while (*cp && *cp != '\n' && *cp != ' '
792 1.1 jtc && *cp != '\t')
793 1.1 jtc {
794 1.1 jtc # ifdef OS2
795 1.1 jtc /* Allow shell search without prepended path
796 1.1 jtc * if shell with / in pathname cannot be found.
797 1.1 jtc * Use / explicitly so \ can be used if explicit
798 1.1 jtc * needs to be forced.
799 1.1 jtc */
800 1.1 jtc if (*cp == '/')
801 1.1 jtc a2 = cp + 1;
802 1.1 jtc # endif /* OS2 */
803 1.1 jtc cp++;
804 1.1 jtc }
805 1.1 jtc if (*cp && *cp != '\n') {
806 1.1 jtc *cp++ = '\0';
807 1.1 jtc while (*cp
808 1.1 jtc && (*cp == ' ' || *cp == '\t'))
809 1.1 jtc cp++;
810 1.1 jtc if (*cp && *cp != '\n') {
811 1.1 jtc a1 = cp;
812 1.1 jtc /* all one argument */
813 1.1 jtc while (*cp && *cp != '\n')
814 1.1 jtc cp++;
815 1.1 jtc }
816 1.1 jtc }
817 1.1 jtc if (*cp == '\n') {
818 1.1 jtc *cp = '\0';
819 1.1 jtc if (a1)
820 1.1 jtc *tp->args-- = a1;
821 1.1 jtc # ifdef OS2
822 1.5 hubertf if (a0 != a2) {
823 1.5 hubertf char *tmp_a0 = str_nsave(a0,
824 1.5 hubertf strlen(a0) + 5, ATEMP);
825 1.5 hubertf if (search_access(tmp_a0, X_OK,
826 1.5 hubertf (int *) 0))
827 1.5 hubertf a0 = a2;
828 1.5 hubertf afree(tmp_a0, ATEMP);
829 1.5 hubertf }
830 1.1 jtc # endif /* OS2 */
831 1.1 jtc shell = a0;
832 1.1 jtc }
833 1.1 jtc }
834 1.1 jtc # ifdef OS2
835 1.1 jtc } else {
836 1.1 jtc /* Use ksh documented shell default if present
837 1.1 jtc * else use OS2_SHELL which is assumed to need
838 1.1 jtc * the /c option and '\' as dir separater.
839 1.1 jtc */
840 1.1 jtc char *p = shell;
841 1.1 jtc
842 1.1 jtc shell = str_val(global("EXECSHELL"));
843 1.1 jtc if (shell && *shell)
844 1.1 jtc shell = search(shell, path, X_OK, (int *) 0);
845 1.1 jtc if (!shell || !*shell) {
846 1.1 jtc shell = p;
847 1.1 jtc *tp->args-- = "/c";
848 1.1 jtc for (p = tp->str; *p; p++)
849 1.1 jtc if (*p == '/')
850 1.1 jtc *p = '\\';
851 1.1 jtc }
852 1.1 jtc # endif /* OS2 */
853 1.1 jtc }
854 1.1 jtc }
855 1.1 jtc #endif /* SHARPBANG */
856 1.1 jtc *tp->args = shell;
857 1.1 jtc
858 1.5 hubertf ksh_execve(tp->args[0], tp->args, ap, 0);
859 1.1 jtc
860 1.1 jtc /* report both the program that was run and the bogus shell */
861 1.1 jtc errorf("%s: %s: %s", tp->str, shell, strerror(errno));
862 1.1 jtc }
863 1.1 jtc
864 1.1 jtc int
865 1.1 jtc shcomexec(wp)
866 1.1 jtc register char **wp;
867 1.1 jtc {
868 1.1 jtc register struct tbl *tp;
869 1.1 jtc
870 1.1 jtc tp = tsearch(&builtins, *wp, hash(*wp));
871 1.1 jtc if (tp == NULL)
872 1.1 jtc internal_errorf(1, "shcomexec: %s", *wp);
873 1.1 jtc return call_builtin(tp, wp);
874 1.1 jtc }
875 1.1 jtc
876 1.1 jtc /*
877 1.1 jtc * Search function tables for a function. If create set, a table entry
878 1.1 jtc * is created if none is found.
879 1.1 jtc */
880 1.1 jtc struct tbl *
881 1.1 jtc findfunc(name, h, create)
882 1.1 jtc const char *name;
883 1.5 hubertf unsigned int h;
884 1.5 hubertf int create;
885 1.1 jtc {
886 1.1 jtc struct block *l;
887 1.1 jtc struct tbl *tp = (struct tbl *) 0;
888 1.1 jtc
889 1.1 jtc for (l = e->loc; l; l = l->next) {
890 1.1 jtc tp = tsearch(&l->funs, name, h);
891 1.1 jtc if (tp)
892 1.1 jtc break;
893 1.1 jtc if (!l->next && create) {
894 1.1 jtc tp = tenter(&l->funs, name, h);
895 1.1 jtc tp->flag = DEFINED;
896 1.1 jtc tp->type = CFUNC;
897 1.1 jtc tp->val.t = (struct op *) 0;
898 1.1 jtc break;
899 1.1 jtc }
900 1.1 jtc }
901 1.1 jtc return tp;
902 1.1 jtc }
903 1.1 jtc
904 1.1 jtc /*
905 1.1 jtc * define function. Returns 1 if function is being undefined (t == 0) and
906 1.1 jtc * function did not exist, returns 0 otherwise.
907 1.1 jtc */
908 1.1 jtc int
909 1.1 jtc define(name, t)
910 1.1 jtc const char *name;
911 1.1 jtc struct op *t;
912 1.1 jtc {
913 1.1 jtc struct tbl *tp;
914 1.1 jtc int was_set = 0;
915 1.1 jtc
916 1.1 jtc while (1) {
917 1.1 jtc tp = findfunc(name, hash(name), TRUE);
918 1.1 jtc
919 1.1 jtc if (tp->flag & ISSET)
920 1.1 jtc was_set = 1;
921 1.1 jtc /* If this function is currently being executed, we zap this
922 1.1 jtc * table entry so findfunc() won't see it
923 1.1 jtc */
924 1.1 jtc if (tp->flag & FINUSE) {
925 1.1 jtc tp->name[0] = '\0';
926 1.1 jtc tp->flag &= ~DEFINED; /* ensure it won't be found */
927 1.1 jtc tp->flag |= FDELETE;
928 1.1 jtc } else
929 1.1 jtc break;
930 1.1 jtc }
931 1.1 jtc
932 1.1 jtc if (tp->flag & ALLOC) {
933 1.1 jtc tp->flag &= ~(ISSET|ALLOC);
934 1.1 jtc tfree(tp->val.t, tp->areap);
935 1.1 jtc }
936 1.1 jtc
937 1.1 jtc if (t == NULL) { /* undefine */
938 1.1 jtc tdelete(tp);
939 1.1 jtc return was_set ? 0 : 1;
940 1.1 jtc }
941 1.1 jtc
942 1.1 jtc tp->val.t = tcopy(t->left, tp->areap);
943 1.1 jtc tp->flag |= (ISSET|ALLOC);
944 1.1 jtc if (t->u.ksh_func)
945 1.5 hubertf tp->flag |= FKSH;
946 1.1 jtc
947 1.1 jtc return 0;
948 1.1 jtc }
949 1.1 jtc
950 1.1 jtc /*
951 1.1 jtc * add builtin
952 1.1 jtc */
953 1.1 jtc void
954 1.1 jtc builtin(name, func)
955 1.1 jtc const char *name;
956 1.1 jtc int (*func) ARGS((char **));
957 1.1 jtc {
958 1.1 jtc register struct tbl *tp;
959 1.1 jtc Tflag flag;
960 1.1 jtc
961 1.1 jtc /* see if any flags should be set for this builtin */
962 1.1 jtc for (flag = 0; ; name++) {
963 1.1 jtc if (*name == '=') /* command does variable assignment */
964 1.1 jtc flag |= KEEPASN;
965 1.1 jtc else if (*name == '*') /* POSIX special builtin */
966 1.1 jtc flag |= SPEC_BI;
967 1.1 jtc else if (*name == '+') /* POSIX regular builtin */
968 1.1 jtc flag |= REG_BI;
969 1.1 jtc else
970 1.1 jtc break;
971 1.1 jtc }
972 1.1 jtc
973 1.1 jtc tp = tenter(&builtins, name, hash(name));
974 1.1 jtc tp->flag = DEFINED | flag;
975 1.1 jtc tp->type = CSHELL;
976 1.1 jtc tp->val.f = func;
977 1.1 jtc }
978 1.1 jtc
979 1.1 jtc /*
980 1.1 jtc * find command
981 1.1 jtc * either function, hashed command, or built-in (in that order)
982 1.1 jtc */
983 1.1 jtc struct tbl *
984 1.1 jtc findcom(name, flags)
985 1.1 jtc const char *name;
986 1.1 jtc int flags; /* FC_* */
987 1.1 jtc {
988 1.1 jtc static struct tbl temp;
989 1.1 jtc unsigned int h = hash(name);
990 1.1 jtc struct tbl *tp = NULL, *tbi;
991 1.1 jtc int insert = Flag(FTRACKALL); /* insert if not found */
992 1.1 jtc char *fpath; /* for function autoloading */
993 1.1 jtc char *npath;
994 1.1 jtc
995 1.1 jtc if (ksh_strchr_dirsep(name) != NULL) {
996 1.1 jtc insert = 0;
997 1.1 jtc /* prevent FPATH search below */
998 1.1 jtc flags &= ~FC_FUNC;
999 1.1 jtc goto Search;
1000 1.1 jtc }
1001 1.1 jtc tbi = (flags & FC_BI) ? tsearch(&builtins, name, h) : NULL;
1002 1.1 jtc /* POSIX says special builtins first, then functions, then
1003 1.1 jtc * POSIX regular builtins, then search path...
1004 1.1 jtc */
1005 1.1 jtc if ((flags & FC_SPECBI) && tbi && (tbi->flag & SPEC_BI))
1006 1.1 jtc tp = tbi;
1007 1.1 jtc if (!tp && (flags & FC_FUNC)) {
1008 1.1 jtc tp = findfunc(name, h, FALSE);
1009 1.1 jtc if (tp && !(tp->flag & ISSET)) {
1010 1.1 jtc if ((fpath = str_val(global("FPATH"))) == null) {
1011 1.1 jtc tp->u.fpath = (char *) 0;
1012 1.1 jtc tp->u2.errno_ = 0;
1013 1.1 jtc } else
1014 1.1 jtc tp->u.fpath = search(name, fpath, R_OK,
1015 1.1 jtc &tp->u2.errno_);
1016 1.1 jtc }
1017 1.1 jtc }
1018 1.1 jtc if (!tp && (flags & FC_REGBI) && tbi && (tbi->flag & REG_BI))
1019 1.1 jtc tp = tbi;
1020 1.1 jtc /* todo: posix says non-special/non-regular builtins must
1021 1.1 jtc * be triggered by some user-controllable means like a
1022 1.1 jtc * special directory in PATH. Requires modifications to
1023 1.1 jtc * the search() function. Tracked aliases should be
1024 1.1 jtc * modified to allow tracking of builtin commands.
1025 1.1 jtc * This should be under control of the FPOSIX flag.
1026 1.1 jtc * If this is changed, also change c_whence...
1027 1.1 jtc */
1028 1.1 jtc if (!tp && (flags & FC_UNREGBI) && tbi)
1029 1.1 jtc tp = tbi;
1030 1.1 jtc if (!tp && (flags & FC_PATH) && !(flags & FC_DEFPATH)) {
1031 1.1 jtc tp = tsearch(&taliases, name, h);
1032 1.1 jtc if (tp && (tp->flag & ISSET) && eaccess(tp->val.s, X_OK) != 0) {
1033 1.1 jtc if (tp->flag & ALLOC) {
1034 1.1 jtc tp->flag &= ~ALLOC;
1035 1.1 jtc afree(tp->val.s, APERM);
1036 1.1 jtc }
1037 1.1 jtc tp->flag &= ~ISSET;
1038 1.1 jtc }
1039 1.1 jtc }
1040 1.1 jtc
1041 1.1 jtc Search:
1042 1.1 jtc if ((!tp || (tp->type == CTALIAS && !(tp->flag&ISSET)))
1043 1.1 jtc && (flags & FC_PATH))
1044 1.1 jtc {
1045 1.1 jtc if (!tp) {
1046 1.1 jtc if (insert && !(flags & FC_DEFPATH)) {
1047 1.1 jtc tp = tenter(&taliases, name, h);
1048 1.1 jtc tp->type = CTALIAS;
1049 1.1 jtc } else {
1050 1.1 jtc tp = &temp;
1051 1.1 jtc tp->type = CEXEC;
1052 1.1 jtc }
1053 1.1 jtc tp->flag = DEFINED; /* make ~ISSET */
1054 1.1 jtc }
1055 1.1 jtc npath = search(name, flags & FC_DEFPATH ? def_path : path,
1056 1.1 jtc X_OK, &tp->u2.errno_);
1057 1.1 jtc if (npath) {
1058 1.1 jtc tp->val.s = tp == &temp ? npath : str_save(npath, APERM);
1059 1.1 jtc tp->flag |= ISSET|ALLOC;
1060 1.1 jtc } else if ((flags & FC_FUNC)
1061 1.1 jtc && (fpath = str_val(global("FPATH"))) != null
1062 1.1 jtc && (npath = search(name, fpath, R_OK,
1063 1.1 jtc &tp->u2.errno_)) != (char *) 0)
1064 1.1 jtc {
1065 1.1 jtc /* An undocumented feature of at&t ksh is that it
1066 1.1 jtc * searches FPATH if a command is not found, even
1067 1.1 jtc * if the command hasn't been set up as an autoloaded
1068 1.1 jtc * function (ie, no typeset -uf).
1069 1.1 jtc */
1070 1.1 jtc tp = &temp;
1071 1.1 jtc tp->type = CFUNC;
1072 1.1 jtc tp->flag = DEFINED; /* make ~ISSET */
1073 1.1 jtc tp->u.fpath = npath;
1074 1.1 jtc }
1075 1.1 jtc }
1076 1.1 jtc return tp;
1077 1.1 jtc }
1078 1.1 jtc
1079 1.1 jtc /*
1080 1.1 jtc * flush executable commands with relative paths
1081 1.1 jtc */
1082 1.1 jtc void
1083 1.1 jtc flushcom(all)
1084 1.1 jtc int all; /* just relative or all */
1085 1.1 jtc {
1086 1.1 jtc struct tbl *tp;
1087 1.1 jtc struct tstate ts;
1088 1.1 jtc
1089 1.1 jtc for (twalk(&ts, &taliases); (tp = tnext(&ts)) != NULL; )
1090 1.1 jtc if ((tp->flag&ISSET) && (all || !ISDIRSEP(tp->val.s[0]))) {
1091 1.1 jtc if (tp->flag&ALLOC) {
1092 1.1 jtc tp->flag &= ~(ALLOC|ISSET);
1093 1.1 jtc afree(tp->val.s, APERM);
1094 1.1 jtc }
1095 1.5 hubertf tp->flag &= ~ISSET;
1096 1.1 jtc }
1097 1.1 jtc }
1098 1.1 jtc
1099 1.1 jtc /* Check if path is something we want to find. Returns -1 for failure. */
1100 1.1 jtc int
1101 1.1 jtc search_access(path, mode, errnop)
1102 1.1 jtc const char *path;
1103 1.1 jtc int mode;
1104 1.1 jtc int *errnop; /* set if candidate found, but not suitable */
1105 1.1 jtc {
1106 1.1 jtc #ifndef OS2
1107 1.1 jtc int ret, err = 0;
1108 1.1 jtc struct stat statb;
1109 1.1 jtc
1110 1.1 jtc if (stat(path, &statb) < 0)
1111 1.1 jtc return -1;
1112 1.1 jtc ret = eaccess(path, mode);
1113 1.1 jtc if (ret < 0)
1114 1.1 jtc err = errno; /* File exists, but we can't access it */
1115 1.5 hubertf else if (mode == X_OK
1116 1.5 hubertf && (!S_ISREG(statb.st_mode)
1117 1.5 hubertf /* This 'cause access() says root can execute everything */
1118 1.5 hubertf || !(statb.st_mode & (S_IXUSR|S_IXGRP|S_IXOTH))))
1119 1.1 jtc {
1120 1.1 jtc ret = -1;
1121 1.1 jtc err = S_ISDIR(statb.st_mode) ? EISDIR : EACCES;
1122 1.1 jtc }
1123 1.5 hubertf if (err && errnop && !*errnop)
1124 1.1 jtc *errnop = err;
1125 1.1 jtc return ret;
1126 1.1 jtc #else /* !OS2 */
1127 1.1 jtc /*
1128 1.1 jtc * NOTE: ASSUMES path can be modified and has enough room at the
1129 1.1 jtc * end of the string for a suffix (ie, 4 extra characters).
1130 1.1 jtc * Certain code knows this (eg, eval.c(globit()),
1131 1.1 jtc * exec.c(search())).
1132 1.1 jtc */
1133 1.1 jtc static char *xsuffixes[] = { ".ksh", ".exe", ".", ".sh", ".cmd",
1134 1.1 jtc ".com", ".bat", (char *) 0
1135 1.1 jtc };
1136 1.1 jtc static char *rsuffixes[] = { ".ksh", ".", ".sh", ".cmd", ".bat",
1137 1.1 jtc (char *) 0
1138 1.1 jtc };
1139 1.1 jtc int i;
1140 1.1 jtc char *mpath = (char *) path;
1141 1.1 jtc char *tp = mpath + strlen(mpath);
1142 1.1 jtc char *p;
1143 1.1 jtc char **sfx;
1144 1.1 jtc
1145 1.1 jtc /* If a suffix has been specified, check if it is one of the
1146 1.1 jtc * suffixes that indicate the file is executable - if so, change
1147 1.1 jtc * the access test to R_OK...
1148 1.1 jtc * This code assumes OS/2 files can have only one suffix...
1149 1.1 jtc */
1150 1.1 jtc if ((p = strrchr((p = ksh_strrchr_dirsep(mpath)) ? p : mpath, '.'))) {
1151 1.1 jtc if (mode == X_OK)
1152 1.1 jtc mode = R_OK;
1153 1.1 jtc return search_access1(mpath, mode, errnop);
1154 1.1 jtc }
1155 1.1 jtc /* Try appending the various suffixes. Different suffixes for
1156 1.1 jtc * read and execute 'cause we don't want to read an executable...
1157 1.1 jtc */
1158 1.1 jtc sfx = mode == R_OK ? rsuffixes : xsuffixes;
1159 1.1 jtc for (i = 0; sfx[i]; i++) {
1160 1.1 jtc strcpy(tp, p = sfx[i]);
1161 1.1 jtc if (search_access1(mpath, R_OK, errnop) == 0)
1162 1.1 jtc return 0;
1163 1.1 jtc *tp = '\0';
1164 1.1 jtc }
1165 1.1 jtc return -1;
1166 1.1 jtc #endif /* !OS2 */
1167 1.1 jtc }
1168 1.1 jtc
1169 1.1 jtc #ifdef OS2
1170 1.1 jtc static int
1171 1.1 jtc search_access1(path, mode, errnop)
1172 1.1 jtc const char *path;
1173 1.1 jtc int mode;
1174 1.1 jtc int *errnop; /* set if candidate found, but not suitable */
1175 1.1 jtc {
1176 1.1 jtc int ret, err = 0;
1177 1.1 jtc struct stat statb;
1178 1.1 jtc
1179 1.1 jtc if (stat(path, &statb) < 0)
1180 1.1 jtc return -1;
1181 1.1 jtc ret = eaccess(path, mode);
1182 1.1 jtc if (ret < 0)
1183 1.1 jtc err = errno; /* File exists, but we can't access it */
1184 1.1 jtc else if (!S_ISREG(statb.st_mode)) {
1185 1.1 jtc ret = -1;
1186 1.1 jtc err = S_ISDIR(statb.st_mode) ? EISDIR : EACCES;
1187 1.1 jtc }
1188 1.5 hubertf if (err && errnop && !*errnop)
1189 1.1 jtc *errnop = err;
1190 1.1 jtc return ret;
1191 1.1 jtc }
1192 1.1 jtc #endif /* OS2 */
1193 1.1 jtc
1194 1.1 jtc /*
1195 1.1 jtc * search for command with PATH
1196 1.1 jtc */
1197 1.1 jtc char *
1198 1.1 jtc search(name, path, mode, errnop)
1199 1.1 jtc const char *name;
1200 1.1 jtc const char *path;
1201 1.1 jtc int mode; /* R_OK or X_OK */
1202 1.1 jtc int *errnop; /* set if candidate found, but not suitable */
1203 1.1 jtc {
1204 1.1 jtc const char *sp, *p;
1205 1.1 jtc char *xp;
1206 1.1 jtc XString xs;
1207 1.1 jtc int namelen;
1208 1.1 jtc
1209 1.1 jtc if (errnop)
1210 1.1 jtc *errnop = 0;
1211 1.1 jtc #ifdef OS2
1212 1.1 jtc /* Xinit() allocates 8 additional bytes, so appended suffixes won't
1213 1.1 jtc * overflow the memory.
1214 1.1 jtc */
1215 1.1 jtc namelen = strlen(name) + 1;
1216 1.1 jtc Xinit(xs, xp, namelen, ATEMP);
1217 1.1 jtc memcpy(Xstring(xs, xp), name, namelen);
1218 1.1 jtc
1219 1.1 jtc if (ksh_strchr_dirsep(name)) {
1220 1.1 jtc if (search_access(Xstring(xs, xp), mode, errnop) >= 0)
1221 1.1 jtc return Xstring(xs, xp); /* not Xclose() - see above */
1222 1.1 jtc Xfree(xs, xp);
1223 1.1 jtc return NULL;
1224 1.1 jtc }
1225 1.1 jtc
1226 1.1 jtc /* Look in current context always. (os2 style) */
1227 1.1 jtc if (search_access(Xstring(xs, xp), mode, errnop) == 0)
1228 1.1 jtc return Xstring(xs, xp); /* not Xclose() - xp may be wrong */
1229 1.1 jtc #else /* OS2 */
1230 1.1 jtc if (ksh_strchr_dirsep(name)) {
1231 1.1 jtc if (search_access(name, mode, errnop) == 0)
1232 1.1 jtc return (char *) name;
1233 1.1 jtc return NULL;
1234 1.1 jtc }
1235 1.1 jtc
1236 1.1 jtc namelen = strlen(name) + 1;
1237 1.1 jtc Xinit(xs, xp, 128, ATEMP);
1238 1.1 jtc #endif /* OS2 */
1239 1.1 jtc
1240 1.1 jtc sp = path;
1241 1.1 jtc while (sp != NULL) {
1242 1.1 jtc xp = Xstring(xs, xp);
1243 1.1 jtc if (!(p = strchr(sp, PATHSEP)))
1244 1.1 jtc p = sp + strlen(sp);
1245 1.1 jtc if (p != sp) {
1246 1.1 jtc XcheckN(xs, xp, p - sp);
1247 1.1 jtc memcpy(xp, sp, p - sp);
1248 1.1 jtc xp += p - sp;
1249 1.1 jtc *xp++ = DIRSEP;
1250 1.1 jtc }
1251 1.1 jtc sp = p;
1252 1.1 jtc XcheckN(xs, xp, namelen);
1253 1.1 jtc memcpy(xp, name, namelen);
1254 1.1 jtc if (search_access(Xstring(xs, xp), mode, errnop) == 0)
1255 1.1 jtc #ifdef OS2
1256 1.1 jtc return Xstring(xs, xp); /* Not Xclose() - see above */
1257 1.1 jtc #else /* OS2 */
1258 1.1 jtc return Xclose(xs, xp + namelen);
1259 1.1 jtc #endif /* OS2 */
1260 1.1 jtc if (*sp++ == '\0')
1261 1.1 jtc sp = NULL;
1262 1.1 jtc }
1263 1.1 jtc Xfree(xs, xp);
1264 1.1 jtc return NULL;
1265 1.1 jtc }
1266 1.1 jtc
1267 1.1 jtc static int
1268 1.1 jtc call_builtin(tp, wp)
1269 1.1 jtc struct tbl *tp;
1270 1.1 jtc char **wp;
1271 1.1 jtc {
1272 1.1 jtc int rv;
1273 1.1 jtc
1274 1.1 jtc builtin_argv0 = wp[0];
1275 1.1 jtc builtin_flag = tp->flag;
1276 1.1 jtc shf_reopen(1, SHF_WR, shl_stdout);
1277 1.1 jtc shl_stdout_ok = 1;
1278 1.1 jtc ksh_getopt_reset(&builtin_opt, GF_ERROR);
1279 1.1 jtc rv = (*tp->val.f)(wp);
1280 1.1 jtc shf_flush(shl_stdout);
1281 1.1 jtc shl_stdout_ok = 0;
1282 1.1 jtc builtin_flag = 0;
1283 1.1 jtc builtin_argv0 = (char *) 0;
1284 1.1 jtc return rv;
1285 1.1 jtc }
1286 1.1 jtc
1287 1.1 jtc /*
1288 1.1 jtc * set up redirection, saving old fd's in e->savefd
1289 1.1 jtc */
1290 1.1 jtc static int
1291 1.1 jtc iosetup(iop, tp)
1292 1.1 jtc register struct ioword *iop;
1293 1.1 jtc struct tbl *tp;
1294 1.1 jtc {
1295 1.1 jtc register int u = -1;
1296 1.1 jtc char *cp = iop->name;
1297 1.1 jtc int iotype = iop->flag & IOTYPE;
1298 1.1 jtc int do_open = 1, do_close = 0, UNINITIALIZED(flags);
1299 1.1 jtc struct ioword iotmp;
1300 1.1 jtc struct stat statb;
1301 1.1 jtc
1302 1.1 jtc if (iotype != IOHERE)
1303 1.5 hubertf cp = evalonestr(cp, DOTILDE|(Flag(FTALKING_I) ? DOGLOB : 0));
1304 1.1 jtc
1305 1.1 jtc /* Used for tracing and error messages to print expanded cp */
1306 1.1 jtc iotmp = *iop;
1307 1.1 jtc iotmp.name = (iotype == IOHERE) ? (char *) 0 : cp;
1308 1.1 jtc iotmp.flag |= IONAMEXP;
1309 1.1 jtc
1310 1.1 jtc if (Flag(FXTRACE))
1311 1.1 jtc shellf("%s%s\n",
1312 1.1 jtc PS4_SUBSTITUTE(str_val(global("PS4"))),
1313 1.1 jtc snptreef((char *) 0, 32, "%R", &iotmp));
1314 1.1 jtc
1315 1.1 jtc switch (iotype) {
1316 1.1 jtc case IOREAD:
1317 1.1 jtc flags = O_RDONLY;
1318 1.1 jtc break;
1319 1.1 jtc
1320 1.1 jtc case IOCAT:
1321 1.1 jtc flags = O_WRONLY | O_APPEND | O_CREAT;
1322 1.1 jtc break;
1323 1.1 jtc
1324 1.1 jtc case IOWRITE:
1325 1.1 jtc flags = O_WRONLY | O_CREAT | O_TRUNC;
1326 1.5 hubertf /* The stat() is here to allow redirections to
1327 1.5 hubertf * things like /dev/null without error.
1328 1.5 hubertf */
1329 1.1 jtc if (Flag(FNOCLOBBER) && !(iop->flag & IOCLOB)
1330 1.1 jtc && (stat(cp, &statb) < 0 || S_ISREG(statb.st_mode)))
1331 1.1 jtc flags |= O_EXCL;
1332 1.1 jtc break;
1333 1.1 jtc
1334 1.1 jtc case IORDWR:
1335 1.1 jtc flags = O_RDWR | O_CREAT;
1336 1.1 jtc break;
1337 1.1 jtc
1338 1.1 jtc case IOHERE:
1339 1.1 jtc do_open = 0;
1340 1.1 jtc /* herein() returns -2 if error has been printed */
1341 1.5 hubertf u = herein(iop->heredoc, iop->flag & IOEVAL);
1342 1.1 jtc /* cp may have wrong name */
1343 1.1 jtc break;
1344 1.1 jtc
1345 1.1 jtc case IODUP:
1346 1.1 jtc {
1347 1.1 jtc const char *emsg;
1348 1.1 jtc
1349 1.1 jtc do_open = 0;
1350 1.1 jtc if (*cp == '-' && !cp[1]) {
1351 1.1 jtc u = 1009; /* prevent error return below */
1352 1.1 jtc do_close = 1;
1353 1.1 jtc } else if ((u = check_fd(cp,
1354 1.1 jtc X_OK | ((iop->flag & IORDUP) ? R_OK : W_OK),
1355 1.1 jtc &emsg)) < 0)
1356 1.1 jtc {
1357 1.1 jtc warningf(TRUE, "%s: %s",
1358 1.1 jtc snptreef((char *) 0, 32, "%R", &iotmp), emsg);
1359 1.1 jtc return -1;
1360 1.1 jtc }
1361 1.1 jtc break;
1362 1.1 jtc }
1363 1.1 jtc }
1364 1.1 jtc if (do_open) {
1365 1.1 jtc if (Flag(FRESTRICTED) && (flags & O_CREAT)) {
1366 1.1 jtc warningf(TRUE, "%s: restricted", cp);
1367 1.1 jtc return -1;
1368 1.1 jtc }
1369 1.1 jtc u = open(cp, flags, 0666);
1370 1.1 jtc #ifdef OS2
1371 1.1 jtc if (u < 0 && strcmp(cp, "/dev/null") == 0)
1372 1.1 jtc u = open("nul", flags, 0666);
1373 1.1 jtc #endif /* OS2 */
1374 1.1 jtc }
1375 1.1 jtc if (u < 0) {
1376 1.1 jtc /* herein() may already have printed message */
1377 1.1 jtc if (u == -1)
1378 1.1 jtc warningf(TRUE, "cannot %s %s: %s",
1379 1.1 jtc iotype == IODUP ? "dup"
1380 1.1 jtc : (iotype == IOREAD || iotype == IOHERE) ?
1381 1.1 jtc "open" : "create", cp, strerror(errno));
1382 1.1 jtc return -1;
1383 1.1 jtc }
1384 1.1 jtc /* Do not save if it has already been redirected (i.e. "cat >x >y"). */
1385 1.1 jtc if (e->savefd[iop->unit] == 0)
1386 1.1 jtc /* c_exec() assumes e->savefd[fd] set for any redirections.
1387 1.1 jtc * Ask savefd() not to close iop->unit - allows error messages
1388 1.1 jtc * to be seen if iop->unit is 2; also means we can't lose
1389 1.1 jtc * the fd (eg, both dup2 below and dup2 in restfd() failing).
1390 1.1 jtc */
1391 1.1 jtc e->savefd[iop->unit] = savefd(iop->unit, 1);
1392 1.1 jtc
1393 1.1 jtc if (do_close)
1394 1.1 jtc close(iop->unit);
1395 1.1 jtc else if (u != iop->unit) {
1396 1.1 jtc if (ksh_dup2(u, iop->unit, TRUE) < 0) {
1397 1.1 jtc warningf(TRUE,
1398 1.1 jtc "could not finish (dup) redirection %s: %s",
1399 1.1 jtc snptreef((char *) 0, 32, "%R", &iotmp),
1400 1.1 jtc strerror(errno));
1401 1.1 jtc if (iotype != IODUP)
1402 1.1 jtc close(u);
1403 1.1 jtc return -1;
1404 1.1 jtc }
1405 1.1 jtc if (iotype != IODUP)
1406 1.1 jtc close(u);
1407 1.1 jtc #ifdef KSH
1408 1.1 jtc /* Touching any co-process fd in an empty exec
1409 1.1 jtc * causes the shell to close its copies
1410 1.1 jtc */
1411 1.1 jtc else if (tp && tp->type == CSHELL && tp->val.f == c_exec) {
1412 1.1 jtc if (iop->flag & IORDUP) /* possible exec <&p */
1413 1.1 jtc coproc_read_close(u);
1414 1.1 jtc else /* possible exec >&p */
1415 1.1 jtc coproc_write_close(u);
1416 1.1 jtc }
1417 1.1 jtc #endif /* KSH */
1418 1.1 jtc }
1419 1.1 jtc if (u == 2) /* Clear any write errors */
1420 1.1 jtc shf_reopen(2, SHF_WR, shl_out);
1421 1.1 jtc return 0;
1422 1.1 jtc }
1423 1.1 jtc
1424 1.1 jtc /*
1425 1.1 jtc * open here document temp file.
1426 1.1 jtc * if unquoted here, expand here temp file into second temp file.
1427 1.1 jtc */
1428 1.1 jtc static int
1429 1.5 hubertf herein(content, sub)
1430 1.5 hubertf const char *content;
1431 1.1 jtc int sub;
1432 1.1 jtc {
1433 1.5 hubertf volatile int fd = -1;
1434 1.5 hubertf struct source *s, *volatile osource;
1435 1.5 hubertf struct shf *volatile shf;
1436 1.5 hubertf struct temp *h;
1437 1.5 hubertf int i;
1438 1.1 jtc
1439 1.1 jtc /* ksh -c 'cat << EOF' can cause this... */
1440 1.5 hubertf if (content == (char *) 0) {
1441 1.1 jtc warningf(TRUE, "here document missing");
1442 1.1 jtc return -2; /* special to iosetup(): don't print error */
1443 1.1 jtc }
1444 1.5 hubertf
1445 1.5 hubertf /* Create temp file to hold content (done before newenv so temp
1446 1.5 hubertf * doesn't get removed too soon).
1447 1.5 hubertf */
1448 1.5 hubertf h = maketemp(ATEMP, TT_HEREDOC_EXP, &e->temps);
1449 1.5 hubertf if (!(shf = h->shf) || (fd = open(h->name, O_RDONLY, 0)) < 0) {
1450 1.5 hubertf warningf(TRUE, "can't %s temporary file %s: %s",
1451 1.5 hubertf !shf ? "create" : "open",
1452 1.5 hubertf h->name, strerror(errno));
1453 1.5 hubertf if (shf)
1454 1.5 hubertf shf_close(shf);
1455 1.5 hubertf return -2 /* special to iosetup(): don't print error */;
1456 1.5 hubertf }
1457 1.5 hubertf
1458 1.5 hubertf osource = source;
1459 1.5 hubertf newenv(E_ERRH);
1460 1.5 hubertf i = ksh_sigsetjmp(e->jbuf, 0);
1461 1.5 hubertf if (i) {
1462 1.5 hubertf source = osource;
1463 1.5 hubertf quitenv();
1464 1.5 hubertf shf_close(shf); /* after quitenv */
1465 1.5 hubertf close(fd);
1466 1.5 hubertf return -2; /* special to iosetup(): don't print error */
1467 1.5 hubertf }
1468 1.1 jtc if (sub) {
1469 1.5 hubertf /* Do substitutions on the content of heredoc */
1470 1.5 hubertf s = pushs(SSTRING, ATEMP);
1471 1.5 hubertf s->start = s->str = content;
1472 1.1 jtc source = s;
1473 1.1 jtc if (yylex(ONEWORD) != LWORD)
1474 1.1 jtc internal_errorf(1, "herein: yylex");
1475 1.5 hubertf source = osource;
1476 1.5 hubertf shf_puts(evalstr(yylval.cp, 0), shf);
1477 1.5 hubertf } else
1478 1.5 hubertf shf_puts(content, shf);
1479 1.5 hubertf
1480 1.5 hubertf quitenv();
1481 1.5 hubertf
1482 1.5 hubertf if (shf_close(shf) == EOF) {
1483 1.5 hubertf close(fd);
1484 1.5 hubertf warningf(TRUE, "error writing %s: %s", h->name,
1485 1.5 hubertf strerror(errno));
1486 1.5 hubertf return -2; /* special to iosetup(): don't print error */
1487 1.1 jtc }
1488 1.1 jtc
1489 1.1 jtc return fd;
1490 1.1 jtc }
1491 1.1 jtc
1492 1.1 jtc #ifdef KSH
1493 1.1 jtc /*
1494 1.1 jtc * ksh special - the select command processing section
1495 1.1 jtc * print the args in column form - assuming that we can
1496 1.1 jtc */
1497 1.1 jtc static char *
1498 1.1 jtc do_selectargs(ap, print_menu)
1499 1.1 jtc register char **ap;
1500 1.1 jtc bool_t print_menu;
1501 1.1 jtc {
1502 1.1 jtc static const char *const read_args[] = {
1503 1.1 jtc "read", "-r", "REPLY", (char *) 0
1504 1.1 jtc };
1505 1.1 jtc char *s;
1506 1.1 jtc int i, argct;
1507 1.1 jtc
1508 1.1 jtc for (argct = 0; ap[argct]; argct++)
1509 1.1 jtc ;
1510 1.1 jtc while (1) {
1511 1.1 jtc /* Menu is printed if
1512 1.1 jtc * - this is the first time around the select loop
1513 1.1 jtc * - the user enters a blank line
1514 1.1 jtc * - the REPLY parameter is empty
1515 1.1 jtc */
1516 1.1 jtc if (print_menu || !*str_val(global("REPLY")))
1517 1.1 jtc pr_menu(ap);
1518 1.1 jtc shellf("%s", str_val(global("PS3")));
1519 1.1 jtc if (call_builtin(findcom("read", FC_BI), (char **) read_args))
1520 1.1 jtc return (char *) 0;
1521 1.1 jtc s = str_val(global("REPLY"));
1522 1.1 jtc if (*s) {
1523 1.1 jtc i = atoi(s);
1524 1.1 jtc return (i >= 1 && i <= argct) ? ap[i - 1] : null;
1525 1.1 jtc }
1526 1.1 jtc print_menu = 1;
1527 1.1 jtc }
1528 1.1 jtc }
1529 1.1 jtc
1530 1.1 jtc struct select_menu_info {
1531 1.1 jtc char *const *args;
1532 1.1 jtc int arg_width;
1533 1.1 jtc int num_width;
1534 1.1 jtc } info;
1535 1.1 jtc
1536 1.1 jtc static char *select_fmt_entry ARGS((void *arg, int i, char *buf, int buflen));
1537 1.1 jtc
1538 1.1 jtc /* format a single select menu item */
1539 1.1 jtc static char *
1540 1.1 jtc select_fmt_entry(arg, i, buf, buflen)
1541 1.1 jtc void *arg;
1542 1.1 jtc int i;
1543 1.1 jtc char *buf;
1544 1.1 jtc int buflen;
1545 1.1 jtc {
1546 1.1 jtc struct select_menu_info *smi = (struct select_menu_info *) arg;
1547 1.1 jtc
1548 1.1 jtc shf_snprintf(buf, buflen, "%*d) %s",
1549 1.1 jtc smi->num_width, i + 1, smi->args[i]);
1550 1.1 jtc return buf;
1551 1.1 jtc }
1552 1.1 jtc
1553 1.1 jtc /*
1554 1.1 jtc * print a select style menu
1555 1.1 jtc */
1556 1.1 jtc int
1557 1.1 jtc pr_menu(ap)
1558 1.1 jtc char *const *ap;
1559 1.1 jtc {
1560 1.1 jtc struct select_menu_info smi;
1561 1.1 jtc char *const *pp;
1562 1.1 jtc int nwidth, dwidth;
1563 1.1 jtc int i, n;
1564 1.1 jtc
1565 1.1 jtc /* Width/column calculations were done once and saved, but this
1566 1.1 jtc * means select can't be used recursively so we re-calculate each
1567 1.1 jtc * time (could save in a structure that is returned, but its probably
1568 1.1 jtc * not worth the bother).
1569 1.1 jtc */
1570 1.1 jtc
1571 1.1 jtc /*
1572 1.1 jtc * get dimensions of the list
1573 1.1 jtc */
1574 1.1 jtc for (n = 0, nwidth = 0, pp = ap; *pp; n++, pp++) {
1575 1.1 jtc i = strlen(*pp);
1576 1.1 jtc nwidth = (i > nwidth) ? i : nwidth;
1577 1.1 jtc }
1578 1.1 jtc /*
1579 1.1 jtc * we will print an index of the form
1580 1.1 jtc * %d)
1581 1.1 jtc * in front of each entry
1582 1.1 jtc * get the max width of this
1583 1.1 jtc */
1584 1.1 jtc for (i = n, dwidth = 1; i >= 10; i /= 10)
1585 1.1 jtc dwidth++;
1586 1.1 jtc
1587 1.1 jtc smi.args = ap;
1588 1.1 jtc smi.arg_width = nwidth;
1589 1.1 jtc smi.num_width = dwidth;
1590 1.1 jtc print_columns(shl_out, n, select_fmt_entry, (void *) &smi,
1591 1.1 jtc dwidth + nwidth + 2);
1592 1.1 jtc
1593 1.1 jtc return n;
1594 1.1 jtc }
1595 1.1 jtc #endif /* KSH */
1596 1.1 jtc #ifdef KSH
1597 1.1 jtc
1598 1.1 jtc /*
1599 1.1 jtc * [[ ... ]] evaluation routines
1600 1.1 jtc */
1601 1.1 jtc
1602 1.1 jtc extern const char *const dbtest_tokens[];
1603 1.1 jtc extern const char db_close[];
1604 1.1 jtc
1605 1.1 jtc /* Test if the current token is a whatever. Accepts the current token if
1606 1.1 jtc * it is. Returns 0 if it is not, non-zero if it is (in the case of
1607 1.1 jtc * TM_UNOP and TM_BINOP, the returned value is a Test_op).
1608 1.1 jtc */
1609 1.1 jtc static int
1610 1.1 jtc dbteste_isa(te, meta)
1611 1.1 jtc Test_env *te;
1612 1.1 jtc Test_meta meta;
1613 1.1 jtc {
1614 1.1 jtc int ret = 0;
1615 1.1 jtc int uqword;
1616 1.1 jtc char *p;
1617 1.1 jtc
1618 1.1 jtc if (!*te->pos.wp)
1619 1.1 jtc return meta == TM_END;
1620 1.1 jtc
1621 1.1 jtc /* unquoted word? */
1622 1.1 jtc for (p = *te->pos.wp; *p == CHAR; p += 2)
1623 1.1 jtc ;
1624 1.1 jtc uqword = *p == EOS;
1625 1.1 jtc
1626 1.1 jtc if (meta == TM_UNOP || meta == TM_BINOP) {
1627 1.1 jtc if (uqword) {
1628 1.1 jtc char buf[8]; /* longer than the longest operator */
1629 1.1 jtc char *q = buf;
1630 1.1 jtc for (p = *te->pos.wp; *p == CHAR
1631 1.1 jtc && q < &buf[sizeof(buf) - 1];
1632 1.1 jtc p += 2)
1633 1.1 jtc *q++ = p[1];
1634 1.1 jtc *q = '\0';
1635 1.1 jtc ret = (int) test_isop(te, meta, buf);
1636 1.1 jtc }
1637 1.1 jtc } else if (meta == TM_END)
1638 1.1 jtc ret = 0;
1639 1.1 jtc else
1640 1.1 jtc ret = uqword
1641 1.1 jtc && strcmp(*te->pos.wp, dbtest_tokens[(int) meta]) == 0;
1642 1.1 jtc
1643 1.1 jtc /* Accept the token? */
1644 1.1 jtc if (ret)
1645 1.1 jtc te->pos.wp++;
1646 1.1 jtc
1647 1.1 jtc return ret;
1648 1.1 jtc }
1649 1.1 jtc
1650 1.1 jtc static const char *
1651 1.1 jtc dbteste_getopnd(te, op, do_eval)
1652 1.1 jtc Test_env *te;
1653 1.1 jtc Test_op op;
1654 1.1 jtc int do_eval;
1655 1.1 jtc {
1656 1.1 jtc char *s = *te->pos.wp;
1657 1.1 jtc
1658 1.1 jtc if (!s)
1659 1.1 jtc return (char *) 0;
1660 1.1 jtc
1661 1.1 jtc te->pos.wp++;
1662 1.1 jtc
1663 1.1 jtc if (!do_eval)
1664 1.1 jtc return null;
1665 1.1 jtc
1666 1.1 jtc if (op == TO_STEQL || op == TO_STNEQ)
1667 1.1 jtc s = evalstr(s, DOTILDE | DOPAT);
1668 1.1 jtc else
1669 1.1 jtc s = evalstr(s, DOTILDE);
1670 1.1 jtc
1671 1.1 jtc return s;
1672 1.1 jtc }
1673 1.1 jtc
1674 1.1 jtc static int
1675 1.1 jtc dbteste_eval(te, op, opnd1, opnd2, do_eval)
1676 1.1 jtc Test_env *te;
1677 1.1 jtc Test_op op;
1678 1.1 jtc const char *opnd1;
1679 1.1 jtc const char *opnd2;
1680 1.1 jtc int do_eval;
1681 1.1 jtc {
1682 1.1 jtc return test_eval(te, op, opnd1, opnd2, do_eval);
1683 1.1 jtc }
1684 1.1 jtc
1685 1.1 jtc static void
1686 1.1 jtc dbteste_error(te, offset, msg)
1687 1.1 jtc Test_env *te;
1688 1.1 jtc int offset;
1689 1.1 jtc const char *msg;
1690 1.1 jtc {
1691 1.1 jtc te->flags |= TEF_ERROR;
1692 1.1 jtc internal_errorf(0, "dbteste_error: %s (offset %d)", msg, offset);
1693 1.1 jtc }
1694 1.1 jtc #endif /* KSH */
1695