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
#	User	Rev	Content
1	greg	1.1	#ifndef lint
2	greg	2.5	static const char RCSid[] = "$Id$";
3	greg	1.1	#endif
4			/*
5			* Routines to communicate with separate process via dual pipes
6	greg	2.5	*
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	greg	1.1	*/
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	greg	2.2	#include "vfork.h"
83	greg	1.1
84	greg	2.4	#ifndef BSD
85			#include <errno.h>
86			#endif
87	greg	1.1
88	greg	2.4
89	greg	1.1	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	greg	2.3	register int cc = 0, nrem = siz;
164	greg	2.4	retry:
165	greg	1.1	while (nrem > 0 && (cc = read(fd, bpos, nrem)) > 0) {
166			bpos += cc;
167			nrem -= cc;
168			}
169	greg	2.4	if (cc < 0) {
170			#ifndef BSD
171			if (errno == EINTR) /* we were interrupted! */
172			goto retry;
173			#endif
174	greg	1.1	return(cc);
175	greg	2.4	}
176	greg	1.1	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	greg	2.3	register int cc = 0, nrem = siz;
187	greg	2.4	retry:
188	greg	1.1	while (nrem > 0 && (cc = write(fd, bpos, nrem)) > 0) {
189			bpos += cc;
190			nrem -= cc;
191			}
192	greg	2.4	if (cc < 0) {
193			#ifndef BSD
194			if (errno == EINTR) /* we were interrupted! */
195			goto retry;
196			#endif
197	greg	1.1	return(cc);
198	greg	2.4	}
199	greg	1.1	return(siz-nrem);
200			}