ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/radiance/ray/src/rt/rxcmain.cpp
Revision: 2.18
Committed: Thu Jun 5 18:26:46 2025 UTC (7 days, 4 hours ago) by greg
Branch: MAIN
CVS Tags: HEAD
Changes since 2.17: +1 -3 lines
Error occurred while calculating annotation data.
Log Message:
fix: Removed unnecessary or redundant progname declarations

File Contents

# Content
1 #ifndef lint
2 static const char RCSid[] = "$Id: rxcmain.cpp,v 2.17 2025/04/22 17:12:25 greg Exp $";
3 #endif
4 /*
5 * rxcmain.c - main for rxcontrib ray contribution tracer
6 */
7
8 #include "copyright.h"
9
10 #include <signal.h>
11 #include <time.h>
12 #include <ctype.h>
13 #include "RcontribSimulManager.h"
14 #include "platform.h"
15 #include "func.h"
16
17 const char *sigerr[NSIG]; /* signal error messages */
18
19 int nproc = 1; /* number of processes requested */
20
21 int inpfmt = 'a'; /* input format */
22 int outfmt = 'f'; /* output format */
23
24 int report_intvl = 0; /* reporting interval (seconds) */
25
26 RcontribSimulManager myRCmanager; // global rcontrib simulation manager
27
28 #define RCONTRIB_FEATURES "Multiprocessing\n" \
29 "Accumulation\nRecovery\n" \
30 "ImmediateIrradiance\n" \
31 "ProgressReporting\nDistanceLimiting\n" \
32 "InputFormats=a,f,d\nOutputFormats=f,d,c\n" \
33 "Outputs=V,W\n" \
34 "OutputCS=RGB,spec\n"
35
36 static void rxcontrib(const int rstart = 0);
37
38 static void
39 printdefaults(void) /* print default values to stdout */
40 {
41 printf("-c %-5d\t\t\t# accumulated rays per record\n", myRCmanager.accum);
42 printf(myRCmanager.HasFlag(RCcontrib) ?
43 "-V+\t\t\t\t# output contributions\n" :
44 "-V-\t\t\t\t# output coefficients\n");
45 if (myRCmanager.HasFlag(RTimmIrrad))
46 printf("-I+\t\t\t\t# immediate irradiance on\n");
47 printf("-n %-2d\t\t\t\t# number of rendering processes\n", nproc);
48 printf("-x %-9d\t\t\t# x resolution\n", myRCmanager.xres);
49 printf("-y %-9d\t\t\t# y resolution\n", myRCmanager.yres);
50 printf(myRCmanager.HasFlag(RTlimDist) ?
51 "-ld+\t\t\t\t# limit distance on\n" :
52 "-ld-\t\t\t\t# limit distance off\n");
53 printf("-f%c%c\t\t\t\t# format input/output = %s/%s\n",
54 inpfmt, outfmt, formstr(inpfmt), formstr(outfmt));
55 if (report_intvl > 0)
56 printf("-t %-9d\t\t\t# time between reports\n", report_intvl);
57 printf(erract[WARNING].pf != NULL ?
58 "-w+\t\t\t\t# warning messages on\n" :
59 "-w-\t\t\t\t# warning messages off\n");
60 print_rdefaults();
61 }
62
63
64 static void
65 onsig( /* fatal signal */
66 int signo
67 )
68 {
69 static int gotsig = 0;
70
71 if (gotsig++) /* two signals and we're gone! */
72 _exit(signo);
73
74 #ifdef SIGALRM
75 alarm(600); /* allow 10 minutes to clean up */
76 signal(SIGALRM, SIG_DFL); /* make certain we do die */
77 #endif
78 eputs("signal - ");
79 eputs(sigerr[signo]);
80 eputs("\n");
81 quit(3);
82 }
83
84
85 static void
86 sigdie( /* set fatal signal */
87 int signo,
88 const char *msg
89 )
90 {
91 if (signal(signo, onsig) == SIG_IGN)
92 signal(signo, SIG_IGN);
93 sigerr[signo] = msg;
94 }
95
96 /* set input/output format */
97 static void
98 setformat(const char *fmt)
99 {
100 switch (fmt[0]) {
101 case 'f':
102 case 'd':
103 SET_FILE_BINARY(stdin);
104 /* fall through */
105 case 'a':
106 inpfmt = fmt[0];
107 break;
108 default:
109 goto fmterr;
110 }
111 switch (fmt[1]) {
112 case '\0':
113 if (inpfmt == 'a')
114 goto fmterr;
115 outfmt = inpfmt;
116 return;
117 case 'f':
118 case 'd':
119 case 'c':
120 outfmt = fmt[1];
121 break;
122 default:
123 goto fmterr;
124 }
125 if (!fmt[2])
126 return;
127 fmterr:
128 sprintf(errmsg, "Unsupported i/o format: -f%s", fmt);
129 error(USER, errmsg);
130 }
131
132 /* Set default options */
133 static void
134 default_options(void)
135 {
136 rand_samp = 1;
137 dstrsrc = 0.9;
138 directrelay = 3;
139 vspretest = 512;
140 srcsizerat = .2;
141 specthresh = .02;
142 specjitter = 1.;
143 maxdepth = -10;
144 minweight = 2e-3;
145 ambres = 256;
146 ambdiv = 350;
147 ambounce = 1;
148 }
149
150 /* Set overriding options */
151 static void
152 override_options(void)
153 {
154 shadthresh = 0;
155 ambssamp = 0;
156 ambacc = 0;
157 }
158
159 int
160 main(int argc, char *argv[])
161 {
162 #define check(ol,al) if (argv[i][ol] || \
163 badarg(argc-i-1,argv+i+1,al)) \
164 goto badopt
165 #define check_bool(olen,var) switch (argv[i][olen]) { \
166 case '\0': var = !var; break; \
167 case 'y': case 'Y': case 't': case 'T': \
168 case '+': case '1': var = 1; break; \
169 case 'n': case 'N': case 'f': case 'F': \
170 case '-': case '0': var = 0; break; \
171 default: goto badopt; }
172 int force_open = 0;
173 int recover = 0;
174 char *curout = NULL;
175 char *prms = NULL;
176 char *binval = NULL;
177 int bincnt = 0;
178 int rval;
179 int i;
180 /* global program name */
181 progname = argv[0];
182 /* feature check only? */
183 strcat(RFeatureList, RCONTRIB_FEATURES);
184 if (argc > 1 && !strcmp(argv[1], "-features"))
185 return feature_status(argc-2, argv+2);
186 /* initialize calcomp routines early */
187 initfunc();
188 calcontext(RCCONTEXT);
189 /* set rcontrib defaults */
190 default_options();
191 /* option city */
192 for (i = 1; i < argc; i++) {
193 /* expand arguments */
194 while ((rval = expandarg(&argc, &argv, i)) > 0)
195 ;
196 if (rval < 0) {
197 sprintf(errmsg, "cannot expand '%s'", argv[i]);
198 error(SYSTEM, errmsg);
199 }
200 if (argv[i] == NULL || argv[i][0] != '-')
201 break; /* break from options */
202 if (!strcmp(argv[i], "-version")) {
203 puts(VersionID);
204 quit(0);
205 }
206 if (!strcmp(argv[i], "-defaults") ||
207 !strcmp(argv[i], "-help")) {
208 override_options();
209 printdefaults();
210 quit(0);
211 }
212 rval = getrenderopt(argc-i, argv+i);
213 if (rval >= 0) {
214 i += rval;
215 continue;
216 }
217 switch (argv[i][1]) {
218 case 'n': /* number of processes */
219 check(2,"i");
220 nproc = atoi(argv[++i]);
221 if (nproc < 0 && (nproc += RadSimulManager::GetNCores()) <= 0)
222 nproc = 1;
223 break;
224 case 'V': /* output contributions? */
225 rval = myRCmanager.HasFlag(RCcontrib);
226 check_bool(2,rval);
227 myRCmanager.SetFlag(RCcontrib, rval);
228 break;
229 case 'x': /* x resolution */
230 check(2,"i");
231 myRCmanager.xres = atoi(argv[++i]);
232 break;
233 case 'y': /* y resolution */
234 check(2,"i");
235 myRCmanager.yres = atoi(argv[++i]);
236 break;
237 case 'w': /* warnings on/off */
238 rval = (erract[WARNING].pf != NULL);
239 check_bool(2,rval);
240 if (rval) erract[WARNING].pf = wputs;
241 else erract[WARNING].pf = NULL;
242 break;
243 case 'l': /* limit distance */
244 if (argv[i][2] != 'd')
245 goto badopt;
246 rval = myRCmanager.HasFlag(RTlimDist);
247 check_bool(3,rval);
248 myRCmanager.SetFlag(RTlimDist, rval);
249 break;
250 case 'I': /* immed. irradiance */
251 rval = myRCmanager.HasFlag(RTimmIrrad);
252 check_bool(2,rval);
253 myRCmanager.SetFlag(RTimmIrrad, rval);
254 break;
255 case 'f': /* force or format */
256 if (argv[i][2] == 'o') {
257 check_bool(3,force_open);
258 break;
259 }
260 setformat(argv[i]+2);
261 myRCmanager.SetDataFormat(outfmt);
262 break;
263 case 'o': /* output file */
264 check(2,"s");
265 curout = argv[++i];
266 break;
267 case 'r': /* recover output */
268 check_bool(2,recover);
269 break;
270 case 'p': /* parameter setting(s) */
271 check(2,"s");
272 set_eparams(prms = argv[++i]);
273 break;
274 case 'c': /* sample count */
275 check(2,"i");
276 myRCmanager.accum = atoi(argv[++i]);
277 break;
278 case 'b': /* bin expression/count */
279 if (argv[i][2] == 'n') {
280 check(3,"s");
281 bincnt = (int)(eval(argv[++i]) + .5);
282 break;
283 }
284 check(2,"s");
285 binval = argv[++i];
286 break;
287 case 'm': /* modifier name */
288 check(2,"s");
289 myRCmanager.AddModifier(argv[++i], curout, prms, binval, bincnt);
290 break;
291 case 'M': /* file of modifier names */
292 check(2,"s");
293 myRCmanager.AddModFile(argv[++i], curout, prms, binval, bincnt);
294 break;
295 case 't': /* reporting interval */
296 check(2,"i");
297 report_intvl = atoi(argv[++i]);
298 break;
299 default:
300 goto badopt;
301 }
302 }
303 if (i != argc-1)
304 error(USER, "expected single octree argument");
305
306 override_options(); /* override some option settings */
307
308 if (!myRCmanager.GetOutput()) // check that we have work to do
309 error(USER, "missing required modifier argument");
310 // get ready to rock...
311 if (setspectrsamp(CNDX, WLPART) < 0)
312 error(USER, "unsupported spectral sampling");
313 /* set up signal handling */
314 sigdie(SIGINT, "Interrupt");
315 #ifdef SIGHUP
316 sigdie(SIGHUP, "Hangup");
317 #endif
318 sigdie(SIGTERM, "Terminate");
319 #ifdef SIGPIPE
320 sigdie(SIGPIPE, "Broken pipe");
321 #endif
322 #ifdef SIGALRM
323 sigdie(SIGALRM, "Alarm clock");
324 #endif
325 #ifdef SIGXCPU
326 sigdie(SIGXCPU, "CPU limit exceeded");
327 sigdie(SIGXFSZ, "File size exceeded");
328 #endif
329 #ifdef NICE
330 nice(NICE); /* lower priority */
331 #endif
332 // load octree
333 myRCmanager.LoadOctree(argv[argc-1]);
334 // add to header
335 myRCmanager.AddHeader(argc-1, argv);
336 {
337 char buf[128] = "SOFTWARE= ";
338 strcpy(buf+10, VersionID);
339 myRCmanager.AddHeader(buf);
340 }
341 // prepare output files
342 if (recover)
343 myRCmanager.outOp = RCOrecover;
344 else if (force_open)
345 myRCmanager.outOp = RCOforce;
346 else
347 myRCmanager.outOp = RCOnew;
348 // rval = # rows recovered
349 rval = myRCmanager.PrepOutput();
350 // check if recovered everything
351 if (rval >= myRCmanager.GetRowMax()) {
352 error(WARNING, "nothing left to compute");
353 quit(0);
354 }
355 rxcontrib(rval); /* trace ray contributions (loop) */
356
357 quit(0); /* exit clean */
358
359 badopt:
360 fprintf(stderr,
361 "Usage: %s [-V][-c count][-r][-e expr][-f source][-o ospec][-p p1=V1,p2=V2][-b binv][-bn N] {-m mod | -M file} [rtrace options] octree\n",
362 progname);
363 sprintf(errmsg, "command line error at '%s'", argv[i]);
364 error(USER, errmsg);
365 return(1); /* pro forma return */
366
367 #undef check
368 #undef check_bool
369 }
370
371
372 // skip specified number of bytes, return false if EOF
373 static bool
374 skipBytes(int n2skip)
375 {
376 while (n2skip-- > 0)
377 if (getchar() == EOF)
378 return false;
379 return true;
380 }
381
382
383 // skip specified number of whitespace-separated words, return false if EOF
384 static bool
385 skipWords(int n2skip)
386 {
387 int c;
388
389 while (n2skip-- > 0) {
390 do {
391 c = getchar();
392 } while (isspace(c));
393 do {
394 if (c == EOF) return false;
395 c = getchar();
396 } while (!isspace(c));
397 }
398 return true;
399 }
400
401
402 // read a bundle of myRCmanager.accum ray origins and directions
403 static bool
404 getRayBundle(FVECT *orig_dir = NULL)
405 {
406 int n2go = myRCmanager.accum;
407
408 switch (inpfmt) {
409 case 'a': // ASCII input
410 if (!orig_dir)
411 return skipWords(6*n2go);
412 while (n2go-- > 0) {
413 if (scanf(FVFORMAT, &orig_dir[0][0],
414 &orig_dir[0][1], &orig_dir[0][2]) != 3)
415 return false;
416 if (scanf(FVFORMAT, &orig_dir[1][0],
417 &orig_dir[1][1], &orig_dir[1][2]) != 3)
418 return false;
419 orig_dir += 2;
420 }
421 break;
422 case 'f': // float input
423 if (!orig_dir)
424 return skipBytes(6*sizeof(float)*n2go);
425 #ifdef SMLFLT
426 if (getbinary(orig_dir, sizeof(FVECT), 2*n2go, stdin) != 2*n2go)
427 return false;
428 orig_dir += 2*n2go;
429 #else
430 while (n2go-- > 0) {
431 float fvecs[6];
432 if (getbinary(fvecs, sizeof(fvecs), 1, stdin) != 1)
433 return false;
434 for (int i = 6; i--; )
435 orig_dir[0][i] = fvecs[i];
436 orig_dir += 2;
437 }
438 #endif
439 break;
440 case 'd': // double input
441 if (!orig_dir)
442 return skipBytes(6*sizeof(double)*n2go);
443 #ifndef SMLFLT
444 if (getbinary(orig_dir, sizeof(FVECT), 2*n2go, stdin) != 2*n2go)
445 return false;
446 orig_dir += 2*n2go;
447 #else
448 while (n2go-- > 0) {
449 double dvecs[6];
450 if (getbinary(dvecs, sizeof(dvecs), 1, stdin) != 1)
451 return false;
452 for (int i = 6; i--; )
453 orig_dir[0][i] = dvecs[i];
454 orig_dir += 2;
455 }
456 #endif
457 break;
458 default:
459 error(INTERNAL, "unsupported format in getRayBundle()");
460 return false;
461 }
462 n2go = myRCmanager.accum; // normalize directions
463 while (n2go-- > 0) {
464 orig_dir -= 2;
465 normalize(orig_dir[1]);
466 }
467 return true;
468 }
469
470
471 // Run loop to load data, report progress, etc.
472 void
473 rxcontrib(const int rstart)
474 {
475 const int totRows = myRCmanager.GetRowMax();
476 FVECT * odarr = (FVECT *)emalloc(sizeof(FVECT)*2*myRCmanager.accum);
477 time_t tstart, last_report;
478 int r = 0;
479
480 while (r < rstart) { // skip input rays already done
481 if (!getRayBundle())
482 goto readerr;
483 r++;
484 }
485 if (report_intvl > 0) { // set up reporting
486 if (r > 0) {
487 sprintf(errmsg, "recovered %.2f%% of total\n",
488 100.*r/totRows);
489 eputs(errmsg);
490 }
491 last_report = tstart = time(0);
492 }
493 // start children as requested
494 myRCmanager.SetThreadCount(nproc);
495
496 while (r < totRows) { // loop until done
497 time_t tnow;
498 if (!getRayBundle(odarr))
499 goto readerr;
500 if (myRCmanager.ComputeRecord(odarr) <= 0)
501 return; // error reported, hopefully...
502 r++;
503 if (report_intvl <= 0)
504 continue;
505 if (r == totRows) // need to finish up?
506 myRCmanager.SetThreadCount(1);
507 tnow = time(0);
508 if ((r < totRows) & (tnow < last_report+report_intvl))
509 continue;
510 sprintf(errmsg, "%.2f%% done after %.3f hours\n",
511 100.*myRCmanager.GetRowFinished()/totRows,
512 (1./3600.)*(tnow - tstart));
513 eputs(errmsg);
514 last_report = tnow;
515 }
516 efree(odarr);
517 return;
518 readerr:
519 sprintf(errmsg, "unexpected EOF on standard input (record %d of %d)",
520 r, totRows);
521 error(USER, errmsg);
522 }
523
524
525 void
526 wputs( /* warning output function */
527 const char *s
528 )
529 {
530 if (!erract[WARNING].pf) return;
531 int lasterrno = errno;
532 eputs(s);
533 errno = lasterrno;
534 }
535
536
537 void
538 eputs( /* put string to stderr */
539 const char *s
540 )
541 {
542 static int midline = 0;
543
544 if (!*s)
545 return;
546 if (!midline++) {
547 fputs(progname, stderr);
548 fputs(": ", stderr);
549 }
550 fputs(s, stderr);
551 if (s[strlen(s)-1] == '\n') {
552 fflush(stderr);
553 midline = 0;
554 }
555 }
556
557
558 /* Exit program */
559 void
560 quit(
561 int code
562 )
563 {
564 myRCmanager.FlushQueue(); // leave nothing in queue
565
566 exit(code);
567 }