ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/radiance/ray/src/rt/rcontrib.c
Revision: 2.39
Committed: Thu Sep 10 01:01:18 2020 UTC (3 years, 8 months ago) by greg
Content type: text/plain
Branch: MAIN
Changes since 2.38: +6 -5 lines
Log Message:
fix(rcontrib): Removed pointless initial report of 0% done after 0 hours

File Contents

# User Rev Content
1 greg 2.1 #ifndef lint
2 greg 2.39 static const char RCSid[] = "$Id: rcontrib.c,v 2.38 2020/09/10 00:45:01 greg Exp $";
3 greg 2.1 #endif
4     /*
5     * Accumulate ray contributions for a set of materials
6     * Initialization and calculation routines
7     */
8    
9 greg 2.20 #include "copyright.h"
10    
11 greg 2.1 #include "rcontrib.h"
12     #include "otypes.h"
13 greg 2.14 #include "source.h"
14 greg 2.1
15 greg 2.2 char *shm_boundary = NULL; /* boundary of shared memory */
16    
17 greg 2.1 CUBE thescene; /* our scene */
18     OBJECT nsceneobjs; /* number of objects in our scene */
19    
20     int dimlist[MAXDIM]; /* sampling dimensions */
21     int ndims = 0; /* number of sampling dimensions */
22     int samplendx = 0; /* index for this sample */
23    
24 greg 2.33 void (*trace)() = NULL; /* trace call (NULL before rcinit) */
25 greg 2.1
26     int do_irrad = 0; /* compute irradiance? */
27    
28 greg 2.3 int rand_samp = 1; /* pure Monte Carlo sampling? */
29 greg 2.1
30 greg 2.8 double dstrsrc = 0.9; /* square source distribution */
31 greg 2.31 double shadthresh = 0.; /* shadow threshold */
32 greg 2.1 double shadcert = .75; /* shadow certainty */
33     int directrelay = 3; /* number of source relays */
34     int vspretest = 512; /* virtual source pretest density */
35     int directvis = 1; /* sources visible? */
36     double srcsizerat = .2; /* maximum ratio source size/dist. */
37    
38     COLOR cextinction = BLKCOLOR; /* global extinction coefficient */
39     COLOR salbedo = BLKCOLOR; /* global scattering albedo */
40     double seccg = 0.; /* global scattering eccentricity */
41     double ssampdist = 0.; /* scatter sampling distance */
42    
43 greg 2.30 double specthresh = .02; /* specular sampling threshold */
44 greg 2.1 double specjitter = 1.; /* specular sampling jitter */
45    
46     int backvis = 1; /* back face visibility */
47    
48 greg 2.3 int maxdepth = -10; /* maximum recursion depth */
49     double minweight = 2e-3; /* minimum ray weight */
50 greg 2.1
51     char *ambfile = NULL; /* ambient file name */
52     COLOR ambval = BLKCOLOR; /* ambient value */
53     int ambvwt = 0; /* initial weight for ambient value */
54 greg 2.31 double ambacc = 0.; /* ambient accuracy */
55 greg 2.1 int ambres = 256; /* ambient resolution */
56     int ambdiv = 350; /* ambient divisions */
57     int ambssamp = 0; /* ambient super-samples */
58     int ambounce = 1; /* ambient bounces */
59     char *amblist[AMBLLEN+1]; /* ambient include/exclude list */
60     int ambincl = -1; /* include == 1, exclude == 0 */
61    
62     int account; /* current accumulation count */
63     RNUMBER raysleft; /* number of rays left to trace */
64     long waitflush; /* how long until next flush */
65    
66 greg 2.4 RNUMBER lastray = 0; /* last ray number sent */
67     RNUMBER lastdone = 0; /* last ray output */
68 greg 2.1
69 greg 2.32 static void trace_contrib(RAY *r); /* our trace callback */
70    
71 greg 2.1 static void mcfree(void *p) { epfree((*(MODCONT *)p).binv); free(p); }
72    
73     LUTAB modconttab = LU_SINIT(NULL,mcfree); /* modifier lookup table */
74    
75     /************************** INITIALIZATION ROUTINES ***********************/
76    
77     char *
78     formstr( /* return format identifier */
79     int f
80     )
81     {
82     switch (f) {
83     case 'a': return("ascii");
84     case 'f': return("float");
85     case 'd': return("double");
86     case 'c': return(COLRFMT);
87     }
88     return("unknown");
89     }
90    
91    
92     /* Add modifier to our list to track */
93     MODCONT *
94 greg 2.20 addmodifier(char *modn, char *outf, char *prms, char *binv, int bincnt)
95 greg 2.1 {
96     LUENT *lep = lu_find(&modconttab,modn);
97     MODCONT *mp;
98     EPNODE *ebinv;
99     int i;
100    
101     if (lep->data != NULL) {
102     sprintf(errmsg, "duplicate modifier '%s'", modn);
103     error(USER, errmsg);
104     }
105 greg 2.27 if (nmods >= MAXMODLIST) {
106     sprintf(errmsg, "too many modifiers (%d limit)", MAXMODLIST);
107     error(INTERNAL, errmsg);
108     }
109 greg 2.26 if (!strcmp(modn, VOIDID)) {
110     sprintf(errmsg, "cannot track '%s' modifier", VOIDID);
111     error(USER, errmsg);
112     }
113 greg 2.1 modname[nmods++] = modn; /* XXX assumes static string */
114     lep->key = modn; /* XXX assumes static string */
115     if (binv == NULL)
116     binv = "0"; /* use single bin if unspecified */
117     ebinv = eparse(binv);
118     if (ebinv->type == NUM) { /* check value if constant */
119     bincnt = (int)(evalue(ebinv) + 1.5);
120     if (bincnt != 1) {
121     sprintf(errmsg, "illegal non-zero constant for bin (%s)",
122     binv);
123     error(USER, errmsg);
124     }
125     } else if (bincnt <= 0) {
126     sprintf(errmsg,
127     "unspecified or illegal bin count for modifier '%s'",
128     modn);
129     error(USER, errmsg);
130     }
131     /* initialize results holder */
132     mp = (MODCONT *)malloc(sizeof(MODCONT)+sizeof(DCOLOR)*(bincnt-1));
133     if (mp == NULL)
134     error(SYSTEM, "out of memory in addmodifier");
135     mp->outspec = outf; /* XXX assumes static string */
136     mp->modname = modn; /* XXX assumes static string */
137 greg 2.28 mp->params = prms; /* XXX assumes static string */
138 greg 2.1 mp->binv = ebinv;
139 greg 2.29 mp->bin0 = 0;
140 greg 2.1 mp->nbins = bincnt;
141     memset(mp->cbin, 0, sizeof(DCOLOR)*bincnt);
142 greg 2.29 /* figure out starting bin */
143     while (!getostream(mp->outspec, mp->modname, mp->bin0, 1))
144     mp->bin0++;
145     /* allocate other output streams */
146     for (i = 0; ++i < mp->nbins; )
147     getostream(mp->outspec, mp->modname, mp->bin0+i, 1);
148 greg 2.1 lep->data = (char *)mp;
149     return(mp);
150     }
151    
152    
153 greg 2.10 /* Add modifiers from a file list */
154 greg 2.1 void
155 greg 2.20 addmodfile(char *fname, char *outf, char *prms, char *binv, int bincnt)
156 greg 2.1 {
157     char *mname[MAXMODLIST];
158     int i;
159     /* find the file & store strings */
160 greg 2.27 i = wordfile(mname, MAXMODLIST, getpath(fname, getrlibpath(), R_OK));
161     if (i < 0) {
162 greg 2.1 sprintf(errmsg, "cannot find modifier file '%s'", fname);
163     error(SYSTEM, errmsg);
164     }
165 greg 2.27 if (i >= MAXMODLIST-1) {
166     sprintf(errmsg, "too many modifiers (%d limit) in file '%s'",
167     MAXMODLIST-1, fname);
168     error(INTERNAL, errmsg);
169     }
170 greg 2.1 for (i = 0; mname[i]; i++) /* add each one */
171 greg 2.20 addmodifier(mname[i], outf, prms, binv, bincnt);
172 greg 2.1 }
173    
174    
175 greg 2.37 /* Check if we have any more rays left (and report progress) */
176     int
177     morays(void)
178     {
179     static RNUMBER total_rays;
180     static time_t tstart, last_report;
181     time_t tnow;
182    
183     if (!raysleft)
184     return(1); /* unknown total, so nothing to do or say */
185    
186     if (report_intvl > 0 && (tnow = time(0)) >= last_report+report_intvl) {
187     if (!total_rays) {
188     total_rays = raysleft;
189     tstart = tnow;
190 greg 2.39 } else {
191     sprintf(errmsg, "%.2f%% done after %.3f hours\n",
192     100.-100.*raysleft/total_rays,
193     (1./3600.)*(tnow - tstart));
194     eputs(errmsg);
195 greg 2.37 }
196     last_report = tnow;
197     }
198     return(--raysleft);
199     }
200    
201    
202     /* Quit program */
203 greg 2.1 void
204 greg 2.37 quit(
205 greg 2.1 int code
206     )
207     {
208     if (nchild > 0) /* close children if any */
209 greg 2.10 end_children(code != 0);
210 greg 2.36 else if (nchild < 0)
211     _exit(code); /* avoid flush() in child */
212 greg 2.1 exit(code);
213     }
214    
215    
216     /* Initialize our process(es) */
217     static void
218 greg 2.28 rcinit(void)
219 greg 2.1 {
220     int i;
221    
222     if (nproc > MAXPROCESS)
223     sprintf(errmsg, "too many processes requested -- reducing to %d",
224     nproc = MAXPROCESS);
225 greg 2.2 if (nproc > 1) {
226     preload_objs(); /* preload auxiliary data */
227     /* set shared memory boundary */
228     shm_boundary = strcpy((char *)malloc(16), "SHM_BOUNDARY");
229     }
230 greg 2.32 trace = trace_contrib; /* set up trace call-back */
231 greg 2.14 for (i = 0; i < nsources; i++) /* tracing to sources as well */
232     source[i].sflags |= SFOLLOW;
233 greg 2.1 if (yres > 0) { /* set up flushing & ray counts */
234     if (xres > 0)
235     raysleft = (RNUMBER)xres*yres;
236     else
237     raysleft = yres;
238     } else
239     raysleft = 0;
240     if ((account = accumulate) > 1)
241     raysleft *= accumulate;
242     waitflush = (yres > 0) & (xres > 1) ? 0 : xres;
243    
244 greg 2.5 if (nproc > 1 && in_rchild()) /* forked child? */
245 greg 2.1 return; /* return to main processing loop */
246    
247 greg 2.5 if (recover) { /* recover previous output? */
248 greg 2.8 if (accumulate <= 0)
249 greg 2.5 reload_output();
250 greg 2.8 else
251 greg 2.5 recover_output();
252     }
253     if (nproc == 1) /* single process? */
254     return;
255 greg 2.8 /* else run appropriate controller */
256     if (accumulate <= 0)
257     feeder_loop();
258     else
259     parental_loop();
260 greg 2.1 quit(0); /* parent musn't return! */
261     }
262    
263     /************************** MAIN CALCULATION PROCESS ***********************/
264    
265     /* Our trace call to sum contributions */
266     static void
267     trace_contrib(RAY *r)
268     {
269     MODCONT *mp;
270 greg 2.19 double bval;
271 greg 2.1 int bn;
272     RREAL contr[3];
273    
274 greg 2.6 if (r->ro == NULL || r->ro->omod == OVOID)
275 greg 2.1 return;
276 greg 2.20 /* shadow ray not on source? */
277     if (r->rsrc >= 0 && source[r->rsrc].so != r->ro)
278     return;
279 greg 2.1
280     mp = (MODCONT *)lu_find(&modconttab,objptr(r->ro->omod)->oname)->data;
281    
282 greg 2.6 if (mp == NULL) /* not in our list? */
283     return;
284 greg 2.1
285 greg 2.21 worldfunc(RCCONTEXT, r); /* else set context */
286 greg 2.22 set_eparams((char *)mp->params);
287 greg 2.21 if ((bval = evalue(mp->binv)) <= -.5) /* and get bin number */
288     return; /* silently ignore negatives */
289 greg 2.19 if ((bn = (int)(bval + .5)) >= mp->nbins) {
290 greg 2.23 sprintf(errmsg, "bad bin number (%d ignored)", bn);
291     error(WARNING, errmsg);
292 greg 2.1 return;
293     }
294 greg 2.14 raycontrib(contr, r, PRIMARY); /* compute coefficient */
295 greg 2.1 if (contrib)
296 greg 2.14 multcolor(contr, r->rcol); /* -> contribution */
297 greg 2.1 addcolor(mp->cbin[bn], contr);
298     }
299    
300    
301 greg 2.7 /* Evaluate irradiance contributions */
302 greg 2.1 static void
303 greg 2.7 eval_irrad(FVECT org, FVECT dir)
304 greg 2.1 {
305 greg 2.7 RAY thisray;
306    
307     VSUM(thisray.rorg, org, dir, 1.1e-4);
308     thisray.rdir[0] = -dir[0];
309     thisray.rdir[1] = -dir[1];
310     thisray.rdir[2] = -dir[2];
311     thisray.rmax = 0.0;
312     rayorigin(&thisray, PRIMARY, NULL, NULL);
313 greg 2.16 /* pretend we hit surface */
314 greg 2.35 thisray.rxt = thisray.rot = 1e-5;
315 greg 2.7 thisray.rod = 1.0;
316 greg 2.15 VCOPY(thisray.ron, dir);
317 greg 2.7 VSUM(thisray.rop, org, dir, 1e-4);
318     samplendx++; /* compute result */
319     (*ofun[Lamb.otype].funp)(&Lamb, &thisray);
320 greg 2.1 }
321    
322    
323 greg 2.7 /* Evaluate radiance contributions */
324 greg 2.1 static void
325 greg 2.7 eval_rad(FVECT org, FVECT dir, double dmax)
326 greg 2.1 {
327     RAY thisray;
328     /* set up ray */
329 greg 2.7 VCOPY(thisray.rorg, org);
330     VCOPY(thisray.rdir, dir);
331     thisray.rmax = dmax;
332 greg 2.1 rayorigin(&thisray, PRIMARY, NULL, NULL);
333     samplendx++; /* call ray evaluation */
334     rayvalue(&thisray);
335     }
336    
337    
338     /* Accumulate and/or output ray contributions (child or only process) */
339     static void
340 greg 2.28 done_contrib(void)
341 greg 2.1 {
342     MODCONT *mp;
343     int i;
344    
345     if (account <= 0 || --account)
346     return; /* not time yet */
347    
348     for (i = 0; i < nmods; i++) { /* output records & clear */
349     mp = (MODCONT *)lu_find(&modconttab,modname[i])->data;
350     mod_output(mp);
351     memset(mp->cbin, 0, sizeof(DCOLOR)*mp->nbins);
352     }
353     end_record(); /* end lines & flush if time */
354    
355     account = accumulate; /* reset accumulation counter */
356     }
357    
358    
359     /* Principal calculation loop (called by main) */
360     void
361 greg 2.28 rcontrib(void)
362 greg 2.1 {
363     static int ignore_warning_given = 0;
364     FVECT orig, direc;
365     double d;
366 greg 2.2 /* initialize (& fork more of us) */
367 greg 2.1 rcinit();
368     /* load rays from stdin & process */
369     #ifdef getc_unlocked
370 greg 2.2 flockfile(stdin); /* avoid mutex overhead */
371 greg 2.1 #endif
372     while (getvec(orig) == 0 && getvec(direc) == 0) {
373     d = normalize(direc);
374 greg 2.17 if (nchild != -1 && (d == 0.0) & (accumulate == 0)) {
375 greg 2.1 if (!ignore_warning_given++)
376     error(WARNING,
377     "dummy ray(s) ignored during accumulation\n");
378     continue;
379     }
380     if (lastray+1 < lastray)
381     lastray = lastdone = 0;
382     ++lastray;
383     if (d == 0.0) { /* zero ==> flush */
384 greg 2.18 if ((yres <= 0) | (xres <= 1))
385 greg 2.17 waitflush = 1; /* flush after */
386     if (nchild == -1)
387     account = 1;
388 greg 2.7 } else if (imm_irrad) { /* else compute */
389     eval_irrad(orig, direc);
390     } else {
391     eval_rad(orig, direc, lim_dist ? d : 0.0);
392 greg 2.1 }
393     done_contrib(); /* accumulate/output */
394     ++lastdone;
395 greg 2.37 if (!morays())
396 greg 2.1 break; /* preemptive EOI */
397     }
398 greg 2.11 if (nchild != -1 && (accumulate <= 0) | (account < accumulate)) {
399 greg 2.1 if (account < accumulate) {
400     error(WARNING, "partial accumulation in final record");
401     accumulate -= account;
402     }
403     account = 1; /* output accumulated totals */
404     done_contrib();
405     }
406 greg 2.9 lu_done(&ofiletab); /* close output files */
407 greg 2.1 if (raysleft)
408     error(USER, "unexpected EOF on input");
409     }