--- ray/src/rt/ambient.c	1992/07/16 12:09:08	2.6
+++ ray/src/rt/ambient.c	1992/07/16 19:44:46	2.11
@@ -7,9 +7,6 @@ static char SCCSid[] = "$SunId$ LBL";
 /*
  *  ambient.c - routines dealing with ambient (inter-reflected) component.
  *
- *  The macro AMBFLUSH (if defined) is the number of ambient values
- *	to wait before flushing to the ambient file.
- *
  *     5/9/86
  */
 
@@ -41,7 +38,6 @@ double  minarad;		/* minimum ambient radius */
 static AMBTREE  atrunk;		/* our ambient trunk node */
 
 static FILE  *ambfp = NULL;	/* ambient file pointer */
-static int  ambheadlen;		/* length of ambient file header */
 
 #define  AMBFLUSH	(BUFSIZ/AMBVALSIZ)
 
@@ -49,7 +45,10 @@ static int  ambheadlen;		/* length of ambient file hea
 
 #define  newambtree()	(AMBTREE *)calloc(8, sizeof(AMBTREE))
 
+extern long  ftell(), lseek();
+static int  initambfile(), avsave(), avinsert(), ambsync();
 
+
 setambres(ar)				/* set ambient resolution */
 int  ar;
 {
@@ -71,7 +70,7 @@ int  ar;
 setambient(afile)			/* initialize calculation */
 char  *afile;
 {
-	extern long  ftell();
+	long  headlen;
 	AMBVAL  amb;
 						/* init ambient limits */
 	setambres(ambres);
@@ -79,12 +78,13 @@ char  *afile;
 	if (afile != NULL)
 		if ((ambfp = fopen(afile, "r+")) != NULL) {
 			initambfile(0);
+			headlen = ftell(ambfp);
 			while (readambval(&amb, ambfp))
 				avinsert(&amb, &atrunk, thescene.cuorg,
 						thescene.cusize);
 							/* align */
-			fseek(ambfp, -((ftell(ambfp)-ambheadlen)%AMBVALSIZ), 1);
-		} else if ((ambfp = fopen(afile, "w")) != NULL)
+			fseek(ambfp, -((ftell(ambfp)-headlen)%AMBVALSIZ), 1);
+		} else if ((ambfp = fopen(afile, "w+")) != NULL)
 			initambfile(1);
 		else {
 			sprintf(errmsg, "cannot open ambient file \"%s\"",
@@ -94,30 +94,6 @@ char  *afile;
 }
 
 
-initambfile(creat)		/* initialize ambient file */
-int  creat;
-{
-	extern char  *progname, *octname;
-
-	setbuf(ambfp, bmalloc(BUFSIZ));
-	if (creat) {			/* new file */
-		fprintf(ambfp, "%s -av %g %g %g -ab %d -aa %g ",
-				progname, colval(ambval,RED),
-				colval(ambval,GRN), colval(ambval,BLU),
-				ambounce, ambacc);
-		fprintf(ambfp, "-ad %d -as %d -ar %d %s\n",
-				ambdiv, ambssamp, ambres,
-				octname==NULL ? "" : octname);
-		fputformat(AMBFMT, ambfp);
-		putc('\n', ambfp);
-		putambmagic(ambfp);
-		fflush(ambfp);
-	} else if (checkheader(ambfp, AMBFMT, NULL) < 0 || !hasambmagic(ambfp))
-		error(USER, "ambient file format error");
-	ambheadlen = ftell(ambfp);
-}
-
-
 ambnotify(obj)			/* record new modifier */
 OBJECT  obj;
 {
@@ -294,8 +270,7 @@ int  al;
 	VCOPY(amb.gpos, gp);
 	VCOPY(amb.gdir, gd);
 						/* insert into tree */
-	avinsert(&amb, &atrunk, thescene.cuorg, thescene.cusize);
-	avsave(&amb);				/* write to file */
+	avsave(&amb);				/* and save to file */
 	return(amb.rad);
 }
 
@@ -327,17 +302,46 @@ FVECT  pv, nv;
 
 
 static
-avsave(av)				/* save an ambient value */
+initambfile(creat)		/* initialize ambient file */
+int  creat;
+{
+	extern char  *progname, *octname, VersionID[];
+
+	setbuf(ambfp, bmalloc(BUFSIZ));
+	if (creat) {			/* new file */
+		fprintf(ambfp, "%s -av %g %g %g -ab %d -aa %g ",
+				progname, colval(ambval,RED),
+				colval(ambval,GRN), colval(ambval,BLU),
+				ambounce, ambacc);
+		fprintf(ambfp, "-ad %d -as %d -ar %d %s\n",
+				ambdiv, ambssamp, ambres,
+				octname==NULL ? "" : octname);
+		fprintf(ambfp, "SOFTWARE= %s\n", VersionID);
+		fputformat(AMBFMT, ambfp);
+		putc('\n', ambfp);
+		putambmagic(ambfp);
+		fflush(ambfp);
+#ifndef  NIX
+		sync();			/* protect against NFS buffering */
+#endif
+	} else if (checkheader(ambfp, AMBFMT, NULL) < 0 || !hasambmagic(ambfp))
+		error(USER, "bad ambient file");
+}
+
+
+static
+avsave(av)				/* insert and save an ambient value */
 AMBVAL  *av;
 {
 	static int  nunflshed = 0;
 
+	avinsert(av, &atrunk, thescene.cuorg, thescene.cusize);
 	if (ambfp == NULL)
 		return;
 	if (writambval(av, ambfp) < 0)
 		goto writerr;
 	if (++nunflshed >= AMBFLUSH) {
-		if (fflush(ambfp) == EOF)
+		if (ambsync() == EOF)
 			goto writerr;
 		nunflshed = 0;
 	}
@@ -382,3 +386,57 @@ double  s;
 memerr:
 	error(SYSTEM, "out of memory in avinsert");
 }
+
+
+#ifdef  NIX
+
+static
+ambsync()			/* flush ambient file */
+{
+	return(fflush(ambfp));
+}
+
+#else
+
+#include  <fcntl.h>
+#include  <sys/types.h>
+#include  <sys/stat.h>
+
+static
+ambsync()			/* synchronize ambient file */
+{
+	static FILE  *ambinp = NULL;
+	struct flock  fls;
+	struct stat  sts;
+	AMBVAL  avs;
+	long  lastpos, flen;
+	register int  n;
+				/* gain exclusive access */
+	fls.l_type = F_WRLCK;
+	fls.l_whence = 0;
+	fls.l_start = 0L;
+	fls.l_len = 0L;
+	if (fcntl(fileno(ambfp), F_SETLKW, &fls) < 0)
+		error(SYSTEM, "cannot lock ambient file");
+				/* see if file has grown */
+	lastpos = lseek(fileno(ambfp), 0L, 1);	/* get previous position */
+	if (fstat(fileno(ambfp), &sts) < 0)	/* get current length */
+		error(SYSTEM, "cannot stat ambient file");
+	flen = sts.st_size;
+	if (n = (flen - lastpos)/AMBVALSIZ) {	/* file has grown */
+		if (ambinp == NULL)		/* use duplicate file */
+			ambinp = fdopen(dup(fileno(ambfp)), "r");
+		while (n--) {			/* load contributed values */
+			readambval(&avs, ambinp);
+			avinsert(&avs,&atrunk,thescene.cuorg,thescene.cusize);
+		}				/* moves shared file pointer */
+		if (n = (flen - lastpos)%AMBVALSIZ)	/* alignment */
+			lseek(fileno(ambfp), flen-n, 0);
+	}
+	n = fflush(ambfp);			/* calls write() at last */
+	fls.l_type = F_UNLCK;			/* release file */
+	fcntl(fileno(ambfp), F_SETLKW, &fls);
+	return(n);
+}
+
+#endif