diff options
Diffstat (limited to 'contrib/tcsh/sh.proc.c')
| -rw-r--r-- | contrib/tcsh/sh.proc.c | 1990 |
1 files changed, 0 insertions, 1990 deletions
diff --git a/contrib/tcsh/sh.proc.c b/contrib/tcsh/sh.proc.c deleted file mode 100644 index a8ebc74..0000000 --- a/contrib/tcsh/sh.proc.c +++ /dev/null @@ -1,1990 +0,0 @@ -/* $Header: /p/tcsh/cvsroot/tcsh/sh.proc.c,v 3.104 2006/09/27 16:59:04 mitr Exp $ */ -/* - * sh.proc.c: Job manipulations - */ -/*- - * Copyright (c) 1980, 1991 The Regents of the University of California. - * All rights reserved. - * - * Redistribution and use in source and binary forms, with or without - * modification, are permitted provided that the following conditions - * are met: - * 1. Redistributions of source code must retain the above copyright - * notice, this list of conditions and the following disclaimer. - * 2. 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. - * 3. Neither the name of the University nor the names of its contributors - * may be used to endorse or promote products derived from this software - * without specific prior written permission. - * - * THIS SOFTWARE IS PROVIDED BY THE REGENTS 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 THE REGENTS 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. - */ -#include "sh.h" - -RCSID("$tcsh: sh.proc.c,v 3.104 2006/09/27 16:59:04 mitr Exp $") - -#include "ed.h" -#include "tc.h" -#include "tc.wait.h" - -#ifdef WINNT_NATIVE -#undef POSIX -#define POSIX -#endif /* WINNT_NATIVE */ -#ifdef aiws -# undef HZ -# define HZ 16 -#endif /* aiws */ - -#if defined(_BSD) || (defined(IRIS4D) && __STDC__) || defined(__lucid) || defined(linux) || defined(__GNU__) || defined(__GLIBC__) -# define BSDWAIT -#endif /* _BSD || (IRIS4D && __STDC__) || __lucid || glibc */ -#ifndef WTERMSIG -# define WTERMSIG(w) (((union wait *) &(w))->w_termsig) -# ifndef BSDWAIT -# define BSDWAIT -# endif /* !BSDWAIT */ -#endif /* !WTERMSIG */ -#ifndef WEXITSTATUS -# define WEXITSTATUS(w) (((union wait *) &(w))->w_retcode) -#endif /* !WEXITSTATUS */ -#ifndef WSTOPSIG -# define WSTOPSIG(w) (((union wait *) &(w))->w_stopsig) -#endif /* !WSTOPSIG */ - -#ifdef __osf__ -# ifndef WCOREDUMP -# define WCOREDUMP(x) (_W_INT(x) & WCOREFLAG) -# endif -#endif - -#ifndef WCOREDUMP -# ifdef BSDWAIT -# define WCOREDUMP(w) (((union wait *) &(w))->w_coredump) -# else /* !BSDWAIT */ -# define WCOREDUMP(w) ((w) & 0200) -# endif /* !BSDWAIT */ -#endif /* !WCOREDUMP */ - -#ifndef JOBDEBUG -# define jobdebug_xprintf(x) (void)0 -# define jobdebug_flush() (void)0 -#else -# define jobdebug_xprintf(s) xprintf s -# define jobdebug_flush() flush() -#endif - -/* - * C Shell - functions that manage processes, handling hanging, termination - */ - -#define BIGINDEX 9 /* largest desirable job index */ - -#ifdef BSDTIMES -# ifdef convex -/* use 'cvxrusage' to get parallel statistics */ -static struct cvxrusage zru = {{0L, 0L}, {0L, 0L}, 0L, 0L, 0L, 0L, - 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, 0L, - {0L, 0L}, 0LL, 0LL, 0LL, 0LL, 0L, 0L, 0L, - 0LL, 0LL, {0L, 0L, 0L, 0L, 0L}}; -# else -static struct rusage zru; -# endif /* convex */ -#else /* !BSDTIMES */ -# ifdef _SEQUENT_ -static struct process_stats zru = {{0L, 0L}, {0L, 0L}, 0, 0, 0, 0, 0, 0, 0, - 0, 0, 0, 0, 0, 0, 0, 0, 0, 0}; -# else /* !_SEQUENT_ */ -# ifdef _SX -static struct tms zru = {0, 0, 0, 0}, lru = {0, 0, 0, 0}; -# else /* !_SX */ -static struct tms zru = {0L, 0L, 0L, 0L}, lru = {0L, 0L, 0L, 0L}; -# endif /* !_SX */ -# endif /* !_SEQUENT_ */ -#endif /* !BSDTIMES */ - -#ifndef BSDTIMES -static int timesdone; /* shtimes buffer full ? */ -#endif /* BSDTIMES */ - -#ifndef RUSAGE_CHILDREN -# define RUSAGE_CHILDREN -1 -#endif /* RUSAGE_CHILDREN */ - -static void pflushall (void); -static void pflush (struct process *); -static void pfree (struct process *); -static void pclrcurr (struct process *); -static void padd (struct command *); -static int pprint (struct process *, int); -static void ptprint (struct process *); -static void pads (Char *); -static void pkill (Char **, int); -static struct process *pgetcurr (struct process *); -static void okpcntl (void); -static void setttypgrp (int); - -/* - * pchild - call queued by the SIGCHLD signal - * indicating that at least one child has terminated or stopped - * thus at least one wait system call will definitely return a - * childs status. Top level routines (like pwait) must be sure - * to mask interrupts when playing with the proclist data structures! - */ -void -pchild(void) -{ - struct process *pp; - struct process *fp; - pid_t pid; -#ifdef BSDWAIT - union wait w; -#else /* !BSDWAIT */ - int w; -#endif /* !BSDWAIT */ - int jobflags; -#ifdef BSDTIMES - struct sysrusage ru; -#else /* !BSDTIMES */ -# ifdef _SEQUENT_ - struct process_stats ru; - struct process_stats cpst1, cpst2; - timeval_t tv; -# else /* !_SEQUENT_ */ - struct tms proctimes; - - if (!timesdone) { - timesdone++; - (void) times(&shtimes); - } -# endif /* !_SEQUENT_ */ -#endif /* !BSDTIMES */ - - jobdebug_xprintf(("pchild()\n")); - -loop: - jobdebug_xprintf(("Waiting...\n")); - jobdebug_flush(); - errno = 0; /* reset, just in case */ - -#ifndef WINNT_NATIVE -# ifdef BSDJOBS -# ifdef BSDTIMES -# ifdef convex - /* use 'cvxwait' to get parallel statistics */ - pid = cvxwait(&w, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG), &ru); -# else - /* both a wait3 and rusage */ -# if !defined(BSDWAIT) || defined(NeXT) || defined(MACH) || defined(linux) || defined(__GNU__) || defined(__GLIBC__) || (defined(IRIS4D) && SYSVREL <= 3) || defined(__lucid) || defined(__osf__) - pid = wait3(&w, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG), &ru); -# else /* BSDWAIT */ - pid = wait3(&w.w_status, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG), &ru); -# endif /* BSDWAIT */ -# endif /* convex */ -# else /* !BSDTIMES */ -# ifdef _SEQUENT_ - (void) get_process_stats(&tv, PS_SELF, 0, &cpst1); - pid = waitpid(-1, &w, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG)); - (void) get_process_stats(&tv, PS_SELF, 0, &cpst2); - pr_stat_sub(&cpst2, &cpst1, &ru); -# else /* !_SEQUENT_ */ -# ifndef POSIX - /* we have a wait3, but no rusage stuff */ - pid = wait3(&w.w_status, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG), 0); -# else /* POSIX */ - pid = waitpid(-1, &w, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG)); -# endif /* POSIX */ -# endif /* !_SEQUENT_ */ -# endif /* !BSDTIMES */ -# else /* !BSDJOBS */ -# ifdef BSDTIMES -# define HAVEwait3 - /* both a wait3 and rusage */ -# ifdef hpux - pid = wait3(&w.w_status, WNOHANG, 0); -# else /* !hpux */ - pid = wait3(&w.w_status, WNOHANG, &ru); -# endif /* !hpux */ -# else /* !BSDTIMES */ -# ifdef ODT /* For Sco Unix 3.2.0 or ODT 1.0 */ -# define HAVEwait3 - pid = waitpid(-1, &w, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG)); -# endif /* ODT */ -# if defined(aiws) || defined(uts) -# define HAVEwait3 - pid = wait3(&w.w_status, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG), 0); -# endif /* aiws || uts */ -# ifndef HAVEwait3 -# ifndef BSDWAIT - /* no wait3, therefore no rusage */ - /* on Sys V, this may hang. I hope it's not going to be a problem */ - pid = wait(&w); -# else /* BSDWAIT */ - /* - * XXX: for greater than 3 we should use waitpid(). - * but then again, SVR4 falls into the POSIX/BSDJOBS category. - */ - pid = wait(&w.w_status); -# endif /* BSDWAIT */ -# endif /* !HAVEwait3 */ -# endif /* !BSDTIMES */ -# endif /* !BSDJOBS */ -#else /* WINNT_NATIVE */ - pid = waitpid(-1, &w, - (setintr && (intty || insource) ? WNOHANG | WUNTRACED : WNOHANG)); -#endif /* WINNT_NATIVE */ - - jobdebug_xprintf(("parent %d pid %d, retval %x termsig %x retcode %x\n", - (int)getpid(), (int)pid, w, WTERMSIG(w), - WEXITSTATUS(w))); - jobdebug_flush(); - - if ((pid == 0) || (pid == -1)) { - handle_pending_signals(); - jobdebug_xprintf(("errno == %d\n", errno)); - if (errno == EINTR) - goto loop; - goto end; - } - for (pp = proclist.p_next; pp != NULL; pp = pp->p_next) - if (pid == pp->p_procid) - goto found; -#if !defined(BSDJOBS) && !defined(WINNT_NATIVE) - /* this should never have happened */ - stderror(ERR_SYNC, pid); - xexit(0); -#else /* BSDJOBS || WINNT_NATIVE */ - goto loop; -#endif /* !BSDJOBS && !WINNT_NATIVE */ -found: - pp->p_flags &= ~(PRUNNING | PSTOPPED | PREPORTED); - if (WIFSTOPPED(w)) { - pp->p_flags |= PSTOPPED; - pp->p_reason = WSTOPSIG(w); - } - else { - if (pp->p_flags & (PTIME | PPTIME) || adrof(STRtime)) -#ifndef BSDTIMES -# ifdef _SEQUENT_ - (void) get_process_stats(&pp->p_etime, PS_SELF, NULL, NULL); -# else /* !_SEQUENT_ */ - pp->p_etime = times(&proctimes); -# endif /* !_SEQUENT_ */ -#else /* BSDTIMES */ - (void) gettimeofday(&pp->p_etime, NULL); -#endif /* BSDTIMES */ - - -#if defined(BSDTIMES) || defined(_SEQUENT_) - pp->p_rusage = ru; -#else /* !BSDTIMES && !_SEQUENT_ */ - (void) times(&proctimes); - pp->p_utime = proctimes.tms_cutime - shtimes.tms_cutime; - pp->p_stime = proctimes.tms_cstime - shtimes.tms_cstime; - shtimes = proctimes; -#endif /* !BSDTIMES && !_SEQUENT_ */ - if (WIFSIGNALED(w)) { - if (WTERMSIG(w) == SIGINT) - pp->p_flags |= PINTERRUPTED; - else - pp->p_flags |= PSIGNALED; - if (WCOREDUMP(w)) - pp->p_flags |= PDUMPED; - pp->p_reason = WTERMSIG(w); - } - else { - pp->p_reason = WEXITSTATUS(w); - if (pp->p_reason != 0) - pp->p_flags |= PAEXITED; - else - pp->p_flags |= PNEXITED; - } - } - jobflags = 0; - fp = pp; - do { - if ((fp->p_flags & (PPTIME | PRUNNING | PSTOPPED)) == 0 && - !child && adrof(STRtime) && -#ifdef BSDTIMES - fp->p_rusage.ru_utime.tv_sec + fp->p_rusage.ru_stime.tv_sec -#else /* !BSDTIMES */ -# ifdef _SEQUENT_ - fp->p_rusage.ps_utime.tv_sec + fp->p_rusage.ps_stime.tv_sec -# else /* !_SEQUENT_ */ -# ifndef POSIX - (fp->p_utime + fp->p_stime) / HZ -# else /* POSIX */ - (fp->p_utime + fp->p_stime) / clk_tck -# endif /* POSIX */ -# endif /* !_SEQUENT_ */ -#endif /* !BSDTIMES */ - >= atoi(short2str(varval(STRtime)))) - fp->p_flags |= PTIME; - jobflags |= fp->p_flags; - } while ((fp = fp->p_friends) != pp); - pp->p_flags &= ~PFOREGND; - if (pp == pp->p_friends && (pp->p_flags & PPTIME)) { - pp->p_flags &= ~PPTIME; - pp->p_flags |= PTIME; - } - if ((jobflags & (PRUNNING | PREPORTED)) == 0) { - fp = pp; - do { - if (fp->p_flags & PSTOPPED) - fp->p_flags |= PREPORTED; - } while ((fp = fp->p_friends) != pp); - while (fp->p_procid != fp->p_jobid) - fp = fp->p_friends; - if (jobflags & PSTOPPED) { - if (pcurrent && pcurrent != fp) - pprevious = pcurrent; - pcurrent = fp; - } - else - pclrcurr(fp); - if (jobflags & PFOREGND) { - if (!(jobflags & (PSIGNALED | PSTOPPED | PPTIME) || -#ifdef notdef - jobflags & PAEXITED || -#endif /* notdef */ - !eq(dcwd->di_name, fp->p_cwd->di_name))) { - /* PWP: print a newline after ^C */ - if (jobflags & PINTERRUPTED) { - xputchar('\r' | QUOTE); - xputchar('\n'); - } -#ifdef notdef - else if ((jobflags & (PTIME|PSTOPPED)) == PTIME) - ptprint(fp); -#endif /* notdef */ - } - } - else { - if (jobflags & PNOTIFY || adrof(STRnotify)) { - xputchar('\r' | QUOTE); - xputchar('\n'); - (void) pprint(pp, NUMBER | NAME | REASON); - if ((jobflags & PSTOPPED) == 0) - pflush(pp); - if (GettingInput) { - errno = 0; - (void) Rawmode(); -#ifdef notdef - /* - * don't really want to do that, because it - * will erase our message in case of multi-line - * input - */ - ClearLines(); -#endif /* notdef */ - ClearDisp(); - Refresh(); - } - } - else { - fp->p_flags |= PNEEDNOTE; - neednote = 1; - } - } - } -#if defined(BSDJOBS) || defined(HAVEwait3) ||defined(WINNT_NATIVE) - goto loop; -#endif /* BSDJOBS || HAVEwait3 */ - end: - ; -} - -void -pnote(void) -{ - struct process *pp; - int flags; - - neednote = 0; - for (pp = proclist.p_next; pp != NULL; pp = pp->p_next) { - if (pp->p_flags & PNEEDNOTE) { - pchild_disabled++; - cleanup_push(&pchild_disabled, disabled_cleanup); - pp->p_flags &= ~PNEEDNOTE; - flags = pprint(pp, NUMBER | NAME | REASON); - if ((flags & (PRUNNING | PSTOPPED)) == 0) - pflush(pp); - cleanup_until(&pchild_disabled); - } - } -} - - -static void -pfree(struct process *pp) -{ - xfree(pp->p_command); - if (pp->p_cwd && --pp->p_cwd->di_count == 0) - if (pp->p_cwd->di_next == 0) - dfree(pp->p_cwd); - xfree(pp); -} - - -/* - * pwait - wait for current job to terminate, maintaining integrity - * of current and previous job indicators. - */ -void -pwait(void) -{ - struct process *fp, *pp; - - /* - * Here's where dead procs get flushed. - */ - for (pp = (fp = &proclist)->p_next; pp != NULL; pp = (fp = pp)->p_next) - if (pp->p_procid == 0) { - fp->p_next = pp->p_next; - pfree(pp); - pp = fp; - } - pjwait(pcurrjob); -} - - -/* - * pjwait - wait for a job to finish or become stopped - * It is assumed to be in the foreground state (PFOREGND) - */ -void -pjwait(struct process *pp) -{ - struct process *fp; - int jobflags, reason; - sigset_t oset, set, pause_mask; - Char *reason_str; - - while (pp->p_procid != pp->p_jobid) - pp = pp->p_friends; - fp = pp; - - do { - if ((fp->p_flags & (PFOREGND | PRUNNING)) == PRUNNING) - xprintf(CGETS(17, 1, "BUG: waiting for background job!\n")); - } while ((fp = fp->p_friends) != pp); - /* - * Now keep pausing as long as we are not interrupted (SIGINT), and the - * target process, or any of its friends, are running - */ - fp = pp; - sigemptyset(&set); - sigaddset(&set, SIGINT); - sigaddset(&set, SIGCHLD); - (void)sigprocmask(SIG_BLOCK, &set, &oset); - cleanup_push(&oset, sigprocmask_cleanup); - pause_mask = oset; - sigdelset(&pause_mask, SIGCHLD); - for (;;) { - handle_pending_signals(); - jobflags = 0; - do - jobflags |= fp->p_flags; - while ((fp = (fp->p_friends)) != pp); - if ((jobflags & PRUNNING) == 0) - break; - jobdebug_xprintf(("%d starting to sigsuspend for SIGCHLD on %d\n", - getpid(), fp->p_procid)); - sigsuspend(&pause_mask); - } - cleanup_until(&oset); - jobdebug_xprintf(("%d returned from sigsuspend loop\n", getpid())); -#ifdef BSDJOBS - if (tpgrp > 0) /* get tty back */ - (void) tcsetpgrp(FSHTTY, tpgrp); -#endif /* BSDJOBS */ - if ((jobflags & (PSIGNALED | PSTOPPED | PTIME)) || - !eq(dcwd->di_name, fp->p_cwd->di_name)) { - if (jobflags & PSTOPPED) { - xputchar('\n'); - if (adrof(STRlistjobs)) { - Char *jobcommand[3]; - - jobcommand[0] = STRjobs; - if (eq(varval(STRlistjobs), STRlong)) - jobcommand[1] = STRml; - else - jobcommand[1] = NULL; - jobcommand[2] = NULL; - - dojobs(jobcommand, NULL); - (void) pprint(pp, SHELLDIR); - } - else - (void) pprint(pp, AREASON | SHELLDIR); - } - else - (void) pprint(pp, AREASON | SHELLDIR); - } - if ((jobflags & (PINTERRUPTED | PSTOPPED)) && setintr && - (!gointr || !eq(gointr, STRminus))) { - if ((jobflags & PSTOPPED) == 0) - pflush(pp); - pintr1(0); - /* NOTREACHED */ - } - reason = 0; - fp = pp; - do { - if (fp->p_reason) - reason = fp->p_flags & (PSIGNALED | PINTERRUPTED) ? - fp->p_reason | META : fp->p_reason; - } while ((fp = fp->p_friends) != pp); - /* - * Don't report on backquoted jobs, cause it will mess up - * their output. - */ - if ((reason != 0) && (adrof(STRprintexitvalue)) && - (pp->p_flags & PBACKQ) == 0) - xprintf(CGETS(17, 2, "Exit %d\n"), reason); - reason_str = putn(reason); - cleanup_push(reason_str, xfree); - setv(STRstatus, reason_str, VAR_READWRITE); - cleanup_ignore(reason_str); - cleanup_until(reason_str); - if (reason && exiterr) - exitstat(); - pflush(pp); -} - -/* - * dowait - wait for all processes to finish - */ - -/*ARGSUSED*/ -void -dowait(Char **v, struct command *c) -{ - struct process *pp; - sigset_t pause_mask; - - USE(c); - USE(v); - pjobs++; - sigprocmask(SIG_BLOCK, NULL, &pause_mask); - sigdelset(&pause_mask, SIGCHLD); - if (setintr) - sigdelset(&pause_mask, SIGINT); -loop: - for (pp = proclist.p_next; pp; pp = pp->p_next) - if (pp->p_procid && /* pp->p_procid == pp->p_jobid && */ - pp->p_flags & PRUNNING) { - handle_pending_signals(); - sigsuspend(&pause_mask); - handle_pending_signals(); - goto loop; - } - pjobs = 0; -} - -/* - * pflushall - flush all jobs from list (e.g. at fork()) - */ -static void -pflushall(void) -{ - struct process *pp; - - for (pp = proclist.p_next; pp != NULL; pp = pp->p_next) - if (pp->p_procid) - pflush(pp); -} - -/* - * pflush - flag all process structures in the same job as the - * the argument process for deletion. The actual free of the - * space is not done here since pflush is called at interrupt level. - */ -static void -pflush(struct process *pp) -{ - struct process *np; - int idx; - - if (pp->p_procid == 0) { - xprintf(CGETS(17, 3, "BUG: process flushed twice")); - return; - } - while (pp->p_procid != pp->p_jobid) - pp = pp->p_friends; - pclrcurr(pp); - if (pp == pcurrjob) - pcurrjob = 0; - idx = pp->p_index; - np = pp; - do { - np->p_index = np->p_procid = 0; - np->p_flags &= ~PNEEDNOTE; - } while ((np = np->p_friends) != pp); - if (idx == pmaxindex) { - for (np = proclist.p_next, idx = 0; np; np = np->p_next) - if (np->p_index > idx) - idx = np->p_index; - pmaxindex = idx; - } -} - -/* - * pclrcurr - make sure the given job is not the current or previous job; - * pp MUST be the job leader - */ -static void -pclrcurr(struct process *pp) -{ - if (pp == pcurrent) { - if (pprevious != NULL) { - pcurrent = pprevious; - pprevious = pgetcurr(pp); - } - else { - pcurrent = pgetcurr(pp); - pprevious = pgetcurr(pp); - } - } - else if (pp == pprevious) - pprevious = pgetcurr(pp); -} - -/* +4 here is 1 for '\0', 1 ea for << >& >> */ -static Char command[PMAXLEN + 4]; -static size_t cmdlen; -static Char *cmdp; - -/* GrP - * unparse - Export padd() functionality - */ -Char * -unparse(struct command *t) -{ - cmdp = command; - cmdlen = 0; - padd(t); - *cmdp++ = '\0'; - return Strsave(command); -} - - -/* - * palloc - allocate a process structure and fill it up. - * an important assumption is made that the process is running. - */ -void -palloc(pid_t pid, struct command *t) -{ - struct process *pp; - int i; - - pp = xcalloc(1, sizeof(struct process)); - pp->p_procid = pid; - pp->p_flags = ((t->t_dflg & F_AMPERSAND) ? 0 : PFOREGND) | PRUNNING; - if (t->t_dflg & F_TIME) - pp->p_flags |= PPTIME; - if (t->t_dflg & F_BACKQ) - pp->p_flags |= PBACKQ; - if (t->t_dflg & F_HUP) - pp->p_flags |= PHUP; - cmdp = command; - cmdlen = 0; - padd(t); - *cmdp++ = 0; - if (t->t_dflg & F_PIPEOUT) { - pp->p_flags |= PPOU; - if (t->t_dflg & F_STDERR) - pp->p_flags |= PDIAG; - } - pp->p_command = Strsave(command); - if (pcurrjob) { - struct process *fp; - - /* careful here with interrupt level */ - pp->p_cwd = 0; - pp->p_index = pcurrjob->p_index; - pp->p_friends = pcurrjob; - pp->p_jobid = pcurrjob->p_procid; - for (fp = pcurrjob; fp->p_friends != pcurrjob; fp = fp->p_friends) - continue; - fp->p_friends = pp; - } - else { - pcurrjob = pp; - pp->p_jobid = pid; - pp->p_friends = pp; - pp->p_cwd = dcwd; - dcwd->di_count++; - if (pmaxindex < BIGINDEX) - pp->p_index = ++pmaxindex; - else { - struct process *np; - - for (i = 1;; i++) { - for (np = proclist.p_next; np; np = np->p_next) - if (np->p_index == i) - goto tryagain; - pp->p_index = i; - if (i > pmaxindex) - pmaxindex = i; - break; - tryagain:; - } - } - if (pcurrent == NULL) - pcurrent = pp; - else if (pprevious == NULL) - pprevious = pp; - } - pp->p_next = proclist.p_next; - proclist.p_next = pp; -#ifdef BSDTIMES - (void) gettimeofday(&pp->p_btime, NULL); -#else /* !BSDTIMES */ -# ifdef _SEQUENT_ - (void) get_process_stats(&pp->p_btime, PS_SELF, NULL, NULL); -# else /* !_SEQUENT_ */ - { - struct tms tmptimes; - - pp->p_btime = times(&tmptimes); - } -# endif /* !_SEQUENT_ */ -#endif /* !BSDTIMES */ -} - -static void -padd(struct command *t) -{ - Char **argp; - - if (t == 0) - return; - switch (t->t_dtyp) { - - case NODE_PAREN: - pads(STRLparensp); - padd(t->t_dspr); - pads(STRspRparen); - break; - - case NODE_COMMAND: - for (argp = t->t_dcom; *argp; argp++) { - pads(*argp); - if (argp[1]) - pads(STRspace); - } - break; - - case NODE_OR: - case NODE_AND: - case NODE_PIPE: - case NODE_LIST: - padd(t->t_dcar); - switch (t->t_dtyp) { - case NODE_OR: - pads(STRspor2sp); - break; - case NODE_AND: - pads(STRspand2sp); - break; - case NODE_PIPE: - pads(STRsporsp); - break; - case NODE_LIST: - pads(STRsemisp); - break; - default: - break; - } - padd(t->t_dcdr); - return; - - default: - break; - } - if ((t->t_dflg & F_PIPEIN) == 0 && t->t_dlef) { - pads((t->t_dflg & F_READ) ? STRspLarrow2sp : STRspLarrowsp); - pads(t->t_dlef); - } - if ((t->t_dflg & F_PIPEOUT) == 0 && t->t_drit) { - pads((t->t_dflg & F_APPEND) ? STRspRarrow2 : STRspRarrow); - if (t->t_dflg & F_STDERR) - pads(STRand); - pads(STRspace); - pads(t->t_drit); - } -} - -static void -pads(Char *cp) -{ - size_t i; - - /* - * Avoid the Quoted Space alias hack! Reported by: - * sam@john-bigboote.ICS.UCI.EDU (Sam Horrocks) - */ - if (cp[0] == STRQNULL[0]) - cp++; - - i = Strlen(cp); - - if (cmdlen >= PMAXLEN) - return; - if (cmdlen + i >= PMAXLEN) { - (void) Strcpy(cmdp, STRsp3dots); - cmdlen = PMAXLEN; - cmdp += 4; - return; - } - (void) Strcpy(cmdp, cp); - cmdp += i; - cmdlen += i; -} - -/* - * psavejob - temporarily save the current job on a one level stack - * so another job can be created. Used for { } in exp6 - * and `` in globbing. - */ -void -psavejob(void) -{ - pholdjob = pcurrjob; - pcurrjob = NULL; -} - -void -psavejob_cleanup(void *dummy) -{ - USE(dummy); - pcurrjob = pholdjob; - pholdjob = NULL; -} - -/* - * pendjob - indicate that a job (set of commands) has been completed - * or is about to begin. - */ -void -pendjob(void) -{ - struct process *pp, *tp; - - if (pcurrjob && (pcurrjob->p_flags & (PFOREGND | PSTOPPED)) == 0) { - pp = pcurrjob; - while (pp->p_procid != pp->p_jobid) - pp = pp->p_friends; - xprintf("[%d]", pp->p_index); - tp = pp; - do { - xprintf(" %d", pp->p_procid); - pp = pp->p_friends; - } while (pp != tp); - xputchar('\n'); - } - pholdjob = pcurrjob = 0; -} - -/* - * pprint - print a job - */ - -/* - * Hacks have been added for SVR4 to deal with pipe's being spawned in - * reverse order - * - * David Dawes (dawes@physics.su.oz.au) Oct 1991 - */ - -static int -pprint(struct process *pp, int flag) -{ - int status, reason; - struct process *tp; - int jobflags, pstatus, pcond; - const char *format; - -#ifdef BACKPIPE - struct process *pipehead = NULL, *pipetail = NULL, *pmarker = NULL; - int inpipe = 0; -#endif /* BACKPIPE */ - - while (pp->p_procid != pp->p_jobid) - pp = pp->p_friends; - if (pp == pp->p_friends && (pp->p_flags & PPTIME)) { - pp->p_flags &= ~PPTIME; - pp->p_flags |= PTIME; - } - tp = pp; - status = reason = -1; - jobflags = 0; - do { -#ifdef BACKPIPE - /* - * The pipeline is reversed, so locate the real head of the pipeline - * if pp is at the tail of a pipe (and not already in a pipeline) - */ - if ((pp->p_friends->p_flags & PPOU) && !inpipe && (flag & NAME)) { - inpipe = 1; - pipetail = pp; - do - pp = pp->p_friends; - while (pp->p_friends->p_flags & PPOU); - pipehead = pp; - pmarker = pp; - /* - * pmarker is used to hold the place of the proc being processed, so - * we can search for the next one downstream later. - */ - } - pcond = (tp != pp || (inpipe && tp == pp)); -#else /* !BACKPIPE */ - pcond = (tp != pp); -#endif /* BACKPIPE */ - - jobflags |= pp->p_flags; - pstatus = (int) (pp->p_flags & PALLSTATES); - if (pcond && linp != linbuf && !(flag & FANCY) && - ((pstatus == status && pp->p_reason == reason) || - !(flag & REASON))) - xputchar(' '); - else { - if (pcond && linp != linbuf) - xputchar('\n'); - if (flag & NUMBER) { -#ifdef BACKPIPE - pcond = ((pp == tp && !inpipe) || - (inpipe && pipetail == tp && pp == pipehead)); -#else /* BACKPIPE */ - pcond = (pp == tp); -#endif /* BACKPIPE */ - if (pcond) - xprintf("[%d]%s %c ", pp->p_index, - pp->p_index < 10 ? " " : "", - pp == pcurrent ? '+' : - (pp == pprevious ? '-' : ' ')); - else - xprintf(" "); - } - if (flag & FANCY) { - xprintf("%5d ", pp->p_procid); -#ifdef TCF - xprintf("%11s ", sitename(pp->p_procid)); -#endif /* TCF */ - } - if (flag & (REASON | AREASON)) { - if (flag & NAME) - format = "%-30s"; - else - format = "%s"; - if (pstatus == status) { - if (pp->p_reason == reason) { - xprintf(format, ""); - goto prcomd; - } - else - reason = (int) pp->p_reason; - } - else { - status = pstatus; - reason = (int) pp->p_reason; - } - switch (status) { - - case PRUNNING: - xprintf(format, CGETS(17, 4, "Running ")); - break; - - case PINTERRUPTED: - case PSTOPPED: - case PSIGNALED: - /* - * tell what happened to the background job - * From: Michael Schroeder - * <mlschroe@immd4.informatik.uni-erlangen.de> - */ - if ((flag & REASON) - || ((flag & AREASON) - && reason != SIGINT - && (reason != SIGPIPE - || (pp->p_flags & PPOU) == 0))) { - char *ptr; - int free_ptr; - - free_ptr = 0; - ptr = (char *)(intptr_t)mesg[pp->p_reason & 0177].pname; - if (ptr == NULL) { - ptr = xasprintf("%s %d", CGETS(17, 5, "Signal"), - pp->p_reason & 0177); - cleanup_push(ptr, xfree); - free_ptr = 1; - } - xprintf(format, ptr); - if (free_ptr != 0) - cleanup_until(ptr); - } - else - reason = -1; - break; - - case PNEXITED: - case PAEXITED: - if (flag & REASON) { - if (pp->p_reason) - xprintf(CGETS(17, 6, "Exit %-25d"), pp->p_reason); - else - xprintf(format, CGETS(17, 7, "Done")); - } - break; - - default: - xprintf(CGETS(17, 8, "BUG: status=%-9o"), - status); - } - } - } -prcomd: - if (flag & NAME) { - xprintf("%S", pp->p_command); - if (pp->p_flags & PPOU) - xprintf(" |"); - if (pp->p_flags & PDIAG) - xprintf("&"); - } - if (flag & (REASON | AREASON) && pp->p_flags & PDUMPED) - xprintf(CGETS(17, 9, " (core dumped)")); - if (tp == pp->p_friends) { - if (flag & AMPERSAND) - xprintf(" &"); - if (flag & JOBDIR && - !eq(tp->p_cwd->di_name, dcwd->di_name)) { - xprintf(CGETS(17, 10, " (wd: ")); - dtildepr(tp->p_cwd->di_name); - xprintf(")"); - } - } - if (pp->p_flags & PPTIME && !(status & (PSTOPPED | PRUNNING))) { - if (linp != linbuf) - xprintf("\n\t"); -#if defined(BSDTIMES) || defined(_SEQUENT_) - prusage(&zru, &pp->p_rusage, &pp->p_etime, - &pp->p_btime); -#else /* !BSDTIMES && !SEQUENT */ - lru.tms_utime = pp->p_utime; - lru.tms_stime = pp->p_stime; - lru.tms_cutime = 0; - lru.tms_cstime = 0; - prusage(&zru, &lru, pp->p_etime, - pp->p_btime); -#endif /* !BSDTIMES && !SEQUENT */ - - } -#ifdef BACKPIPE - pcond = ((tp == pp->p_friends && !inpipe) || - (inpipe && pipehead->p_friends == tp && pp == pipetail)); -#else /* !BACKPIPE */ - pcond = (tp == pp->p_friends); -#endif /* BACKPIPE */ - if (pcond) { - if (linp != linbuf) - xputchar('\n'); - if (flag & SHELLDIR && !eq(tp->p_cwd->di_name, dcwd->di_name)) { - xprintf(CGETS(17, 11, "(wd now: ")); - dtildepr(dcwd->di_name); - xprintf(")\n"); - } - } -#ifdef BACKPIPE - if (inpipe) { - /* - * if pmaker == pipetail, we are finished that pipeline, and - * can now skip to past the head - */ - if (pmarker == pipetail) { - inpipe = 0; - pp = pipehead; - } - else { - /* - * set pp to one before the one we want next, so the while below - * increments to the correct spot. - */ - do - pp = pp->p_friends; - while (pp->p_friends->p_friends != pmarker); - pmarker = pp->p_friends; - } - } - pcond = ((pp = pp->p_friends) != tp || inpipe); -#else /* !BACKPIPE */ - pcond = ((pp = pp->p_friends) != tp); -#endif /* BACKPIPE */ - } while (pcond); - - if (jobflags & PTIME && (jobflags & (PSTOPPED | PRUNNING)) == 0) { - if (jobflags & NUMBER) - xprintf(" "); - ptprint(tp); - } - return (jobflags); -} - -/* - * All 4.3 BSD derived implementations are buggy and I've had enough. - * The following implementation produces similar code and works in all - * cases. The 4.3BSD one works only for <, >, != - */ -# undef timercmp -# define timercmp(tvp, uvp, cmp) \ - (((tvp)->tv_sec == (uvp)->tv_sec) ? \ - ((tvp)->tv_usec cmp (uvp)->tv_usec) : \ - ((tvp)->tv_sec cmp (uvp)->tv_sec)) - -static void -ptprint(struct process *tp) -{ -#ifdef BSDTIMES - struct timeval tetime, diff; - static struct timeval ztime; - struct sysrusage ru; - struct process *pp = tp; - - ru = zru; - tetime = ztime; - do { - ruadd(&ru, &pp->p_rusage); - tvsub(&diff, &pp->p_etime, &pp->p_btime); - if (timercmp(&diff, &tetime, >)) - tetime = diff; - } while ((pp = pp->p_friends) != tp); - prusage(&zru, &ru, &tetime, &ztime); -#else /* !BSDTIMES */ -# ifdef _SEQUENT_ - timeval_t tetime, diff; - static timeval_t ztime; - struct process_stats ru; - struct process *pp = tp; - - ru = zru; - tetime = ztime; - do { - ruadd(&ru, &pp->p_rusage); - tvsub(&diff, &pp->p_etime, &pp->p_btime); - if (timercmp(&diff, &tetime, >)) - tetime = diff; - } while ((pp = pp->p_friends) != tp); - prusage(&zru, &ru, &tetime, &ztime); -# else /* !_SEQUENT_ */ -# ifndef POSIX - static time_t ztime = 0; - static time_t zu_time = 0; - static time_t zs_time = 0; - time_t tetime, diff; - time_t u_time, s_time; - -# else /* POSIX */ - static clock_t ztime = 0; - static clock_t zu_time = 0; - static clock_t zs_time = 0; - clock_t tetime, diff; - clock_t u_time, s_time; - -# endif /* POSIX */ - struct tms zts, rts; - struct process *pp = tp; - - u_time = zu_time; - s_time = zs_time; - tetime = ztime; - do { - u_time += pp->p_utime; - s_time += pp->p_stime; - diff = pp->p_etime - pp->p_btime; - if (diff > tetime) - tetime = diff; - } while ((pp = pp->p_friends) != tp); - zts.tms_utime = zu_time; - zts.tms_stime = zs_time; - zts.tms_cutime = 0; - zts.tms_cstime = 0; - rts.tms_utime = u_time; - rts.tms_stime = s_time; - rts.tms_cutime = 0; - rts.tms_cstime = 0; - prusage(&zts, &rts, tetime, ztime); -# endif /* !_SEQUENT_ */ -#endif /* !BSDTIMES */ -} - -/* - * dojobs - print all jobs - */ -/*ARGSUSED*/ -void -dojobs(Char **v, struct command *c) -{ - struct process *pp; - int flag = NUMBER | NAME | REASON; - int i; - - USE(c); - if (chkstop) - chkstop = 2; - if (*++v) { - if (v[1] || !eq(*v, STRml)) - stderror(ERR_JOBS); - flag |= FANCY | JOBDIR; - } - for (i = 1; i <= pmaxindex; i++) - for (pp = proclist.p_next; pp; pp = pp->p_next) - if (pp->p_index == i && pp->p_procid == pp->p_jobid) { - pp->p_flags &= ~PNEEDNOTE; - if (!(pprint(pp, flag) & (PRUNNING | PSTOPPED))) - pflush(pp); - break; - } -} - -/* - * dofg - builtin - put the job into the foreground - */ -/*ARGSUSED*/ -void -dofg(Char **v, struct command *c) -{ - struct process *pp; - - USE(c); - okpcntl(); - ++v; - do { - pp = pfind(*v); - if (!pstart(pp, 1)) { - pp->p_procid = 0; - stderror(ERR_NAME|ERR_BADJOB, pp->p_command, strerror(errno)); - continue; - } - pjwait(pp); - } while (*v && *++v); -} - -/* - * %... - builtin - put the job into the foreground - */ -/*ARGSUSED*/ -void -dofg1(Char **v, struct command *c) -{ - struct process *pp; - - USE(c); - okpcntl(); - pp = pfind(v[0]); - if (!pstart(pp, 1)) { - pp->p_procid = 0; - stderror(ERR_NAME|ERR_BADJOB, pp->p_command, strerror(errno)); - return; - } - pjwait(pp); -} - -/* - * dobg - builtin - put the job into the background - */ -/*ARGSUSED*/ -void -dobg(Char **v, struct command *c) -{ - struct process *pp; - - USE(c); - okpcntl(); - ++v; - do { - pp = pfind(*v); - if (!pstart(pp, 0)) { - pp->p_procid = 0; - stderror(ERR_NAME|ERR_BADJOB, pp->p_command, strerror(errno)); - } - } while (*v && *++v); -} - -/* - * %... & - builtin - put the job into the background - */ -/*ARGSUSED*/ -void -dobg1(Char **v, struct command *c) -{ - struct process *pp; - - USE(c); - pp = pfind(v[0]); - if (!pstart(pp, 0)) { - pp->p_procid = 0; - stderror(ERR_NAME|ERR_BADJOB, pp->p_command, strerror(errno)); - } -} - -/* - * dostop - builtin - stop the job - */ -/*ARGSUSED*/ -void -dostop(Char **v, struct command *c) -{ - USE(c); -#ifdef BSDJOBS - pkill(++v, SIGSTOP); -#endif /* BSDJOBS */ -} - -/* - * dokill - builtin - superset of kill (1) - */ -/*ARGSUSED*/ -void -dokill(Char **v, struct command *c) -{ - int signum, len = 0; - const char *name; - Char *sigptr; - - USE(c); - v++; - if (v[0] && v[0][0] == '-') { - if (v[0][1] == 'l') { - for (signum = 0; signum <= nsig; signum++) { - if ((name = mesg[signum].iname) != NULL) { - len += strlen(name) + 1; - if (len >= TermH - 1) { - xputchar('\n'); - len = strlen(name) + 1; - } - xprintf("%s ", name); - } - } - xputchar('\n'); - return; - } - sigptr = &v[0][1]; - if (v[0][1] == 's') { - if (v[1]) { - v++; - sigptr = &v[0][0]; - } else { - stderror(ERR_NAME | ERR_TOOFEW); - } - } - if (Isdigit(*sigptr)) { - char *ep; - signum = strtoul(short2str(sigptr), &ep, 0); - if (*ep || signum < 0 || signum > (MAXSIG-1)) - stderror(ERR_NAME | ERR_BADSIG); - } - else { - for (signum = 0; signum <= nsig; signum++) - if (mesg[signum].iname && - eq(sigptr, str2short(mesg[signum].iname))) - goto gotsig; - setname(short2str(sigptr)); - stderror(ERR_NAME | ERR_UNKSIG); - } -gotsig: - v++; - } - else - signum = SIGTERM; - pkill(v, signum); -} - -static void -pkill(Char **v, int signum) -{ - struct process *pp, *np; - int jobflags = 0, err1 = 0; - pid_t pid; - Char *cp, **vp, **globbed; - - /* Avoid globbing %?x patterns */ - for (vp = v; vp && *vp; vp++) - if (**vp == '%') - (void) quote(*vp); - - v = glob_all_or_error(v); - globbed = v; - cleanup_push(globbed, blk_cleanup); - - pchild_disabled++; - cleanup_push(&pchild_disabled, disabled_cleanup); - if (setintr) { - pintr_disabled++; - cleanup_push(&pintr_disabled, disabled_cleanup); - } - - while (v && (cp = *v)) { - if (*cp == '%') { - np = pp = pfind(cp); - do - jobflags |= np->p_flags; - while ((np = np->p_friends) != pp); -#ifdef BSDJOBS - switch (signum) { - - case SIGSTOP: - case SIGTSTP: - case SIGTTIN: - case SIGTTOU: - if ((jobflags & PRUNNING) == 0) { -# ifdef SUSPENDED - xprintf(CGETS(17, 12, "%S: Already suspended\n"), cp); -# else /* !SUSPENDED */ - xprintf(CGETS(17, 13, "%S: Already stopped\n"), cp); -# endif /* !SUSPENDED */ - err1++; - goto cont; - } - break; - /* - * suspend a process, kill -CONT %, then type jobs; the shell - * says it is suspended, but it is running; thanks jaap.. - */ - case SIGCONT: - if (!pstart(pp, 0)) { - pp->p_procid = 0; - stderror(ERR_NAME|ERR_BADJOB, pp->p_command, - strerror(errno)); - } - goto cont; - default: - break; - } -#endif /* BSDJOBS */ - if (killpg(pp->p_jobid, signum) < 0) { - xprintf("%S: %s\n", cp, strerror(errno)); - err1++; - } -#ifdef BSDJOBS - if (signum == SIGTERM || signum == SIGHUP) - (void) killpg(pp->p_jobid, SIGCONT); -#endif /* BSDJOBS */ - } - else if (!(Isdigit(*cp) || *cp == '-')) - stderror(ERR_NAME | ERR_JOBARGS); - else { - char *ep; -#ifndef WINNT_NATIVE - pid = strtol(short2str(cp), &ep, 10); -#else - pid = strtoul(short2str(cp), &ep, 0); -#endif /* WINNT_NATIVE */ - if (*ep) - stderror(ERR_NAME | ERR_JOBARGS); - else if (kill(pid, signum) < 0) { - xprintf("%d: %s\n", pid, strerror(errno)); - err1++; - goto cont; - } -#ifdef BSDJOBS - if (signum == SIGTERM || signum == SIGHUP) - (void) kill(pid, SIGCONT); -#endif /* BSDJOBS */ - } -cont: - v++; - } - cleanup_until(&pchild_disabled); - if (err1) - stderror(ERR_SILENT); -} - -/* - * pstart - start the job in foreground/background - */ -int -pstart(struct process *pp, int foregnd) -{ - int rv = 0; - struct process *np; - /* We don't use jobflags in this function right now (see below) */ - /* long jobflags = 0; */ - - pchild_disabled++; - cleanup_push(&pchild_disabled, disabled_cleanup); - np = pp; - do { - /* We don't use jobflags in this function right now (see below) */ - /* jobflags |= np->p_flags; */ - if (np->p_flags & (PRUNNING | PSTOPPED)) { - np->p_flags |= PRUNNING; - np->p_flags &= ~PSTOPPED; - if (foregnd) - np->p_flags |= PFOREGND; - else - np->p_flags &= ~PFOREGND; - } - } while ((np = np->p_friends) != pp); - if (!foregnd) - pclrcurr(pp); - (void) pprint(pp, foregnd ? NAME | JOBDIR : NUMBER | NAME | AMPERSAND); - - /* GrP run jobcmd hook if foregrounding */ - if (foregnd) { - job_cmd(pp->p_command); - } - -#ifdef BSDJOBS - if (foregnd) { - rv = tcsetpgrp(FSHTTY, pp->p_jobid); - } - /* - * 1. child process of csh (shell script) receives SIGTTIN/SIGTTOU - * 2. parent process (csh) receives SIGCHLD - * 3. The "csh" signal handling function pchild() is invoked - * with a SIGCHLD signal. - * 4. pchild() calls wait3(WNOHANG) which returns 0. - * The child process is NOT ready to be waited for at this time. - * pchild() returns without picking-up the correct status - * for the child process which generated the SIGCHLD. - * 5. CONSEQUENCE : csh is UNaware that the process is stopped - * 6. THIS LINE HAS BEEN COMMENTED OUT : if (jobflags&PSTOPPED) - * (beto@aixwiz.austin.ibm.com - aug/03/91) - * 7. I removed the line completely and added extra checks for - * pstart, so that if a job gets attached to and dies inside - * a debugger it does not confuse the shell. [christos] - * 8. on the nec sx-4 there seems to be a problem, which requires - * a syscall(151, getpid(), getpid()) in osinit. Don't ask me - * what this is doing. [schott@rzg.mpg.de] - */ - - if (rv != -1) - rv = killpg(pp->p_jobid, SIGCONT); -#endif /* BSDJOBS */ - cleanup_until(&pchild_disabled); - return rv != -1; -} - -void -panystop(int neednl) -{ - struct process *pp; - - chkstop = 2; - for (pp = proclist.p_next; pp; pp = pp->p_next) - if (pp->p_flags & PSTOPPED) - stderror(ERR_STOPPED, neednl ? "\n" : ""); -} - -struct process * -pfind(Char *cp) -{ - struct process *pp, *np; - - if (cp == 0 || cp[1] == 0 || eq(cp, STRcent2) || eq(cp, STRcentplus)) { - if (pcurrent == NULL) - stderror(ERR_NAME | ERR_JOBCUR); - return (pcurrent); - } - if (eq(cp, STRcentminus) || eq(cp, STRcenthash)) { - if (pprevious == NULL) - stderror(ERR_NAME | ERR_JOBPREV); - return (pprevious); - } - if (Isdigit(cp[1])) { - int idx = atoi(short2str(cp + 1)); - - for (pp = proclist.p_next; pp; pp = pp->p_next) - if (pp->p_index == idx && pp->p_procid == pp->p_jobid) - return (pp); - stderror(ERR_NAME | ERR_NOSUCHJOB); - } - np = NULL; - for (pp = proclist.p_next; pp; pp = pp->p_next) - if (pp->p_procid == pp->p_jobid) { - if (cp[1] == '?') { - Char *dp; - - for (dp = pp->p_command; *dp; dp++) { - if (*dp != cp[2]) - continue; - if (prefix(cp + 2, dp)) - goto match; - } - } - else if (prefix(cp + 1, pp->p_command)) { - match: - if (np) - stderror(ERR_NAME | ERR_AMBIG); - np = pp; - } - } - if (np) - return (np); - stderror(ERR_NAME | (cp[1] == '?' ? ERR_JOBPAT : ERR_NOSUCHJOB)); - /* NOTREACHED */ - return (0); -} - - -/* - * pgetcurr - find most recent job that is not pp, preferably stopped - */ -static struct process * -pgetcurr(struct process *pp) -{ - struct process *np; - struct process *xp = NULL; - - for (np = proclist.p_next; np; np = np->p_next) - if (np != pcurrent && np != pp && np->p_procid && - np->p_procid == np->p_jobid) { - if (np->p_flags & PSTOPPED) - return (np); - if (xp == NULL) - xp = np; - } - return (xp); -} - -/* - * donotify - flag the job so as to report termination asynchronously - */ -/*ARGSUSED*/ -void -donotify(Char **v, struct command *c) -{ - struct process *pp; - - USE(c); - pp = pfind(*++v); - pp->p_flags |= PNOTIFY; -} - -#ifdef SIGSYNCH -static void -synch_handler(int sno) -{ - USE(sno); -} -#endif /* SIGSYNCH */ - -/* - * Do the fork and whatever should be done in the child side that - * should not be done if we are not forking at all (like for simple builtin's) - * Also do everything that needs any signals fiddled with in the parent side - * - * Wanttty tells whether process and/or tty pgrps are to be manipulated: - * -1: leave tty alone; inherit pgrp from parent - * 0: already have tty; manipulate process pgrps only - * 1: want to claim tty; manipulate process and tty pgrps - * It is usually just the value of tpgrp. - */ - -pid_t -pfork(struct command *t, int wanttty) -{ - pid_t pid; - int ignint = 0; - pid_t pgrp; -#ifdef SIGSYNCH - struct sigaction osa, nsa; -#endif /* SIGSYNCH */ - - /* - * A child will be uninterruptible only under very special conditions. - * Remember that the semantics of '&' is implemented by disconnecting the - * process from the tty so signals do not need to ignored just for '&'. - * Thus signals are set to default action for children unless: we have had - * an "onintr -" (then specifically ignored) we are not playing with - * signals (inherit action) - */ - if (setintr) - ignint = (tpgrp == -1 && (t->t_dflg & F_NOINTERRUPT)) - || (gointr && eq(gointr, STRminus)); - - /* - * Check for maximum nesting of 16 processes to avoid Forking loops - */ - if (child == 16) - stderror(ERR_NESTING, 16); -#ifdef SIGSYNCH - nsa.sa_handler = synch_handler; - sigfillset(&nsa.sa_mask); - nsa.sa_flags = SA_RESTART; - if (sigaction(SIGSYNCH, &nsa, &osa)) - stderror(ERR_SYSTEM, "pfork: sigaction set", strerror(errno)); -#endif /* SIGSYNCH */ - /* - * Hold pchild() until we have the process installed in our table. - */ - if (wanttty < 0) { - pchild_disabled++; - cleanup_push(&pchild_disabled, disabled_cleanup); - } - while ((pid = fork()) == -1) - if (setintr == 0) - (void) sleep(FORKSLEEP); - else - stderror(ERR_NOPROC); - if (pid == 0) { - (void)cleanup_push_mark(); /* Never to be popped */ - pchild_disabled = 0; - settimes(); - pgrp = pcurrjob ? pcurrjob->p_jobid : getpid(); - pflushall(); - pcurrjob = NULL; -#if !defined(BSDTIMES) && !defined(_SEQUENT_) - timesdone = 0; -#endif /* !defined(BSDTIMES) && !defined(_SEQUENT_) */ - child++; - if (setintr) { - setintr = 0; /* until I think otherwise */ - /* - * Children just get blown away on SIGINT, SIGQUIT unless "onintr - * -" seen. - */ - (void) signal(SIGINT, ignint ? SIG_IGN : SIG_DFL); - (void) signal(SIGQUIT, ignint ? SIG_IGN : SIG_DFL); -#ifdef BSDJOBS - if (wanttty >= 0) { - /* make stoppable */ - (void) signal(SIGTSTP, SIG_DFL); - (void) signal(SIGTTIN, SIG_DFL); - (void) signal(SIGTTOU, SIG_DFL); - } -#endif /* BSDJOBS */ - sigaction(SIGTERM, &parterm, NULL); - } - else if (tpgrp == -1 && (t->t_dflg & F_NOINTERRUPT)) { - (void) signal(SIGINT, SIG_IGN); - (void) signal(SIGQUIT, SIG_IGN); - } -#ifdef OREO - signal(SIGIO, SIG_IGN); /* ignore SIGIO in child too */ -#endif /* OREO */ - - pgetty(wanttty, pgrp); - /* - * Nohup and nice apply only to NODE_COMMAND's but it would be nice - * (?!?) if you could say "nohup (foo;bar)" Then the parser would have - * to know about nice/nohup/time - */ - if (t->t_dflg & F_NOHUP) - (void) signal(SIGHUP, SIG_IGN); - if (t->t_dflg & F_NICE) { - int nval = SIGN_EXTEND_CHAR(t->t_nice); -#ifdef HAVE_SETPRIORITY - if (setpriority(PRIO_PROCESS, 0, nval) == -1 && errno) - stderror(ERR_SYSTEM, "setpriority", strerror(errno)); -#else /* !HAVE_SETPRIORITY */ - (void) nice(nval); -#endif /* !HAVE_SETPRIORITY */ - } -#ifdef F_VER - if (t->t_dflg & F_VER) { - tsetenv(STRSYSTYPE, t->t_systype ? STRbsd43 : STRsys53); - dohash(NULL, NULL); - } -#endif /* F_VER */ -#ifdef SIGSYNCH - /* rfw 8/89 now parent can continue */ - if (kill(getppid(), SIGSYNCH)) - stderror(ERR_SYSTEM, "pfork child: kill", strerror(errno)); -#endif /* SIGSYNCH */ - - } - else { -#ifdef POSIXJOBS - if (wanttty >= 0) { - /* - * `Walking' process group fix from Beto Appleton. - * (beto@aixwiz.austin.ibm.com) - * If setpgid fails at this point that means that - * our process leader has died. We flush the current - * job and become the process leader ourselves. - * The parent will figure that out later. - */ - pgrp = pcurrjob ? pcurrjob->p_jobid : pid; - if (setpgid(pid, pgrp) == -1 && errno == EPERM) { - pcurrjob = NULL; - /* - * We don't care if this causes an error here; - * then we are already in the right process group - */ - (void) setpgid(pid, pgrp = pid); - } - } -#endif /* POSIXJOBS */ - palloc(pid, t); -#ifdef SIGSYNCH - { - sigset_t pause_mask; - - /* - * rfw 8/89 Wait for child to own terminal. Solves half of ugly - * synchronization problem. With this change, we know that the only - * reason setpgrp to a previous process in a pipeline can fail is that - * the previous process has already exited. Without this hack, he may - * either have exited or not yet started to run. Two uglies become - * one. - */ - sigprocmask(SIG_BLOCK, NULL, &pause); - sigdelset(&pause_mask, SIGCHLD); - sigdelset(&pause_mask, SIGSYNCH); - sigsuspend(&pause_mask); - handle_pending_signals(); - if (sigaction(SIGSYNCH, &osa, NULL)) - stderror(ERR_SYSTEM, "pfork parent: sigaction restore", - strerror(errno)); - } -#endif /* SIGSYNCH */ - - if (wanttty < 0) - cleanup_until(&pchild_disabled); - } - return (pid); -} - -static void -okpcntl(void) -{ - if (tpgrp == -1) - stderror(ERR_JOBCONTROL); - if (tpgrp == 0) - stderror(ERR_JOBCTRLSUB); -} - - -static void -setttypgrp(int pgrp) -{ - /* - * If we are piping out a builtin, eg. 'echo | more' things can go - * out of sequence, i.e. the more can run before the echo. This - * can happen even if we have vfork, since the echo will be forked - * with the regular fork. In this case, we need to set the tty - * pgrp ourselves. If that happens, then the process will be still - * alive. And the tty process group will already be set. - * This should fix the famous sequent problem as a side effect: - * The controlling terminal is lost if all processes in the - * terminal process group are zombies. In this case tcgetpgrp() - * returns 0. If this happens we must set the terminal process - * group again. - */ - if (tcgetpgrp(FSHTTY) != pgrp) { -#ifdef POSIXJOBS - struct sigaction old; - - /* - * tcsetpgrp will set SIGTTOU to all the the processes in - * the background according to POSIX... We ignore this here. - */ - sigaction(SIGTTOU, NULL, &old); - signal(SIGTTOU, SIG_IGN); -#endif - (void) tcsetpgrp(FSHTTY, pgrp); -# ifdef POSIXJOBS - sigaction(SIGTTOU, &old, NULL); -# endif - - } -} - - -/* - * if we don't have vfork(), things can still go in the wrong order - * resulting in the famous 'Stopped (tty output)'. But some systems - * don't permit the setpgid() call, (these are more recent secure - * systems such as ibm's aix), when they do. Then we'd rather print - * an error message than hang the shell! - * I am open to suggestions how to fix that. - */ -void -pgetty(int wanttty, pid_t pgrp) -{ -#ifdef BSDJOBS -# ifdef POSIXJOBS - sigset_t oset, set; -# endif /* POSIXJOBS */ - - jobdebug_xprintf(("wanttty %d pid %d opgrp%d pgrp %d tpgrp %d\n", - wanttty, (int)getpid(), (int)pgrp, (int)mygetpgrp(), - (int)tcgetpgrp(FSHTTY))); -# ifdef POSIXJOBS - /* - * christos: I am blocking the tty signals till I've set things - * correctly.... - */ - if (wanttty > 0) { - sigemptyset(&set); - sigaddset(&set, SIGTSTP); - sigaddset(&set, SIGTTIN); - (void)sigprocmask(SIG_BLOCK, &set, &oset); - cleanup_push(&oset, sigprocmask_cleanup); - } -# endif /* POSIXJOBS */ - -# ifndef POSIXJOBS - if (wanttty > 0) - setttypgrp(pgrp); -# endif /* !POSIXJOBS */ - - /* - * From: Michael Schroeder <mlschroe@immd4.informatik.uni-erlangen.de> - * Don't check for tpgrp >= 0 so even non-interactive shells give - * background jobs process groups Same for the comparison in the other part - * of the #ifdef - */ - if (wanttty >= 0) { - if (setpgid(0, pgrp) == -1) { -# ifdef POSIXJOBS - /* Walking process group fix; see above */ - if (setpgid(0, pgrp = getpid()) == -1) { -# endif /* POSIXJOBS */ - stderror(ERR_SYSTEM, "setpgid child:\n", strerror(errno)); - xexit(0); -# ifdef POSIXJOBS - } - wanttty = pgrp; /* Now we really want the tty, since we became the - * the process group leader - */ -# endif /* POSIXJOBS */ - } - } - -# ifdef POSIXJOBS - if (wanttty > 0) { - setttypgrp(pgrp); - cleanup_until(&oset); - } -# endif /* POSIXJOBS */ - - jobdebug_xprintf(("wanttty %d pid %d pgrp %d tpgrp %d\n", - wanttty, getpid(), mygetpgrp(), tcgetpgrp(FSHTTY))); - - if (tpgrp > 0) - tpgrp = 0; /* gave tty away */ -#endif /* BSDJOBS */ -} |
