Please note that diffs are not public domain; they are subject to the copyright notices on the relevant files. =================================================================== RCS file: /ftp/cvs/cvsroot/src/lib/libc/gen/popen.c,v rcsdiff: /ftp/cvs/cvsroot/src/lib/libc/gen/popen.c,v: warning: Unknown phrases like `commitid ...;' are present. retrieving revision 1.5 retrieving revision 1.11 diff -u -p -r1.5 -r1.11 --- src/lib/libc/gen/popen.c 1993/08/26 00:44:55 1.5 +++ src/lib/libc/gen/popen.c 1995/06/16 07:05:33 1.11 @@ -1,6 +1,8 @@ +/* $NetBSD: popen.c,v 1.11 1995/06/16 07:05:33 jtc Exp $ */ + /* - * Copyright (c) 1988 The Regents of the University of California. - * All rights reserved. + * Copyright (c) 1988, 1993 + * The Regents of the University of California. All rights reserved. * * This code is derived from software written by Ken Arnold and * published in UNIX Review, Vol. 6, No. 8. @@ -35,99 +37,128 @@ */ #if defined(LIBC_SCCS) && !defined(lint) -/*static char *sccsid = "from: @(#)popen.c 5.15 (Berkeley) 2/23/91";*/ -static char *rcsid = "$Id: popen.c,v 1.5 1993/08/26 00:44:55 jtc Exp $"; +#if 0 +static char sccsid[] = "@(#)popen.c 8.1 (Berkeley) 6/4/93"; +#else +static char rcsid[] = "$NetBSD: popen.c,v 1.11 1995/06/16 07:05:33 jtc Exp $"; +#endif #endif /* LIBC_SCCS and not lint */ #include #include + +#include #include +#include #include #include #include -#include #include -static pid_t *pids; - +static struct pid { + struct pid *next; + FILE *fp; + pid_t pid; +} *pidlist; + FILE * -popen(command, type) - const char *command; +popen(program, type) + const char *program; const char *type; { + struct pid *cur; FILE *iop; - int pdes[2], fds, pid; + int pdes[2], pid; if (*type != 'r' && *type != 'w' || type[1]) { errno = EINVAL; return (NULL); } - if (pids == NULL) { - if ((fds = getdtablesize()) <= 0) - return (NULL); - if ((pids = (pid_t *)malloc((u_int)(fds * sizeof(int)))) == NULL) - return (NULL); - bzero((char *)pids, fds * sizeof(pid_t)); - } - if (pipe(pdes) < 0) + if ((cur = malloc(sizeof(struct pid))) == NULL) return (NULL); + + if (pipe(pdes) < 0) { + free(cur); + return (NULL); + } + switch (pid = vfork()) { - case -1: /* error */ - (void) close(pdes[0]); - (void) close(pdes[1]); + case -1: /* Error. */ + (void)close(pdes[0]); + (void)close(pdes[1]); + free(cur); return (NULL); /* NOTREACHED */ - case 0: /* child */ + case 0: /* Child. */ if (*type == 'r') { if (pdes[1] != STDOUT_FILENO) { - (void) dup2(pdes[1], STDOUT_FILENO); - (void) close(pdes[1]); + (void)dup2(pdes[1], STDOUT_FILENO); + (void)close(pdes[1]); } (void) close(pdes[0]); } else { if (pdes[0] != STDIN_FILENO) { - (void) dup2(pdes[0], STDIN_FILENO); - (void) close(pdes[0]); + (void)dup2(pdes[0], STDIN_FILENO); + (void)close(pdes[0]); } - (void) close(pdes[1]); + (void)close(pdes[1]); } - execl(_PATH_BSHELL, "sh", "-c", command, (char *) 0); + execl(_PATH_BSHELL, "sh", "-c", program, NULL); _exit(127); /* NOTREACHED */ } - /* parent; assume fdopen can't fail... */ + + /* Parent; assume fdopen can't fail. */ if (*type == 'r') { iop = fdopen(pdes[0], type); - (void) close(pdes[1]); + (void)close(pdes[1]); } else { iop = fdopen(pdes[1], type); - (void) close(pdes[0]); + (void)close(pdes[0]); } - pids[fileno(iop)] = pid; + + /* Link into list of file descriptors. */ + cur->fp = iop; + cur->pid = pid; + cur->next = pidlist; + pidlist = cur; + return (iop); } +/* + * pclose -- + * Pclose returns -1 if stream is not associated with a `popened' command, + * if already `pclosed', or waitpid returns an error. + */ int pclose(iop) FILE *iop; { - register int fdes; - int omask; + register struct pid *cur, *last; int pstat; pid_t pid; - /* - * pclose returns -1 if stream is not associated with a - * `popened' command, if already `pclosed', or waitpid - * returns an error. - */ - if (pids == NULL || pids[fdes = fileno(iop)] == 0) + (void)fclose(iop); + + /* Find the appropriate file pointer. */ + for (last = NULL, cur = pidlist; cur; last = cur, cur = cur->next) + if (cur->fp == iop) + break; + if (cur == NULL) return (-1); - (void) fclose(iop); + do { - pid = waitpid(pids[fdes], &pstat, 0); + pid = waitpid(cur->pid, &pstat, 0); } while (pid == -1 && errno == EINTR); - pids[fdes] = 0; + + /* Remove the entry from the linked list. */ + if (last == NULL) + pidlist = cur->next; + else + last->next = cur->next; + free(cur); + return (pid == -1 ? -1 : pstat); }