| /ast/src/cmd/nmake/ |
| H A D | command.c | 41 #define READY 004 /* job ready to run */
42 #define RUNNING 005 /* job action sent to coshell */
67 struct Context_s /* job target context */
75 struct Joblist_s /* job list cell */
79 Cojob_t* cojob; /* coshell job info */
80 Rule_t* target; /* target for job */
82 Context_t* context; /* job target context */
84 int status; /* job status */
85 Flags_t flags; /* job flags */
88 typedef struct Jobstate_s /* job stat
278 commit(Joblist_t* job, register char* s) argument
337 push(Joblist_t* job) argument
377 pop(Joblist_t* job) argument
414 discard(register Joblist_t* job) argument
456 save(Joblist_t* job) argument
503 restore(register Joblist_t* job, Sfio_t* buf, Sfio_t* att) argument
631 execute(register Joblist_t* job) argument
860 done(register Joblist_t* job, int clear, Cojob_t* cojob) argument
1110 register Joblist_t* job; local
1358 register Joblist_t* job; local
1658 register Joblist_t* job; local
[all...] |
| /ast/src/cmd/ksh93/sh/ |
| H A D | defs.c | 46 struct jobs job = {0}; variable in typeref:struct:jobs
|
| H A D | jobs.c | 207 for(pw=job.pwlist;pw;pw=pwnext)
269 for(csp=job.colist; csp; csp = csp->next)
294 for(csp=(struct cosh*)job.colist;csp;csp=csp->next)
307 for(n=0,pw=job.pwlist; pw; pw=pwnext)
333 * Reap one job
351 for(pw=job.pwlist;pw;pw=pw->p_nxtjob)
366 if(sfprintf(sfstderr,"ksh: job line %4d: reap pid=%d critical=%d signal=%d\n",__LINE__,getpid(),job.in_critical,sig) <=0)
370 job.savesig = 0;
379 if(!(flags&WNOHANG) && !sh.intrap && job
[all...] |
| H A D | xec.c | 159 while(job.waitsafe && job.savesig==SIGCHLD)
163 job.in_critical++;
165 job.in_critical--;
749 struct cosh *csp = job.colist;
789 csp->next = job.colist;
790 job.colist = csp;
1000 job.curpgid = 0;
1001 job.curjobid = 0;
1614 /* disable foreground job monito
[all...] |
| H A D | fault.c | 132 if(sig==SIGTERM && job.in_critical)
178 if(sig==SIGHUP && job.curpgid)
179 killpg(job.curpgid,SIGHUP);
539 job.curpgid = 0;
540 job.parent = (pid_t)-1;
543 job.parent = 0;
558 /* stop child job */
559 killpg(job.curpgid,SIGTSTP);
583 if(job.in_critical)
|
| H A D | subshell.c | 86 void *jobs; /* save job info */
474 int savejobpgid = job.curpgid;
475 int *saveexitval = job.exitval;
528 job.curpgid = 0;
592 /* disable job control */
594 sp->jobcontrol = job.jobcontrol;
596 job.jobcontrol=0;
651 /* re-enable job control */
654 job.jobcontrol = sp->jobcontrol;
706 job
[all...] |
| H A D | main.c | 448 tcsetpgrp(job.fd,shp->gd->pid);
493 if(job.pwlist)
561 job.waitall = job.curpgid = 0;
|
| H A D | io.c | 612 if(f2==job.fd)
613 job.fd=fd;
1707 if(origfd==job.fd)
1708 job.fd = savefd;
1782 if(savefd==job.fd)
1783 job.fd=origfd;
1929 if(job.waitsafe && job.savesig)
|
| H A D | init.c | 1678 job.exitval = 0;
1681 job.in_critical = 0;
|
| /ast/src/cmd/at/ |
| H A D | atd.c | 32 * <job-i> AT_JOB_MODE
34 * job names are encoded with <uid.gid.time> base 64 where
35 * <time> is the earliest absolute time the job can be run
143 Table_t job; /* job by <start,name> */ member in struct:__anon39::__anon40
145 Table_t pid; /* job by pid */
160 unsigned long sequence; /* job id sequence */
492 * insert a job into the run list
496 submit(State_t* state, register Job_t* job) argument
498 dtinsert(state->table.job
511 complete(State_t* state, register Job_t* job) argument
547 drop(register State_t* state, register Job_t* job) argument
560 execute(register State_t* state, register Job_t* job) argument
586 reap(register State_t* state, register Job_t* job, int status) argument
610 register Job_t* job; local
678 Job_t* job; local
784 register Job_t* job; local
[all...] |
| /ast/src/cmd/ksh93/include/ |
| H A D | jobs.h | 23 * Interface to job control for shell
76 struct process *p_nxtjob; /* next job structure */
77 struct process *p_nxtproc; /* next process in current job */
78 Shell_t *p_shp; /* shell that posted the job */
80 Cojob_t *p_cojob; /* coshell job */
86 short p_job; /* job number of process */
93 struct termios p_stty; /* terminal state for job */
118 char jobcontrol; /* turned on for real job control */
121 char toclear; /* job table needs clearing */
124 struct cosh *colist; /* coshell job lis
[all...] |
| /ast/src/cmd/jcl/ |
| H A D | jcm.c | 25 "[+NAME?jcm - job control-M deck converter]"
26 "[+DESCRIPTION?\bjcm\b converts the control-M job scheduler decks named by"
40 "[l:lowercase?Convert job and library names to lower case.]"
142 Jcmjob_t* job; member in struct:Jcmevent_s
406 register Jcmjob_t* job; local
409 if (!(job = newof(0, Jcmjob_t, 1, strlen(s))))
411 strcpy(job->base, s);
413 lower(job->base);
414 job->name = stash(parameterize(state.tmp, s, s + 27, 0, 0));
416 lower(job
508 assert(register Jcmjob_t* job, register Jcmlist_t* reqs, register Jcmlist_t* deps, Jcmevent_t* group) argument
641 register Jcmjob_t* job; local
[all...] |
| /ast/src/lib/libcoshell/ |
| H A D | cowait.c | 25 * wait for and return status of job or the next coshell job that completes
26 * job==co for non-blocking wait
38 cat(Cojob_t* job, char** path, Sfio_t* op) argument
48 errormsg(state.lib, ERROR_LIBRARY|2, "%s: cannot open job %d serialized output", *path, job->id);
129 cowait(register Coshell_t* co, Cojob_t* job, int timeout) argument
150 if (co || job && (co = job->coshell))
171 if (cj->pid == CO_PID_ZOMBIE && (!job || c
[all...] |
| /ast/src/cmd/coshell/ |
| H A D | job.c | 25 * remote coshell server job and connection support
47 for (jp = state.job; jp <= state.jobmax; jp++)
75 if ((jp = state.con[fd].info.pass.job) && jp->pid)
98 * check the job table for hogs running on busy shells
110 for (jp = state.job; jp <= state.jobmax; jp++)
118 message((-4, "jobcheck: %s: job %d pid %d lost", sp->name, jp->rid, jp->pid));
134 error(ERROR_OUTPUT|2, state.con[jp->fd].info.user.fds[2], "%s: job=%d pid=%d %s", sp->name, jp - state.job, jp->pid, state.migrate);
135 n = sfprintf(state.string, "job=%d; pid=%d; host=%s; type=%s; %s\n", jp - state.job, j
[all...] |
| H A D | Makefile | 9 service.h main.c job.c schedule.c shell.c command.c \
|
| H A D | shell.c | 174 for (jp = state.job; sp->running && jp <= state.jobmax; jp++)
262 * find a free job slot
268 if (jp++ >= state.jobmax) jp = state.job;
273 error(ERROR_OUTPUT|2, con[fd].info.user.fds[2], "job table full");
318 jp - state.job,
325 sfprintf(state.string, "print '#%05d.%05d'\n", jp - state.job, con[fd].info.user.fds[1]);
335 sfprintf(state.string, "print -u2 '#%05d.%05d'\n", jp - state.job, con[fd].info.user.fds[2]);
352 sfprintf(state.string, "%s &\nprint -u3 j %d $!\n", err, jp - state.job);
359 message((-5, "job: %s", s));
|
| H A D | cotest.c | 55 if (!(state.job = state.jobnext = newof(0, Cojob_t, state.fdtotal / 2, 0)))
56 error(3, "out of space [job]");
|
| H A D | service.h | 37 int sig; /* last signal sent to job */ \
42 unsigned long busy; /* time when job becomes hog */ \
43 unsigned long lost; /* time when job is lost */ \
103 #define HOG (~0L) /* hog job busy time */
106 #define LOST (1*60) /* job/shell lost secs */
141 #define JOB (1<<3) /* schedule job */
237 Cojob_t* job; member in struct:__anon61
298 Cojob_t* job; member in struct:__anon66
|
| H A D | command.c | 123 * send a job control kill message to fd
138 * pass job control signals to the server and self
315 j job status\n\
316 k [ckst] job terminate [continue|kill|stop|term] job\n\
458 if (jp = con[n].info.pass.job) sfprintf(state.string, "%3d pass %-3d %s %d%s\n", n, con[n].info.pass.fd, jp->shell->name, jp->pid, con[n].info.pass.serialize ? " serialize" : "");
571 for (jp = state.job; jp <= state.jobmax; jp++)
595 sfprintf(state.string, "%3d%4d%4d%6s%7s%c%-16s %s%s%s", jp - state.job, jp->fd, jp->rid, t, fmtelapsed(cs.time - jp->start, 1), jp->ref <= 0 ? '*' : jp->lost ? (jp->lost > cs.time ? '?' : '!') : ' ', jp->shell->name, v, *v ? " " : "", jp->label);
602 error(ERROR_OUTPUT|2, con[fd].info.user.fds[2], "job id required");
603 else if ((jp = state.job
[all...] |
| H A D | main.c | 126 if (!(state.job = state.jobnext = newof(0, Cojob_t, n, 0)))
127 error(3, "out of space [job]");
157 * set the job limits
332 if ((jp = state.job + (int)strtol(s, NiL, 0)) > state.jobmax) continue;
344 * <s> is the job pid
400 * <s> is the job exit code and user,sys times
443 if (csread(fd, s = state.buf, 13, CS_EXACT) != 13 || s[0] != '#' || (jp = state.job + (int)strtol(s + 1, NiL, 10)) > state.jobmax || fstat(state.con[fd].info.pass.fd = (int)strtol(s + 7, NiL, 10), &st))
448 state.con[fd].info.pass.job = jp->pid ? jp : 0;
614 jp = state.con[fd].info.pass.job;
622 if (*(s = state.con[fd].info.pass.job
[all...] |
| /ast/src/cmd/ksh93/ |
| H A D | Makefile | 24 SHOPT_BGX == 1 /* one SIGCHLD trap per completed job */
|
| /ast/src/cmd/std/ |
| H A D | pss.h | 119 Pss_id_t job; member in struct:Pssent_s
|
| H A D | pss-ps.c | 251 pe->job = number(s, &e, 10);
|
| /ast/src/cmd/ksh93/tests/ |
| H A D | functions.sh | 1015 tmp1=$tmp/job.1
1016 tmp2=$tmp/job.2
1027 [[ $(< $tmp2) == $pid ]] || err_exit 'wrong pid for & job in function'
|
| /ast/src/cmd/ksh93/bltins/ |
| H A D | misc.c | 24 * jobs [-lnp] [job...]
31 * wait [job...]
417 if(!sh_isoption(SH_MONITOR) || !job.jobcontrol)
|