1 #define NOPLAN9DEFINES
2 #include <u.h>
3 #include <libc.h>
4 
5 #include <signal.h>
6 #include <sys/types.h>
7 #include <sys/time.h>
8 #include <sys/resource.h>
9 #include <sys/wait.h>
10 
11 static struct {
12 	int sig;
13 	char *str;
14 } tab[] = {
15 	SIGHUP,		"hangup",
16 	SIGINT,		"interrupt",
17 	SIGQUIT,		"quit",
18 	SIGILL,		"sys: trap: illegal instruction",
19 	SIGTRAP,		"sys: trace trap",
20 	SIGABRT,		"sys: abort",
21 #ifdef SIGEMT
22 	SIGEMT,		"sys: emulate instruction executed",
23 #endif
24 	SIGFPE,		"sys: fp: trap",
25 	SIGKILL,		"sys: kill",
26 	SIGBUS,		"sys: bus error",
27 	SIGSEGV,		"sys: segmentation violation",
28 	SIGALRM,		"alarm",
29 	SIGTERM,		"kill",
30 	SIGURG,		"sys: urgent condition on socket",
31 	SIGSTOP,		"sys: stop",
32 	SIGTSTP,		"sys: tstp",
33 	SIGCONT,		"sys: cont",
34 	SIGCHLD,		"sys: child",
35 	SIGTTIN,		"sys: ttin",
36 	SIGTTOU,		"sys: ttou",
37 	SIGIO,		"sys: i/o possible on fd",
38 	SIGXCPU,		"sys: cpu time limit exceeded",
39 	SIGXFSZ,		"sys: file size limit exceeded",
40 	SIGVTALRM,	"sys: virtual time alarm",
41 	SIGPROF,		"sys: profiling timer alarm",
42 	SIGWINCH,	"sys: window size change",
43 #ifdef SIGINFO
44 	SIGINFO,		"sys: status request",
45 #endif
46 	SIGUSR1,		"sys: usr1",
47 	SIGUSR2,		"sys: usr2",
48 	SIGPIPE,		"sys: write on closed pipe",
49 };
50 	
51 char*
52 _p9sigstr(int sig, char *tmp)
53 {
54 	int i;
55 
56 	for(i=0; i<nelem(tab); i++)
57 		if(tab[i].sig == sig)
58 			return tab[i].str;
59 	if(tmp == nil)
60 		return nil;
61 	sprint(tmp, "sys: signal %d", sig);
62 	return tmp;
63 }
64 
65 int
66 _p9strsig(char *s)
67 {
68 	int i;
69 
70 	for(i=0; i<nelem(tab); i++)
71 		if(strcmp(s, tab[i].str) == 0)
72 			return tab[i].sig;
73 	return 0;
74 }
75 
76 static int
77 _await(char *str, int n, int opt)
78 {
79 	int pid, status, cd;
80 	struct rusage ru;
81 	char buf[128], tmp[64];
82 	ulong u, s;
83 
84 	for(;;){
85 		pid = wait3(&status, opt, &ru);
86 		if(pid <= 0)
87 			return -1;
88 		u = ru.ru_utime.tv_sec*1000+((ru.ru_utime.tv_usec+500)/1000);
89 		s = ru.ru_stime.tv_sec*1000+((ru.ru_stime.tv_usec+500)/1000);
90 		if(WIFEXITED(status)){
91 			status = WEXITSTATUS(status);
92 			if(status)
93 				snprint(buf, sizeof buf, "%d %lud %lud %lud %d", pid, u, s, u+s, status);
94 			else
95 				snprint(buf, sizeof buf, "%d %lud %lud %lud ''", pid, u, s, u+s, status);
96 			strecpy(str, str+n, buf);
97 			return strlen(str);
98 		}
99 		if(WIFSIGNALED(status)){
100 			cd = WCOREDUMP(status);
101 			USED(cd);
102 			snprint(buf, sizeof buf, "%d %lud %lud %lud '%s'", pid, u, s, u+s, _p9sigstr(WTERMSIG(status), tmp));
103 			strecpy(str, str+n, buf);
104 			return strlen(str);
105 		}
106 	}
107 }
108 
109 int
110 await(char *str, int n)
111 {
112 	return _await(str, n, 0);
113 }
114 
115 int
116 awaitnohang(char *str, int n)
117 {
118 	return _await(str, n, WNOHANG);
119 }
120