popen.c revision 1.1 1 1.1 cgd /*
2 1.1 cgd * Copyright (c) 1988 The Regents of the University of California.
3 1.1 cgd * All rights reserved.
4 1.1 cgd *
5 1.1 cgd * This code is derived from software written by Ken Arnold and
6 1.1 cgd * published in UNIX Review, Vol. 6, No. 8.
7 1.1 cgd *
8 1.1 cgd * Redistribution and use in source and binary forms, with or without
9 1.1 cgd * modification, are permitted provided that the following conditions
10 1.1 cgd * are met:
11 1.1 cgd * 1. Redistributions of source code must retain the above copyright
12 1.1 cgd * notice, this list of conditions and the following disclaimer.
13 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
14 1.1 cgd * notice, this list of conditions and the following disclaimer in the
15 1.1 cgd * documentation and/or other materials provided with the distribution.
16 1.1 cgd * 3. All advertising materials mentioning features or use of this software
17 1.1 cgd * must display the following acknowledgement:
18 1.1 cgd * This product includes software developed by the University of
19 1.1 cgd * California, Berkeley and its contributors.
20 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
21 1.1 cgd * may be used to endorse or promote products derived from this software
22 1.1 cgd * without specific prior written permission.
23 1.1 cgd *
24 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
25 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
26 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
27 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
28 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
29 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
30 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
31 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
32 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
33 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
34 1.1 cgd * SUCH DAMAGE.
35 1.1 cgd *
36 1.1 cgd */
37 1.1 cgd
38 1.1 cgd #ifndef lint
39 1.1 cgd static char sccsid[] = "@(#)popen.c 5.9 (Berkeley) 2/25/91";
40 1.1 cgd #endif /* not lint */
41 1.1 cgd
42 1.1 cgd #include <sys/types.h>
43 1.1 cgd #include <sys/wait.h>
44 1.1 cgd #include <signal.h>
45 1.1 cgd #include <unistd.h>
46 1.1 cgd #include <stdio.h>
47 1.1 cgd #include <stdlib.h>
48 1.1 cgd #include <string.h>
49 1.1 cgd
50 1.1 cgd /*
51 1.1 cgd * Special version of popen which avoids call to shell. This insures noone
52 1.1 cgd * may create a pipe to a hidden program as a side effect of a list or dir
53 1.1 cgd * command.
54 1.1 cgd */
55 1.1 cgd static int *pids;
56 1.1 cgd static int fds;
57 1.1 cgd
58 1.1 cgd FILE *
59 1.1 cgd ftpd_popen(program, type)
60 1.1 cgd char *program, *type;
61 1.1 cgd {
62 1.1 cgd register char *cp;
63 1.1 cgd FILE *iop;
64 1.1 cgd int argc, gargc, pdes[2], pid;
65 1.1 cgd char **pop, *argv[100], *gargv[1000], *vv[2];
66 1.1 cgd extern char **ftpglob(), **copyblk();
67 1.1 cgd
68 1.1 cgd if (*type != 'r' && *type != 'w' || type[1])
69 1.1 cgd return(NULL);
70 1.1 cgd
71 1.1 cgd if (!pids) {
72 1.1 cgd if ((fds = getdtablesize()) <= 0)
73 1.1 cgd return(NULL);
74 1.1 cgd if ((pids = (int *)malloc((u_int)(fds * sizeof(int)))) == NULL)
75 1.1 cgd return(NULL);
76 1.1 cgd bzero((char *)pids, fds * sizeof(int));
77 1.1 cgd }
78 1.1 cgd if (pipe(pdes) < 0)
79 1.1 cgd return(NULL);
80 1.1 cgd
81 1.1 cgd /* break up string into pieces */
82 1.1 cgd for (argc = 0, cp = program;; cp = NULL)
83 1.1 cgd if (!(argv[argc++] = strtok(cp, " \t\n")))
84 1.1 cgd break;
85 1.1 cgd
86 1.1 cgd /* glob each piece */
87 1.1 cgd gargv[0] = argv[0];
88 1.1 cgd for (gargc = argc = 1; argv[argc]; argc++) {
89 1.1 cgd if (!(pop = ftpglob(argv[argc]))) { /* globbing failed */
90 1.1 cgd vv[0] = argv[argc];
91 1.1 cgd vv[1] = NULL;
92 1.1 cgd pop = copyblk(vv);
93 1.1 cgd }
94 1.1 cgd argv[argc] = (char *)pop; /* save to free later */
95 1.1 cgd while (*pop && gargc < 1000)
96 1.1 cgd gargv[gargc++] = *pop++;
97 1.1 cgd }
98 1.1 cgd gargv[gargc] = NULL;
99 1.1 cgd
100 1.1 cgd iop = NULL;
101 1.1 cgd switch(pid = vfork()) {
102 1.1 cgd case -1: /* error */
103 1.1 cgd (void)close(pdes[0]);
104 1.1 cgd (void)close(pdes[1]);
105 1.1 cgd goto pfree;
106 1.1 cgd /* NOTREACHED */
107 1.1 cgd case 0: /* child */
108 1.1 cgd if (*type == 'r') {
109 1.1 cgd if (pdes[1] != 1) {
110 1.1 cgd dup2(pdes[1], 1);
111 1.1 cgd dup2(pdes[1], 2); /* stderr, too! */
112 1.1 cgd (void)close(pdes[1]);
113 1.1 cgd }
114 1.1 cgd (void)close(pdes[0]);
115 1.1 cgd } else {
116 1.1 cgd if (pdes[0] != 0) {
117 1.1 cgd dup2(pdes[0], 0);
118 1.1 cgd (void)close(pdes[0]);
119 1.1 cgd }
120 1.1 cgd (void)close(pdes[1]);
121 1.1 cgd }
122 1.1 cgd execv(gargv[0], gargv);
123 1.1 cgd _exit(1);
124 1.1 cgd }
125 1.1 cgd /* parent; assume fdopen can't fail... */
126 1.1 cgd if (*type == 'r') {
127 1.1 cgd iop = fdopen(pdes[0], type);
128 1.1 cgd (void)close(pdes[1]);
129 1.1 cgd } else {
130 1.1 cgd iop = fdopen(pdes[1], type);
131 1.1 cgd (void)close(pdes[0]);
132 1.1 cgd }
133 1.1 cgd pids[fileno(iop)] = pid;
134 1.1 cgd
135 1.1 cgd pfree: for (argc = 1; argv[argc] != NULL; argc++) {
136 1.1 cgd blkfree((char **)argv[argc]);
137 1.1 cgd free((char *)argv[argc]);
138 1.1 cgd }
139 1.1 cgd return(iop);
140 1.1 cgd }
141 1.1 cgd
142 1.1 cgd ftpd_pclose(iop)
143 1.1 cgd FILE *iop;
144 1.1 cgd {
145 1.1 cgd register int fdes;
146 1.1 cgd int omask;
147 1.1 cgd union wait stat_loc;
148 1.1 cgd int pid;
149 1.1 cgd
150 1.1 cgd /*
151 1.1 cgd * pclose returns -1 if stream is not associated with a
152 1.1 cgd * `popened' command, or, if already `pclosed'.
153 1.1 cgd */
154 1.1 cgd if (pids == 0 || pids[fdes = fileno(iop)] == 0)
155 1.1 cgd return(-1);
156 1.1 cgd (void)fclose(iop);
157 1.1 cgd omask = sigblock(sigmask(SIGINT)|sigmask(SIGQUIT)|sigmask(SIGHUP));
158 1.1 cgd while ((pid = wait((int *)&stat_loc)) != pids[fdes] && pid != -1);
159 1.1 cgd (void)sigsetmask(omask);
160 1.1 cgd pids[fdes] = 0;
161 1.1 cgd return(pid == -1 ? -1 : stat_loc.w_status);
162 1.1 cgd }
163