ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/radiance/src/hd/rholo2l.c
(Generate patch)

Comparing src/hd/rholo2l.c (file contents):
Revision 3.3 by gregl, Fri Oct 31 15:49:41 1997 UTC vs.
Revision 3.11 by gregl, Tue Jan 20 15:04:23 1998 UTC

# Line 10 | Line 10 | static char SCCSid[] = "$SunId$ SGI";
10  
11   #include "rholo.h"
12   #include "random.h"
13 + #include "paths.h"
14   #include "selcall.h"
15   #include <signal.h>
16   #include <sys/time.h>
17  
18   #ifndef MAXPROC
19 < #define MAXPROC         16
19 > #define MAXPROC         64
20   #endif
21  
22 < static char     PFILE[] = "/usr/tmp/RHpersist"; /* persist file name */
22 > int     nprocs = 0;                             /* running process count */
23  
24 + static char     pfile[] = TEMPLATE;             /* persist file name */
25 +
26   static int      rtpd[MAXPROC][3];               /* process descriptors */
27   static float    *rtbuf = NULL;                  /* allocated i/o buffer */
28   static int      maxqlen = 0;                    /* maximum packets per queue */
26 – static int      nprocs = 0;                     /* number of processes */
29  
30   static PACKET   *pqueue[MAXPROC];               /* packet queues */
31   static int      pqlen[MAXPROC];                 /* packet queue lengths */
# Line 34 | Line 36 | start_rtrace()                 /* start rtrace process */
36   {
37          static char     buf1[8];
38          int     rmaxpack = 0;
39 <        int     psiz, npt, n;
39 >        int     psiz, n;
40                                          /* get number of processes */
41 <        if ((npt = ncprocs) <= 0)
41 >        if (ncprocs <= 0 || nprocs > 0)
42                  return(0);
43 <        if (npt > MAXPROC) {
43 >        if (ncprocs > MAXPROC) {
44                  sprintf(errmsg,
45                          "number of rtrace processes reduced from %d to %d",
46 <                                npt, MAXPROC);
46 >                                ncprocs, MAXPROC);
47                  error(WARNING, errmsg);
48 <                npt = MAXPROC;
48 >                ncprocs = MAXPROC;
49          }
50 <                                        /* add compulsory options */
51 <        rtargv[rtargc++] = "-i-";
52 <        rtargv[rtargc++] = "-I-";
53 <        rtargv[rtargc++] = "-h-";
54 <        rtargv[rtargc++] = "-ld-";
55 <        sprintf(buf1, "%d", RPACKSIZ);
56 <        rtargv[rtargc++] = "-x"; rtargv[rtargc++] = buf1;
57 <        rtargv[rtargc++] = "-y"; rtargv[rtargc++] = "0";
58 <        rtargv[rtargc++] = "-fff";
59 <        rtargv[rtargc++] = "-ovl";
60 <        rtargv[rtargc++] = nowarn ? "-w-" : "-w+";
61 <        if (npt > 1) {
62 <                rtargv[rtargc++] = "-PP"; rtargv[rtargc++] = PFILE;
50 >        if (rtargv[rtargc-1] != vval(OCTREE)) {
51 >                                                /* add compulsory options */
52 >                rtargv[rtargc++] = "-i-";
53 >                rtargv[rtargc++] = "-I-";
54 >                rtargv[rtargc++] = "-h-";
55 >                rtargv[rtargc++] = "-ld-";
56 >                sprintf(buf1, "%d", RPACKSIZ);
57 >                rtargv[rtargc++] = "-x"; rtargv[rtargc++] = buf1;
58 >                rtargv[rtargc++] = "-y"; rtargv[rtargc++] = "0";
59 >                rtargv[rtargc++] = "-fff";
60 >                rtargv[rtargc++] = vbool(VDIST) ? "-ovl" : "-ovL";
61 >                if (nowarn)
62 >                        rtargv[rtargc++] = "-w-";
63 >                if (ncprocs > 1) {
64 >                        mktemp(pfile);
65 >                        rtargv[rtargc++] = "-PP"; rtargv[rtargc++] = pfile;
66 >                }
67 >                rtargv[rtargc++] = vval(OCTREE);
68 >                rtargv[rtargc] = NULL;
69          }
62 –        rtargv[rtargc++] = vval(OCTREE);
63 –        rtargv[rtargc] = NULL;
70          maxqlen = 0;
71 <        for (nprocs = 0; nprocs < npt; nprocs++) {      /* spawn children */
71 >        for (nprocs = 0; nprocs < ncprocs; nprocs++) {  /* spawn children */
72                  psiz = open_process(rtpd[nprocs], rtargv);
73                  if (psiz <= 0)
74                          error(SYSTEM, "cannot start rtrace process");
# Line 71 | Line 77 | start_rtrace()                 /* start rtrace process */
77                          if (!(maxqlen = n))
78                                  error(INTERNAL,
79                                          "bad pipe buffer size assumption");
80 +                        sleep(2);
81                  } else if (n != maxqlen)
82                          error(INTERNAL, "varying pipe buffer size!");
83                  rmaxpack += n;
# Line 253 | Line 260 | flush_queue()                  /* empty all rtrace queues */
260                  if (pqlen[i]) {
261                          if (rpdone == NULL) {           /* tack on queue */
262                                  rpdone = rpl = pqueue[i];
263 <                                nr = rpl->nr;
263 >                                if ((nr = rpl->nr) < RPACKSIZ) nr++;
264                          } else {
265                                  rpl->next = pqueue[i];
266                                  nr = 0;
# Line 291 | Line 298 | killpersist()                  /* kill persistent process */
298          FILE    *fp;
299          int     pid;
300  
301 <        if ((fp = fopen(PFILE, "r")) == NULL)
301 >        if ((fp = fopen(pfile, "r")) == NULL)
302                  return;
303          if (fscanf(fp, "%*s %d", &pid) != 1 || kill(pid, SIGALRM) < 0)
304 <                unlink(PFILE);
304 >                unlink(pfile);
305          fclose(fp);
306   }
307  

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines