|
Packit Service |
95ac19 |
/* $OpenBSD: jobs.c,v 1.43 2015/09/10 22:48:58 nicm Exp $ */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*-
|
|
Packit Service |
95ac19 |
* Copyright (c) 2003, 2004, 2005, 2006, 2007, 2008, 2009, 2011,
|
|
Packit Service |
95ac19 |
* 2012, 2013, 2014, 2015, 2016, 2018
|
|
Packit Service |
95ac19 |
* mirabilos <m@mirbsd.org>
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* Provided that these terms and disclaimer and all copyright notices
|
|
Packit Service |
95ac19 |
* are retained or reproduced in an accompanying document, permission
|
|
Packit Service |
95ac19 |
* is granted to deal in this work without restriction, including un-
|
|
Packit Service |
95ac19 |
* limited rights to use, publicly perform, distribute, sell, modify,
|
|
Packit Service |
95ac19 |
* merge, give away, or sublicence.
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* This work is provided "AS IS" and WITHOUT WARRANTY of any kind, to
|
|
Packit Service |
95ac19 |
* the utmost extent permitted by applicable law, neither express nor
|
|
Packit Service |
95ac19 |
* implied; without malicious intent or gross negligence. In no event
|
|
Packit Service |
95ac19 |
* may a licensor, author or contributor be held liable for indirect,
|
|
Packit Service |
95ac19 |
* direct, other damage, loss, or other issues arising in any way out
|
|
Packit Service |
95ac19 |
* of dealing in the work, even if advised of the possibility of such
|
|
Packit Service |
95ac19 |
* damage or existence of a defect, except proven that it results out
|
|
Packit Service |
95ac19 |
* of said person's immediate fault when using the work as intended.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#include "sh.h"
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
__RCSID("$MirOS: src/bin/mksh/jobs.c,v 1.125 2018/01/05 20:08:34 tg Exp $");
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#if HAVE_KILLPG
|
|
Packit Service |
95ac19 |
#define mksh_killpg killpg
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
/* cross fingers and hope kill is killpg-endowed */
|
|
Packit Service |
95ac19 |
#define mksh_killpg(p,s) kill(-(p), (s))
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Order important! */
|
|
Packit Service |
95ac19 |
#define PRUNNING 0
|
|
Packit Service |
95ac19 |
#define PEXITED 1
|
|
Packit Service |
95ac19 |
#define PSIGNALLED 2
|
|
Packit Service |
95ac19 |
#define PSTOPPED 3
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
typedef struct proc Proc;
|
|
Packit Service |
95ac19 |
/* to take alignment into consideration */
|
|
Packit Service |
95ac19 |
struct proc_dummy {
|
|
Packit Service |
95ac19 |
Proc *next;
|
|
Packit Service |
95ac19 |
pid_t pid;
|
|
Packit Service |
95ac19 |
int state;
|
|
Packit Service |
95ac19 |
int status;
|
|
Packit Service |
95ac19 |
char command[128];
|
|
Packit Service |
95ac19 |
};
|
|
Packit Service |
95ac19 |
/* real structure */
|
|
Packit Service |
95ac19 |
struct proc {
|
|
Packit Service |
95ac19 |
/* next process in pipeline (if any) */
|
|
Packit Service |
95ac19 |
Proc *next;
|
|
Packit Service |
95ac19 |
/* process id of this Unix process in the job */
|
|
Packit Service |
95ac19 |
pid_t pid;
|
|
Packit Service |
95ac19 |
/* one of the four P… above */
|
|
Packit Service |
95ac19 |
int state;
|
|
Packit Service |
95ac19 |
/* wait status */
|
|
Packit Service |
95ac19 |
int status;
|
|
Packit Service |
95ac19 |
/* process command string from vistree */
|
|
Packit Service |
95ac19 |
char command[256 - (ALLOC_OVERHEAD +
|
|
Packit Service |
95ac19 |
offsetof(struct proc_dummy, command[0]))];
|
|
Packit Service |
95ac19 |
};
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Notify/print flag - j_print() argument */
|
|
Packit Service |
95ac19 |
#define JP_SHORT 1 /* print signals processes were killed by */
|
|
Packit Service |
95ac19 |
#define JP_MEDIUM 2 /* print [job-num] -/+ command */
|
|
Packit Service |
95ac19 |
#define JP_LONG 3 /* print [job-num] -/+ pid command */
|
|
Packit Service |
95ac19 |
#define JP_PGRP 4 /* print pgrp */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* put_job() flags */
|
|
Packit Service |
95ac19 |
#define PJ_ON_FRONT 0 /* at very front */
|
|
Packit Service |
95ac19 |
#define PJ_PAST_STOPPED 1 /* just past any stopped jobs */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Job.flags values */
|
|
Packit Service |
95ac19 |
#define JF_STARTED 0x001 /* set when all processes in job are started */
|
|
Packit Service |
95ac19 |
#define JF_WAITING 0x002 /* set if j_waitj() is waiting on job */
|
|
Packit Service |
95ac19 |
#define JF_W_ASYNCNOTIFY 0x004 /* set if waiting and async notification ok */
|
|
Packit Service |
95ac19 |
#define JF_XXCOM 0x008 /* set for $(command) jobs */
|
|
Packit Service |
95ac19 |
#define JF_FG 0x010 /* running in foreground (also has tty pgrp) */
|
|
Packit Service |
95ac19 |
#define JF_SAVEDTTY 0x020 /* j->ttystat is valid */
|
|
Packit Service |
95ac19 |
#define JF_CHANGED 0x040 /* process has changed state */
|
|
Packit Service |
95ac19 |
#define JF_KNOWN 0x080 /* $! referenced */
|
|
Packit Service |
95ac19 |
#define JF_ZOMBIE 0x100 /* known, unwaited process */
|
|
Packit Service |
95ac19 |
#define JF_REMOVE 0x200 /* flagged for removal (j_jobs()/j_noityf()) */
|
|
Packit Service |
95ac19 |
#define JF_USETTYMODE 0x400 /* tty mode saved if process exits normally */
|
|
Packit Service |
95ac19 |
#define JF_SAVEDTTYPGRP 0x800 /* j->saved_ttypgrp is valid */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
typedef struct job Job;
|
|
Packit Service |
95ac19 |
struct job {
|
|
Packit Service |
95ac19 |
Job *next; /* next job in list */
|
|
Packit Service |
95ac19 |
Proc *proc_list; /* process list */
|
|
Packit Service |
95ac19 |
Proc *last_proc; /* last process in list */
|
|
Packit Service |
95ac19 |
struct timeval systime; /* system time used by job */
|
|
Packit Service |
95ac19 |
struct timeval usrtime; /* user time used by job */
|
|
Packit Service |
95ac19 |
pid_t pgrp; /* process group of job */
|
|
Packit Service |
95ac19 |
pid_t ppid; /* pid of process that forked job */
|
|
Packit Service |
95ac19 |
int job; /* job number: %n */
|
|
Packit Service |
95ac19 |
int flags; /* see JF_* */
|
|
Packit Service |
95ac19 |
volatile int state; /* job state */
|
|
Packit Service |
95ac19 |
int status; /* exit status of last process */
|
|
Packit Service |
95ac19 |
int age; /* number of jobs started */
|
|
Packit Service |
95ac19 |
Coproc_id coproc_id; /* 0 or id of coprocess output pipe */
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
mksh_ttyst ttystat; /* saved tty state for stopped jobs */
|
|
Packit Service |
95ac19 |
pid_t saved_ttypgrp; /* saved tty process group for stopped jobs */
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
};
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Flags for j_waitj() */
|
|
Packit Service |
95ac19 |
#define JW_NONE 0x00
|
|
Packit Service |
95ac19 |
#define JW_INTERRUPT 0x01 /* ^C will stop the wait */
|
|
Packit Service |
95ac19 |
#define JW_ASYNCNOTIFY 0x02 /* asynchronous notification during wait ok */
|
|
Packit Service |
95ac19 |
#define JW_STOPPEDWAIT 0x04 /* wait even if job stopped */
|
|
Packit Service |
95ac19 |
#define JW_PIPEST 0x08 /* want PIPESTATUS */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Error codes for j_lookup() */
|
|
Packit Service |
95ac19 |
#define JL_NOSUCH 0 /* no such job */
|
|
Packit Service |
95ac19 |
#define JL_AMBIG 1 /* %foo or %?foo is ambiguous */
|
|
Packit Service |
95ac19 |
#define JL_INVALID 2 /* non-pid, non-% job id */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static const char * const lookup_msgs[] = {
|
|
Packit Service |
95ac19 |
"no such job",
|
|
Packit Service |
95ac19 |
"ambiguous",
|
|
Packit Service |
95ac19 |
"argument must be %job or process id"
|
|
Packit Service |
95ac19 |
};
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static Job *job_list; /* job list */
|
|
Packit Service |
95ac19 |
static Job *last_job;
|
|
Packit Service |
95ac19 |
static Job *async_job;
|
|
Packit Service |
95ac19 |
static pid_t async_pid;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static int nzombie; /* # of zombies owned by this process */
|
|
Packit Service |
95ac19 |
static int njobs; /* # of jobs started */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef CHILD_MAX
|
|
Packit Service |
95ac19 |
#define CHILD_MAX 25
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
/* held_sigchld is set if sigchld occurs before a job is completely started */
|
|
Packit Service |
95ac19 |
static volatile sig_atomic_t held_sigchld;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
static struct shf *shl_j;
|
|
Packit Service |
95ac19 |
static bool ttypgrp_ok; /* set if can use tty pgrps */
|
|
Packit Service |
95ac19 |
static pid_t restore_ttypgrp = -1;
|
|
Packit Service |
95ac19 |
static int const tt_sigs[] = { SIGTSTP, SIGTTIN, SIGTTOU };
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static void j_set_async(Job *);
|
|
Packit Service |
95ac19 |
static void j_startjob(Job *);
|
|
Packit Service |
95ac19 |
static int j_waitj(Job *, int, const char *);
|
|
Packit Service |
95ac19 |
static void j_sigchld(int);
|
|
Packit Service |
95ac19 |
static void j_print(Job *, int, struct shf *);
|
|
Packit Service |
95ac19 |
static Job *j_lookup(const char *, int *);
|
|
Packit Service |
95ac19 |
static Job *new_job(void);
|
|
Packit Service |
95ac19 |
static Proc *new_proc(void);
|
|
Packit Service |
95ac19 |
static void check_job(Job *);
|
|
Packit Service |
95ac19 |
static void put_job(Job *, int);
|
|
Packit Service |
95ac19 |
static void remove_job(Job *, const char *);
|
|
Packit Service |
95ac19 |
static int kill_job(Job *, int);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static void tty_init_talking(void);
|
|
Packit Service |
95ac19 |
static void tty_init_state(void);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* initialise job control */
|
|
Packit Service |
95ac19 |
void
|
|
Packit Service |
95ac19 |
j_init(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
bool mflagset = Flag(FMONITOR) != 127;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
Flag(FMONITOR) = 0;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
(void)sigemptyset(&sm_default);
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &sm_default, NULL);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
(void)sigemptyset(&sm_sigchld);
|
|
Packit Service |
95ac19 |
(void)sigaddset(&sm_sigchld, SIGCHLD);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[SIGCHLD], j_sigchld,
|
|
Packit Service |
95ac19 |
SS_RESTORE_ORIG|SS_FORCE|SS_SHTRAP);
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
/* Make sure SIGCHLD isn't ignored - can do odd things under SYSV */
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[SIGCHLD], SIG_DFL, SS_RESTORE_ORIG|SS_FORCE);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (!mflagset && Flag(FTALKING))
|
|
Packit Service |
95ac19 |
Flag(FMONITOR) = 1;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* shl_j is used to do asynchronous notification (used in
|
|
Packit Service |
95ac19 |
* an interrupt handler, so need a distinct shf)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
shl_j = shf_fdopen(2, SHF_WR, NULL);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR) || Flag(FTALKING)) {
|
|
Packit Service |
95ac19 |
int i;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* the TF_SHELL_USES test is a kludge that lets us know if
|
|
Packit Service |
95ac19 |
* if the signals have been changed by the shell.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
for (i = NELEM(tt_sigs); --i >= 0; ) {
|
|
Packit Service |
95ac19 |
sigtraps[tt_sigs[i]].flags |= TF_SHELL_USES;
|
|
Packit Service |
95ac19 |
/* j_change() sets this to SS_RESTORE_DFL if FMONITOR */
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[tt_sigs[i]], SIG_IGN,
|
|
Packit Service |
95ac19 |
SS_RESTORE_IGN|SS_FORCE);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* j_change() calls tty_init_talking() and tty_init_state() */
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR))
|
|
Packit Service |
95ac19 |
j_change();
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (Flag(FTALKING)) {
|
|
Packit Service |
95ac19 |
tty_init_talking();
|
|
Packit Service |
95ac19 |
tty_init_state();
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static int
|
|
Packit Service |
95ac19 |
proc_errorlevel(Proc *p)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
switch (p->state) {
|
|
Packit Service |
95ac19 |
case PEXITED:
|
|
Packit Service |
95ac19 |
return ((WEXITSTATUS(p->status)) & 255);
|
|
Packit Service |
95ac19 |
case PSIGNALLED:
|
|
Packit Service |
95ac19 |
return (ksh_sigmask(WTERMSIG(p->status)));
|
|
Packit Service |
95ac19 |
default:
|
|
Packit Service |
95ac19 |
return (0);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#if !defined(MKSH_UNEMPLOYED) && HAVE_GETSID
|
|
Packit Service |
95ac19 |
/* suspend the shell */
|
|
Packit Service |
95ac19 |
void
|
|
Packit Service |
95ac19 |
j_suspend(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
struct sigaction sa, osa;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Restore tty and pgrp. */
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok) {
|
|
Packit Service |
95ac19 |
if (tty_hasstate)
|
|
Packit Service |
95ac19 |
mksh_tcset(tty_fd, &tty_state);
|
|
Packit Service |
95ac19 |
if (restore_ttypgrp >= 0) {
|
|
Packit Service |
95ac19 |
if (tcsetpgrp(tty_fd, restore_ttypgrp) < 0) {
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds,
|
|
Packit Service |
95ac19 |
Tj_suspend, "tcsetpgrp", cstrerror(errno));
|
|
Packit Service |
95ac19 |
} else if (setpgid(0, restore_ttypgrp) < 0) {
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds,
|
|
Packit Service |
95ac19 |
Tj_suspend, "setpgid", cstrerror(errno));
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Suspend the shell. */
|
|
Packit Service |
95ac19 |
memset(&sa, 0, sizeof(sa));
|
|
Packit Service |
95ac19 |
sigemptyset(&sa.sa_mask);
|
|
Packit Service |
95ac19 |
sa.sa_handler = SIG_DFL;
|
|
Packit Service |
95ac19 |
sigaction(SIGTSTP, &sa, &osa;;
|
|
Packit Service |
95ac19 |
kill(0, SIGTSTP);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Back from suspend, reset signals, pgrp and tty. */
|
|
Packit Service |
95ac19 |
sigaction(SIGTSTP, &osa, NULL);
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok) {
|
|
Packit Service |
95ac19 |
if (restore_ttypgrp >= 0) {
|
|
Packit Service |
95ac19 |
if (setpgid(0, kshpid) < 0) {
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds,
|
|
Packit Service |
95ac19 |
Tj_suspend, "setpgid", cstrerror(errno));
|
|
Packit Service |
95ac19 |
ttypgrp_ok = false;
|
|
Packit Service |
95ac19 |
} else if (tcsetpgrp(tty_fd, kshpid) < 0) {
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds,
|
|
Packit Service |
95ac19 |
Tj_suspend, "tcsetpgrp", cstrerror(errno));
|
|
Packit Service |
95ac19 |
ttypgrp_ok = false;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
tty_init_state();
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* job cleanup before shell exit */
|
|
Packit Service |
95ac19 |
void
|
|
Packit Service |
95ac19 |
j_exit(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
/* kill stopped, and possibly running, jobs */
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
bool killed = false;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next) {
|
|
Packit Service |
95ac19 |
if (j->ppid == procpid &&
|
|
Packit Service |
95ac19 |
(j->state == PSTOPPED ||
|
|
Packit Service |
95ac19 |
(j->state == PRUNNING &&
|
|
Packit Service |
95ac19 |
((j->flags & JF_FG) ||
|
|
Packit Service |
95ac19 |
(Flag(FLOGIN) && !Flag(FNOHUP) && procpid == kshpid))))) {
|
|
Packit Service |
95ac19 |
killed = true;
|
|
Packit Service |
95ac19 |
if (j->pgrp == 0)
|
|
Packit Service |
95ac19 |
kill_job(j, SIGHUP);
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
mksh_killpg(j->pgrp, SIGHUP);
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (j->state == PSTOPPED) {
|
|
Packit Service |
95ac19 |
if (j->pgrp == 0)
|
|
Packit Service |
95ac19 |
kill_job(j, SIGCONT);
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
mksh_killpg(j->pgrp, SIGCONT);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (killed)
|
|
Packit Service |
95ac19 |
sleep(1);
|
|
Packit Service |
95ac19 |
j_notify();
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (kshpid == procpid && restore_ttypgrp >= 0) {
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Need to restore the tty pgrp to what it was when the
|
|
Packit Service |
95ac19 |
* shell started up, so that the process that started us
|
|
Packit Service |
95ac19 |
* will be able to access the tty when we are done.
|
|
Packit Service |
95ac19 |
* Also need to restore our process group in case we are
|
|
Packit Service |
95ac19 |
* about to do an exec so that both our parent and the
|
|
Packit Service |
95ac19 |
* process we are to become will be able to access the tty.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
tcsetpgrp(tty_fd, restore_ttypgrp);
|
|
Packit Service |
95ac19 |
setpgid(0, restore_ttypgrp);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR)) {
|
|
Packit Service |
95ac19 |
Flag(FMONITOR) = 0;
|
|
Packit Service |
95ac19 |
j_change();
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
/* turn job control on or off according to Flag(FMONITOR) */
|
|
Packit Service |
95ac19 |
void
|
|
Packit Service |
95ac19 |
j_change(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
int i;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR)) {
|
|
Packit Service |
95ac19 |
bool use_tty = Flag(FTALKING);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* don't call mksh_tcget until we own the tty process group */
|
|
Packit Service |
95ac19 |
if (use_tty)
|
|
Packit Service |
95ac19 |
tty_init_talking();
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* no controlling tty, no SIGT* */
|
|
Packit Service |
95ac19 |
if ((ttypgrp_ok = (use_tty && tty_fd >= 0 && tty_devtty))) {
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[SIGTTIN], SIG_DFL,
|
|
Packit Service |
95ac19 |
SS_RESTORE_ORIG|SS_FORCE);
|
|
Packit Service |
95ac19 |
/* wait to be given tty (POSIX.1, B.2, job control) */
|
|
Packit Service |
95ac19 |
while (/* CONSTCOND */ 1) {
|
|
Packit Service |
95ac19 |
pid_t ttypgrp;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if ((ttypgrp = tcgetpgrp(tty_fd)) < 0) {
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds,
|
|
Packit Service |
95ac19 |
"j_init", "tcgetpgrp",
|
|
Packit Service |
95ac19 |
cstrerror(errno));
|
|
Packit Service |
95ac19 |
ttypgrp_ok = false;
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (ttypgrp == kshpgrp)
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
kill(0, SIGTTIN);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
for (i = NELEM(tt_sigs); --i >= 0; )
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[tt_sigs[i]], SIG_IGN,
|
|
Packit Service |
95ac19 |
SS_RESTORE_DFL|SS_FORCE);
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok && kshpgrp != kshpid) {
|
|
Packit Service |
95ac19 |
if (setpgid(0, kshpid) < 0) {
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds,
|
|
Packit Service |
95ac19 |
"j_init", "setpgid", cstrerror(errno));
|
|
Packit Service |
95ac19 |
ttypgrp_ok = false;
|
|
Packit Service |
95ac19 |
} else {
|
|
Packit Service |
95ac19 |
if (tcsetpgrp(tty_fd, kshpid) < 0) {
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds,
|
|
Packit Service |
95ac19 |
"j_init", "tcsetpgrp",
|
|
Packit Service |
95ac19 |
cstrerror(errno));
|
|
Packit Service |
95ac19 |
ttypgrp_ok = false;
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
restore_ttypgrp = kshpgrp;
|
|
Packit Service |
95ac19 |
kshpgrp = kshpid;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#ifndef MKSH_DISABLE_TTY_WARNING
|
|
Packit Service |
95ac19 |
if (use_tty && !ttypgrp_ok)
|
|
Packit Service |
95ac19 |
warningf(false, Tf_sD_s, "warning",
|
|
Packit Service |
95ac19 |
"won't have full job control");
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
} else {
|
|
Packit Service |
95ac19 |
ttypgrp_ok = false;
|
|
Packit Service |
95ac19 |
if (Flag(FTALKING))
|
|
Packit Service |
95ac19 |
for (i = NELEM(tt_sigs); --i >= 0; )
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[tt_sigs[i]], SIG_IGN,
|
|
Packit Service |
95ac19 |
SS_RESTORE_IGN|SS_FORCE);
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
for (i = NELEM(tt_sigs); --i >= 0; ) {
|
|
Packit Service |
95ac19 |
if (sigtraps[tt_sigs[i]].flags &
|
|
Packit Service |
95ac19 |
(TF_ORIG_IGN | TF_ORIG_DFL))
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[tt_sigs[i]],
|
|
Packit Service |
95ac19 |
(sigtraps[tt_sigs[i]].flags & TF_ORIG_IGN) ?
|
|
Packit Service |
95ac19 |
SIG_IGN : SIG_DFL,
|
|
Packit Service |
95ac19 |
SS_RESTORE_ORIG|SS_FORCE);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
tty_init_state();
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#if HAVE_NICE
|
|
Packit Service |
95ac19 |
/* run nice(3) and ignore the result */
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
ksh_nice(int ness)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
#if defined(__USE_FORTIFY_LEVEL) && (__USE_FORTIFY_LEVEL > 0)
|
|
Packit Service |
95ac19 |
int eno;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
errno = 0;
|
|
Packit Service |
95ac19 |
/* this is gonna annoy users; complain to your distro, people! */
|
|
Packit Service |
95ac19 |
if (nice(ness) == -1 && (eno = errno) != 0)
|
|
Packit Service |
95ac19 |
warningf(false, Tf_sD_s, "bgnice", cstrerror(eno));
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
(void)nice(ness);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* execute tree in child subprocess */
|
|
Packit Service |
95ac19 |
int
|
|
Packit Service |
95ac19 |
exchild(struct op *t, int flags,
|
|
Packit Service |
95ac19 |
volatile int *xerrok,
|
|
Packit Service |
95ac19 |
/* used if XPCLOSE or XCCLOSE */
|
|
Packit Service |
95ac19 |
int close_fd)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
/* for pipelines */
|
|
Packit Service |
95ac19 |
static Proc *last_proc;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
int rv = 0, forksleep, jwflags = JW_NONE;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
pid_t cldpid;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (flags & XPIPEST) {
|
|
Packit Service |
95ac19 |
flags &= ~XPIPEST;
|
|
Packit Service |
95ac19 |
jwflags |= JW_PIPEST;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (flags & XEXEC)
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Clear XFORK|XPCLOSE|XCCLOSE|XCOPROC|XPIPEO|XPIPEI|XXCOM|XBGND
|
|
Packit Service |
95ac19 |
* (also done in another execute() below)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
return (execute(t, flags & (XEXEC | XERROK), xerrok));
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
/* no SIGCHLDs while messing with job and process lists */
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
p = new_proc();
|
|
Packit Service |
95ac19 |
p->next = NULL;
|
|
Packit Service |
95ac19 |
p->state = PRUNNING;
|
|
Packit Service |
95ac19 |
p->status = 0;
|
|
Packit Service |
95ac19 |
p->pid = 0;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* link process into jobs list */
|
|
Packit Service |
95ac19 |
if (flags & XPIPEI) {
|
|
Packit Service |
95ac19 |
/* continuing with a pipe */
|
|
Packit Service |
95ac19 |
if (!last_job)
|
|
Packit Service |
95ac19 |
internal_errorf("exchild: XPIPEI and no last_job - pid %d",
|
|
Packit Service |
95ac19 |
(int)procpid);
|
|
Packit Service |
95ac19 |
j = last_job;
|
|
Packit Service |
95ac19 |
if (last_proc)
|
|
Packit Service |
95ac19 |
last_proc->next = p;
|
|
Packit Service |
95ac19 |
last_proc = p;
|
|
Packit Service |
95ac19 |
} else {
|
|
Packit Service |
95ac19 |
/* fills in j->job */
|
|
Packit Service |
95ac19 |
j = new_job();
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* we don't consider XXCOMs foreground since they don't get
|
|
Packit Service |
95ac19 |
* tty process group and we don't save or restore tty modes.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
j->flags = (flags & XXCOM) ? JF_XXCOM :
|
|
Packit Service |
95ac19 |
((flags & XBGND) ? 0 : (JF_FG|JF_USETTYMODE));
|
|
Packit Service |
95ac19 |
timerclear(&j->usrtime);
|
|
Packit Service |
95ac19 |
timerclear(&j->systime);
|
|
Packit Service |
95ac19 |
j->state = PRUNNING;
|
|
Packit Service |
95ac19 |
j->pgrp = 0;
|
|
Packit Service |
95ac19 |
j->ppid = procpid;
|
|
Packit Service |
95ac19 |
j->age = ++njobs;
|
|
Packit Service |
95ac19 |
j->proc_list = p;
|
|
Packit Service |
95ac19 |
j->coproc_id = 0;
|
|
Packit Service |
95ac19 |
last_job = j;
|
|
Packit Service |
95ac19 |
last_proc = p;
|
|
Packit Service |
95ac19 |
put_job(j, PJ_PAST_STOPPED);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
vistree(p->command, sizeof(p->command), t);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* create child process */
|
|
Packit Service |
95ac19 |
forksleep = 1;
|
|
Packit Service |
95ac19 |
while ((cldpid = fork()) < 0 && errno == EAGAIN && forksleep < 32) {
|
|
Packit Service |
95ac19 |
if (intrsig)
|
|
Packit Service |
95ac19 |
/* allow user to ^C out... */
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
sleep(forksleep);
|
|
Packit Service |
95ac19 |
forksleep <<= 1;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
/* ensure $RANDOM changes between parent and child */
|
|
Packit Service |
95ac19 |
rndset((unsigned long)cldpid);
|
|
Packit Service |
95ac19 |
/* fork failed? */
|
|
Packit Service |
95ac19 |
if (cldpid < 0) {
|
|
Packit Service |
95ac19 |
kill_job(j, SIGKILL);
|
|
Packit Service |
95ac19 |
remove_job(j, "fork failed");
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
errorf("can't fork - try again");
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
p->pid = cldpid ? cldpid : (procpid = getpid());
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
/* job control set up */
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR) && !(flags&XXCOM)) {
|
|
Packit Service |
95ac19 |
bool dotty = false;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (j->pgrp == 0) {
|
|
Packit Service |
95ac19 |
/* First process */
|
|
Packit Service |
95ac19 |
j->pgrp = p->pid;
|
|
Packit Service |
95ac19 |
dotty = true;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* set pgrp in both parent and child to deal with race
|
|
Packit Service |
95ac19 |
* condition
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
setpgid(p->pid, j->pgrp);
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok && dotty && !(flags & XBGND))
|
|
Packit Service |
95ac19 |
tcsetpgrp(tty_fd, j->pgrp);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* used to close pipe input fd */
|
|
Packit Service |
95ac19 |
if (close_fd >= 0 && (((flags & XPCLOSE) && cldpid) ||
|
|
Packit Service |
95ac19 |
((flags & XCCLOSE) && !cldpid)))
|
|
Packit Service |
95ac19 |
close(close_fd);
|
|
Packit Service |
95ac19 |
if (!cldpid) {
|
|
Packit Service |
95ac19 |
/* child */
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Do this before restoring signal */
|
|
Packit Service |
95ac19 |
if (flags & XCOPROC)
|
|
Packit Service |
95ac19 |
coproc_cleanup(false);
|
|
Packit Service |
95ac19 |
cleanup_parents_env();
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* If FMONITOR or FTALKING is set, these signals are ignored,
|
|
Packit Service |
95ac19 |
* if neither FMONITOR nor FTALKING are set, the signals have
|
|
Packit Service |
95ac19 |
* their inherited values.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR) && !(flags & XXCOM)) {
|
|
Packit Service |
95ac19 |
for (forksleep = NELEM(tt_sigs); --forksleep >= 0; )
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[tt_sigs[forksleep]], SIG_DFL,
|
|
Packit Service |
95ac19 |
SS_RESTORE_DFL|SS_FORCE);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
#if HAVE_NICE
|
|
Packit Service |
95ac19 |
if (Flag(FBGNICE) && (flags & XBGND))
|
|
Packit Service |
95ac19 |
ksh_nice(4);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if ((flags & XBGND)
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
&& !Flag(FMONITOR)
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
) {
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[SIGINT], SIG_IGN,
|
|
Packit Service |
95ac19 |
SS_RESTORE_IGN|SS_FORCE);
|
|
Packit Service |
95ac19 |
setsig(&sigtraps[SIGQUIT], SIG_IGN,
|
|
Packit Service |
95ac19 |
SS_RESTORE_IGN|SS_FORCE);
|
|
Packit Service |
95ac19 |
if ((!(flags & (XPIPEI | XCOPROC))) &&
|
|
Packit Service |
95ac19 |
((forksleep = open("/dev/null", 0)) > 0)) {
|
|
Packit Service |
95ac19 |
(void)ksh_dup2(forksleep, 0, true);
|
|
Packit Service |
95ac19 |
close(forksleep);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
/* in case of $(jobs) command */
|
|
Packit Service |
95ac19 |
remove_job(j, "child");
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
/* remove_job needs SIGCHLD blocked still */
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
nzombie = 0;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
ttypgrp_ok = false;
|
|
Packit Service |
95ac19 |
Flag(FMONITOR) = 0;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
Flag(FTALKING) = 0;
|
|
Packit Service |
95ac19 |
cleartraps();
|
|
Packit Service |
95ac19 |
/* no return */
|
|
Packit Service |
95ac19 |
execute(t, (flags & XERROK) | XEXEC, NULL);
|
|
Packit Service |
95ac19 |
#ifndef MKSH_SMALL
|
|
Packit Service |
95ac19 |
if (t->type == TPIPE)
|
|
Packit Service |
95ac19 |
unwind(LLEAVE);
|
|
Packit Service |
95ac19 |
internal_warningf("%s: execute() returned", "exchild");
|
|
Packit Service |
95ac19 |
fptreef(shl_out, 8, "%s: tried to execute {\n\t%T\n}\n",
|
|
Packit Service |
95ac19 |
"exchild", t);
|
|
Packit Service |
95ac19 |
shf_flush(shl_out);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
unwind(LLEAVE);
|
|
Packit Service |
95ac19 |
/* NOTREACHED */
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* shell (parent) stuff */
|
|
Packit Service |
95ac19 |
if (!(flags & XPIPEO)) {
|
|
Packit Service |
95ac19 |
/* last process in a job */
|
|
Packit Service |
95ac19 |
j_startjob(j);
|
|
Packit Service |
95ac19 |
if (flags & XCOPROC) {
|
|
Packit Service |
95ac19 |
j->coproc_id = coproc.id;
|
|
Packit Service |
95ac19 |
/* n jobs using co-process output */
|
|
Packit Service |
95ac19 |
coproc.njobs++;
|
|
Packit Service |
95ac19 |
/* j using co-process input */
|
|
Packit Service |
95ac19 |
coproc.job = (void *)j;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (flags & XBGND) {
|
|
Packit Service |
95ac19 |
j_set_async(j);
|
|
Packit Service |
95ac19 |
if (Flag(FTALKING)) {
|
|
Packit Service |
95ac19 |
shf_fprintf(shl_out, "[%d]", j->job);
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p; p = p->next)
|
|
Packit Service |
95ac19 |
shf_fprintf(shl_out, Tf__d,
|
|
Packit Service |
95ac19 |
(int)p->pid);
|
|
Packit Service |
95ac19 |
shf_putchar('\n', shl_out);
|
|
Packit Service |
95ac19 |
shf_flush(shl_out);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
rv = j_waitj(j, jwflags, "jw:last proc");
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (rv);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* start the last job: only used for $(command) jobs */
|
|
Packit Service |
95ac19 |
void
|
|
Packit Service |
95ac19 |
startlast(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* no need to report error - waitlast() will do it */
|
|
Packit Service |
95ac19 |
if (last_job) {
|
|
Packit Service |
95ac19 |
/* ensure it isn't removed by check_job() */
|
|
Packit Service |
95ac19 |
last_job->flags |= JF_WAITING;
|
|
Packit Service |
95ac19 |
j_startjob(last_job);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* wait for last job: only used for $(command) jobs */
|
|
Packit Service |
95ac19 |
int
|
|
Packit Service |
95ac19 |
waitlast(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
int rv;
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
j = last_job;
|
|
Packit Service |
95ac19 |
if (!j || !(j->flags & JF_STARTED)) {
|
|
Packit Service |
95ac19 |
if (!j)
|
|
Packit Service |
95ac19 |
warningf(true, Tf_sD_s, "waitlast", "no last job");
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
internal_warningf(Tf_sD_s, "waitlast", Tnot_started);
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
/* not so arbitrary, non-zero value */
|
|
Packit Service |
95ac19 |
return (125);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
rv = j_waitj(j, JW_NONE, "waitlast");
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (rv);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* wait for child, interruptable. */
|
|
Packit Service |
95ac19 |
int
|
|
Packit Service |
95ac19 |
waitfor(const char *cp, int *sigp)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
int rv, ecode, flags = JW_INTERRUPT|JW_ASYNCNOTIFY;
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
*sigp = 0;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (cp == NULL) {
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* wait for an unspecified job - always returns 0, so
|
|
Packit Service |
95ac19 |
* don't have to worry about exited/signaled jobs
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
for (j = job_list; j; j = j->next)
|
|
Packit Service |
95ac19 |
/* AT&T ksh will wait for stopped jobs - we don't */
|
|
Packit Service |
95ac19 |
if (j->ppid == procpid && j->state == PRUNNING)
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
if (!j) {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
return (-1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
} else if ((j = j_lookup(cp, &ecode))) {
|
|
Packit Service |
95ac19 |
/* don't report normal job completion */
|
|
Packit Service |
95ac19 |
flags &= ~JW_ASYNCNOTIFY;
|
|
Packit Service |
95ac19 |
if (j->ppid != procpid) {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
return (-1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
} else {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (ecode != JL_NOSUCH)
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_sD_s, cp, lookup_msgs[ecode]);
|
|
Packit Service |
95ac19 |
return (-1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* AT&T ksh will wait for stopped jobs - we don't */
|
|
Packit Service |
95ac19 |
rv = j_waitj(j, flags, "jw:waitfor");
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (rv < 0)
|
|
Packit Service |
95ac19 |
/* we were interrupted */
|
|
Packit Service |
95ac19 |
*sigp = ksh_sigmask(-rv);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (rv);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* kill (built-in) a job */
|
|
Packit Service |
95ac19 |
int
|
|
Packit Service |
95ac19 |
j_kill(const char *cp, int sig)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
int rv = 0, ecode;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if ((j = j_lookup(cp, &ecode)) == NULL) {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_sD_s, cp, lookup_msgs[ecode]);
|
|
Packit Service |
95ac19 |
return (1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (j->pgrp == 0) {
|
|
Packit Service |
95ac19 |
/* started when !Flag(FMONITOR) */
|
|
Packit Service |
95ac19 |
if (kill_job(j, sig) < 0) {
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_sD_s, cp, cstrerror(errno));
|
|
Packit Service |
95ac19 |
rv = 1;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
} else {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (j->state == PSTOPPED && (sig == SIGTERM || sig == SIGHUP))
|
|
Packit Service |
95ac19 |
mksh_killpg(j->pgrp, SIGCONT);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (mksh_killpg(j->pgrp, sig) < 0) {
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_sD_s, cp, cstrerror(errno));
|
|
Packit Service |
95ac19 |
rv = 1;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (rv);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
/* fg and bg built-ins: called only if Flag(FMONITOR) set */
|
|
Packit Service |
95ac19 |
int
|
|
Packit Service |
95ac19 |
j_resume(const char *cp, int bg)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
int ecode, rv = 0;
|
|
Packit Service |
95ac19 |
bool running;
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if ((j = j_lookup(cp, &ecode)) == NULL) {
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_sD_s, cp, lookup_msgs[ecode]);
|
|
Packit Service |
95ac19 |
return (1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (j->pgrp == 0) {
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
bi_errorf("job not job-controlled");
|
|
Packit Service |
95ac19 |
return (1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (bg)
|
|
Packit Service |
95ac19 |
shprintf("[%d] ", j->job);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
running = false;
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p != NULL; p = p->next) {
|
|
Packit Service |
95ac19 |
if (p->state == PSTOPPED) {
|
|
Packit Service |
95ac19 |
p->state = PRUNNING;
|
|
Packit Service |
95ac19 |
p->status = 0;
|
|
Packit Service |
95ac19 |
running = true;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
shf_puts(p->command, shl_stdout);
|
|
Packit Service |
95ac19 |
if (p->next)
|
|
Packit Service |
95ac19 |
shf_puts("| ", shl_stdout);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
shf_putc('\n', shl_stdout);
|
|
Packit Service |
95ac19 |
shf_flush(shl_stdout);
|
|
Packit Service |
95ac19 |
if (running)
|
|
Packit Service |
95ac19 |
j->state = PRUNNING;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
put_job(j, PJ_PAST_STOPPED);
|
|
Packit Service |
95ac19 |
if (bg)
|
|
Packit Service |
95ac19 |
j_set_async(j);
|
|
Packit Service |
95ac19 |
else {
|
|
Packit Service |
95ac19 |
/* attach tty to job */
|
|
Packit Service |
95ac19 |
if (j->state == PRUNNING) {
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok && (j->flags & JF_SAVEDTTY))
|
|
Packit Service |
95ac19 |
mksh_tcset(tty_fd, &j->ttystat);
|
|
Packit Service |
95ac19 |
/* See comment in j_waitj regarding saved_ttypgrp. */
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok &&
|
|
Packit Service |
95ac19 |
tcsetpgrp(tty_fd, (j->flags & JF_SAVEDTTYPGRP) ?
|
|
Packit Service |
95ac19 |
j->saved_ttypgrp : j->pgrp) < 0) {
|
|
Packit Service |
95ac19 |
rv = errno;
|
|
Packit Service |
95ac19 |
if (j->flags & JF_SAVEDTTY)
|
|
Packit Service |
95ac19 |
mksh_tcset(tty_fd, &tty_state);
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_ldfailed,
|
|
Packit Service |
95ac19 |
"fg: 1st", "tcsetpgrp", tty_fd,
|
|
Packit Service |
95ac19 |
(long)((j->flags & JF_SAVEDTTYPGRP) ?
|
|
Packit Service |
95ac19 |
j->saved_ttypgrp : j->pgrp),
|
|
Packit Service |
95ac19 |
cstrerror(rv));
|
|
Packit Service |
95ac19 |
return (1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
j->flags |= JF_FG;
|
|
Packit Service |
95ac19 |
j->flags &= ~JF_KNOWN;
|
|
Packit Service |
95ac19 |
if (j == async_job)
|
|
Packit Service |
95ac19 |
async_job = NULL;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (j->state == PRUNNING && mksh_killpg(j->pgrp, SIGCONT) < 0) {
|
|
Packit Service |
95ac19 |
int eno = errno;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (!bg) {
|
|
Packit Service |
95ac19 |
j->flags &= ~JF_FG;
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok && (j->flags & JF_SAVEDTTY))
|
|
Packit Service |
95ac19 |
mksh_tcset(tty_fd, &tty_state);
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok && tcsetpgrp(tty_fd, kshpgrp) < 0)
|
|
Packit Service |
95ac19 |
warningf(true, Tf_ldfailed,
|
|
Packit Service |
95ac19 |
"fg: 2nd", "tcsetpgrp", tty_fd,
|
|
Packit Service |
95ac19 |
(long)kshpgrp, cstrerror(errno));
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_s_sD_s, "can't continue job",
|
|
Packit Service |
95ac19 |
cp, cstrerror(eno));
|
|
Packit Service |
95ac19 |
return (1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (!bg) {
|
|
Packit Service |
95ac19 |
if (ttypgrp_ok) {
|
|
Packit Service |
95ac19 |
j->flags &= ~(JF_SAVEDTTY | JF_SAVEDTTYPGRP);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
rv = j_waitj(j, JW_NONE, "jw:resume");
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
return (rv);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* are there any running or stopped jobs ? */
|
|
Packit Service |
95ac19 |
int
|
|
Packit Service |
95ac19 |
j_stopped_running(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
int which = 0;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next) {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (j->ppid == procpid && j->state == PSTOPPED)
|
|
Packit Service |
95ac19 |
which |= 1;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (Flag(FLOGIN) && !Flag(FNOHUP) && procpid == kshpid &&
|
|
Packit Service |
95ac19 |
j->ppid == procpid && j->state == PRUNNING)
|
|
Packit Service |
95ac19 |
which |= 2;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (which) {
|
|
Packit Service |
95ac19 |
shellf("You have %s%s%s jobs\n",
|
|
Packit Service |
95ac19 |
which & 1 ? "stopped" : "",
|
|
Packit Service |
95ac19 |
which == 3 ? " and " : "",
|
|
Packit Service |
95ac19 |
which & 2 ? "running" : "");
|
|
Packit Service |
95ac19 |
return (1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (0);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* list jobs for jobs built-in */
|
|
Packit Service |
95ac19 |
int
|
|
Packit Service |
95ac19 |
j_jobs(const char *cp, int slp,
|
|
Packit Service |
95ac19 |
/* 0: short, 1: long, 2: pgrp */
|
|
Packit Service |
95ac19 |
int nflag)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job *j, *tmp;
|
|
Packit Service |
95ac19 |
int how, zflag = 0;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (nflag < 0) {
|
|
Packit Service |
95ac19 |
/* kludge: print zombies */
|
|
Packit Service |
95ac19 |
nflag = 0;
|
|
Packit Service |
95ac19 |
zflag = 1;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (cp) {
|
|
Packit Service |
95ac19 |
int ecode;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if ((j = j_lookup(cp, &ecode)) == NULL) {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
bi_errorf(Tf_sD_s, cp, lookup_msgs[ecode]);
|
|
Packit Service |
95ac19 |
return (1);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
j = job_list;
|
|
Packit Service |
95ac19 |
how = slp == 0 ? JP_MEDIUM : (slp == 1 ? JP_LONG : JP_PGRP);
|
|
Packit Service |
95ac19 |
for (; j; j = j->next) {
|
|
Packit Service |
95ac19 |
if ((!(j->flags & JF_ZOMBIE) || zflag) &&
|
|
Packit Service |
95ac19 |
(!nflag || (j->flags & JF_CHANGED))) {
|
|
Packit Service |
95ac19 |
j_print(j, how, shl_stdout);
|
|
Packit Service |
95ac19 |
if (j->state == PEXITED || j->state == PSIGNALLED)
|
|
Packit Service |
95ac19 |
j->flags |= JF_REMOVE;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (cp)
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
/* Remove jobs after printing so there won't be multiple + or - jobs */
|
|
Packit Service |
95ac19 |
for (j = job_list; j; j = tmp) {
|
|
Packit Service |
95ac19 |
tmp = j->next;
|
|
Packit Service |
95ac19 |
if (j->flags & JF_REMOVE)
|
|
Packit Service |
95ac19 |
remove_job(j, Tjobs);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
return (0);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* list jobs for top-level notification */
|
|
Packit Service |
95ac19 |
void
|
|
Packit Service |
95ac19 |
j_notify(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job *j, *tmp;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
for (j = job_list; j; j = j->next) {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR) && (j->flags & JF_CHANGED))
|
|
Packit Service |
95ac19 |
j_print(j, JP_MEDIUM, shl_out);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Remove job after doing reports so there aren't
|
|
Packit Service |
95ac19 |
* multiple +/- jobs.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (j->state == PEXITED || j->state == PSIGNALLED)
|
|
Packit Service |
95ac19 |
j->flags |= JF_REMOVE;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
for (j = job_list; j; j = tmp) {
|
|
Packit Service |
95ac19 |
tmp = j->next;
|
|
Packit Service |
95ac19 |
if (j->flags & JF_REMOVE) {
|
|
Packit Service |
95ac19 |
if (j == async_job || (j->flags & JF_KNOWN)) {
|
|
Packit Service |
95ac19 |
j->flags = (j->flags & ~JF_REMOVE) | JF_ZOMBIE;
|
|
Packit Service |
95ac19 |
j->job = -1;
|
|
Packit Service |
95ac19 |
nzombie++;
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
remove_job(j, "notify");
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
shf_flush(shl_out);
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Return pid of last process in last asynchronous job */
|
|
Packit Service |
95ac19 |
pid_t
|
|
Packit Service |
95ac19 |
j_async(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (async_job)
|
|
Packit Service |
95ac19 |
async_job->flags |= JF_KNOWN;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (async_pid);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Make j the last async process
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
j_set_async(Job *j)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job *jl, *oldest;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (async_job && (async_job->flags & (JF_KNOWN|JF_ZOMBIE)) == JF_ZOMBIE)
|
|
Packit Service |
95ac19 |
remove_job(async_job, "async");
|
|
Packit Service |
95ac19 |
if (!(j->flags & JF_STARTED)) {
|
|
Packit Service |
95ac19 |
internal_warningf(Tf_sD_s, "j_async", Tjob_not_started);
|
|
Packit Service |
95ac19 |
return;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
async_job = j;
|
|
Packit Service |
95ac19 |
async_pid = j->last_proc->pid;
|
|
Packit Service |
95ac19 |
while (nzombie > CHILD_MAX) {
|
|
Packit Service |
95ac19 |
oldest = NULL;
|
|
Packit Service |
95ac19 |
for (jl = job_list; jl; jl = jl->next)
|
|
Packit Service |
95ac19 |
if (jl != async_job && (jl->flags & JF_ZOMBIE) &&
|
|
Packit Service |
95ac19 |
(!oldest || jl->age < oldest->age))
|
|
Packit Service |
95ac19 |
oldest = jl;
|
|
Packit Service |
95ac19 |
if (!oldest) {
|
|
Packit Service |
95ac19 |
/* XXX debugging */
|
|
Packit Service |
95ac19 |
if (!(async_job->flags & JF_ZOMBIE) || nzombie != 1) {
|
|
Packit Service |
95ac19 |
internal_warningf("%s: bad nzombie (%d)",
|
|
Packit Service |
95ac19 |
"j_async", nzombie);
|
|
Packit Service |
95ac19 |
nzombie = 0;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
remove_job(oldest, "zombie");
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Start a job: set STARTED, check for held signals and set j->last_proc
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
j_startjob(Job *j)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
j->flags |= JF_STARTED;
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p->next; p = p->next)
|
|
Packit Service |
95ac19 |
;
|
|
Packit Service |
95ac19 |
j->last_proc = p;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
if (held_sigchld) {
|
|
Packit Service |
95ac19 |
held_sigchld = 0;
|
|
Packit Service |
95ac19 |
/* Don't call j_sigchld() as it may remove job... */
|
|
Packit Service |
95ac19 |
kill(procpid, SIGCHLD);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* wait for job to complete or change state
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static int
|
|
Packit Service |
95ac19 |
j_waitj(Job *j,
|
|
Packit Service |
95ac19 |
/* see JW_* */
|
|
Packit Service |
95ac19 |
int flags,
|
|
Packit Service |
95ac19 |
const char *where)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
int rv;
|
|
Packit Service |
95ac19 |
#ifdef MKSH_NO_SIGSUSPEND
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* No auto-notify on the job we are waiting on.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
j->flags |= JF_WAITING;
|
|
Packit Service |
95ac19 |
if (flags & JW_ASYNCNOTIFY)
|
|
Packit Service |
95ac19 |
j->flags |= JF_W_ASYNCNOTIFY;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (!Flag(FMONITOR))
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
flags |= JW_STOPPEDWAIT;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
while (j->state == PRUNNING ||
|
|
Packit Service |
95ac19 |
((flags & JW_STOPPEDWAIT) && j->state == PSTOPPED)) {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
#ifdef MKSH_NO_SIGSUSPEND
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &sm_default, &omask);
|
|
Packit Service |
95ac19 |
pause();
|
|
Packit Service |
95ac19 |
/* note that handlers may run here so they need to know */
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
sigsuspend(&sm_default);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
j_sigchld(SIGCHLD);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (fatal_trap) {
|
|
Packit Service |
95ac19 |
int oldf = j->flags & (JF_WAITING|JF_W_ASYNCNOTIFY);
|
|
Packit Service |
95ac19 |
j->flags &= ~(JF_WAITING|JF_W_ASYNCNOTIFY);
|
|
Packit Service |
95ac19 |
runtraps(TF_FATAL);
|
|
Packit Service |
95ac19 |
/* not reached... */
|
|
Packit Service |
95ac19 |
j->flags |= oldf;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if ((flags & JW_INTERRUPT) && (rv = trap_pending())) {
|
|
Packit Service |
95ac19 |
j->flags &= ~(JF_WAITING|JF_W_ASYNCNOTIFY);
|
|
Packit Service |
95ac19 |
return (-rv);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
j->flags &= ~(JF_WAITING|JF_W_ASYNCNOTIFY);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (j->flags & JF_FG) {
|
|
Packit Service |
95ac19 |
j->flags &= ~JF_FG;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR) && ttypgrp_ok && j->pgrp) {
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Save the tty's current pgrp so it can be restored
|
|
Packit Service |
95ac19 |
* when the job is foregrounded. This is to
|
|
Packit Service |
95ac19 |
* deal with things like the GNU su which does
|
|
Packit Service |
95ac19 |
* a fork/exec instead of an exec (the fork means
|
|
Packit Service |
95ac19 |
* the execed shell gets a different pid from its
|
|
Packit Service |
95ac19 |
* pgrp, so naturally it sets its pgrp and gets hosed
|
|
Packit Service |
95ac19 |
* when it gets foregrounded by the parent shell which
|
|
Packit Service |
95ac19 |
* has restored the tty's pgrp to that of the su
|
|
Packit Service |
95ac19 |
* process).
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (j->state == PSTOPPED &&
|
|
Packit Service |
95ac19 |
(j->saved_ttypgrp = tcgetpgrp(tty_fd)) >= 0)
|
|
Packit Service |
95ac19 |
j->flags |= JF_SAVEDTTYPGRP;
|
|
Packit Service |
95ac19 |
if (tcsetpgrp(tty_fd, kshpgrp) < 0)
|
|
Packit Service |
95ac19 |
warningf(true, Tf_ldfailed,
|
|
Packit Service |
95ac19 |
"j_waitj:", "tcsetpgrp", tty_fd,
|
|
Packit Service |
95ac19 |
(long)kshpgrp, cstrerror(errno));
|
|
Packit Service |
95ac19 |
if (j->state == PSTOPPED) {
|
|
Packit Service |
95ac19 |
j->flags |= JF_SAVEDTTY;
|
|
Packit Service |
95ac19 |
mksh_tcget(tty_fd, &j->ttystat);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (tty_hasstate) {
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Only restore tty settings if job was originally
|
|
Packit Service |
95ac19 |
* started in the foreground. Problems can be
|
|
Packit Service |
95ac19 |
* caused by things like 'more foobar &' which will
|
|
Packit Service |
95ac19 |
* typically get and save the shell's vi/emacs tty
|
|
Packit Service |
95ac19 |
* settings before setting up the tty for itself;
|
|
Packit Service |
95ac19 |
* when more exits, it restores the 'original'
|
|
Packit Service |
95ac19 |
* settings, and things go down hill from there...
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (j->state == PEXITED && j->status == 0 &&
|
|
Packit Service |
95ac19 |
(j->flags & JF_USETTYMODE)) {
|
|
Packit Service |
95ac19 |
mksh_tcget(tty_fd, &tty_state);
|
|
Packit Service |
95ac19 |
} else {
|
|
Packit Service |
95ac19 |
mksh_tcset(tty_fd, &tty_state);
|
|
Packit Service |
95ac19 |
/*-
|
|
Packit Service |
95ac19 |
* Don't use tty mode if job is stopped and
|
|
Packit Service |
95ac19 |
* later restarted and exits. Consider
|
|
Packit Service |
95ac19 |
* the sequence:
|
|
Packit Service |
95ac19 |
* vi foo (stopped)
|
|
Packit Service |
95ac19 |
* ...
|
|
Packit Service |
95ac19 |
* stty something
|
|
Packit Service |
95ac19 |
* ...
|
|
Packit Service |
95ac19 |
* fg (vi; ZZ)
|
|
Packit Service |
95ac19 |
* mode should be that of the stty, not what
|
|
Packit Service |
95ac19 |
* was before the vi started.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (j->state == PSTOPPED)
|
|
Packit Service |
95ac19 |
j->flags &= ~JF_USETTYMODE;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* If it looks like user hit ^C to kill a job, pretend we got
|
|
Packit Service |
95ac19 |
* one too to break out of for loops, etc. (AT&T ksh does this
|
|
Packit Service |
95ac19 |
* even when not monitoring, but this doesn't make sense since
|
|
Packit Service |
95ac19 |
* a tty generated ^C goes to the whole process group)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR) && j->state == PSIGNALLED &&
|
|
Packit Service |
95ac19 |
WIFSIGNALED(j->last_proc->status)) {
|
|
Packit Service |
95ac19 |
int termsig;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if ((termsig = WTERMSIG(j->last_proc->status)) > 0 &&
|
|
Packit Service |
95ac19 |
termsig < ksh_NSIG &&
|
|
Packit Service |
95ac19 |
(sigtraps[termsig].flags & TF_TTY_INTR))
|
|
Packit Service |
95ac19 |
trapsig(termsig);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
j_usrtime = j->usrtime;
|
|
Packit Service |
95ac19 |
j_systime = j->systime;
|
|
Packit Service |
95ac19 |
rv = j->status;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (!(p = j->proc_list)) {
|
|
Packit Service |
95ac19 |
; /* nothing */
|
|
Packit Service |
95ac19 |
} else if (flags & JW_PIPEST) {
|
|
Packit Service |
95ac19 |
uint32_t num = 0;
|
|
Packit Service |
95ac19 |
struct tbl *vp;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
unset(vp_pipest, 1);
|
|
Packit Service |
95ac19 |
vp = vp_pipest;
|
|
Packit Service |
95ac19 |
vp->flag = DEFINED | ISSET | INTEGER | RDONLY | ARRAY | INT_U;
|
|
Packit Service |
95ac19 |
goto got_array;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
while (p != NULL) {
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
struct tbl *vq;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* strlen(vp_pipest->name) == 10 */
|
|
Packit Service |
95ac19 |
vq = alloc(offsetof(struct tbl, name[0]) + 11,
|
|
Packit Service |
95ac19 |
vp_pipest->areap);
|
|
Packit Service |
95ac19 |
memset(vq, 0, offsetof(struct tbl, name[0]));
|
|
Packit Service |
95ac19 |
memcpy(vq->name, vp_pipest->name, 11);
|
|
Packit Service |
95ac19 |
vp->u.array = vq;
|
|
Packit Service |
95ac19 |
vp = vq;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
vp->areap = vp_pipest->areap;
|
|
Packit Service |
95ac19 |
vp->ua.index = ++num;
|
|
Packit Service |
95ac19 |
vp->flag = DEFINED | ISSET | INTEGER | RDONLY |
|
|
Packit Service |
95ac19 |
ARRAY | INT_U | AINDEX;
|
|
Packit Service |
95ac19 |
got_array:
|
|
Packit Service |
95ac19 |
vp->val.i = proc_errorlevel(p);
|
|
Packit Service |
95ac19 |
if (Flag(FPIPEFAIL) && vp->val.i)
|
|
Packit Service |
95ac19 |
rv = vp->val.i;
|
|
Packit Service |
95ac19 |
p = p->next;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
} else if (Flag(FPIPEFAIL)) {
|
|
Packit Service |
95ac19 |
do {
|
|
Packit Service |
95ac19 |
const int i = proc_errorlevel(p);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (i)
|
|
Packit Service |
95ac19 |
rv = i;
|
|
Packit Service |
95ac19 |
} while ((p = p->next));
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (!(flags & JW_ASYNCNOTIFY)
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
&& (!Flag(FMONITOR) || j->state != PSTOPPED)
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
) {
|
|
Packit Service |
95ac19 |
j_print(j, JP_SHORT, shl_out);
|
|
Packit Service |
95ac19 |
shf_flush(shl_out);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (j->state != PSTOPPED
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
&& (!Flag(FMONITOR) || !(flags & JW_ASYNCNOTIFY))
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
)
|
|
Packit Service |
95ac19 |
remove_job(j, where);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (rv);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* SIGCHLD handler to reap children and update job states
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
/* ARGSUSED */
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
j_sigchld(int sig MKSH_A_UNUSED)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
int saved_errno = errno;
|
|
Packit Service |
95ac19 |
Job *j;
|
|
Packit Service |
95ac19 |
Proc *p = NULL;
|
|
Packit Service |
95ac19 |
pid_t pid;
|
|
Packit Service |
95ac19 |
int status;
|
|
Packit Service |
95ac19 |
struct rusage ru0, ru1;
|
|
Packit Service |
95ac19 |
#ifdef MKSH_NO_SIGSUSPEND
|
|
Packit Service |
95ac19 |
sigset_t omask;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* this handler can run while SIGCHLD is not blocked, so block it now */
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_BLOCK, &sm_sigchld, &omask);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Don't wait for any processes if a job is partially started.
|
|
Packit Service |
95ac19 |
* This is so we don't do away with the process group leader
|
|
Packit Service |
95ac19 |
* before all the processes in a pipe line are started (so the
|
|
Packit Service |
95ac19 |
* setpgid() won't fail)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
for (j = job_list; j; j = j->next)
|
|
Packit Service |
95ac19 |
if (j->ppid == procpid && !(j->flags & JF_STARTED)) {
|
|
Packit Service |
95ac19 |
held_sigchld = 1;
|
|
Packit Service |
95ac19 |
goto j_sigchld_out;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
getrusage(RUSAGE_CHILDREN, &ru0;;
|
|
Packit Service |
95ac19 |
do {
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
pid = waitpid(-1, &status, (WNOHANG |
|
|
Packit Service |
95ac19 |
#if defined(WCONTINUED) && defined(WIFCONTINUED)
|
|
Packit Service |
95ac19 |
WCONTINUED |
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
WUNTRACED));
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
pid = wait(&status);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* return if this would block (0) or no children
|
|
Packit Service |
95ac19 |
* or interrupted (-1)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (pid <= 0)
|
|
Packit Service |
95ac19 |
goto j_sigchld_out;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
getrusage(RUSAGE_CHILDREN, &ru1;;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* find job and process structures for this pid */
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next)
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p != NULL; p = p->next)
|
|
Packit Service |
95ac19 |
if (p->pid == pid)
|
|
Packit Service |
95ac19 |
goto found;
|
|
Packit Service |
95ac19 |
found:
|
|
Packit Service |
95ac19 |
if (j == NULL) {
|
|
Packit Service |
95ac19 |
/* Can occur if process has kids, then execs shell
|
|
Packit Service |
95ac19 |
warningf(true, "bad process waited for (pid = %d)",
|
|
Packit Service |
95ac19 |
pid);
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
ru0 = ru1;
|
|
Packit Service |
95ac19 |
continue;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
timeradd(&j->usrtime, &ru1.ru_utime, &j->usrtime);
|
|
Packit Service |
95ac19 |
timersub(&j->usrtime, &ru0.ru_utime, &j->usrtime);
|
|
Packit Service |
95ac19 |
timeradd(&j->systime, &ru1.ru_stime, &j->systime);
|
|
Packit Service |
95ac19 |
timersub(&j->systime, &ru0.ru_stime, &j->systime);
|
|
Packit Service |
95ac19 |
ru0 = ru1;
|
|
Packit Service |
95ac19 |
p->status = status;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (WIFSTOPPED(status))
|
|
Packit Service |
95ac19 |
p->state = PSTOPPED;
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
#if defined(WCONTINUED) && defined(WIFCONTINUED)
|
|
Packit Service |
95ac19 |
if (WIFCONTINUED(status)) {
|
|
Packit Service |
95ac19 |
p->state = j->state = PRUNNING;
|
|
Packit Service |
95ac19 |
/* skip check_job(), no-op in this case */
|
|
Packit Service |
95ac19 |
continue;
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (WIFSIGNALED(status))
|
|
Packit Service |
95ac19 |
p->state = PSIGNALLED;
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
p->state = PEXITED;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* check to see if entire job is done */
|
|
Packit Service |
95ac19 |
check_job(j);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#ifndef MKSH_NOPROSPECTOFWORK
|
|
Packit Service |
95ac19 |
while (/* CONSTCOND */ 1);
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
while (/* CONSTCOND */ 0);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
j_sigchld_out:
|
|
Packit Service |
95ac19 |
#ifdef MKSH_NO_SIGSUSPEND
|
|
Packit Service |
95ac19 |
sigprocmask(SIG_SETMASK, &omask, NULL);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
errno = saved_errno;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Called only when a process in j has exited/stopped (ie, called only
|
|
Packit Service |
95ac19 |
* from j_sigchld()). If no processes are running, the job status
|
|
Packit Service |
95ac19 |
* and state are updated, asynchronous job notification is done and,
|
|
Packit Service |
95ac19 |
* if unneeded, the job is removed.
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
check_job(Job *j)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
int jstate;
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* XXX debugging (nasty - interrupt routine using shl_out) */
|
|
Packit Service |
95ac19 |
if (!(j->flags & JF_STARTED)) {
|
|
Packit Service |
95ac19 |
internal_warningf("check_job: job started (flags 0x%X)",
|
|
Packit Service |
95ac19 |
(unsigned int)j->flags);
|
|
Packit Service |
95ac19 |
return;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
jstate = PRUNNING;
|
|
Packit Service |
95ac19 |
for (p=j->proc_list; p != NULL; p = p->next) {
|
|
Packit Service |
95ac19 |
if (p->state == PRUNNING)
|
|
Packit Service |
95ac19 |
/* some processes still running */
|
|
Packit Service |
95ac19 |
return;
|
|
Packit Service |
95ac19 |
if (p->state > jstate)
|
|
Packit Service |
95ac19 |
jstate = p->state;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
j->state = jstate;
|
|
Packit Service |
95ac19 |
j->status = proc_errorlevel(j->last_proc);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Note when co-process dies: can't be done in j_wait() nor
|
|
Packit Service |
95ac19 |
* remove_job() since neither may be called for non-interactive
|
|
Packit Service |
95ac19 |
* shells.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (j->state == PEXITED || j->state == PSIGNALLED) {
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* No need to keep co-process input any more
|
|
Packit Service |
95ac19 |
* (at least, this is what ksh93d thinks)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (coproc.job == j) {
|
|
Packit Service |
95ac19 |
coproc.job = NULL;
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* XXX would be nice to get the closes out of here
|
|
Packit Service |
95ac19 |
* so they aren't done in the signal handler.
|
|
Packit Service |
95ac19 |
* Would mean a check in coproc_getfd() to
|
|
Packit Service |
95ac19 |
* do "if job == 0 && write >= 0, close write".
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
coproc_write_close(coproc.write);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
/* Do we need to keep the output? */
|
|
Packit Service |
95ac19 |
if (j->coproc_id && j->coproc_id == coproc.id &&
|
|
Packit Service |
95ac19 |
--coproc.njobs == 0)
|
|
Packit Service |
95ac19 |
coproc_readw_close(coproc.read);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
j->flags |= JF_CHANGED;
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
if (Flag(FMONITOR) && !(j->flags & JF_XXCOM)) {
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Only put stopped jobs at the front to avoid confusing
|
|
Packit Service |
95ac19 |
* the user (don't want finished jobs effecting %+ or %-)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (j->state == PSTOPPED)
|
|
Packit Service |
95ac19 |
put_job(j, PJ_ON_FRONT);
|
|
Packit Service |
95ac19 |
if (Flag(FNOTIFY) &&
|
|
Packit Service |
95ac19 |
(j->flags & (JF_WAITING|JF_W_ASYNCNOTIFY)) != JF_WAITING) {
|
|
Packit Service |
95ac19 |
/* Look for the real file descriptor 2 */
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
struct env *ep;
|
|
Packit Service |
95ac19 |
int fd = 2;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
for (ep = e; ep; ep = ep->oenv)
|
|
Packit Service |
95ac19 |
if (ep->savefd && ep->savefd[2])
|
|
Packit Service |
95ac19 |
fd = ep->savefd[2];
|
|
Packit Service |
95ac19 |
shf_reopen(fd, SHF_WR, shl_j);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Can't call j_notify() as it removes jobs. The job
|
|
Packit Service |
95ac19 |
* must stay in the job list as j_waitj() may be
|
|
Packit Service |
95ac19 |
* running with this job.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
j_print(j, JP_MEDIUM, shl_j);
|
|
Packit Service |
95ac19 |
shf_flush(shl_j);
|
|
Packit Service |
95ac19 |
if (!(j->flags & JF_WAITING) && j->state != PSTOPPED)
|
|
Packit Service |
95ac19 |
remove_job(j, "notify");
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
if (
|
|
Packit Service |
95ac19 |
#ifndef MKSH_UNEMPLOYED
|
|
Packit Service |
95ac19 |
!Flag(FMONITOR) &&
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
!(j->flags & (JF_WAITING|JF_FG)) &&
|
|
Packit Service |
95ac19 |
j->state != PSTOPPED) {
|
|
Packit Service |
95ac19 |
if (j == async_job || (j->flags & JF_KNOWN)) {
|
|
Packit Service |
95ac19 |
j->flags |= JF_ZOMBIE;
|
|
Packit Service |
95ac19 |
j->job = -1;
|
|
Packit Service |
95ac19 |
nzombie++;
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
remove_job(j, "checkjob");
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Print job status in either short, medium or long format.
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
j_print(Job *j, int how, struct shf *shf)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
int state;
|
|
Packit Service |
95ac19 |
int status;
|
|
Packit Service |
95ac19 |
#ifdef WCOREDUMP
|
|
Packit Service |
95ac19 |
bool coredumped;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
char jobchar = ' ';
|
|
Packit Service |
95ac19 |
char buf[64];
|
|
Packit Service |
95ac19 |
const char *filler;
|
|
Packit Service |
95ac19 |
int output = 0;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (how == JP_PGRP) {
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* POSIX doesn't say what to do it there is no process
|
|
Packit Service |
95ac19 |
* group leader (ie, !FMONITOR). We arbitrarily return
|
|
Packit Service |
95ac19 |
* last pid (which is what $! returns).
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
shf_fprintf(shf, Tf_dN, (int)(j->pgrp ? j->pgrp :
|
|
Packit Service |
95ac19 |
(j->last_proc ? j->last_proc->pid : 0)));
|
|
Packit Service |
95ac19 |
return;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
j->flags &= ~JF_CHANGED;
|
|
Packit Service |
95ac19 |
filler = j->job > 10 ? "\n " : "\n ";
|
|
Packit Service |
95ac19 |
if (j == job_list)
|
|
Packit Service |
95ac19 |
jobchar = '+';
|
|
Packit Service |
95ac19 |
else if (j == job_list->next)
|
|
Packit Service |
95ac19 |
jobchar = '-';
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p != NULL;) {
|
|
Packit Service |
95ac19 |
#ifdef WCOREDUMP
|
|
Packit Service |
95ac19 |
coredumped = false;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
switch (p->state) {
|
|
Packit Service |
95ac19 |
case PRUNNING:
|
|
Packit Service |
95ac19 |
memcpy(buf, "Running", 8);
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
case PSTOPPED: {
|
|
Packit Service |
95ac19 |
int stopsig = WSTOPSIG(p->status);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
strlcpy(buf, stopsig > 0 && stopsig < ksh_NSIG ?
|
|
Packit Service |
95ac19 |
sigtraps[stopsig].mess : "Stopped", sizeof(buf));
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
case PEXITED: {
|
|
Packit Service |
95ac19 |
int exitstatus = (WEXITSTATUS(p->status)) & 255;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (how == JP_SHORT)
|
|
Packit Service |
95ac19 |
buf[0] = '\0';
|
|
Packit Service |
95ac19 |
else if (exitstatus == 0)
|
|
Packit Service |
95ac19 |
memcpy(buf, "Done", 5);
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
shf_snprintf(buf, sizeof(buf), "Done (%d)",
|
|
Packit Service |
95ac19 |
exitstatus);
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
case PSIGNALLED: {
|
|
Packit Service |
95ac19 |
int termsig = WTERMSIG(p->status);
|
|
Packit Service |
95ac19 |
#ifdef WCOREDUMP
|
|
Packit Service |
95ac19 |
if (WCOREDUMP(p->status))
|
|
Packit Service |
95ac19 |
coredumped = true;
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* kludge for not reporting 'normal termination
|
|
Packit Service |
95ac19 |
* signals' (i.e. SIGINT, SIGPIPE)
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
if (how == JP_SHORT &&
|
|
Packit Service |
95ac19 |
#ifdef WCOREDUMP
|
|
Packit Service |
95ac19 |
!coredumped &&
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
(termsig == SIGINT || termsig == SIGPIPE)) {
|
|
Packit Service |
95ac19 |
buf[0] = '\0';
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
strlcpy(buf, termsig > 0 && termsig < ksh_NSIG ?
|
|
Packit Service |
95ac19 |
sigtraps[termsig].mess : "Signalled",
|
|
Packit Service |
95ac19 |
sizeof(buf));
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
default:
|
|
Packit Service |
95ac19 |
buf[0] = '\0';
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (how != JP_SHORT) {
|
|
Packit Service |
95ac19 |
if (p == j->proc_list)
|
|
Packit Service |
95ac19 |
shf_fprintf(shf, "[%d] %c ", j->job, jobchar);
|
|
Packit Service |
95ac19 |
else
|
|
Packit Service |
95ac19 |
shf_puts(filler, shf);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (how == JP_LONG)
|
|
Packit Service |
95ac19 |
shf_fprintf(shf, "%5d ", (int)p->pid);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (how == JP_SHORT) {
|
|
Packit Service |
95ac19 |
if (buf[0]) {
|
|
Packit Service |
95ac19 |
output = 1;
|
|
Packit Service |
95ac19 |
#ifdef WCOREDUMP
|
|
Packit Service |
95ac19 |
shf_fprintf(shf, "%s%s ",
|
|
Packit Service |
95ac19 |
buf, coredumped ? " (core dumped)" : null);
|
|
Packit Service |
95ac19 |
#else
|
|
Packit Service |
95ac19 |
shf_puts(buf, shf);
|
|
Packit Service |
95ac19 |
shf_putchar(' ', shf);
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
} else {
|
|
Packit Service |
95ac19 |
output = 1;
|
|
Packit Service |
95ac19 |
shf_fprintf(shf, "%-20s %s%s%s", buf, p->command,
|
|
Packit Service |
95ac19 |
p->next ? "|" : null,
|
|
Packit Service |
95ac19 |
#ifdef WCOREDUMP
|
|
Packit Service |
95ac19 |
coredumped ? " (core dumped)" :
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
null);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
state = p->state;
|
|
Packit Service |
95ac19 |
status = p->status;
|
|
Packit Service |
95ac19 |
p = p->next;
|
|
Packit Service |
95ac19 |
while (p && p->state == state && p->status == status) {
|
|
Packit Service |
95ac19 |
if (how == JP_LONG)
|
|
Packit Service |
95ac19 |
shf_fprintf(shf, "%s%5d %-20s %s%s", filler,
|
|
Packit Service |
95ac19 |
(int)p->pid, T1space, p->command,
|
|
Packit Service |
95ac19 |
p->next ? "|" : null);
|
|
Packit Service |
95ac19 |
else if (how == JP_MEDIUM)
|
|
Packit Service |
95ac19 |
shf_fprintf(shf, Tf__ss, p->command,
|
|
Packit Service |
95ac19 |
p->next ? "|" : null);
|
|
Packit Service |
95ac19 |
p = p->next;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (output)
|
|
Packit Service |
95ac19 |
shf_putc('\n', shf);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Convert % sequence to job
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static Job *
|
|
Packit Service |
95ac19 |
j_lookup(const char *cp, int *ecodep)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job *j, *last_match;
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
size_t len;
|
|
Packit Service |
95ac19 |
int job = 0;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (ctype(*cp, C_DIGIT) && getn(cp, &job)) {
|
|
Packit Service |
95ac19 |
/* Look for last_proc->pid (what $! returns) first... */
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next)
|
|
Packit Service |
95ac19 |
if (j->last_proc && j->last_proc->pid == job)
|
|
Packit Service |
95ac19 |
return (j);
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* ...then look for process group (this is non-POSIX,
|
|
Packit Service |
95ac19 |
* but should not break anything
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next)
|
|
Packit Service |
95ac19 |
if (j->pgrp && j->pgrp == job)
|
|
Packit Service |
95ac19 |
return (j);
|
|
Packit Service |
95ac19 |
goto j_lookup_nosuch;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (*cp != '%') {
|
|
Packit Service |
95ac19 |
j_lookup_invalid:
|
|
Packit Service |
95ac19 |
if (ecodep)
|
|
Packit Service |
95ac19 |
*ecodep = JL_INVALID;
|
|
Packit Service |
95ac19 |
return (NULL);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
switch (*++cp) {
|
|
Packit Service |
95ac19 |
case '\0': /* non-standard */
|
|
Packit Service |
95ac19 |
case '+':
|
|
Packit Service |
95ac19 |
case '%':
|
|
Packit Service |
95ac19 |
if (job_list != NULL)
|
|
Packit Service |
95ac19 |
return (job_list);
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
case '-':
|
|
Packit Service |
95ac19 |
if (job_list != NULL && job_list->next)
|
|
Packit Service |
95ac19 |
return (job_list->next);
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
case '0': case '1': case '2': case '3': case '4':
|
|
Packit Service |
95ac19 |
case '5': case '6': case '7': case '8': case '9':
|
|
Packit Service |
95ac19 |
if (!getn(cp, &job))
|
|
Packit Service |
95ac19 |
goto j_lookup_invalid;
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next)
|
|
Packit Service |
95ac19 |
if (j->job == job)
|
|
Packit Service |
95ac19 |
return (j);
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* %?string */
|
|
Packit Service |
95ac19 |
case '?':
|
|
Packit Service |
95ac19 |
last_match = NULL;
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next)
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p != NULL; p = p->next)
|
|
Packit Service |
95ac19 |
if (strstr(p->command, cp+1) != NULL) {
|
|
Packit Service |
95ac19 |
if (last_match) {
|
|
Packit Service |
95ac19 |
if (ecodep)
|
|
Packit Service |
95ac19 |
*ecodep = JL_AMBIG;
|
|
Packit Service |
95ac19 |
return (NULL);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
last_match = j;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (last_match)
|
|
Packit Service |
95ac19 |
return (last_match);
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* %string */
|
|
Packit Service |
95ac19 |
default:
|
|
Packit Service |
95ac19 |
len = strlen(cp);
|
|
Packit Service |
95ac19 |
last_match = NULL;
|
|
Packit Service |
95ac19 |
for (j = job_list; j != NULL; j = j->next)
|
|
Packit Service |
95ac19 |
if (strncmp(cp, j->proc_list->command, len) == 0) {
|
|
Packit Service |
95ac19 |
if (last_match) {
|
|
Packit Service |
95ac19 |
if (ecodep)
|
|
Packit Service |
95ac19 |
*ecodep = JL_AMBIG;
|
|
Packit Service |
95ac19 |
return (NULL);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
last_match = j;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (last_match)
|
|
Packit Service |
95ac19 |
return (last_match);
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
j_lookup_nosuch:
|
|
Packit Service |
95ac19 |
if (ecodep)
|
|
Packit Service |
95ac19 |
*ecodep = JL_NOSUCH;
|
|
Packit Service |
95ac19 |
return (NULL);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static Job *free_jobs;
|
|
Packit Service |
95ac19 |
static Proc *free_procs;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* allocate a new job and fill in the job number.
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static Job *
|
|
Packit Service |
95ac19 |
new_job(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
int i;
|
|
Packit Service |
95ac19 |
Job *newj, *j;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (free_jobs != NULL) {
|
|
Packit Service |
95ac19 |
newj = free_jobs;
|
|
Packit Service |
95ac19 |
free_jobs = free_jobs->next;
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
newj = alloc(sizeof(Job), APERM);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* brute force method */
|
|
Packit Service |
95ac19 |
for (i = 1; ; i++) {
|
|
Packit Service |
95ac19 |
for (j = job_list; j && j->job != i; j = j->next)
|
|
Packit Service |
95ac19 |
;
|
|
Packit Service |
95ac19 |
if (j == NULL)
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
newj->job = i;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (newj);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Allocate new process struct
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static Proc *
|
|
Packit Service |
95ac19 |
new_proc(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (free_procs != NULL) {
|
|
Packit Service |
95ac19 |
p = free_procs;
|
|
Packit Service |
95ac19 |
free_procs = free_procs->next;
|
|
Packit Service |
95ac19 |
} else
|
|
Packit Service |
95ac19 |
p = alloc(sizeof(Proc), APERM);
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
return (p);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* Take job out of job_list and put old structures into free list.
|
|
Packit Service |
95ac19 |
* Keeps nzombies, last_job and async_job up to date.
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
remove_job(Job *j, const char *where)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Proc *p, *tmp;
|
|
Packit Service |
95ac19 |
Job **prev, *curr;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
prev = &job_list;
|
|
Packit Service |
95ac19 |
curr = job_list;
|
|
Packit Service |
95ac19 |
while (curr && curr != j) {
|
|
Packit Service |
95ac19 |
prev = &curr->next;
|
|
Packit Service |
95ac19 |
curr = *prev;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (curr != j) {
|
|
Packit Service |
95ac19 |
internal_warningf("remove_job: job %s (%s)", Tnot_found, where);
|
|
Packit Service |
95ac19 |
return;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
*prev = curr->next;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* free up proc structures */
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p != NULL; ) {
|
|
Packit Service |
95ac19 |
tmp = p;
|
|
Packit Service |
95ac19 |
p = p->next;
|
|
Packit Service |
95ac19 |
tmp->next = free_procs;
|
|
Packit Service |
95ac19 |
free_procs = tmp;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if ((j->flags & JF_ZOMBIE) && j->ppid == procpid)
|
|
Packit Service |
95ac19 |
--nzombie;
|
|
Packit Service |
95ac19 |
j->next = free_jobs;
|
|
Packit Service |
95ac19 |
free_jobs = j;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
if (j == last_job)
|
|
Packit Service |
95ac19 |
last_job = NULL;
|
|
Packit Service |
95ac19 |
if (j == async_job)
|
|
Packit Service |
95ac19 |
async_job = NULL;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* put j in a particular location (taking it out job_list if it is there
|
|
Packit Service |
95ac19 |
* already)
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
put_job(Job *j, int where)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Job **prev, *curr;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/* Remove job from list (if there) */
|
|
Packit Service |
95ac19 |
prev = &job_list;
|
|
Packit Service |
95ac19 |
curr = job_list;
|
|
Packit Service |
95ac19 |
while (curr && curr != j) {
|
|
Packit Service |
95ac19 |
prev = &curr->next;
|
|
Packit Service |
95ac19 |
curr = *prev;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
if (curr == j)
|
|
Packit Service |
95ac19 |
*prev = curr->next;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
switch (where) {
|
|
Packit Service |
95ac19 |
case PJ_ON_FRONT:
|
|
Packit Service |
95ac19 |
j->next = job_list;
|
|
Packit Service |
95ac19 |
job_list = j;
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
case PJ_PAST_STOPPED:
|
|
Packit Service |
95ac19 |
prev = &job_list;
|
|
Packit Service |
95ac19 |
curr = job_list;
|
|
Packit Service |
95ac19 |
for (; curr && curr->state == PSTOPPED; prev = &curr->next,
|
|
Packit Service |
95ac19 |
curr = *prev)
|
|
Packit Service |
95ac19 |
;
|
|
Packit Service |
95ac19 |
j->next = curr;
|
|
Packit Service |
95ac19 |
*prev = j;
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
/*
|
|
Packit Service |
95ac19 |
* nuke a job (called when unable to start full job).
|
|
Packit Service |
95ac19 |
*
|
|
Packit Service |
95ac19 |
* If jobs are compiled in then this routine expects sigchld to be blocked.
|
|
Packit Service |
95ac19 |
*/
|
|
Packit Service |
95ac19 |
static int
|
|
Packit Service |
95ac19 |
kill_job(Job *j, int sig)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
Proc *p;
|
|
Packit Service |
95ac19 |
int rval = 0;
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
for (p = j->proc_list; p != NULL; p = p->next)
|
|
Packit Service |
95ac19 |
if (p->pid != 0)
|
|
Packit Service |
95ac19 |
if (kill(p->pid, sig) < 0)
|
|
Packit Service |
95ac19 |
rval = -1;
|
|
Packit Service |
95ac19 |
return (rval);
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
tty_init_talking(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
switch (tty_init_fd()) {
|
|
Packit Service |
95ac19 |
case 0:
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
case 1:
|
|
Packit Service |
95ac19 |
#ifndef MKSH_DISABLE_TTY_WARNING
|
|
Packit Service |
95ac19 |
warningf(false, Tf_sD_s_sD_s,
|
|
Packit Service |
95ac19 |
"No controlling tty", Topen, T_devtty, cstrerror(errno));
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
case 2:
|
|
Packit Service |
95ac19 |
#ifndef MKSH_DISABLE_TTY_WARNING
|
|
Packit Service |
95ac19 |
warningf(false, Tf_sD_s_s, Tcant_find, Ttty_fd,
|
|
Packit Service |
95ac19 |
cstrerror(errno));
|
|
Packit Service |
95ac19 |
#endif
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
case 3:
|
|
Packit Service |
95ac19 |
warningf(false, Tf_ssfaileds, "j_ttyinit",
|
|
Packit Service |
95ac19 |
Ttty_fd_dupof, cstrerror(errno));
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
case 4:
|
|
Packit Service |
95ac19 |
warningf(false, Tf_sD_sD_s, "j_ttyinit",
|
|
Packit Service |
95ac19 |
"can't set close-on-exec flag", cstrerror(errno));
|
|
Packit Service |
95ac19 |
break;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
|
|
Packit Service |
95ac19 |
static void
|
|
Packit Service |
95ac19 |
tty_init_state(void)
|
|
Packit Service |
95ac19 |
{
|
|
Packit Service |
95ac19 |
if (tty_fd >= 0) {
|
|
Packit Service |
95ac19 |
mksh_tcget(tty_fd, &tty_state);
|
|
Packit Service |
95ac19 |
tty_hasstate = true;
|
|
Packit Service |
95ac19 |
}
|
|
Packit Service |
95ac19 |
}
|