![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to sh.proc.c CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [CSRG BSD Unix] / 41BSD / cmd / csh|
Return to sh.proc.c CVS log | Up to [CSRG BSD Unix] / 41BSD / cmd / csh |
1.1 root 1: static char *sccsid = "@(#)sh.proc.c 4.1 10/9/80";
2:
3: #include "sh.h"
4: #include "sh.dir.h"
5: #include "sh.proc.h"
6: #include <wait.h>
7: #include <sys/ioctl.h>
8:
9: /*
10: * C Shell - functions that manage processes, handling hanging, termination
11: */
12:
13: #define BIGINDEX 9 /* largest desirable job index */
14:
15: /*
16: * pchild - called at interrupt level by the SIGCHLD signal
17: * indicating that at least one child has terminated or stopped
18: * thus at least one wait system call will definitely return a
19: * childs status. Top level routines (like pwait) must be sure
20: * to mask interrupts when playing with the proclist data structures!
21: */
22: pchild()
23: {
24: register struct process *pp;
25: register struct process *fp;
26: register int pid;
27: union wait w;
28: int jobflags;
29: #ifdef VMUNIX
30: struct vtimes vt;
31: #endif
32:
33: if (!timesdone)
34: timesdone++, times(&shtimes);
35: loop:
36: pid = wait3(&w.w_status, (setintr ? WNOHANG|WUNTRACED:WNOHANG),
37: #ifndef VMUNIX
38: 0);
39: #else
40: &vt);
41: #endif
42: if (pid <= 0) {
43: if (errno == EINTR) {
44: errno = 0;
45: goto loop;
46: }
47: pnoprocesses = pid == -1;
48: return;
49: }
50: for (pp = proclist.p_next; pp != PNULL; pp = pp->p_next)
51: if (pid == pp->p_pid)
52: goto found;
53: goto loop;
54: found:
55: if (pid == atoi(value("child")))
56: unsetv("child");
57: pp->p_flags &= ~(PRUNNING|PSTOPPED|PREPORTED);
58: if (WIFSTOPPED(w)) {
59: pp->p_flags |= PSTOPPED;
60: pp->p_reason = w.w_stopsig;
61: } else {
62: if (pp->p_flags & (PTIME|PPTIME) || adrof("time")) {
63: time_t oldcutimes, oldcstimes;
64: oldcutimes = shtimes.tms_cutime;
65: oldcstimes = shtimes.tms_cstime;
66: time(&pp->p_etime);
67: times(&shtimes);
68: pp->p_utime = shtimes.tms_cutime - oldcutimes;
69: pp->p_stime = shtimes.tms_cstime - oldcstimes;
70: } else
71: times(&shtimes);
72: #ifdef VMUNIX
73: pp->p_vtimes = vt;
74: #endif
75: if (WIFSIGNALED(w)) {
76: if (w.w_termsig == SIGINT)
77: pp->p_flags |= PINTERRUPTED;
78: else
79: pp->p_flags |= PSIGNALED;
80: if (w.w_coredump)
81: pp->p_flags |= PDUMPED;
82: pp->p_reason = w.w_termsig;
83: } else {
84: pp->p_reason = w.w_retcode;
85: #ifdef IIASA
86: if (pp->p_reason >= 3)
87: #else
88: if (pp->p_reason != 0)
89: #endif
90: pp->p_flags |= PAEXITED;
91: else
92: pp->p_flags |= PNEXITED;
93: }
94: }
95: jobflags = 0;
96: fp = pp;
97: do {
98: if ((fp->p_flags & (PPTIME|PRUNNING|PSTOPPED)) == 0 &&
99: !child && adrof("time") &&
100: (fp->p_utime + fp->p_stime) / HZ >=
101: atoi(value("time")))
102: fp->p_flags |= PTIME;
103: jobflags |= fp->p_flags;
104: } while ((fp = fp->p_friends) != pp);
105: pp->p_flags &= ~PFOREGND;
106: if (pp == pp->p_friends && (pp->p_flags & PPTIME)) {
107: pp->p_flags &= ~PPTIME;
108: pp->p_flags |= PTIME;
109: }
110: if ((jobflags & (PRUNNING|PREPORTED)) == 0) {
111: fp = pp;
112: do {
113: if (fp->p_flags&PSTOPPED)
114: fp->p_flags |= PREPORTED;
115: } while((fp = fp->p_friends) != pp);
116: while(fp->p_pid != fp->p_jobid)
117: fp = fp->p_friends;
118: if (jobflags&PFOREGND) {
119: if (jobflags&PSTOPPED) {
120: if (pcurrent && pcurrent != fp)
121: pprevious = pcurrent;
122: pcurrent = fp;
123: } else
124: pclrcurr(fp);
125: if (jobflags & (PSIGNALED|PSTOPPED|PPTIME) ||
126: #ifdef IIASA
127: jobflags & PAEXITED ||
128: #endif
129: !eq(dcwd->di_name, fp->p_cwd->di_name)) {
130: if (jobflags & PSTOPPED)
131: printf("\n");
132: pprint(fp, AREASON|SHELLDIR);
133: } else if ((jobflags & (PTIME|PSTOPPED)) == PTIME)
134: ptprint(fp);
135: } else {
136: if (jobflags&PNOTIFY || adrof("notify")) {
137: printf("\215\n");
138: pprint(pp, NUMBER|NAME|REASON);
139: if ((jobflags&PSTOPPED) == 0)
140: pflush(pp);
141: } else {
142: if ((jobflags&PSTOPPED) == 0)
143: pclrcurr(fp);
144: fp->p_flags |= PNEEDNOTE;
145: neednote++;
146: }
147: }
148: }
149: goto loop;
150: }
151:
152: pnote()
153: {
154: register struct process *pp;
155: int flags;
156:
157: neednote = 0;
158: for (pp = proclist.p_next; pp != PNULL; pp = pp->p_next) {
159: if (pp->p_flags & PNEEDNOTE) {
160: sighold(SIGCHLD);
161: pp->p_flags &= ~PNEEDNOTE;
162: flags = pprint(pp, NUMBER|NAME|REASON);
163: if ((flags&(PRUNNING|PSTOPPED)) == 0)
164: pflush(pp);
165: sigrelse(SIGCHLD);
166: }
167: }
168: }
169:
170: /*
171: * pwait - wait for current job to terminate, maintaining integrity
172: * of current and previous job indicators.
173: */
174: pwait()
175: {
176: register struct process *fp, *pp;
177:
178: /*
179: * Here's where dead procs get flushed.
180: */
181: sighold(SIGCHLD);
182: for (pp = (fp = &proclist)->p_next; pp != PNULL; pp = (fp = pp)->p_next)
183: if (pp->p_pid == 0) {
184: fp->p_next = pp->p_next;
185: xfree(pp->p_command);
186: if (pp->p_cwd && --pp->p_cwd->di_count == 0)
187: if (pp->p_cwd->di_next == 0)
188: dfree(pp->p_cwd);
189: xfree((char *)pp);
190: pp = fp;
191: }
192: sigrelse(SIGCHLD);
193: if (setintr)
194: sigignore(SIGINT);
195: pjwait(pcurrjob);
196: }
197:
198: /*
199: * pjwait - wait for a job to finish or become stopped
200: * It is assumed to be in the foreground state (PFOREGND)
201: */
202: pjwait(pp)
203: register struct process *pp;
204: {
205: register struct process *fp;
206: int jobflags, reason;
207:
208: fp = pp;
209: do {
210: if ((fp->p_flags&(PFOREGND|PRUNNING)) == PRUNNING)
211: printf("BUG: waiting for background job!\n");
212: } while ((fp = fp->p_friends) != pp);
213: /*
214: * Now keep pausing as long as we are not interrupted (SIGINT),
215: * and the target process, or any of its friends, are running
216: */
217: fp = pp;
218: for (;;) {
219: sighold(SIGCHLD);
220: jobflags = 0;
221: do
222: jobflags |= fp->p_flags;
223: while((fp = (fp->p_friends)) != pp);
224: if ((jobflags & PRUNNING) == 0)
225: break;
226: sigpause(SIGCHLD);
227: }
228: sigrelse(SIGCHLD);
229: if (tpgrp > 0)
230: ioctl(FSHTTY, TIOCSPGRP, &tpgrp); /* get tty back */
231: if (jobflags & PSTOPPED)
232: return;
233: if ((jobflags&PINTERRUPTED) && setintr &&
234: (!gointr || !eq(gointr, "-"))) {
235: pflush(pp);
236: pintr();
237: /*NOTREACHED*/
238: }
239: reason = 0;
240: fp = pp;
241: do {
242: if (fp->p_reason)
243: reason = fp->p_flags & (PSIGNALED|PINTERRUPTED) ?
244: fp->p_reason | QUOTE : fp->p_reason;
245: } while ((fp = fp->p_friends) != pp);
246: set("status", putn(reason));
247: if (reason && exiterr)
248: exitstat();
249: pflush(pp);
250: }
251:
252: /*
253: * dowait - wait for all processes to finish
254: */
255: dowait()
256: {
257: register struct process *pp;
258:
259: pjobs++;
260: if (setintr)
261: sigrelse(SIGINT);
262: loop:
263: sighold(SIGCHLD);
264: for (pp = proclist.p_next; pp; pp = pp->p_next)
265: if (pp->p_pid && pp->p_pid == pp->p_jobid &&
266: pp->p_flags&PRUNNING) {
267: sigpause(SIGCHLD);
268: goto loop;
269: }
270: sigrelse(SIGCHLD);
271: pjobs = 0;
272: }
273:
274: /*
275: * pflushall - flush all jobs from list (e.g. at fork())
276: */
277: pflushall()
278: {
279: register struct process *pp;
280:
281: for (pp = proclist.p_next; pp != PNULL; pp = pp->p_next)
282: if (pp->p_pid)
283: pflush(pp);
284: }
285:
286: /*
287: * pflush - flag all process structures in the same job as the
288: * the argument process for deletion. The actual free of the
289: * space is not done here since pflush is called at interrupt level.
290: */
291: pflush(pp)
292: register struct process *pp;
293: {
294: register struct process *np;
295: register int index;
296:
297: if (pp->p_pid == 0) {
298: printf("BUG: process flushed twice");
299: return;
300: }
301: while (pp->p_pid != pp->p_jobid)
302: pp = pp->p_friends;
303: pclrcurr(pp);
304: if (pp == pcurrjob)
305: pcurrjob = 0;
306: index = pp->p_index;
307: np = pp;
308: do {
309: np->p_index = np->p_pid = 0;
310: np->p_flags &= ~PNEEDNOTE;
311: } while ((np = np->p_friends) != pp);
312: if (index == pmaxindex) {
313: for (np = proclist.p_next, index = 0; np; np = np->p_next)
314: if (np->p_index > index)
315: index = np->p_index;
316: pmaxindex = index;
317: }
318: }
319:
320: /*
321: * pclrcurr - make sure the given job is not the current or previous job;
322: * pp MUST be the job leader
323: */
324: pclrcurr(pp)
325: register struct process *pp;
326: {
327:
328: if (pp == pcurrent)
329: if (pprevious != PNULL) {
330: pcurrent = pprevious;
331: pprevious = pgetcurr(pp);
332: } else {
333: pcurrent = pgetcurr(pp);
334: pprevious = pgetcurr(pp);
335: }
336: else if (pp == pprevious)
337: pprevious = pgetcurr(pp);
338: }
339:
340: /* +4 here is 1 for '\0', 1 ea for << >& >> */
341: char command[PMAXLEN+4];
342: int cmdlen;
343: char *cmdp;
344: /*
345: * palloc - allocate a process structure and fill it up.
346: * an important assumption is made that the process is running.
347: */
348: palloc(pid, t)
349: int pid;
350: register struct command *t;
351: {
352: register struct process *pp;
353: int i;
354:
355: pp = (struct process *)calloc(1, sizeof(struct process));
356: pp->p_pid = pid;
357: pp->p_flags = t->t_dflg & FAND ? PRUNNING : PRUNNING|PFOREGND;
358: if (t->t_dflg & FTIME)
359: pp->p_flags |= PPTIME;
360: cmdp = command;
361: cmdlen = 0;
362: padd(t);
363: *cmdp++ = 0;
364: if (t->t_dflg & FPOU) {
365: pp->p_flags |= PPOU;
366: if (t->t_dflg & FDIAG)
367: pp->p_flags |= PDIAG;
368: }
369: pp->p_command = savestr(command);
370: if (pcurrjob) {
371: struct process *fp;
372: /* careful here with interrupt level */
373: pp->p_cwd = 0;
374: pp->p_index = pcurrjob->p_index;
375: pp->p_friends = pcurrjob;
376: pp->p_jobid = pcurrjob->p_pid;
377: for (fp = pcurrjob; fp->p_friends != pcurrjob; fp = fp->p_friends)
378: ;
379: fp->p_friends = pp;
380: } else {
381: pcurrjob = pp;
382: pp->p_jobid = pid;
383: pp->p_friends = pp;
384: pp->p_cwd = dcwd;
385: dcwd->di_count++;
386: if (pmaxindex < BIGINDEX)
387: pp->p_index = ++pmaxindex;
388: else {
389: struct process *np;
390:
391: for (i = 1; ; i++) {
392: for (np = proclist.p_next; np; np = np->p_next)
393: if (np->p_index == i)
394: goto tryagain;
395: pmaxindex = pp->p_index = i;
396: break;
397: tryagain:;
398: }
399: }
400: if (pcurrent == PNULL)
401: pcurrent = pp;
402: else if (pprevious == PNULL)
403: pprevious = pp;
404: }
405: pp->p_next = proclist.p_next;
406: proclist.p_next = pp;
407: time(&pp->p_btime);
408: }
409:
410: padd(t)
411: register struct command *t;
412: {
413: char **argp;
414:
415: if (t == 0)
416: return;
417: switch (t->t_dtyp) {
418:
419: case TPAR:
420: pads("( ");
421: padd(t->t_dspr);
422: pads(" )");
423: break;
424:
425: case TCOM:
426: for (argp = t->t_dcom; *argp; argp++) {
427: pads(*argp);
428: if (argp[1])
429: pads(" ");
430: }
431: break;
432:
433: case TFIL:
434: padd(t->t_dcar);
435: pads(" | ");
436: padd(t->t_dcdr);
437: return;
438:
439: case TLST:
440: padd(t->t_dcar);
441: pads("; ");
442: padd(t->t_dcdr);
443: return;
444: }
445: if ((t->t_dflg & FPIN) == 0 && t->t_dlef) {
446: pads((t->t_dflg & FHERE) ? " << " : " < ");
447: pads(t->t_dlef);
448: }
449: if ((t->t_dflg & FPOU) == 0 && t->t_drit) {
450: pads((t->t_dflg & FCAT) ? " >>" : " >");
451: if (t->t_dflg & FDIAG)
452: pads("&");
453: pads(" ");
454: pads(t->t_drit);
455: }
456: }
457:
458: pads(cp)
459: char *cp;
460: {
461: register int i = strlen(cp);
462:
463: if (cmdlen >= PMAXLEN)
464: return;
465: if (cmdlen + i >= PMAXLEN) {
466: strcpy(cmdp, " ...");
467: cmdlen = PMAXLEN;
468: cmdp += 4;
469: return;
470: }
471: strcpy(cmdp, cp);
472: cmdp += i;
473: cmdlen += i;
474: }
475:
476: /*
477: * psavejob - temporarily save the current job on a one level stack
478: * so another job can be created. Used for { } in exp6
479: * and `` in globbing.
480: */
481: psavejob()
482: {
483:
484: pholdjob = pcurrjob;
485: pcurrjob = PNULL;
486: }
487:
488: /*
489: * prestjob - opposite of psavejob. This may be missed if we are interrupted
490: * somewhere, but pendjob cleans up anyway.
491: */
492: prestjob()
493: {
494:
495: pcurrjob = pholdjob;
496: pholdjob = PNULL;
497: }
498:
499: /*
500: * pendjob - indicate that a job (set of commands) has been completed
501: * or is about to begin.
502: */
503: pendjob()
504: {
505: register struct process *pp, *tp;
506:
507: if (pcurrjob && (pcurrjob->p_flags&(PFOREGND|PSTOPPED)) == 0) {
508: pp = pcurrjob;
509: while (pp->p_pid != pp->p_jobid)
510: pp = pp->p_friends;
511: printf("[%d]", pp->p_index);
512: tp = pp;
513: do {
514: printf(" %d", pp->p_pid);
515: pp = pp->p_friends;
516: } while (pp != tp);
517: printf("\n");
518: }
519: pholdjob = pcurrjob = 0;
520: }
521:
522: /*
523: * pprint - print a job
524: */
525: pprint(pp, flag)
526: register struct process *pp;
527: {
528: register status, reason;
529: struct process *tp;
530: extern char *linp, linbuf[];
531: int jobflags, pstatus;
532: char *format;
533:
534: while (pp->p_pid != pp->p_jobid)
535: pp = pp->p_friends;
536: if (pp == pp->p_friends && (pp->p_flags & PPTIME)) {
537: pp->p_flags &= ~PPTIME;
538: pp->p_flags |= PTIME;
539: }
540: tp = pp;
541: status = reason = -1;
542: jobflags = 0;
543: do {
544: jobflags |= pp->p_flags;
545: pstatus = pp->p_flags & PALLSTATES;
546: if (tp != pp && linp != linbuf && !(flag&FANCY) &&
547: (pstatus == status && pp->p_reason == reason ||
548: !(flag&REASON)))
549: printf(" ");
550: else {
551: if (tp != pp && linp != linbuf)
552: printf("\n");
553: if(flag&NUMBER)
554: if (pp == tp)
555: printf("[%d]%s %c ", pp->p_index,
556: pp->p_index < 10 ? " " : "",
557: pp==pcurrent ? '+' :
558: (pp == pprevious ? '-' : ' '));
559: else
560: printf(" ");
561: if (flag&FANCY)
562: printf("%5d ", pp->p_pid);
563: if (flag&(REASON|AREASON)) {
564: if (flag&NAME)
565: format = "%-21s";
566: else
567: format = "%s";
568: if (pstatus == status)
569: if (pp->p_reason == reason) {
570: printf(format, "");
571: goto prcomd;
572: } else
573: reason = pp->p_reason;
574: else {
575: status = pstatus;
576: reason = pp->p_reason;
577: }
578: switch (status) {
579:
580: case PRUNNING:
581: printf(format, "Running ");
582: break;
583:
584: case PINTERRUPTED:
585: case PSTOPPED:
586: case PSIGNALED:
587: if (flag&REASON || reason != SIGINT ||
588: reason != SIGPIPE)
589: printf(format, mesg[pp->p_reason].pname);
590: break;
591:
592: case PNEXITED:
593: case PAEXITED:
594: if (flag & REASON)
595: if (pp->p_reason)
596: printf("Exit %-16d", pp->p_reason);
597: else
598: printf(format, "Done");
599: break;
600:
601: default:
602: printf("BUG: status=%-9o", status);
603: }
604: }
605: }
606: prcomd:
607: if (flag&NAME) {
608: printf("%s", pp->p_command);
609: if (pp->p_flags & PPOU)
610: printf(" |");
611: if (pp->p_flags & PDIAG)
612: printf("&");
613: }
614: if (flag&(REASON|AREASON) && pp->p_flags&PDUMPED)
615: printf(" (core dumped)");
616: if (tp == pp->p_friends) {
617: if (flag&ERSAND)
618: printf(" &");
619: if (flag&JOBDIR &&
620: !eq(tp->p_cwd->di_name, dcwd->di_name)) {
621: printf(" (wd: ");
622: dtildepr(value("home"), tp->p_cwd->di_name);
623: printf(")");
624: }
625: }
626: if (pp->p_flags&PPTIME && !(status&(PSTOPPED|PRUNNING))) {
627: if (linp != linbuf)
628: printf("\n\t");
629: #ifndef VMUNIX
630: ptimes(pp->p_utime, pp->p_stime, pp->p_etime-pp->p_btime);
631: #else
632: pvtimes(&zvms, &pp->p_vtimes, pp->p_etime - pp->p_btime);
633: #endif
634: }
635: if (tp == pp->p_friends) {
636: if (linp != linbuf)
637: printf("\n");
638: if (flag&SHELLDIR && !eq(tp->p_cwd->di_name, dcwd->di_name)) {
639: printf("(wd now: ");
640: dtildepr(value("home"), dcwd->di_name);
641: printf(")\n");
642: }
643: }
644: } while ((pp = pp->p_friends) != tp);
645: if (jobflags&PTIME && (jobflags&(PSTOPPED|PRUNNING)) == 0) {
646: if (jobflags & NUMBER)
647: printf(" ");
648: ptprint(tp);
649: }
650: return (jobflags);
651: }
652:
653: ptprint(tp)
654: register struct process *tp;
655: {
656: time_t tetime = 0;
657: #ifdef VMUNIX
658: struct vtimes vmt;
659: #else
660: time_t tutime = 0, tstime = 0;
661: #endif
662: register struct process *pp = tp;
663:
664: vmt = zvms;
665: do {
666: #ifdef VMUNIX
667: vmsadd(&vmt, &pp->p_vtimes);
668: #else
669: tutime += pp->p_utime;
670: tstime += pp->p_stime;
671: #endif
672: if (pp->p_etime - pp->p_btime > tetime)
673: tetime = pp->p_etime - pp->p_btime;
674: } while ((pp = pp->p_friends) != tp);
675: #ifdef VMUNIX
676: pvtimes(&zvms, &vmt, tetime);
677: #else
678: ptimes(tutime, tstime, tetime);
679: #endif
680: }
681:
682: /*
683: * dojobs - print all jobs
684: */
685: dojobs(v)
686: char **v;
687: {
688: register struct process *pp;
689: register int flag = NUMBER|NAME|REASON;
690: int i;
691:
692: if (chkstop)
693: chkstop = 2;
694: if (*++v) {
695: if (v[1] || !eq(*v, "-l"))
696: error("Usage: jobs [ -l ]");
697: flag |= FANCY|JOBDIR;
698: }
699: for (i = 1; i <= pmaxindex; i++)
700: for (pp = proclist.p_next; pp; pp = pp->p_next)
701: if (pp->p_index == i && pp->p_pid == pp->p_jobid) {
702: pp->p_flags &= ~PNEEDNOTE;
703: if (!(pprint(pp, flag) & (PRUNNING|PSTOPPED)))
704: pflush(pp);
705: break;
706: }
707: }
708:
709: /*
710: * dofg - builtin - put the job into the foreground
711: */
712: dofg(v)
713: char **v;
714: {
715: register struct process *pp;
716:
717: okpcntl();
718: ++v;
719: do {
720: pp = pfind(*v);
721: pstart(pp, 1);
722: if (setintr)
723: sigignore(SIGINT);
724: pjwait(pp);
725: } while (*v && *++v);
726: }
727:
728: /*
729: * %... - builtin - put the job into the foreground
730: */
731: dofg1(v)
732: char **v;
733: {
734: register struct process *pp;
735:
736: okpcntl();
737: pp = pfind(v[0]);
738: pstart(pp, 1);
739: if (setintr)
740: sigignore(SIGINT);
741: pjwait(pp);
742: }
743:
744: /*
745: * dobg - builtin - put the job into the background
746: */
747: dobg(v)
748: char **v;
749: {
750: register struct process *pp;
751:
752: okpcntl();
753: ++v;
754: do {
755: pp = pfind(*v);
756: pstart(pp, 0);
757: } while (*v && *++v);
758: }
759:
760: /*
761: * %... & - builtin - put the job into the background
762: */
763: dobg1(v)
764: char **v;
765: {
766: register struct process *pp;
767:
768: pp = pfind(v[0]);
769: pstart(pp, 0);
770: }
771:
772: /*
773: * dostop - builtin - stop the job
774: */
775: dostop(v)
776: char **v;
777: {
778:
779: pkill(++v, SIGSTOP);
780: }
781:
782: /*
783: * dokill - builtin - superset of kill (1)
784: */
785: dokill(v)
786: char **v;
787: {
788: register int signum;
789: register char *name;
790:
791: v++;
792: if (v[0] && v[0][0] == '-') {
793: if (v[0][1] == 'l') {
794: for (signum = 1; signum <= NSIG; signum++) {
795: if (name = mesg[signum].iname)
796: printf("%s ", name);
797: if (signum == 16)
798: printf("\n");
799: }
800: printf("\n");
801: return;
802: }
803: if (digit(v[0][1])) {
804: signum = atoi(v[0]+1);
805: if (signum < 1 || signum > NSIG)
806: bferr("Bad signal number");
807: } else {
808: name = &v[0][1];
809: for (signum = 1; signum <= NSIG; signum++)
810: if (mesg[signum].iname &&
811: eq(name, mesg[signum].iname))
812: goto gotsig;
813: setname(name);
814: bferr("Unknown signal; kill -l lists signals");
815: }
816: gotsig:
817: v++;
818: } else
819: signum = SIGTERM;
820: pkill(v, signum);
821: }
822:
823: pkill(v, signum)
824: char **v;
825: int signum;
826: {
827: register struct process *pp, *np;
828: register int jobflags = 0;
829: int pid;
830: extern char *sys_errlist[];
831: int err = 0;
832:
833: if (setintr)
834: sighold(SIGINT);
835: sighold(SIGCHLD);
836: while (*v) {
837: if (**v == '%') {
838: np = pp = pfind(*v);
839: do
840: jobflags |= np->p_flags;
841: while ((np = np->p_friends) != pp);
842: switch (signum) {
843:
844: case SIGSTOP:
845: case SIGTSTP:
846: case SIGTTIN:
847: case SIGTTOU:
848: if ((jobflags & PRUNNING) == 0) {
849: printf("%s: Already stopped\n", *v);
850: err++;
851: goto cont;
852: }
853: }
854: killpg(pp->p_jobid, signum);
855: if (signum == SIGTERM || signum == SIGHUP)
856: killpg(pp->p_jobid, SIGCONT);
857: } else if (!digit(**v))
858: bferr("Arguments should be jobs or process id's");
859: else {
860: pid = atoi(*v);
861: if (kill(pid, signum) < 0) {
862: printf("%d: ", pid);
863: printf("%s\n", sys_errlist[errno]);
864: err++;
865: goto cont;
866: }
867: if (signum == SIGTERM || signum == SIGHUP)
868: kill(pid, SIGCONT);
869: }
870: cont:
871: v++;
872: }
873: sigrelse(SIGCHLD);
874: if (setintr)
875: sigrelse(SIGINT);
876: if (err)
877: error(NOSTR);
878: }
879:
880: /*
881: * pstart - start the job in foreground/background
882: */
883: pstart(pp, foregnd)
884: register struct process *pp;
885: int foregnd;
886: {
887: register struct process *np;
888: int jobflags = 0;
889:
890: sighold(SIGCHLD);
891: np = pp;
892: do {
893: jobflags |= np->p_flags;
894: if (np->p_flags&(PRUNNING|PSTOPPED)) {
895: np->p_flags |= PRUNNING;
896: np->p_flags &= ~PSTOPPED;
897: if (foregnd)
898: np->p_flags |= PFOREGND;
899: else
900: np->p_flags &= ~PFOREGND;
901: }
902: } while((np = np->p_friends) != pp);
903: pprint(pp, foregnd ? NAME|JOBDIR : NUMBER|NAME|AMPERSAND);
904: if (foregnd)
905: ioctl(FSHTTY, TIOCSPGRP, &pp->p_jobid);
906: if (jobflags&PSTOPPED)
907: killpg(pp->p_jobid, SIGCONT);
908: sigrelse(SIGCHLD);
909: }
910:
911: panystop(neednl)
912: {
913: register struct process *pp;
914:
915: chkstop = 2;
916: for (pp = proclist.p_next; pp; pp = pp->p_next)
917: if (pp->p_flags & PSTOPPED)
918: error("\nThere are stopped jobs" + 1 - neednl);
919: }
920:
921: struct process *
922: pfind(cp)
923: char *cp;
924: {
925: register struct process *pp, *np;
926:
927: if (cp == 0 || cp[1] == 0 || eq(cp, "%%") || eq(cp, "%+")) {
928: if (pcurrent == PNULL)
929: bferr("No current job");
930: return (pcurrent);
931: }
932: if (eq(cp, "%-") || eq(cp, "%#")) {
933: if (pprevious == PNULL)
934: bferr("No previous job");
935: return (pprevious);
936: }
937: if (digit(cp[1])) {
938: int index = atoi(cp+1);
939: for (pp = proclist.p_next; pp; pp = pp->p_next)
940: if (pp->p_index == index && pp->p_pid == pp->p_jobid)
941: return (pp);
942: bferr("No such job");
943: }
944: np = PNULL;
945: for (pp = proclist.p_next; pp; pp = pp->p_next)
946: if (pp->p_pid == pp->p_jobid) {
947: if (cp[1] == '?') {
948: register char *dp;
949: for (dp = pp->p_command; *dp; dp++) {
950: if (*dp != cp[2])
951: continue;
952: if (prefix(cp+2, dp))
953: goto match;
954: }
955: } else if (prefix(cp+1, pp->p_command)) {
956: match:
957: if (np)
958: bferr("Ambiguous");
959: np = pp;
960: }
961: }
962: if (np)
963: return (np);
964: if (cp[1] == '?')
965: bferr("No job matches pattern");
966: else
967: bferr("No such job");
968: }
969:
970: /*
971: * pgetcurr - find a job that is not pp and ``most recent''
972: */
973: struct process *
974: pgetcurr(pp)
975: register struct process *pp;
976: {
977: register struct process *np;
978:
979: for (np = proclist.p_next; np; np = np->p_next)
980: if (np != pcurrent && np != pp && np->p_pid &&
981: np->p_pid == np->p_jobid) {
982: return (np);
983: }
984: return (PNULL);
985: }
986:
987: /*
988: * donotify - flag the job so as to report termination asynchronously
989: */
990: donotify(v)
991: char **v;
992: {
993: register struct process *pp;
994:
995: pp = pfind(*++v);
996: pp->p_flags |= PNOTIFY;
997: }
998:
999: /*
1000: * Do the fork and whatever should be done in the child side that
1001: * should not be done if we are not forking at all (like for simple builtin's)
1002: * Also do everything that needs any signals fiddled with in the parent side
1003: *
1004: * Wanttty tells whether process and/or tty pgrps are to be manipulated:
1005: * -1: leave tty alone; inherit pgrp from parent
1006: * 0: already have tty; manipulate process pgrps only
1007: * 1: want to claim tty; manipulate process and tty pgrps
1008: * It is usually just the value of tpgrp.
1009: */
1010: pfork(t, wanttty)
1011: struct command *t; /* command we are forking for */
1012: int wanttty;
1013: {
1014: register int pid;
1015: bool ignint = 0;
1016: int pgrp;
1017:
1018: /*
1019: * A child will be uninterruptible only under very special
1020: * conditions. Remember that the semantics of '&' is
1021: * implemented by disconnecting the process from the tty so
1022: * signals do not need to ignored just for '&'.
1023: * Thus signals are set to default action for children unless:
1024: * we have had an "onintr -" (then specifically ignored)
1025: * we are not playing with signals (inherit action)
1026: */
1027: if (setintr)
1028: ignint = (tpgrp == -1 && (t->t_dflg&FINT))
1029: || (gointr && eq(gointr, "-"));
1030: /*
1031: * Hold SIGCHLD until we have the process installed in our table.
1032: */
1033: sighold(SIGCHLD);
1034: while ((pid = fork()) < 0)
1035: if (setintr == 0)
1036: sleep(FORKSLEEP);
1037: else {
1038: sigrelse(SIGINT);
1039: sigrelse(SIGCHLD);
1040: error("No more processes");
1041: }
1042: if (pid == 0) {
1043: settimes();
1044: pgrp = pcurrjob ? pcurrjob->p_jobid : getpid();
1045: pflushall();
1046: pcurrjob = PNULL;
1047: timesdone = 0;
1048: child++;
1049: if (setintr) {
1050: setintr = 0; /* until I think otherwise */
1051: sigrelse(SIGCHLD);
1052: /*
1053: * Children just get blown away on SIGINT, SIGQUIT
1054: * unless "onintr -" seen.
1055: */
1056: signal(SIGINT, ignint ? SIG_IGN : SIG_DFL);
1057: signal(SIGQUIT, ignint ? SIG_IGN : SIG_DFL);
1058: if (wanttty >= 0) {
1059: /* make stoppable */
1060: signal(SIGTSTP, SIG_DFL);
1061: signal(SIGTTIN, SIG_DFL);
1062: signal(SIGTTOU, SIG_DFL);
1063: }
1064: signal(SIGTERM, parterm);
1065: } else if (tpgrp == -1 && (t->t_dflg&FINT)) {
1066: signal(SIGINT, SIG_IGN);
1067: signal(SIGQUIT, SIG_IGN);
1068: }
1069: if (wanttty > 0)
1070: ioctl(FSHTTY, TIOCSPGRP, &pgrp);
1071: if (wanttty >= 0 && tpgrp >= 0)
1072: setpgrp(0, pgrp);
1073: if (tpgrp > 0)
1074: tpgrp = 0; /* gave tty away */
1075: /*
1076: * Nohup and nice apply only to TCOM's but it would be
1077: * nice (?!?) if you could say "nohup (foo;bar)"
1078: * Then the parser would have to know about nice/nohup/time
1079: */
1080: if (t->t_dflg & FNOHUP)
1081: signal(SIGHUP, SIG_IGN);
1082: if (t->t_dflg & FNICE) {
1083: /* sigh...
1084: nice(20);
1085: nice(-10);
1086: */
1087: nice(t->t_nice);
1088: }
1089:
1090: } else {
1091: palloc(pid, t);
1092: sigrelse(SIGCHLD);
1093: }
1094:
1095: return (pid);
1096: }
1097:
1098: okpcntl()
1099: {
1100:
1101: if (tpgrp == -1)
1102: error("No job control in this shell");
1103: if (tpgrp == 0)
1104: error("No job control in subshells");
1105: }
This archive runs on limited infrastructure. Preserving old code on modern bandwidth. Automated agents are requested to crawl responsibly.