ViewVC Help

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

root/radiance/src/rt/persist.c

Comparing src/rt/persist.c (file contents):
Revision 2.26 by greg, Sat Feb 22 02:07:29 2003 UTC vs.
Revision 2.45 by greg, Sat Jun 7 05:09:46 2025 UTC

#	Line 7 | Line 7 | static const char      RCSid[] = "$Id$";
7		*  External symbols declared in ray.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	<	*/
10	>	#include "copyright.h"
11
12	+	#include <string.h>
13	+	#include <signal.h>
14	+	#include <sys/stat.h>
15	+	#include <sys/types.h>
16	+
17	+	#include "platform.h"
18	+	#ifndef NON_POSIX /* XXX need abstraction for process management */
19	+	#include <sys/wait.h>
20	+	#endif
21	+
22	+	#include "rtprocess.h" /* getpid() */
23		#include "standard.h"
24		#include "random.h"
25	+	#include "ray.h"
26
27		#ifdef F_SETLKW
71	–	#include "paths.h"
28		#include "selcall.h"
73	–	#include <signal.h>
74	–	#include <sys/stat.h>
29
30		#ifndef TIMELIM
31		#define TIMELIM         (8*3600)        /* time limit for holding pattern */
32		#endif
33
80	–	#ifndef freebsd
81	–	#define mkfifo(fn,md)   mknod(fn, S_IFIFO|(md), 0)
82	–	#endif
83	–
84	–	extern void     io_process();
85	–
34		extern int      headismine;     /* boolean true if header belongs to me */
87	–
35		extern char     *progname;      /* global program name */
89	–
36		extern char     *errfile;       /* global error file name */
91	–
37		static char     *persistfname = NULL;   /* persist file name */
38		static int      persistfd = -1;         /* persist file descriptor */
94	–
39		static char     inpname[TEMPLEN+1], outpname[TEMPLEN+1], errname[TEMPLEN+1];
40
41	+	typedef void (rsighandler_t)(int);
42	+	static rsighandler_t sig_io;
43	+	static rsighandler_t sig_alrm;
44
45	+
46		void
47	<	pfdetach()              /* release persist (and header) resources */
47	>	pfdetach(void)          /* release persist (and header) resources */
48		{
49		if (persistfd >= 0)
50		close(persistfd);
#	Line 110 | Line 58 | pfdetach()             /* release persist (and header) resources
58
59
60		void
61	<	pfclean()               /* clean up persist files */
61	>	pfclean(void)           /* clean up persist files */
62		{
63		if (persistfd >= 0)
64		close(persistfd);
#	Line 126 | Line 74 | pfclean()              /* clean up persist files */
74
75
76		void
77	<	pflock(lf)              /* place or release exclusive lock on file */
78	<	int     lf;
77	>	pflock(         /* place or release exclusive lock on file */
78	>	int     lf
79	>	)
80		{
81		struct flock    fls;
82
#	Line 140 | Line 89 | int    lf;
89		}
90
91
92	<	persistfile(pfn)        /* open persist file and lock it */
93	<	char    *pfn;
92	>	void
93	>	persistfile(    /* open persist file and lock it */
94	>	char    *pfn
95	>	)
96		{
97		persistfd = open(pfn, O_WRONLY|O_CREAT|O_EXCL, 0644);
98		if (persistfd >= 0) {
#	Line 162 | Line 113 | char   *pfn;
113
114		static int      got_io;
115
116	<	static void sig_io() { got_io++; }
116	>	static void sig_io(int i) { got_io++; }
117
118	<	static void sig_alrm() { quit(0); }
118	>	static void sig_alrm(int i) { quit(0); }
119
120
121		void
122	<	pfhold()                /* holding pattern for idle rendering process */
122	>	pfhold(void)            /* holding pattern for idle rendering process */
123		{
124	<	void    (*oldalrm)();
124	>	rsighandler_t   *oldalrm;
125		char    buf[512];
126	<	register int    n;
126	>	int     n;
127		/* close input and output descriptors */
128	<	close(fileno(stdin));
129	<	close(fileno(stdout));
128	>	close(0);
129	>	close(1);
130		if (errfile == NULL)
131	<	close(fileno(stderr));
131	>	close(2);
132		/* create named pipes for input and output */
133		if (mkfifo(mktemp(strcpy(inpname,TEMPLATE)), 0600) < 0)
134		goto createrr;
#	Line 191 | Line 142 | pfhold()               /* holding pattern for idle rendering proces
142		n = strlen(buf);
143		if (write(persistfd, buf, n) < n)
144		error(SYSTEM, "error writing persist file");
145	<	lseek(persistfd, (off_t)0L, 0);
145	>	lseek(persistfd, (off_t)0, SEEK_SET);
146		/* wait TIMELIM for someone to signal us */
147		got_io = 0;
148		signal(SIGIO, sig_io);
149	<	oldalrm = (void (*)())signal(SIGALRM, sig_alrm);
149	>	oldalrm = signal(SIGALRM, sig_alrm);
150		alarm(TIMELIM);
151		pflock(0);                      /* unlock persist file for attach */
152		while (!got_io)
#	Line 205 | Line 156 | pfhold()               /* holding pattern for idle rendering proces
156		signal(SIGIO, SIG_DFL);
157		pflock(1);                      /* grab persist file back */
158		/* someone wants us; reopen stdin and stdout */
208	–	/*
209	–	if (freopen(inpname, "r", stdin) == NULL)
210	–	goto openerr;
211	–	if (freopen(outpname, "w", stdout) == NULL)
212	–	goto openerr;
213	–	*/
159		close(0);
160		if (open(inpname, O_RDONLY) != 0)
161		error(INTERNAL, "unexpected stdin file number");
#	Line 233 | Line 178 | pfhold()               /* holding pattern for idle rendering proces
178		return;
179		createrr:
180		error(SYSTEM, "cannot create named pipes in pfhold");
236	–	openerr:
237	–	error(SYSTEM, "cannot open named pipes in pfhold");
181		}
182
183
184		void
185	<	io_process()            /* just act as go-between for actual process */
185	>	io_process(void)                /* just act as go-between for actual process */
186		{
187	<	register char   *cp;
188	<	register int    nr, n;
187	>	char    *cp;
188	>	int     nr, n;
189		char    buf[BUFSIZ], *pfin, *pfout, *pferr;
190		int     pid, nfds;
191		int     fdout, fderr = -1;
#	Line 262 | Line 205 | io_process()           /* just act as go-between for actual pro
205		ftruncate(persistfd, (off_t)0L);        /* truncate persist file */
206		pfdetach();                     /* close & release persist file */
207		buf[nr] = '\0';                 /* parse what we got */
208	<	if ((cp = index(buf, ' ')) == NULL)
208	>	if ((cp = strchr(buf, ' ')) == NULL)
209		goto formerr;
210		*cp++ = '\0';
211		if ((pid = atoi(cp)) <= 0)
212		goto formerr;
213	<	if ((cp = index(cp, '\n')) == NULL)
213	>	if ((cp = strchr(cp, '\n')) == NULL)
214		goto formerr;
215		pfin = ++cp;
216	<	if ((cp = index(cp, '\n')) == NULL)
216	>	if ((cp = strchr(cp, '\n')) == NULL)
217		goto formerr;
218		*cp++ = '\0';
219		pfout = cp;
220	<	if ((cp = index(cp, '\n')) == NULL)
220	>	if ((cp = strchr(cp, '\n')) == NULL)
221		goto formerr;
222		*cp++ = '\0';
223		pferr = cp;
224	<	if ((cp = index(cp, '\n')) == NULL)
224	>	if ((cp = strchr(cp, '\n')) == NULL)
225		goto formerr;
226		*cp++ = '\0';
227		if (cp-buf != nr)
#	Line 351 | Line 294 | io_process()           /* just act as go-between for actual pro
294		if (!strncmp(cp, progname, n) &&
295		cp[n++] == ':' &&
296		cp[n++] == ' ') {
297	<	register struct erract  *ep;
297	>	struct erract   *ep;
298		for (ep = erract; ep < erract+NERRS;
299		ep++)
300		if (ep->pre[0] &&
#	Line 386 | Line 329 | io_process()           /* just act as go-between for actual pro
329		} while ((nr -= n) > 0);
330		}
331		}
332	<	wait(0);                /* wait for feeder process */
332	>	kill(pid, SIGTERM);     /* no more process to feed, so... */
333	>	waitpid(pid, 0, 0);     /* wait for feeder process */
334		_exit(status);
335		formerr:
336		error(USER, "format error in persist file");
#	Line 398 | Line 342 | writerr:
342
343		#else
344
345	<	void pfclean() {}
345	>	void pfclean(void) {}
346
347		#endif

Diff Legend

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