src/common/process.c

#ifndef lint
static const char       RCSid[] = "$Id$";
#endif
/*
 * Routines to communicate with separate process via dual pipes
 *
 * External symbols declared in standard.h
 */

/* ====================================================================
 * The Radiance Software License, Version 1.0
 *
 * Copyright (c) 1990 - 2002 The Regents of the University of California,
 * through Lawrence Berkeley National Laboratory.   All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1. Redistributions of source code must retain the above copyright
 *         notice, this list of conditions and the following disclaimer.
 *
 * 2. Redistributions in binary form must reproduce the above copyright
 *       notice, this list of conditions and the following disclaimer in
 *       the documentation and/or other materials provided with the
 *       distribution.
 *
 * 3. The end-user documentation included with the redistribution,
 *           if any, must include the following acknowledgment:
 *             "This product includes Radiance software
 *                 (http://radsite.lbl.gov/)
 *                 developed by the Lawrence Berkeley National Laboratory
 *               (http://www.lbl.gov/)."
 *       Alternately, this acknowledgment may appear in the software itself,
 *       if and wherever such third-party acknowledgments normally appear.
 *
 * 4. The names "Radiance," "Lawrence Berkeley National Laboratory"
 *       and "The Regents of the University of California" must
 *       not be used to endorse or promote products derived from this
 *       software without prior written permission. For written
 *       permission, please contact [email protected].
 *
 * 5. Products derived from this software may not be called "Radiance",
 *       nor may "Radiance" appear in their name, without prior written
 *       permission of Lawrence Berkeley National Laboratory.
 *
 * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED.   IN NO EVENT SHALL Lawrence Berkeley National Laboratory OR
 * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
 * USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
 * OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 * ====================================================================
 *
 * This software consists of voluntary contributions made by many
 * individuals on behalf of Lawrence Berkeley National Laboratory.   For more
 * information on Lawrence Berkeley National Laboratory, please see
 * <http://www.lbl.gov/>.
 */

                                /* find pipe buffer limit */
#include  <sys/param.h>

#ifndef PIPE_BUF
#ifdef PIPSIZ
#define PIPE_BUF        PIPSIZ
#else
#ifdef PIPE_MAX
#define PIPE_BUF        PIPE_MAX
#else
#define PIPE_BUF        512             /* hyperconservative */
#endif
#endif
#endif

#include  "vfork.h"

#ifndef BSD
#include  <errno.h>
#endif


int
open_process(pd, av)            /* open communication to separate process */
int     pd[3];
char    *av[];
{
        extern char     *getpath(), *getenv();
        char    *compath;
        int     p0[2], p1[2];
                                        /* find executable */
        compath = getpath(av[0], getenv("PATH"), 1);
        if (compath == 0)
                return(0);
        if (pipe(p0) < 0 || pipe(p1) < 0)
                return(-1);
        if ((pd[2] = vfork()) == 0) {           /* if child */
                close(p0[1]);
                close(p1[0]);
                if (p0[0] != 0) {       /* connect p0 to stdin */
                        dup2(p0[0], 0);
                        close(p0[0]);
                }
                if (p1[1] != 1) {       /* connect p1 to stdout */
                        dup2(p1[1], 1);
                        close(p1[1]);
                }
                execv(compath, av);     /* exec command */
                perror(compath);
                _exit(127);
        }
        if (pd[2] == -1)
                return(-1);
        close(p0[0]);
        close(p1[1]);
        pd[0] = p1[0];
        pd[1] = p0[1];
        return(PIPE_BUF);
}


int
process(pd, recvbuf, sendbuf, nbr, nbs)         /* process data through pd */
int     pd[3];
char    *recvbuf, *sendbuf;
int     nbr, nbs;
{
        if (nbs > PIPE_BUF)
                return(-1);
        if (writebuf(pd[1], sendbuf, nbs) < nbs)
                return(-1);
        return(readbuf(pd[0], recvbuf, nbr));
}


