ViewVC Help

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

root/Development/ray/src/common/rtprocess.h

Comparing ray/src/common/rtprocess.h (file contents):
Revision 3.18 by greg, Fri Feb 28 05:18:49 2020 UTC vs.
Revision 3.25 by greg, Tue Oct 29 00:35:06 2024 UTC

#	Line 8 | Line 8
8		#ifndef _RAD_PROCESS_H_
9		#define _RAD_PROCESS_H_
10
11	<	#include  <errno.h>
12	<	#include <stdio.h>
11	>	#include <errno.h>
12	>	#include "paths.h"
13		#if defined(_WIN32) || defined(_WIN64)
14		#include <windows.h> /* DWORD etc. */
15		typedef DWORD RT_PID;
#	Line 17 | Line 17
17		#define getpid _getpid
18		#define execv _execv
19		#define execvp _execvp
20	+	#ifdef _MSC_VER
21	+	#include <BaseTsd.h>
22	+	typedef SSIZE_T ssize_t;
23	+	#endif
24		#else
21	–	#include <sys/param.h>
22	–	#include <sys/types.h>
25		typedef pid_t RT_PID;
26		#endif
27
26	–	#include "paths.h"
28
29		#ifdef __cplusplus
30		extern "C" {
#	Line 53 | Line 54 | extern "C" {
54		attached to the standard output of the child, and subsequent writes
55		to that descriptor in the parent send data to the standard input
56		of the child. The returned r descriptor is set to -1, since
57	<	there is no output to read from any longer in the child.  The
57	>	there is no longer any output to read from the child.  The
58		default w descriptor of 1 will cause the child to act as a filter
59		on the output of the parent.  Make sure to call fflush(stdout) first
60		if any data was buffered.  It is illegal to set both PF_FILT_INP and
61		PF_FILT_OUT, as a circular process is guaranteed to hang.
62	+
63	+	If you want behavior similar to popen(cmd, "w") (again Unix-only),
64	+	keeping stdout open in parent, use a duplicate descriptor like so:
65	+	{
66	+	SUBPROC rtp = sp_inactive;
67	+	FILE    *fout;
68	+	fflush(stdout);
69	+	rtp.w = dup(fileno(stdout));
70	+	rtp.flags |= PF_FILT_OUT;
71	+	if (open_process(&rtp, cmd_argv) <= 0) {
72	+	perror(cmd_argv[0]); exit(1);
73	+	}
74	+	fout = fdopen(rtp.w, "w");
75	+	...write data to filter using fout until finished...
76	+	fclose(fout);
77	+	if (close_process(&rtp)) {
78	+	perror(cmd_argv[0]); exit(1);
79	+	}
80	+	...can continue sending data directly to stdout...
81	+	}
82	+	We could also have called open_process() after fdopen() above, or after
83	+	using fopen() on a file if we wanted to insert our filter before it.
84	+	A similar sequence may be used to filter from stdin without closing
85	+	it, though process termination becomes more difficult with two readers.
86	+	Filtering input from a file works better, since the file is then read by
87	+	the child only, as in:
88	+	{
89	+	SUBPROC rtp = sp_inactive;
90	+	FILE    *fin = fopen(fname, "r");
91	+	if (fin == NULL) {
92	+	open_error(fname); exit(1);
93	+	}
94	+	rtp.r = fileno(fin);
95	+	rtp.flags |= PF_FILT_INP;
96	+	if (open_process(&rtp, cmd_argv) <= 0) {
97	+	perror(cmd_argv[0]); fclose(fin); exit(1);
98	+	}
99	+	...read filtered file data from fin until EOF...
100	+	fclose(fin);
101	+	if (close_process(&rtp)) {
102	+	perror(cmd_argv[0]); exit(1);
103	+	}
104	+	}
105		*/
106
107
#	Line 90 | Line 134 | typedef struct {
134
135		extern int open_process(SUBPROC *pd, char *av[]);
136		extern int close_processes(SUBPROC pd[], int nproc);
137	<	extern int process(SUBPROC *pd, char *recvbuf, char *sendbuf, int nbr, int nbs);
138	<	extern int readbuf(int fd, char *bpos, int siz);
139	<	extern int writebuf(int fd, char *bpos, int siz);
137	>	extern int process(SUBPROC *pd, void *recvbuf, void *sendbuf, int nbr, int nbs);
138	>	extern ssize_t readbuf(int fd, void *bpos, ssize_t siz);
139	>	extern ssize_t writebuf(int fd, const void *bpos, ssize_t siz);
140
141		#if defined(_WIN32) || defined(_WIN64)
142		/* any non-negative increment will send the process to IDLE_PRIORITY_CLASS. */

Diff Legend

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