ViewVC Help

View File | Revision Log | Show Annotations | Download File | Root Listing

root/Development/ray/src/common/process.c

Comparing ray/src/common/process.c (file contents):
Revision 2.4 by greg, Fri Apr 16 10:26:45 1993 UTC vs.
Revision 2.11 by greg, Fri Jan 15 19:01:53 2021 UTC

#	Line 1 | Line 1
1	–	/* Copyright (c) 1991 Regents of the University of California */
2	–
1		#ifndef lint
2	<	static char SCCSid[] = "$SunId$ LBL";
2	>	static const char       RCSid[] = "$Id$";
3		#endif
6	–
4		/*
5		* Routines to communicate with separate process via dual pipes
6	+	*
7	+	* External symbols declared in rtprocess.h
8		*/
9
10	<	/* find pipe buffer limit */
12	<	#include  <sys/param.h>
10	>	#include "copyright.h"
11
12	<	#ifndef PIPE_BUF
15	<	#ifdef PIPSIZ
16	<	#define PIPE_BUF        PIPSIZ
17	<	#else
18	<	#ifdef PIPE_MAX
19	<	#define PIPE_BUF        PIPE_MAX
20	<	#else
21	<	#define PIPE_BUF        512             /* hyperconservative */
22	<	#endif
23	<	#endif
24	<	#endif
12	>	#include "rtprocess.h"
13
14	<	#include  "vfork.h"
14	>	/*
15
16	<	#ifndef BSD
17	<	#include  <errno.h>
30	<	#endif
16	>	The functions open_process() and close_process() exist in
17	>	(currently) two versions, which are found in the files:
18
19	+	win_process.c
20	+	unix_process.c
21
22	<	int
34	<	open_process(pd, av)            /* open communication to separate process */
35	<	int     pd[3];
36	<	char    *av[];
37	<	{
38	<	extern char     *getpath(), *getenv();
39	<	char    *compath;
40	<	int     p0[2], p1[2];
41	<	/* find executable */
42	<	compath = getpath(av[0], getenv("PATH"), 1);
43	<	if (compath == 0)
44	<	return(0);
45	<	if (pipe(p0) < 0 || pipe(p1) < 0)
46	<	return(-1);
47	<	if ((pd[2] = vfork()) == 0) {           /* if child */
48	<	close(p0[1]);
49	<	close(p1[0]);
50	<	if (p0[0] != 0) {       /* connect p0 to stdin */
51	<	dup2(p0[0], 0);
52	<	close(p0[0]);
53	<	}
54	<	if (p1[1] != 1) {       /* connect p1 to stdout */
55	<	dup2(p1[1], 1);
56	<	close(p1[1]);
57	<	}
58	<	execv(compath, av);     /* exec command */
59	<	perror(compath);
60	<	_exit(127);
61	<	}
62	<	if (pd[2] == -1)
63	<	return(-1);
64	<	close(p0[0]);
65	<	close(p1[1]);
66	<	pd[0] = p1[0];
67	<	pd[1] = p0[1];
68	<	return(PIPE_BUF);
69	<	}
22	>	*/
23
71	–
24		int
25	<	process(pd, recvbuf, sendbuf, nbr, nbs)         /* process data through pd */
26	<	int     pd[3];
27	<	char    *recvbuf, *sendbuf;
28	<	int     nbr, nbs;
25	>	process(                /* process data through pd */
26	>	SUBPROC *pd,
27	>	char    *recvbuf, char *sendbuf,
28	>	int     nbr, int nbs
29	>	)
30		{
31	<	if (nbs > PIPE_BUF)
31	>	if (!(pd->flags & PF_RUNNING))
32		return(-1);
33	<	if (writebuf(pd[1], sendbuf, nbs) < nbs)
33	>	if (writebuf(pd->w, sendbuf, nbs) < nbs)
34		return(-1);
35	<	return(readbuf(pd[0], recvbuf, nbr));
35	>	return(readbuf(pd->r, recvbuf, nbr));
36		}
37
38
86	–	int
87	–	close_process(pd)               /* close pipes and wait for process */
88	–	int     pd[3];
89	–	{
90	–	int     pid, status;
39
40	<	close(pd[1]);
41	<	close(pd[0]);
42	<	while ((pid = wait(&status)) != -1)
43	<	if (pid == pd[2])
44	<	return(status>>8 & 0xff);
45	<	return(-1);             /* ? unknown status */
98	<	}
99	<
100	<
101	<	int
102	<	readbuf(fd, bpos, siz)          /* read all of requested buffer */
103	<	int     fd;
104	<	char    *bpos;
105	<	int     siz;
40	>	ssize_t
41	>	readbuf(                /* read all of requested buffer */
42	>	int     fd,
43	>	char    *bpos,
44	>	ssize_t siz
45	>	)
46		{
47	<	register int    cc = 0, nrem = siz;
47	>	ssize_t cc = 0, nrem = siz;
48		retry:
49		while (nrem > 0 && (cc = read(fd, bpos, nrem)) > 0) {
50		bpos += cc;
#	Line 121 | Line 61 | retry:
61		}
62
63
64	<	int
65	<	writebuf(fd, bpos, siz)         /* write all of requested buffer */
66	<	int     fd;
67	<	char    *bpos;
68	<	int     siz;
64	>	ssize_t
65	>	writebuf(               /* write all of requested buffer */
66	>	int     fd,
67	>	char    *bpos,
68	>	ssize_t siz
69	>	)
70		{
71	<	register int    cc = 0, nrem = siz;
71	>	ssize_t cc = 0, nrem = siz;
72		retry:
73		while (nrem > 0 && (cc = write(fd, bpos, nrem)) > 0) {
74		bpos += cc;

Diff Legend

–	Removed lines
+	Added lines
<	Changed lines (old)
>	Changed lines (new)