int
close_process(pd)               /* close pipes and wait for process */
int     pd[3];
{
        int     pid, status;

        close(pd[1]);
        close(pd[0]);
        while ((pid = wait(&status)) != -1)
                if (pid == pd[2])
                        return(status>>8 & 0xff);
        return(-1);             /* ? unknown status */
}


int
readbuf(fd, bpos, siz)          /* read all of requested buffer */
int     fd;
char    *bpos;
int     siz;
{
        register int    cc = 0, nrem = siz;
retry:
        while (nrem > 0 && (cc = read(fd, bpos, nrem)) > 0) {
                bpos += cc;
                nrem -= cc;
        }
        if (cc < 0) {
#ifndef BSD
                if (errno == EINTR)     /* we were interrupted! */
                        goto retry;
#endif
                return(cc);
        }
        return(siz-nrem);
}


int
writebuf(fd, bpos, siz)         /* write all of requested buffer */
int     fd;
char    *bpos;
int     siz;
{
        register int    cc = 0, nrem = siz;
retry:
        while (nrem > 0 && (cc = write(fd, bpos, nrem)) > 0) {
                bpos += cc;
                nrem -= cc;
        }
        if (cc < 0) {
#ifndef BSD
                if (errno == EINTR)     /* we were interrupted! */
                        goto retry;
#endif
                return(cc);
        }
        return(siz-nrem);
}
Revision:	2.5
Committed:	Sat Feb 22 02:07:22 2003 UTC (21 years, 2 months ago) by greg
Content type:	text/plain
Branch:	MAIN
Changes since 2.4:	+60 -4 lines
Log Message:	Changes and check-in for 3.5 release Includes new source files and modifications not recorded for many years See ray/doc/notes/ReleaseNotes for notes between 3.1 and 3.5 release
#	Content
1	#ifndef lint
2	static const char RCSid[] = "$Id$";
3	#endif
4	/*
5	* Routines to communicate with separate process via dual pipes
6	*
7	* External symbols declared in standard.h
8	*/
9
10	/* ====================================================================
11	* The Radiance Software License, Version 1.0
12	*
13	* Copyright (c) 1990 - 2002 The Regents of the University of California,
14	* through Lawrence Berkeley National Laboratory. All rights reserved.
15	*
16	* Redistribution and use in source and binary forms, with or without
17	* modification, are permitted provided that the following conditions
18	* are met:
19	*
20	* 1. Redistributions of source code must retain the above copyright
21	* notice, this list of conditions and the following disclaimer.
22	*
23	* 2. Redistributions in binary form must reproduce the above copyright
24	* notice, this list of conditions and the following disclaimer in
25	* the documentation and/or other materials provided with the
26	* distribution.
27	*
28	* 3. The end-user documentation included with the redistribution,
29	* if any, must include the following acknowledgment:
30	* "This product includes Radiance software
31	* (http://radsite.lbl.gov/)
32	* developed by the Lawrence Berkeley National Laboratory
33	* (http://www.lbl.gov/)."
34	* Alternately, this acknowledgment may appear in the software itself,
35	* if and wherever such third-party acknowledgments normally appear.
36	*
37	* 4. The names "Radiance," "Lawrence Berkeley National Laboratory"
38	* and "The Regents of the University of California" must
39	* not be used to endorse or promote products derived from this
40	* software without prior written permission. For written
41	* permission, please contact [email protected].
42	*
43	* 5. Products derived from this software may not be called "Radiance",
44	* nor may "Radiance" appear in their name, without prior written
45	* permission of Lawrence Berkeley National Laboratory.
46	*
47	* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
48	* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
49	* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
50	* DISCLAIMED. IN NO EVENT SHALL Lawrence Berkeley National Laboratory OR
51	* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
52	* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
53	* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
54	* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
55	* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
56	* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
57	* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
58	* SUCH DAMAGE.
59	* ====================================================================
60	*
61	* This software consists of voluntary contributions made by many
62	* individuals on behalf of Lawrence Berkeley National Laboratory. For more
63	* information on Lawrence Berkeley National Laboratory, please see
64	* <http://www.lbl.gov/>.
65	*/
66
67	/* find pipe buffer limit */
68	#include <sys/param.h>
69
70	#ifndef PIPE_BUF
71	#ifdef PIPSIZ
72	#define PIPE_BUF PIPSIZ
73	#else
74	#ifdef PIPE_MAX
75	#define PIPE_BUF PIPE_MAX
76	#else
77	#define PIPE_BUF 512 /* hyperconservative */
78	#endif
79	#endif
80	#endif
81
82	#include "vfork.h"
83
84	#ifndef BSD
85	#include <errno.h>
86	#endif
87
88
89	int
90	open_process(pd, av) /* open communication to separate process */
91	int pd[3];
92	char *av[];
93	{
94	extern char getpath(), getenv();
95	char *compath;
96	int p0[2], p1[2];
97	/* find executable */
98	compath = getpath(av[0], getenv("PATH"), 1);
99	if (compath == 0)
100	return(0);
101	if (pipe(p0) < 0 \|\| pipe(p1) < 0)
102	return(-1);
103	if ((pd[2] = vfork()) == 0) { /* if child */
104	close(p0[1]);
105	close(p1[0]);
106	if (p0[0] != 0) { /* connect p0 to stdin */
107	dup2(p0[0], 0);
108	close(p0[0]);
109	}
110	if (p1[1] != 1) { /* connect p1 to stdout */
111	dup2(p1[1], 1);
112	close(p1[1]);
113	}
114	execv(compath, av); /* exec command */
115	perror(compath);
116	_exit(127);
117	}
118	if (pd[2] == -1)
119	return(-1);
120	close(p0[0]);
121	close(p1[1]);
122	pd[0] = p1[0];
123	pd[1] = p0[1];
124	return(PIPE_BUF);
125	}
126
127
128	int
129	process(pd, recvbuf, sendbuf, nbr, nbs) /* process data through pd */
130	int pd[3];
131	char recvbuf, sendbuf;
132	int nbr, nbs;
133	{
134	if (nbs > PIPE_BUF)
135	return(-1);
136	if (writebuf(pd[1], sendbuf, nbs) < nbs)
137	return(-1);
138	return(readbuf(pd[0], recvbuf, nbr));
139	}
140
141
142	int
143	close_process(pd) /* close pipes and wait for process */
144	int pd[3];
145	{
146	int pid, status;
147
148	close(pd[1]);
149	close(pd[0]);
150	while ((pid = wait(&status)) != -1)
151	if (pid == pd[2])
152	return(status>>8 & 0xff);
153	return(-1); /* ? unknown status */
154	}
155
156
157	int
158	readbuf(fd, bpos, siz) /* read all of requested buffer */
159	int fd;
160	char *bpos;
161	int siz;
162	{
163	register int cc = 0, nrem = siz;
164	retry:
165	while (nrem > 0 && (cc = read(fd, bpos, nrem)) > 0) {
166	bpos += cc;
167	nrem -= cc;
168	}
169	if (cc < 0) {
170	#ifndef BSD
171	if (errno == EINTR) /* we were interrupted! */
172	goto retry;
173	#endif
174	return(cc);
175	}
176	return(siz-nrem);
177	}
178
179
180	int
181	writebuf(fd, bpos, siz) /* write all of requested buffer */
182	int fd;
183	char *bpos;
184	int siz;
185	{
186	register int cc = 0, nrem = siz;
187	retry:
188	while (nrem > 0 && (cc = write(fd, bpos, nrem)) > 0) {
189	bpos += cc;
190	nrem -= cc;
191	}
192	if (cc < 0) {
193	#ifndef BSD
194	if (errno == EINTR) /* we were interrupted! */
195	goto retry;
196	#endif
197	return(cc);
198	}
199	return(siz-nrem);
200	}