ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/radiance/ray/src/rt/RpictSimulManager.cpp
Revision: 2.12
Committed: Mon Sep 16 23:49:13 2024 UTC (7 months, 2 weeks ago) by greg
Branch: MAIN
Changes since 2.11: +24 -17 lines
Log Message:
feat(rxpiece): Initial working version of rxpiece C++ tiling renderer

File Contents

# Content
1 #ifndef lint
2 static const char RCSid[] = "$Id: RpictSimulManager.cpp,v 2.11 2024/08/27 18:50:01 greg Exp $";
3 #endif
4 /*
5 * RpictSimulManager.cpp
6 *
7 * Rpict simulation manager implementation
8 *
9 * Created by Greg Ward on 07/11/2024.
10 */
11
12 #define DEBUG 1 // XXX temporary!
13
14 #include <ctype.h>
15 #include "platform.h"
16 #include "RpictSimulManager.h"
17 #include "depthcodec.h"
18 #include "random.h"
19
20 /************* Imported globals from rxpmain.c *************/
21
22 extern VIEW ourview; /* viewing parameters */
23 extern int hres, vres; /* current image resolution */
24
25 extern int psample; /* pixel sample size */
26 extern double maxdiff; /* max. sample difference */
27 extern double dstrpix; /* square pixel distribution */
28
29 extern double mblur; /* motion blur parameter */
30
31 extern double dblur; /* depth-of-field blur parameter */
32
33 // Assign a pixel value (& depth) from rendered ray value
34 bool
35 PixelAccess::SetPixel(int x, int y, const RAY *rp)
36 {
37 if (!rp) return false;
38
39 COLOR col;
40 float zv = 0; // get depth if needed
41 if (DepthType())
42 zv = raydistance(rp);
43
44 switch (ColorSpace()) {
45 case RDTscolor: // keeping rendered spectrum?
46 case RDTscolr:
47 return SetPixel(x, y, rp->rcol, zv);
48 case RDTrgb:
49 case RDTrgbe:
50 case RDTxyz:
51 case RDTxyze:
52 scolor_out(col, primp, rp->rcol);
53 return SetPixel(x, y, col, zv);
54 default:
55 error(INTERNAL, "botched color space type in SetPixel()");
56 }
57 return false;
58 }
59
60 // Set color space after non-empty initialization
61 bool
62 PixelAccess::SetColorSpace(RenderDataType cs, RGBPRIMP pr)
63 {
64 if (!dtyp) return false;
65
66 if (!(cs = RDTcolorT(cs)))
67 cs = RDTcolorT(dtyp);
68 else if (RDTcommonE(cs) ^ RDTcommonE(dtyp))
69 return false;
70
71 if (NCSAMP == 3) {
72 if (cs == RDTscolr) cs = RDTrgbe;
73 else if (cs == RDTscolor) cs = RDTrgb;
74 }
75 switch (cs) {
76 case RDTxyze:
77 case RDTxyz:
78 primp = xyzprims;
79 break;
80 case RDTrgbe:
81 case RDTrgb:
82 primp = pr ? pr : stdprims;
83 break;
84 case RDTscolr:
85 case RDTscolor:
86 primp = NULL;
87 break;
88 default:
89 error(INTERNAL, "botched color space type in SetColorSpace()");
90 }
91 dtyp = RDTnewCT(dtyp, cs);
92 return true;
93 }
94
95 /*
96 * Set up rendering frame (call after octree loaded)
97 * Overall dimensions may be adjusted for view,
98 * optional pixel aspect ratio and tile grid
99 * Increments frameNo if >0
100 */
101 bool
102 RpictSimulManager::NewFrame(const VIEW &v, int xydim[2], double *ap, const int *tgrid)
103 {
104 double pasp = 1.;
105
106 if (!xydim) return false;
107 if (!ap) ap = &pasp;
108 if (&v == &vw) {
109 pvw.type = 0;
110 } else {
111 pvw = vw; // save previous view for motion blur
112 vw = v;
113 }
114 const char * verr = setview(&vw);
115 if (verr) {
116 error(WARNING, verr);
117 vw = pvw;
118 return false;
119 }
120 const double va = viewaspect(&vw);
121 normaspect(va, ap, &xydim[0], &xydim[1]);
122 // set up tiling?
123 if (tgrid && (tgrid[0] > 0) & (tgrid[1] > 0) & (tgrid[0]*tgrid[1] > 1)) {
124 if ((8*tgrid[0] >= xydim[0]) | (8*tgrid[1] >= xydim[1])) {
125 error(WARNING, "Excessive tiling for image size");
126 return false;
127 }
128 xydim[0] -= xydim[0] % (tgsize[0] = tgrid[0]);
129 xydim[1] -= xydim[1] % (tgsize[1] = tgrid[1]);
130 *ap = va * xydim[0] / xydim[1];
131 } else
132 tgsize[0] = tgsize[1] = 1;
133
134 if (vw.vaft > FTINY) rtFlags |= RTlimDist;
135 else rtFlags &= ~RTlimDist;
136 hvres[0] = xydim[0]; hvres[1] = xydim[1];
137 thvres[0] = hvres[0]/tgsize[0]; // presumed tile width
138 thvres[1] = hvres[1]/tgsize[1]; // ...and height
139 frameNo += (frameNo > 0); // caller may override after
140 return true;
141 }
142
143 // Call-back for rendered pixel
144 int
145 RpictSimulManager::RtCall(RAY *r, void *cd)
146 {
147 RpictSimulManager * rsp = (RpictSimulManager *)cd;
148 const int ty = (r->rno-1) / rsp->TWidth();
149 const int tx = r->rno-1 - (RNUMBER)ty*rsp->TWidth();
150
151 if (ty >= rsp->THeight()) {
152 error(INTERNAL, "bad pixel calculation position in RtCall()");
153 return -1;
154 }
155 if (!rsp->doneMap.TestAndSet(tx, ty)) {
156 error(WARNING, "duplicate pixel calculation");
157 return 0;
158 }
159 return rsp->pacc.SetPixel(tx, ty, r);
160 }
161
162 // Set up the specified tile (or entire image if NULL)
163 bool
164 RpictSimulManager::SetTile(const int ti[2])
165 {
166 tvw = vw; ptvw = pvw;
167
168 if (ti) {
169 if ((ti[0] < 0) | (ti[0] >= tgsize[0]) |
170 (ti[1] < 0) | (ti[1] >= tgsize[1])) {
171 error(INTERNAL, "illegal tile specification in SetTile()");
172 return false;
173 }
174 const char * verr = cropview(&tvw,
175 (double)ti[0]/tgsize[0],
176 (double)ti[1]/tgsize[1],
177 (ti[0]+1.)/tgsize[0],
178 (ti[1]+1.)/tgsize[1]);
179 if (verr) {
180 sprintf(errmsg, "crop failure @ tile (%d,%d)/(%d,%d): %s",
181 ti[0], ti[1], tgsize[0], tgsize[1], verr);
182 error(USER, errmsg);
183 return false;
184 } // previous tile view for blur
185 if (!ptvw.type | (mblur <= FTINY) ||
186 cropview(&ptvw, (double)ti[0]/tgsize[0],
187 (double)ti[1]/tgsize[1],
188 (ti[0]+1.)/tgsize[0],
189 (ti[1]+1.)/tgsize[1]))
190 ptvw.type = 0;
191
192 } else if ((tgsize[0] > 1) | (tgsize[1] > 1)) {
193 error(INTERNAL, "missing tile specification in SetTile()");
194 return false;
195 }
196 return doneMap.NewBitMap(TWidth(), THeight());
197 }
198
199 #define pixjitter() (.5+dstrpix*(.5-frandom()))
200
201 // Send the indicated pixel to ray tracer
202 bool
203 RpictSimulManager::ComputePixel(int x, int y)
204 {
205 DCHECK(doneMap.OffBitMap(x,y),
206 CONSISTENCY, "illegal pixel index in ComputPixel()");
207 int i;
208 FVECT rodir[2];
209 double hpos = (x+pixjitter())/TWidth();
210 double vpos = (y+pixjitter())/THeight();
211 double dlim = viewray(rodir[0], rodir[1], &tvw, hpos, vpos);
212 if (dlim < -FTINY) { // off view?
213 pacc.SetPixel(x, y, scblack);
214 doneMap.Set(x, y);
215 return true;
216 }
217 if (ptvw.type) { // add motion blur if requested
218 FVECT rorg2, rdir2;
219 double dlim2 = viewray(rorg2, rdir2, &ptvw, hpos, vpos);
220 if (dlim2 >= -FTINY) {
221 const double d = mblur*(.5-frandom());
222 dlim = (1.-d)*dlim + d*dlim2;
223 for (i = 3; i--; ) {
224 rodir[0][i] = (1.-d)*rodir[0][i] + d*rorg2[i];
225 rodir[1][i] = (1.-d)*rodir[1][i] + d*rdir2[i];
226 }
227 if (normalize(rodir[1]) == 0)
228 return false;
229 }
230 }
231 // depth-of-field blur if any
232 if (!jitteraperture(rodir[0], rodir[1], &tvw, dblur))
233 return false;
234 // include aft clipping distance?
235 for (i = (dlim > FTINY)*3; i--; )
236 rodir[1][i] *= dlim;
237
238 return EnqueueRay(rodir[0], rodir[1], (RNUMBER)y*TWidth()+x+1);
239 }
240
241 // Check if neighbor differences are below pixel sampling threshold
242 bool
243 RpictSimulManager::BelowSampThresh(const int x, const int y, const int noff[4][2]) const
244 {
245 SCOLOR pval[4];
246 float dist[4];
247 int i, j;
248
249 for (i = 4; i--; ) { // get pixels from tile store
250 const int px = x + noff[i][0];
251 const int py = y + noff[i][1];
252 if (!doneMap.Check(px, py) ||
253 !pacc.GetPixel(px, py, pval[i], &dist[i]))
254 return false;
255 }
256 // do pairwise comparisons
257 for (i = (pacc.DepthType() != RDTnone)*4; --i > 0; )
258 for (j = i; j--; )
259 if ((dist[i] - dist[j] > maxdiff*dist[j]) |
260 (dist[j] - dist[i] > maxdiff*dist[i]))
261 return false;
262 if (pacc.NC() > 3) {
263 for (i = 4; --i; )
264 for (j = i; j--; )
265 if (sbigsdiff(pval[i], pval[j], maxdiff))
266 return false;
267 } else {
268 for (i = 4; --i; )
269 for (j = i; j--; )
270 if (bigdiff(pval[i], pval[j], maxdiff))
271 return false;
272 }
273 return true;
274 }
275
276 // Fill an interior square patch with interpolated values
277 void
278 RpictSimulManager::FillSquare(const int x, const int y, const int noff[4][2])
279 {
280 SCOLOR pval[4];
281 float dist[4];
282 int i, j;
283 // assumes 4 corners are valid!
284 for (i = 4; i--; ) {
285 DCHECK(!doneMap.Check(x+noff[i][0], y+noff[i][1]),
286 CONSISTENCY, "inclusion of bad pixel in FillSquare()");
287 pacc.GetPixel(x+noff[i][0], y+noff[i][1], pval[i], &dist[i]);
288 }
289 i = abs(noff[1][0]-noff[0][0]);
290 j = abs(noff[1][1]-noff[0][1]); // i==j for diamond fill
291 const int slen = (i > j) ? i : j;
292 const bool spectr = (pacc.NC() > 3);
293 for (i = slen+1 + (i==j)*slen; i--; ) {
294 const double c1 = (i>slen ? i-slen-.5 : (double)i)/slen;
295 for (j = slen + (i<=slen); j--; ) {
296 const double c2 = (j + (i>slen)*.5)/slen;
297 const int px = int(x + (1.-c1)*(1.-c2)*noff[0][0] +
298 c1*(1.-c2)*noff[1][0] +
299 (1.-c1)*c2*noff[2][0] +
300 c1*c2*noff[3][0] + .5);
301 const int py = int(y + (1.-c1)*(1.-c2)*noff[0][1] +
302 c1*(1.-c2)*noff[1][1] +
303 (1.-c1)*c2*noff[2][1] +
304 c1*c2*noff[3][1] + .5);
305 if (!doneMap.TestAndSet(px, py))
306 continue;
307 float zval = 0;
308 if (pacc.DepthType())
309 zval = (1.-c1)*(1.-c2)*dist[0] + c1*(1.-c2)*dist[1] +
310 (1.-c1)*c2*dist[2] + c1*c2*dist[3];
311 if (spectr) { // XXX assumes pacc.NC() == NCSAMP
312 SCOLOR ipval, tpval;
313 copyscolor(ipval, pval[0]);
314 scalescolor(ipval, (1.-c1)*(1.-c2));
315 copyscolor(tpval, pval[1]);
316 scalescolor(tpval, c1*(1.-c2));
317 saddscolor(ipval, tpval);
318 copyscolor(tpval, pval[2]);
319 scalescolor(tpval, (1.-c1)*c2);
320 saddscolor(ipval, tpval);
321 copyscolor(tpval, pval[3]);
322 scalescolor(tpval, c1*c2);
323 saddscolor(ipval, tpval);
324 pacc.SetPixel(px, py, ipval, zval);
325 } else { // tristimulus interpolation
326 COLOR ipval, tpval;
327 copycolor(ipval, pval[0]);
328 scalecolor(ipval, (1.-c1)*(1.-c2));
329 copycolor(tpval, pval[1]);
330 scalecolor(tpval, c1*(1.-c2));
331 addcolor(ipval, tpval);
332 copycolor(tpval, pval[2]);
333 scalecolor(tpval, (1.-c1)*c2);
334 addcolor(ipval, tpval);
335 copycolor(tpval, pval[3]);
336 scalecolor(tpval, c1*c2);
337 addcolor(ipval, tpval);
338 pacc.SetPixel(px, py, ipval, zval);
339 }
340 }
341 }
342 }
343
344 // helper function to set up quincunx sampling
345 static void
346 SetQuincunx(ABitMap2 *bmp2, int noff[4][2], const int spc, bool odd, int x0, int y)
347 {
348 if (odd) { // order neighbors CCW
349 noff[0][0] = spc>>1; noff[0][1] = 0;
350 noff[1][0] = 0; noff[1][1] = spc>>1;
351 noff[2][0] = -(spc>>1); noff[2][1] = 0;
352 noff[3][0] = 0; noff[3][1] = -(spc>>1);
353 } else {
354 noff[0][0] = spc>>1; noff[0][1] = spc>>1;
355 noff[1][0] = -(spc>>1); noff[1][1] = spc>>1;
356 noff[2][0] = -(spc>>1); noff[2][1] = -(spc>>1);
357 noff[3][0] = spc>>1; noff[3][1] = -(spc>>1);
358 }
359 int nsteps; // non-negative range
360 if (x0 < -(spc>>1)) {
361 nsteps = (spc-1 - x0 - (spc>>1))/spc;
362 x0 += nsteps*spc;
363 }
364 if (y < 0) { // get past y==0
365 nsteps = ((spc>>1)-1 - y)/(spc>>1);
366 y += nsteps*(spc>>1);
367 odd ^= nsteps&1;
368 }
369 while (y < bmp2->Height()) {
370 for (int x = x0 + odd*(spc>>1); x < bmp2->Width(); x += spc)
371 bmp2->Set(x, y);
372 y += spc>>1;
373 odd = !odd;
374 }
375 }
376
377 // Render (or finish rendering) current tile
378 bool
379 RpictSimulManager::RenderRect(const int x0, const int y0)
380 {
381 if (!tvw.type || !Ready()) {
382 error(INTERNAL, "need octree and view for RenderRect()");
383 return false;
384 }
385 ABitMap2 doneSamples = doneMap;
386 int sp2 = ceil(log2((TWidth()>THeight() ? TWidth() : THeight()) - 1.));
387 int layer = 0;
388 int x, y;
389 while (sp2 > 0) {
390 ABitMap2 sampMap(TWidth(), THeight());
391 int noff[4][2];
392 if ((prCB != NULL) & (barPix == NULL))
393 (*prCB)(100.*doneMap.SumTotal()/doneMap.Width()/doneMap.Height());
394 SetQuincunx(&sampMap, noff, 1<<sp2, layer&1, x0, y0);
395 sampMap -= doneSamples; // avoid resampling pixels
396 // Are we into adaptive sampling realm?
397 if (noff[0][0]*noff[0][0] + noff[0][1]*noff[0][1] < psample*psample) {
398 if (FlushQueue() < 0) // need results to check thresholds
399 return false;
400 ABitMap2 fillMap = sampMap;
401 for (x = y = 0; sampMap.Find(&x, &y); x++)
402 if (BelowSampThresh(x, y, noff))
403 sampMap.Reset(x, y);
404 // spread sampling to neighbors...
405 const ABitMap2 origSampMap = sampMap;
406 for (x = 4; x--; ) {
407 ABitMap2 stamp = origSampMap;
408 stamp.Shift(noff[x][0] + noff[(x+1)&3][0],
409 noff[x][1] + noff[(x+1)&3][1]);
410 sampMap |= stamp;
411 } // ...but don't resample what's done
412 sampMap -= doneSamples;
413 // interpolate smooth regions
414 fillMap -= sampMap;
415 fillMap -= doneSamples;
416 for (x = y = 0; fillMap.Find(&x, &y); x++)
417 FillSquare(x, y, noff);
418 doneSamples |= doneMap;
419 } // compute required ray samples
420 for (x = y = 0; sampMap.Find(&x, &y); x++)
421 if (!ComputePixel(x, y))
422 return false;
423 doneSamples |= sampMap; // samples now done or at least queued
424 sp2 -= layer++ & 1; // next denser sampling
425 }
426 if (FlushQueue() < 0) // make sure we got everyone
427 return false;
428 x = y = 0;
429 if (doneMap.Find(&x, &y, false)) {
430 sprintf(errmsg, "missed %.4f%% of pixels in rectangle\n",
431 100. - 100.*doneMap.SumTotal() /
432 doneMap.Width() / doneMap.Height());
433 error(WARNING, errmsg);
434 }
435 if ((prCB != NULL) & (barPix == NULL))
436 (*prCB)(100.);
437 return true;
438 }
439
440 /*
441 * Render the specified tile in frame
442 * Tile pixels are contiguous unless ystride != 0
443 * Tiles numbered from upper-left at (0,0)
444 * Pixel type influenced by this->prims assignment
445 */
446 bool
447 RpictSimulManager::RenderTile(COLORV *rp, int ystride, float *zp, const int *tile)
448 {
449 if (!rp | (GetWidth() <= 0) | (GetHeight() <= 0) | !vw.type)
450 return false;
451 if (!ystride) // contiguous rows?
452 ystride = TWidth();
453 pacc.Init(rp, ystride, zp);
454 if (prims == xyzprims)
455 pacc.SetColorSpace(RDTxyz);
456 else if (prims)
457 pacc.SetColorSpace(RDTrgb, prims);
458
459 return SetTile(tile) && RenderRect();
460 }
461
462 // Same but store as common-exponent COLR or SCOLR
463 bool
464 RpictSimulManager::RenderTile(COLRV *bp, int ystride, float *zp, const int *tile)
465 {
466 if (!bp | (GetWidth() <= 0) | (GetHeight() <= 0) | !vw.type)
467 return false;
468 if (!ystride) // contiguous rows?
469 ystride = TWidth();
470 pacc.Init(bp, ystride, zp);
471 if (prims == xyzprims)
472 pacc.SetColorSpace(RDTxyze);
473 else if (prims)
474 pacc.SetColorSpace(RDTrgbe, prims);
475
476 return SetTile(tile) && RenderRect();
477 }
478
479 // Same but also use 16-bit encoded depth buffer
480 bool
481 RpictSimulManager::RenderTile(COLRV *bp, int ystride, short *dp, const int *tile)
482 {
483 if (!bp | (GetWidth() <= 0) | (GetHeight() <= 0) | !vw.type)
484 return false;
485 if (!ystride) // contiguous rows?
486 ystride = TWidth();
487 pacc.Init(bp, ystride, dp);
488 if (prims == xyzprims)
489 pacc.SetColorSpace(RDTxyze);
490 else if (prims)
491 pacc.SetColorSpace(RDTrgbe, prims);
492
493 return SetTile(tile) && RenderRect();
494 }
495
496 // Back to float color with 16-bit depth
497 bool
498 RpictSimulManager::RenderTile(COLORV *rp, int ystride, short *dp, const int *tile)
499 {
500 if (!rp | (GetWidth() <= 0) | (GetHeight() <= 0) | !vw.type)
501 return false;
502 if (!ystride) // contiguous rows?
503 ystride = TWidth();
504 pacc.Init(rp, ystride, dp);
505 if (prims == xyzprims)
506 pacc.SetColorSpace(RDTxyz);
507 else if (prims)
508 pacc.SetColorSpace(RDTrgb, prims);
509
510 return SetTile(tile) && RenderRect();
511 }
512
513 // Allocate a new render bar
514 void
515 RpictSimulManager::NewBar(int ht)
516 {
517 delete [] barPix;
518 delete [] barDepth;
519 if (ht > GetHeight()) ht = GetHeight();
520 if ((ht <= 0) | (GetWidth() <= 0)) {
521 doneMap.NewBitMap(0,0);
522 pacc.Init();
523 barPix = NULL; barDepth = NULL;
524 return;
525 }
526 thvres[0] = GetWidth();
527 thvres[1] = ht;
528 const int NC = prims ? 3 : NCSAMP;
529 barPix = new COLORV [ht*thvres[0]*NC];
530 barDepth = new float [ht*thvres[0]];
531 pacc.Init(barPix + (ht-1)*thvres[0]*NC,
532 -thvres[0], barDepth + (ht-1)*thvres[0]);
533 if (prims == xyzprims)
534 pacc.SetColorSpace(RDTxyz);
535 else if (prims)
536 pacc.SetColorSpace(RDTrgb, prims);
537
538 doneMap.NewBitMap(TWidth(), THeight());
539 }
540
541 // Shift render bar area the specified amount down the frame
542 bool
543 RpictSimulManager::LowerBar(int v, int ytop)
544 {
545 if (!barPix | !barDepth | (v > THeight()) | !tvw.type)
546 return false;
547 if (v <= 0) return !v;
548 if ((ytop -= v) <= 0)
549 return true;
550 tvw.voff -= double(v)/THeight();
551 ptvw.voff -= double(v)/THeight();
552 if (v == THeight()) {
553 doneMap.ClearBitMap();
554 return true;
555 }
556 const int NC = pacc.NC();
557 doneMap.Shift(0, v, false); // lift finished pixel samples
558 memmove(barPix, barPix + NC*TWidth()*v,
559 sizeof(COLORV)*NC*TWidth()*(THeight()-v));
560 memmove(barDepth, barDepth + TWidth()*v,
561 sizeof(float)*TWidth()*(THeight()-v));
562 if (ytop < THeight()) // mark what we won't do as finished
563 doneMap.ClearRect(0, 0, TWidth(), THeight()-ytop, true);
564 return true;
565 }
566
567 // Continue rendering from the specified position
568 bool
569 RpictSimulManager::RenderBelow(int ytop, const int vstep, FILE *pfp, const int dt, FILE *dfp)
570 {
571 if (ytop <= 0)
572 return true;
573 ptvw = pvw; // set starting bar's view
574 tvw = vw;
575 const char * verr = cropview(&tvw, 0., double(ytop-THeight())/GetHeight(),
576 1., double(ytop)/GetHeight());
577 if (verr) {
578 sprintf(errmsg, "illegal render bar below y=%d: %s", ytop, verr);
579 error(INTERNAL, errmsg);
580 return false;
581 }
582 if (!ptvw.type | (mblur <= FTINY) ||
583 cropview(&ptvw, 0., double(ytop-THeight())/GetHeight(),
584 1., double(ytop)/GetHeight()))
585 ptvw.type = 0;
586 // update spectral sampling
587 int rv = setspectrsamp(CNDX, WLPART);
588 if (rv < 0) {
589 error(USER, "unsupported spectral sampling");
590 return false;
591 }
592 if (!rv & (RDTcolorT(dt) != RDTscolor) & (RDTcolorT(dt) != RDTscolr))
593 error(WARNING, "spectral range incompatible with color output");
594 COLORV ** parr = NULL; // set up tiny source drawing
595 float ** zarr = NULL;
596 if (!ptvw.type && directvis && dblur <= FTINY) {
597 parr = new COLORV * [THeight()];
598 zarr = new float * [THeight()];
599 for (int n = THeight(); n-- > 0; ) {
600 parr[THeight()-1-n] = barPix + pacc.NC()*TWidth()*n;
601 zarr[THeight()-1-n] = barDepth + TWidth()*n;
602 }
603 ourview = vw; hres = GetWidth(); vres = GetHeight();
604 init_drawsources(psample);
605 }
606 int lastOut = ytop; // render down frame
607 while (ytop > 0) {
608 if (prCB)
609 (*prCB)(100.*(GetHeight()-ytop)/GetHeight());
610 if (!RenderRect(0, THeight()-ytop)) // render this bar
611 return false;
612 int nlines = lastOut - ytop + THeight();
613 if (nlines > ytop)
614 nlines = ytop;
615 else if (parr) // drawing sources?
616 drawsources(parr, prims, zarr,
617 0, hres, lastOut-nlines, nlines);
618
619 if (dfp) { // write out depth scanlines?
620 const float * dp = barDepth + TWidth()*(ytop-lastOut);
621 if (RDTdepthT(dt) == RDTdshort) {
622 for (int n = TWidth()*nlines; n-- > 0; dp++)
623 if (putint(depth2code(*dp, pacc.refDepth), 2, dfp) == EOF)
624 error(SYSTEM, "cannot write 16-bit depth buffer");
625 } else if (putbinary(dp, sizeof(float), TWidth()*nlines, dfp)
626 != TWidth()*nlines)
627 error(SYSTEM, "cannot write raw depth buffer");
628 }
629 COLORV * bpos = barPix + pacc.NC()*TWidth()*(ytop-lastOut);
630 while (nlines-- > 0) { // write pixel scanlines
631 switch (RDTcolorT(dt)) {
632 case RDTrgbe:
633 case RDTxyze:
634 if (fwritescan((COLOR *)bpos, TWidth(), pfp) < 0)
635 error(SYSTEM, "cannot write RGBE/XYZE output");
636 break;
637 case RDTscolr:
638 if (fwritesscan(bpos, pacc.NC(), TWidth(), pfp) < 0)
639 error(SYSTEM, "cannot write SCOLOR output");
640 break;
641 case RDTrgb:
642 case RDTxyz:
643 case RDTscolor:
644 if (putbinary(bpos, sizeof(COLORV)*pacc.NC(), TWidth(), pfp)
645 != TWidth())
646 error(SYSTEM, "cannot write SCOLOR output");
647 break;
648 default:
649 error(INTERNAL, "botched output color type in RenderBelow()");
650 break;
651 }
652 bpos += pacc.NC()*TWidth();
653 --lastOut;
654 } // flush each scan bar
655 if (fflush(pfp) == EOF || (dfp && fflush(dfp) == EOF))
656 error(SYSTEM, "output write error");
657 // advance down the frame
658 if (lastOut > 0 && !LowerBar(vstep, ytop))
659 return false;
660 ytop -= vstep;
661 }
662 delete [] parr;
663 delete [] zarr;
664 if (prCB)
665 (*prCB)(100.);
666 return true;
667 }
668
669 // Open new output picture file (and optional depth file)
670 RenderDataType
671 RpictSimulManager::NewOutput(FILE *pdfp[2], const char *pfname,
672 RenderDataType dt, const char *dfname)
673 {
674 pdfp[0] = pdfp[1] = NULL;
675 if (!RDTcolorT(dt))
676 error(INTERNAL, "missing color output type in NewOutput()");
677 if (NCSAMP == 3) {
678 if (RDTcolorT(dt) == RDTscolr)
679 dt = RDTnewCT(dt, prims==xyzprims ? RDTxyze : RDTrgbe);
680 else if (RDTcolorT(dt) == RDTscolor)
681 dt = RDTnewCT(dt, prims==xyzprims ? RDTxyz : RDTrgb);
682 }
683 if (!RDTdepthT(dt) ^ !dfname)
684 error(INTERNAL, "depth output requires file name and type in NewOutput()");
685 int fd = 1;
686 if (pfname) { // open picture output file
687 if (pfname[0] == '!') {
688 error(INTERNAL, "writing picture to a command not supported");
689 return RDTnone;
690 }
691 fd = open(pfname, O_RDWR|O_CREAT|O_EXCL, 0666);
692 }
693 if (fd < 0) {
694 if ((frameNo <= 0) | (errno != EEXIST)) {
695 sprintf(errmsg, "cannot open picture file '%s'", pfname);
696 error(SYSTEM, errmsg);
697 }
698 return RDTnone; // may be expected in sequence run
699 }
700 if (fd == 1)
701 pdfp[0] = stdout;
702 else if (!(pdfp[0] = fdopen(fd, "w+")))
703 error(SYSTEM, "failure calling fdopen()");
704 SET_FILE_BINARY(pdfp[0]); // write picture header
705 if ((pdfp[0] != stdout) | (frameNo <= 1)) {
706 newheader("RADIANCE", pdfp[0]);
707 fputs(GetHeadStr(), pdfp[0]);
708 }
709 fputs(VIEWSTR, pdfp[0]); fprintview(&vw, pdfp[0]); fputc('\n', pdfp[0]);
710 if (frameNo > 0)
711 fprintf(pdfp[0], "FRAME=%d\n", frameNo);
712 double pasp = viewaspect(&vw) * GetWidth() / GetHeight();
713 if ((0.99 > pasp) | (pasp > 1.01))
714 fputaspect(pasp, pdfp[0]);
715 fputnow(pdfp[0]);
716 switch (RDTcolorT(dt)) { // set primaries and picture format
717 case RDTrgbe:
718 if (!prims | (prims == xyzprims)) prims = stdprims;
719 fputprims(prims, pdfp[0]);
720 fputformat(COLRFMT, pdfp[0]);
721 break;
722 case RDTxyze:
723 prims = xyzprims;
724 fputformat(CIEFMT, pdfp[0]);
725 break;
726 case RDTscolr:
727 prims = NULL;
728 fputwlsplit(WLPART, pdfp[0]);
729 fputncomp(NCSAMP, pdfp[0]);
730 fputformat(SPECFMT, pdfp[0]);
731 break;
732 case RDTrgb:
733 if (!prims | (prims == xyzprims)) prims = stdprims;
734 fputprims(prims, pdfp[0]);
735 fputncomp(3, pdfp[0]);
736 fputendian(pdfp[0]);
737 fputformat("float", pdfp[0]);
738 break;
739 case RDTxyz:
740 prims = xyzprims;
741 fputprims(prims, pdfp[0]);
742 fputncomp(3, pdfp[0]);
743 fputendian(pdfp[0]);
744 fputformat("float", pdfp[0]);
745 break;
746 case RDTscolor:
747 prims = NULL;
748 fputwlsplit(WLPART, pdfp[0]);
749 fputncomp(NCSAMP, pdfp[0]);
750 fputendian(pdfp[0]);
751 fputformat("float", pdfp[0]);
752 break;
753 default:; // pro forma - caught this above
754 }
755 fputc('\n', pdfp[0]); // flush picture header
756 if (fflush(pdfp[0]) == EOF) {
757 sprintf(errmsg, "cannot write header to picture '%s'", pfname);
758 error(SYSTEM, errmsg);
759 fclose(pdfp[0]);
760 pdfp[0] = NULL;
761 return RDTnone;
762 }
763 if (dfname) { // open depth output
764 if (dfname[0] == '!')
765 pdfp[1] = popen(dfname+1, "w");
766 else
767 pdfp[1] = fopen(dfname, "w+");
768 if (!pdfp[1]) {
769 sprintf(errmsg, "cannot open depth output '%s'", dfname);
770 error(SYSTEM, errmsg);
771 fclose(pdfp[0]);
772 pdfp[0] = NULL;
773 return RDTnone;
774 }
775 SET_FILE_BINARY(pdfp[1]);
776 }
777 if (RDTdepthT(dt) == RDTdshort) { // write header for 16-bit depth?
778 newheader("RADIANCE", pdfp[1]);
779 fputs(GetHeadStr(), pdfp[1]);
780 fputs(VIEWSTR, pdfp[1]); fprintview(&vw, pdfp[1]); fputc('\n', pdfp[1]);
781 fputs(DEPTHSTR, pdfp[1]); fputs(dunit, pdfp[1]); fputc('\n', pdfp[1]);
782 fputformat(DEPTH16FMT, pdfp[1]);
783 fputc('\n', pdfp[1]); // end-of-info
784 if (fflush(pdfp[1]) == EOF) {
785 sprintf(errmsg, "cannot write header to '%s'", dfname);
786 error(SYSTEM, errmsg);
787 fclose(pdfp[0]); fclose(pdfp[1]);
788 pdfp[0] = pdfp[1] = NULL;
789 return RDTnone;
790 }
791 }
792 return dt; // ready to roll
793 }
794
795 /*
796 * Render and write a frame to the named file
797 * Include any header lines set prior to call
798 * Picture file must not exist
799 * Write pixels to stdout if !pfname
800 * Write depth to a command if dfname[0]=='!'
801 */
802 RenderDataType
803 RpictSimulManager::RenderFrame(const char *pfname, RenderDataType dt, const char *dfname)
804 {
805 FILE *pdfp[2];
806 // prepare output file(s)
807 dt = NewOutput(pdfp, pfname, dt, dfname);
808 if (dt == RDTnone)
809 return RDTnone;
810 // add resolution string(s)
811 fprtresolu(GetWidth(), GetHeight(), pdfp[0]);
812 if (RDTdepthT(dt) == RDTdshort)
813 fprtresolu(GetWidth(), GetHeight(), pdfp[1]);
814
815 const int bheight = (psample > 1) ? int(8*psample+.99) : 16;
816 const int vstep = bheight >> (psample > 1);
817
818 NewBar(bheight); // render frame if we can
819 if (!RenderBelow(GetHeight(), vstep, pdfp[0], dt, pdfp[1])) {
820 fclose(pdfp[0]);
821 if (pdfp[1]) (dfname[0] == '!') ? pclose(pdfp[1]) : fclose(pdfp[1]);
822 Cleanup();
823 return RDTnone;
824 }
825 NewBar(); // clean up and return
826 if (pdfp[0] != stdout)
827 fclose(pdfp[0]);
828 if (pdfp[1]) {
829 if (dfname[0] == '!') {
830 int status = pclose(pdfp[1]);
831 if (status) {
832 sprintf(errmsg, "depth output (%s) error status: %d",
833 dfname, status);
834 error(USER, errmsg);
835 return RDTnone;
836 }
837 } else
838 fclose(pdfp[1]);
839 }
840 return dt;
841 }
842
843 // passed struct for header line callback
844 static struct HeaderInfo {
845 char fmt[MAXFMTLEN];
846 char depth_unit[32];
847 int ncomp;
848 RGBPRIMS prims;
849 VIEW vw;
850 bool gotWL;
851 bool gotprims;
852 bool gotview;
853 bool endianMatch;
854
855 HeaderInfo() {
856 strcpy(fmt, "MISSING");
857 depth_unit[0] = '\0';
858 ncomp = 3;
859 vw = stdview;
860 gotWL = false;
861 gotprims = false;
862 gotview = false;
863 endianMatch = true;
864 }
865 } hinfo; // XXX single copy to hold custom primitives
866
867 // helper function checks header line and records req. info.
868 static int
869 head_check(char *s, void *p)
870 {
871 HeaderInfo * hp = (HeaderInfo *)p;
872 int rval;
873
874 if (isncomp(s)) {
875 hp->ncomp = ncompval(s);
876 return 1;
877 }
878 if (iswlsplit(s)) {
879 hp->gotWL = wlsplitval(WLPART, s);
880 return 1;
881 }
882 if (isprims(s)) {
883 hp->gotprims = primsval(hp->prims, s);
884 return 1;
885 }
886 if (isview(s)) {
887 hp->gotview |= (sscanview(&hp->vw, s) > 0);
888 return 1;
889 }
890 if (!strncmp(s, DEPTHSTR, LDEPTHSTR)) {
891 strlcpy(hp->depth_unit, s+LDEPTHSTR, sizeof(hp->depth_unit));
892 char * cp = hp->depth_unit;
893 while (*cp) cp++;
894 while (cp > hp->depth_unit && isspace(cp[-1])) cp--;
895 *cp = '\0';
896 return 1;
897 }
898 if ((rval = isbigendian(s)) >= 0) {
899 hp->endianMatch = (rval == nativebigendian());
900 return 1;
901 }
902 if (formatval(hp->fmt, s))
903 return 1;
904 return 0;
905 }
906
907 // Reopen output file(s), leaving pointers at end of (each) header
908 RenderDataType
909 RpictSimulManager::ReopenOutput(FILE *pdfp[2], const char *pfname, const char *dfname)
910 {
911 extern const char HDRSTR[];
912
913 if (!pfname || pfname[0] == '!') {
914 pdfp[0] = pdfp[1] = NULL;
915 return RDTnone;
916 }
917 RenderDataType dt = RDTnone;
918 pdfp[1] = NULL;
919 pdfp[0] = fopen(pfname, "r+");
920 if (!pdfp[0]) {
921 sprintf(errmsg, "cannot reopen output picture '%s'", pfname);
922 error(SYSTEM, errmsg);
923 return RDTnone;
924 }
925 SET_FILE_BINARY(pdfp[0]); // read header information
926 if (getheader(pdfp[0], head_check, &hinfo) < 0) {
927 fclose(pdfp[0]);
928 pdfp[0] = NULL;
929 return RDTnone;
930 }
931 if (!hinfo.gotview) {
932 sprintf(errmsg, "missing view for '%s'", pfname);
933 error(USER, errmsg);
934 fclose(pdfp[0]);
935 pdfp[0] = NULL;
936 return RDTnone;
937 }
938 if (hinfo.ncomp < 3) {
939 sprintf(errmsg, "bad # components (%d) in '%s'", hinfo.ncomp, pfname);
940 error(USER, errmsg);
941 fclose(pdfp[0]);
942 pdfp[0] = NULL;
943 return RDTnone;
944 }
945 // set rendering/output space
946 if (!strcmp(hinfo.fmt, COLRFMT)) {
947 prims = hinfo.prims; // XXX static array
948 int n = 8*hinfo.gotprims;
949 while (n--)
950 if (!FABSEQ(hinfo.prims[0][n], stdprims[0][n]))
951 break;
952 if (n < 0)
953 prims = stdprims;
954 dt = RDTnewCT(dt, RDTrgbe);
955 } else if (!strcmp(hinfo.fmt, CIEFMT)) {
956 prims = xyzprims;
957 dt = RDTnewCT(dt, RDTxyze);
958 } else if (!strcmp(hinfo.fmt, SPECFMT)) {
959 if ((hinfo.ncomp <= 3) | (hinfo.ncomp > MAXCSAMP)) {
960 sprintf(errmsg, "incompatible sample count (%d) in '%s'",
961 hinfo.ncomp, pfname);
962 error(USER, errmsg);
963 fclose(pdfp[0]);
964 pdfp[0] = NULL;
965 return RDTnone;
966 }
967 NCSAMP = hinfo.ncomp; // overrides global setting
968 prims = NULL;
969 dt = RDTnewCT(dt, RDTscolr);
970 } else if (!strcmp(hinfo.fmt, "float")) {
971 if (!hinfo.endianMatch) {
972 sprintf(errmsg, "incompatible byte ordering in '%s'", pfname);
973 error(USER, errmsg);
974 fclose(pdfp[0]);
975 pdfp[0] = NULL;
976 return RDTnone;
977 }
978 if (hinfo.ncomp == 3) {
979 prims = hinfo.prims; // custom primaries?
980 int n = 8*hinfo.gotprims;
981 while (n--)
982 if (!FABSEQ(hinfo.prims[0][n], stdprims[0][n]))
983 break;
984 if (n < 0) // standard primaries?
985 prims = stdprims;
986 else if (hinfo.gotprims) { // or check if XYZ
987 for (n = 8; n--; )
988 if (!FABSEQ(prims[0][n], xyzprims[0][n]))
989 break;
990 if (n < 0)
991 prims = xyzprims;
992 }
993 if (prims == xyzprims)
994 dt = RDTnewCT(dt, RDTxyz);
995 else
996 dt = RDTnewCT(dt, RDTrgb);
997 } else {
998 NCSAMP = hinfo.ncomp; // overrides global setting
999 prims = NULL;
1000 dt = RDTnewCT(dt, RDTscolor);
1001 }
1002 } else {
1003 sprintf(errmsg, "unknown format (%s) for '%s'", hinfo.fmt, pfname);
1004 error(USER, errmsg);
1005 fclose(pdfp[0]);
1006 pdfp[0] = NULL;
1007 return RDTnone;
1008 }
1009 if (hinfo.gotview) { // header view overrides
1010 pvw = vw;
1011 vw = hinfo.vw;
1012 }
1013 if (!dfname) // no depth file?
1014 return dt;
1015
1016 if (dfname[0] == '!') {
1017 error(USER, "depth data cannot be reloaded from command");
1018 fclose(pdfp[0]);
1019 pdfp[0] = NULL;
1020 return RDTnone;
1021 }
1022 pdfp[1] = fopen(dfname, "r+");
1023 if (!pdfp[1]) {
1024 sprintf(errmsg, "cannot reopen depth file '%s'", dfname);
1025 error(SYSTEM, errmsg);
1026 fclose(pdfp[0]);
1027 pdfp[0] = NULL;
1028 return RDTnone;
1029 }
1030 SET_FILE_BINARY(pdfp[1]);
1031 int n, len = strlen(HDRSTR);
1032 char buf[32]; // sniff for 16-bit header
1033 if (getbinary(buf, 1, len+1, pdfp[1]) < len+1) {
1034 sprintf(errmsg, "empty depth file '%s'", dfname);
1035 error(SYSTEM, errmsg);
1036 fclose(pdfp[0]); fclose(pdfp[1]);
1037 pdfp[0] = pdfp[1] = NULL;
1038 return RDTnone;
1039 }
1040 for (n = 0; n < len; n++)
1041 if (buf[n] != HDRSTR[n])
1042 break; // not a Radiance header
1043 rewind(pdfp[1]);
1044 if ((n < len) | !isprint(buf[len]))
1045 return RDTnewDT(dt, RDTdfloat);
1046
1047 HeaderInfo dinfo; // thinking it's 16-bit encoded
1048 if (getheader(pdfp[1], head_check, &dinfo) < 0)
1049 sprintf(errmsg, "bad header in encoded depth file '%s'",
1050 dfname);
1051 else if (strcmp(dinfo.fmt, DEPTH16FMT))
1052 sprintf(errmsg, "wrong format (%s) for depth file '%s'",
1053 dinfo.fmt, dfname);
1054 else if (!SetReferenceDepth(dinfo.depth_unit))
1055 sprintf(errmsg, "bad/missing reference depth (%s) in '%s'",
1056 dinfo.depth_unit, dfname);
1057 else
1058 errmsg[0] = '\0';
1059
1060 if (errmsg[0]) {
1061 error(USER, errmsg);
1062 fclose(pdfp[1]); fclose(pdfp[0]);
1063 pdfp[0] = pdfp[1] = NULL;
1064 return RDTnone;
1065 }
1066 return RDTnewDT(dt, RDTdshort);
1067 }
1068
1069 // Resume partially finished rendering
1070 // Picture file must exist
1071 RenderDataType
1072 RpictSimulManager::ResumeFrame(const char *pfname, const char *dfname)
1073 {
1074 FILE *pdfp[2];
1075
1076 RenderDataType dt = ReopenOutput(pdfp, pfname, dfname);
1077 if (dt == RDTnone)
1078 return RDTnone;
1079
1080 int bytesPer = 0; // figure out how far we got...
1081 switch (RDTcolorT(dt)) {
1082 case RDTrgbe:
1083 case RDTxyze:
1084 break;
1085 case RDTscolr:
1086 bytesPer = NCSAMP + 1; // XXX assumes no compression
1087 break;
1088 case RDTrgb:
1089 case RDTxyz:
1090 bytesPer = sizeof(float)*3;
1091 break;
1092 case RDTscolor:
1093 bytesPer = sizeof(float)*NCSAMP;
1094 break;
1095 default:
1096 sprintf(errmsg, "unknown format for '%s'", pfname);
1097 error(USER, errmsg);
1098 fclose(pdfp[0]);
1099 if (pdfp[1]) fclose(pdfp[1]);
1100 return RDTnone;
1101 }
1102 RESOLU res;
1103 if (!fgetsresolu(&res, pdfp[0]) || res.rt != PIXSTANDARD) {
1104 sprintf(errmsg, "missing/bad resolution for '%s'", pfname);
1105 error(USER, errmsg);
1106 fclose(pdfp[0]);
1107 if (pdfp[1]) fclose(pdfp[1]);
1108 return RDTnone;
1109 }
1110 frameNo = 0; // set up unreferenced frame
1111 int hvdim[2] = {res.xr, res.yr};
1112 double noAdj = 0;
1113 if (!NewFrame(vw, hvdim, &noAdj) ||
1114 (hvdim[0] != res.xr) | (hvdim[1] != res.yr)) {
1115 error(CONSISTENCY, "unexpected resolution change in ResumeFrame()");
1116 fclose(pdfp[0]);
1117 if (pdfp[1]) fclose(pdfp[1]);
1118 return RDTnone;
1119 }
1120 long dataStart = ftell(pdfp[0]); // picture starting point
1121 if (dataStart < 0) {
1122 sprintf(errmsg, "cannot seek on '%s'", pfname);
1123 error(SYSTEM, errmsg);
1124 fclose(pdfp[0]);
1125 if (pdfp[1]) fclose(pdfp[1]);
1126 return RDTnone;
1127 }
1128 long doneScans = 0;
1129 if (bytesPer) { // fixed-width records?
1130 fseek(pdfp[0], 0, SEEK_END);
1131 long dataEnd = ftell(pdfp[0]);
1132 doneScans = (dataEnd - dataStart)/(bytesPer*GetWidth());
1133 if (dataEnd-dataStart > bytesPer*GetWidth()*doneScans)
1134 fseek(pdfp[0], dataStart + bytesPer*GetWidth()*doneScans, SEEK_SET);
1135 } else { // else get compressed scanlines
1136 COLR * scan = (COLR *)tempbuffer(sizeof(COLR)*GetWidth());
1137 while (freadcolrs(scan, GetWidth(), pdfp[0]) >= 0)
1138 ++doneScans;
1139 if (!feof(pdfp[0])) {
1140 sprintf(errmsg, "error reading compressed scanline from '%s'", pfname);
1141 error(USER, errmsg);
1142 fclose(pdfp[0]);
1143 if (pdfp[1]) fclose(pdfp[1]);
1144 return RDTnone;
1145 }
1146 }
1147 if (doneScans >= GetHeight()) { // nothing left to do?
1148 sprintf(errmsg, "output file '%s' is already complete", pfname);
1149 error(WARNING, errmsg);
1150 fclose(pdfp[0]);
1151 if (pdfp[1]) fclose(pdfp[1]);
1152 return dt;
1153 }
1154 if (!doneScans) {
1155 sprintf(errmsg, "restarting empty frame '%s'", pfname);
1156 error(WARNING, errmsg);
1157 }
1158 long toSkip = 0;
1159 switch (RDTdepthT(dt)) { // append depth file, too?
1160 case RDTdfloat:
1161 toSkip = sizeof(float)*GetWidth()*doneScans;
1162 break;
1163 case RDTdshort:
1164 if (!fgetsresolu(&res, pdfp[1]) || (res.rt != PIXSTANDARD) |
1165 (res.xr != GetWidth()) | (res.yr != GetHeight())) {
1166 sprintf(errmsg, "missing/bad resolution for '%s'", dfname);
1167 error(USER, errmsg);
1168 fclose(pdfp[0]); fclose(pdfp[0]);
1169 return RDTnone;
1170 }
1171 toSkip = 2L*GetWidth()*doneScans;
1172 break;
1173 default:;
1174 } // fseek() needed for output
1175 if (pdfp[1] && fseek(pdfp[1], toSkip, SEEK_CUR) < 0) {
1176 sprintf(errmsg, "cannot seek on depth file '%s'", dfname);
1177 error(SYSTEM, errmsg);
1178 fclose(pdfp[0]); fclose(pdfp[1]);
1179 return RDTnone;
1180 }
1181 int bheight = (psample > 1) ? int(8*psample+.99) : 16;
1182 if (bheight > GetHeight()-doneScans)
1183 bheight = GetHeight()-doneScans;
1184 int vstep = bheight >> (psample > 1);
1185 vstep += !vstep;
1186
1187 NewBar(bheight); // render remainder if we can
1188 if (!RenderBelow(GetHeight()-doneScans, vstep, pdfp[0], dt, pdfp[1])) {
1189 fclose(pdfp[0]);
1190 if (pdfp[1]) fclose(pdfp[1]);
1191 Cleanup();
1192 return RDTnone;
1193 }
1194 NewBar(); // close up and return success
1195 fclose(pdfp[0]);
1196 if (pdfp[1]) fclose(pdfp[1]);
1197 return dt;
1198 }