2 * Copyright (c) 2004-2009, Jilles Tjoelker
5 * Redistribution and use in source and binary forms, with
6 * or without modification, are permitted provided that the
7 * following conditions are met:
9 * 1. Redistributions of source code must retain the above
10 * copyright notice, this list of conditions and the
11 * following disclaimer.
12 * 2. Redistributions in binary form must reproduce the
13 * above copyright notice, this list of conditions and
14 * the following disclaimer in the documentation and/or
15 * other materials provided with the distribution.
17 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND
18 * CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED
19 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
20 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
21 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
22 * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY
23 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
24 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
25 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
26 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
27 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
28 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
29 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
30 * USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY
34 #include <sys/cdefs.h>
35 __FBSDID("$FreeBSD$");
37 #include <sys/types.h>
38 #include <sys/event.h>
55 fprintf(stderr, "usage: pwait [-t timeout] [-ov] pid ...\n");
60 * pwait - wait for processes to terminate
63 main(int argc, char *argv[])
67 int oflag, tflag, verbose;
68 int i, kq, n, nleft, opt, status;
76 memset(&itv, 0, sizeof(itv));
78 while ((opt = getopt(argc, argv, "ot:v")) != -1) {
86 timeout = strtod(optarg, &end);
87 if (end == optarg || errno == ERANGE || timeout < 0) {
88 errx(EX_DATAERR, "timeout value");
101 errx(EX_DATAERR, "timeout unit");
103 if (timeout > 100000000L) {
104 errx(EX_DATAERR, "timeout value");
106 itv.it_value.tv_sec = (time_t)timeout;
107 timeout -= (time_t)timeout;
108 itv.it_value.tv_usec =
109 (suseconds_t)(timeout * 1000000UL);
129 err(EX_OSERR, "kqueue");
132 e = malloc((argc + tflag) * sizeof(struct kevent));
134 err(EX_OSERR, "malloc");
137 for (n = 0; n < argc; n++) {
139 /* Undocumented Solaris compat */
140 if (!strncmp(s, "/proc/", 6)) {
144 pid = strtol(s, &end, 10);
145 if (pid < 0 || *end != '\0' || errno != 0) {
146 warnx("%s: bad process id", s);
149 for (i = 0; i < nleft; i++) {
150 if (e[i].ident == (uintptr_t)pid) {
158 EV_SET(e + nleft, pid, EVFILT_PROC, EV_ADD, NOTE_EXIT, 0, NULL);
159 if (kevent(kq, e + nleft, 1, NULL, 0, NULL) == -1) {
169 if (nleft > 0 && tflag) {
171 * Explicitly detect SIGALRM so that an exit status of 124
172 * can be returned rather than 142.
174 EV_SET(e + nleft, SIGALRM, EVFILT_SIGNAL, EV_ADD, 0, 0, NULL);
175 if (kevent(kq, e + nleft, 1, NULL, 0, NULL) == -1) {
176 err(EX_OSERR, "kevent");
178 /* Ignore SIGALRM to not interrupt kevent(2). */
179 signal(SIGALRM, SIG_IGN);
180 if (setitimer(ITIMER_REAL, &itv, NULL) == -1) {
181 err(EX_OSERR, "setitimer");
185 n = kevent(kq, NULL, 0, e, nleft + tflag, NULL);
187 err(EX_OSERR, "kevent");
189 for (i = 0; i < n; i++) {
190 if (e[i].filter == EVFILT_SIGNAL) {
198 if (WIFEXITED(status)) {
199 printf("%ld: exited with status %d.\n",
201 WEXITSTATUS(status));
202 } else if (WIFSIGNALED(status)) {
203 printf("%ld: killed by signal %d.\n",
207 printf("%ld: terminated.\n",