--- ray/src/rt/raypwin.c	2008/02/08 18:27:31	2.1
+++ ray/src/rt/raypwin.c	2009/12/15 19:13:45	2.6
@@ -1,5 +1,5 @@
 #ifndef lint
-static const char RCSid[] = "$Id: raypwin.c,v 2.1 2008/02/08 18:27:31 greg Exp $";
+static const char RCSid[] = "$Id: raypwin.c,v 2.6 2009/12/15 19:13:45 greg Exp $";
 #endif
 /*
  *  raypwin.c - interface for parallel rendering using Radiance (Windows ver)
@@ -13,71 +13,113 @@ static const char RCSid[] = "$Id: raypwin.c,v 2.1 2008
  * See raypcalls.c for an explanation of these routines.
  */
 
-/***** XXX CURRENTLY, THIS IS JUST A COLLECTION OF FATAL STUBS XXX *****/
+/***** XXX CURRENTLY, THIS IS JUST A COLLECTION OF IMPOTENT STUBS XXX *****/
 
 #include  "ray.h"
 
+int		ray_pnprocs = 0;	/* number of child processes */
+int		ray_pnidle = 0;		/* number of idle children */
 
-extern void
+static RAY	queued_ray;
+
+void
 ray_pinit(		/* initialize ray-tracing processes */
 	char	*otnm,
 	int	nproc
 )
 {
-	error(CONSISTENCY, "parallel ray processing unimplemented");
+	ray_pdone(0);
+	ray_init(otnm);
+	ray_popen(nproc);
 }
 
 
-extern void
+int
 ray_psend(			/* add a ray to our send queue */
 	RAY	*r
 )
 {
-	error(CONSISTENCY, "parallel ray processing unimplemented");
+	if (r == NULL)
+		return(0);
+	if (ray_pnidle <= 0)
+		return(0);
+	queued_ray = *r;
+	ray_pnidle = 0;
+	return(1);
 }
 
 
-extern int
+int
 ray_pqueue(			/* queue a ray for computation */
 	RAY	*r
 )
 {
-	return(0);
+	if (r == NULL)
+		return(0);
+	if (ray_pnidle <= 0) {
+		RAY	new_ray = *r;
+		*r = queued_ray;
+		queued_ray = new_ray;
+	}
+	samplendx++;
+	rayvalue(r);
+	return(1);
 }
 
 
-extern int
+int
 ray_presult(		/* check for a completed ray */
 	RAY	*r,
 	int	poll
 )
 {
-	return(-1);
+	if (r == NULL)
+		return(0);
+	if (ray_pnidle <= 0) {
+		*r = queued_ray;
+		samplendx++;
+		rayvalue(r);
+		ray_pnidle = 1;
+		return(1);
+	}
+	return(0);
 }
 
 
-extern void
+void
 ray_pdone(		/* reap children and free data */
 	int	freall
 )
 {
+	ray_done(freall);
+	ray_pnprocs = ray_pnidle = 0;
 }
 
 
-extern void
+void
 ray_popen(			/* open the specified # processes */
 	int	nadd
 )
 {
-	error(CONSISTENCY, "parallel ray processing unimplemented");
+	if (ray_pnprocs + nadd > 1) {
+		error(WARNING, "only single process supported");
+		nadd = 1 - ray_pnprocs;
+	}
+	ray_pnprocs += nadd;
+	ray_pnidle += nadd;
 }
 
 
-extern void
+void
 ray_pclose(		/* close one or more child processes */
 	int	nsub
 )
 {
+	if (nsub > ray_pnprocs)
+		nsub = ray_pnprocs;
+	ray_pnprocs -= nsub;
+	if ((ray_pnidle -= nsub) < 0)
+		ray_pnidle = 0;
 }