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

Comparing ray/src/rt/rc2.c (file contents):
Revision 2.1 by greg, Sat Jun 9 07:16:47 2012 UTC vs.
Revision 2.26 by greg, Wed Nov 15 18:02:53 2023 UTC

# Line 6 | Line 6 | static const char RCSid[] = "$Id$";
6   * File i/o and recovery
7   */
8  
9 + #include <ctype.h>
10 + #include "platform.h"
11   #include "rcontrib.h"
12   #include "resolu.h"
11 – #include "platform.h"
13  
14 + /* Close output stream and free record */
15 + static void
16 + closestream(void *p)
17 + {
18 +        STREAMOUT       *sop = (STREAMOUT *)p;
19 +        
20 +        if (sop->ofp != NULL) {
21 +                int     status = 0;
22 +                if (sop->outpipe)
23 +                        status = pclose(sop->ofp);
24 +                else if (sop->ofp != stdout)
25 +                        status = fclose(sop->ofp);
26 +                if (status)
27 +                        error(SYSTEM, "error closing output stream");
28 +        }
29 +        free(p);
30 + }
31 +
32 + LUTAB   ofiletab = LU_SINIT(free,closestream);  /* output file table */
33 +
34   #define OF_MODIFIER     01
35   #define OF_BIN          02
36  
# Line 83 | Line 104 | printheader(FILE *fout, const char *info)
104                  if (octname[strlen(octname)-1] != '\n')
105                          fputc('\n', fout);
106          } else {
107 <                FILE    *fin = fopen(octname, "r");
107 >                FILE    *fin = fopen(octname, (outfmt=='a') ? "r" : "rb");
108                  if (fin == NULL)
109                          quit(1);
110 <                checkheader(fin, "ignore", fout);
110 >                checkheader(fin, OCTFMT, fout);
111                  fclose(fin);
112          }
113          printargs(gargc-1, gargv, fout);        /* add our command */
114          fprintf(fout, "SOFTWARE= %s\n", VersionID);
115          fputnow(fout);
116 +        fputncomp(NCSAMP, fout);
117          if (info != NULL)                       /* add extra info if given */
118                  fputs(info, fout);
119 +        if ((outfmt == 'f') | (outfmt == 'd'))
120 +                fputendian(fout);
121          fputformat(formstr(outfmt), fout);
122          fputc('\n', fout);                      /* empty line ends header */
123   }
# Line 112 | Line 136 | printresolu(FILE *fout, int xr, int yr)
136   STREAMOUT *
137   getostream(const char *ospec, const char *mname, int bn, int noopen)
138   {
115 –        /* static const DCOLOR  nocontrib = BLKCOLOR; */
139          static STREAMOUT        stdos;
140 +        char                    info[1024];
141          int                     ofl;
142          char                    oname[1024];
143          LUENT                   *lep;
144          STREAMOUT               *sop;
145 <        
145 >        char                    *cp;
146 >
147 >        info[0] = '\0';
148          if (ospec == NULL) {                    /* use stdout? */
149 <                if (!noopen && !using_stdout) {
149 >                if (!noopen & !using_stdout) {
150                          if (outfmt != 'a')
151                                  SET_FILE_BINARY(stdout);
126 –                        if (header)
127 –                                printheader(stdout, NULL);
128 –                        printresolu(stdout, xres, yres);
129 –                        if (waitflush > 0)
130 –                                fflush(stdout);
131 –                        stdos.xr = xres; stdos.yr = yres;
152   #ifdef getc_unlocked
153                          flockfile(stdout);      /* avoid lock/unlock overhead */
154   #endif
155 +                        if (header) {
156 +                                cp = info;
157 +                                if (yres > 0) {
158 +                                        sprintf(cp, "NROWS=%d\n", yres *
159 +                                                        (xres + !xres) );
160 +                                        while (*cp) ++cp;
161 +                                }
162 +                                if ((xres <= 0) | (stdos.reclen > 1))
163 +                                        sprintf(cp, "NCOLS=%d\n", stdos.reclen);
164 +                                printheader(stdout, info);
165 +                        }
166 +                        if (stdos.reclen == 1)
167 +                                printresolu(stdout, xres, yres);
168 +                        if (waitflush > 0)
169 +                                fflush(stdout);
170 +                        stdos.xr = xres; stdos.yr = yres;
171                          using_stdout = 1;
172                  }
173                  stdos.ofp = stdout;
# Line 151 | Line 187 | getostream(const char *ospec, const char *mname, int b
187                  sop = (STREAMOUT *)malloc(sizeof(STREAMOUT));
188                  if (sop == NULL)
189                          error(SYSTEM, "out of memory in getostream");
190 <                sop->outpipe = oname[0] == '!';
190 >                sop->outpipe = (oname[0] == '!');
191                  sop->reclen = 0;
192                  sop->ofp = NULL;                /* open iff noopen==0 */
193                  sop->xr = xres; sop->yr = yres;
# Line 161 | Line 197 | getostream(const char *ospec, const char *mname, int b
197                          errno = EEXIST;         /* file exists */
198                          goto openerr;
199                  }
200 +        } else if (noopen && outfmt == 'c' &&   /* stream exists to picture? */
201 +                        (sop->xr > 0) & (sop->yr > 0)) {
202 +                if (ofl & OF_BIN)
203 +                        return(NULL);           /* let caller offset bins */
204 +                sprintf(errmsg, "output '%s' not a valid picture", oname);
205 +                error(WARNING, errmsg);
206          }
207          if (!noopen && sop->ofp == NULL) {      /* open output stream */
166 –                long            i;
208                  if (oname[0] == '!')            /* output to command */
209                          sop->ofp = popen(oname+1, "w");
210                  else                            /* else open file */
# Line 175 | Line 216 | getostream(const char *ospec, const char *mname, int b
216   #ifdef getc_unlocked
217                  flockfile(sop->ofp);            /* avoid lock/unlock overhead */
218   #endif
219 +                if (accumulate > 0) {           /* global resolution */
220 +                        sop->xr = xres; sop->yr = yres;
221 +                }
222                  if (header) {
223 <                        char    info[512];
180 <                        char    *cp = info;
223 >                        cp = info;
224                          if (ofl & OF_MODIFIER || sop->reclen == 1) {
225                                  sprintf(cp, "MODIFIER=%s\n", mname);
226                                  while (*cp) ++cp;
# Line 186 | Line 229 | getostream(const char *ospec, const char *mname, int b
229                                  sprintf(cp, "BIN=%d\n", bn);
230                                  while (*cp) ++cp;
231                          }
232 <                        *cp = '\0';
232 >                        if (sop->yr > 0) {
233 >                                sprintf(cp, "NROWS=%d\n", sop->yr *
234 >                                                (sop->xr + !sop->xr) );
235 >                                while (*cp) ++cp;
236 >                        }
237 >                        if ((sop->xr <= 0) | (sop->reclen > 1))
238 >                                sprintf(cp, "NCOLS=%d\n", sop->reclen);
239                          printheader(sop->ofp, info);
240                  }
241 <                if (accumulate > 0) {           /* global resolution */
242 <                        sop->xr = xres; sop->yr = yres;
194 <                }
195 <                printresolu(sop->ofp, sop->xr, sop->yr);
196 < #if 0
197 <                                                /* play catch-up */
198 <                for (i = accumulate > 0 ? lastdone/accumulate : 0; i--; ) {
199 <                        int     j = sop->reclen;
200 <                        if (j <= 0) j = 1;
201 <                        while (j--)
202 <                                put_contrib(nocontrib, sop->ofp);
203 <                        if (outfmt == 'a')
204 <                                putc('\n', sop->ofp);
205 <                }
206 < #endif
241 >                if (sop->reclen == 1)
242 >                        printresolu(sop->ofp, sop->xr, sop->yr);
243                  if (waitflush > 0)
244                          fflush(sop->ofp);
245          }
# Line 235 | Line 271 | getvec(FVECT vec)
271                  }
272                  break;
273          case 'f':                                       /* binary float */
274 <                if (fread((char *)vf, sizeof(float), 3, stdin) != 3)
274 >                if (getbinary(vf, sizeof(float), 3, stdin) != 3)
275                          return(-1);
276                  VCOPY(vec, vf);
277                  break;
278          case 'd':                                       /* binary double */
279 <                if (fread((char *)vd, sizeof(double), 3, stdin) != 3)
279 >                if (getbinary(vd, sizeof(double), 3, stdin) != 3)
280                          return(-1);
281                  VCOPY(vec, vd);
282                  break;
# Line 253 | Line 289 | getvec(FVECT vec)
289  
290   /* Put out ray contribution to file */
291   static void
292 < put_contrib(const DCOLOR cnt, FILE *fout)
292 > put_contrib(const DCOLORV *cnt, FILE *fout)
293   {
294          double  sf = 1;
295 <        float   fv[3];
296 <        COLR    cv;
295 >        SCOLOR  fv;
296 >        SCOLR   cv;
297 >        int     i;
298  
299          if (accumulate > 1)
300                  sf = 1./(double)accumulate;
301          switch (outfmt) {
302          case 'a':
303 <                if (accumulate > 1)
304 <                        fprintf(fout, "%.6e\t%.6e\t%.6e\t",
268 <                                        sf*cnt[0], sf*cnt[1], sf*cnt[2]);
269 <                else
270 <                        fprintf(fout, "%.6e\t%.6e\t%.6e\t",
271 <                                        cnt[0], cnt[1], cnt[2]);
303 >                for (i = 0; i < NCSAMP; i++)
304 >                        fprintf(fout, "%.6e\t", sf*cnt[i]);
305                  break;
306          case 'f':
307 <                if (accumulate > 1) {
308 <                        fv[0] = sf*cnt[0]; fv[1] = sf*cnt[1]; fv[2] = sf*cnt[2];
309 <                } else
310 <                        copycolor(fv, cnt);
311 <                fwrite(fv, sizeof(float), 3, fout);
307 >                for (i = NCSAMP; i-- > 0; )
308 >                        fv[i] = cnt[i];
309 >                if (accumulate > 1)
310 >                        scalescolor(fv, sf);
311 >                putbinary(fv, sizeof(COLORV), NCSAMP, fout);
312                  break;
313          case 'd':
314                  if (accumulate > 1) {
315 <                        double  dv[3];
316 <                        dv[0] = sf*cnt[0]; dv[1] = sf*cnt[1]; dv[2] = sf*cnt[2];
317 <                        fwrite(dv, sizeof(double), 3, fout);
315 >                        DCOLORV dv[MAXCSAMP];
316 >                        for (i = NCSAMP; i-- > 0; )
317 >                                dv[i] = sf*cnt[i];
318 >                        putbinary(dv, sizeof(DCOLORV), NCSAMP, fout);
319                  } else
320 <                        fwrite(cnt, sizeof(double), 3, fout);
320 >                        putbinary(cnt, sizeof(DCOLORV), NCSAMP, fout);
321                  break;
322          case 'c':
323 +                for (i = NCSAMP; i-- > 0; )
324 +                        fv[i] = cnt[i];
325                  if (accumulate > 1)
326 <                        setcolr(cv, sf*cnt[0], sf*cnt[1], sf*cnt[2]);
327 <                else
328 <                        setcolr(cv, cnt[0], cnt[1], cnt[2]);
293 <                fwrite(cv, sizeof(cv), 1, fout);
326 >                        scalescolor(fv, sf);
327 >                scolor_scolr(cv, fv);
328 >                putbinary(cv, 1, LSCOLR, fout);
329                  break;
330          default:
331                  error(INTERNAL, "botched output format");
# Line 302 | Line 337 | put_contrib(const DCOLOR cnt, FILE *fout)
337   void
338   mod_output(MODCONT *mp)
339   {
340 <        STREAMOUT       *sop = getostream(mp->outspec, mp->modname, 0,0);
340 >        STREAMOUT       *sop = getostream(mp->outspec, mp->modname, mp->bin0, 0);
341          int             j;
342  
343 <        put_contrib(mp->cbin[0], sop->ofp);
343 >        put_contrib(mp->cbin, sop->ofp);
344          if (mp->nbins > 3 &&    /* minor optimization */
345 <                        sop == getostream(mp->outspec, mp->modname, 1,0))
345 >                        sop == getostream(mp->outspec, mp->modname, mp->bin0+1, 0)) {
346                  for (j = 1; j < mp->nbins; j++)
347 <                        put_contrib(mp->cbin[j], sop->ofp);
348 <        else
347 >                        put_contrib(mcbin(mp,j), sop->ofp);
348 >        } else {
349                  for (j = 1; j < mp->nbins; j++) {
350 <                        sop = getostream(mp->outspec, mp->modname,j,0);
351 <                        put_contrib(mp->cbin[j], sop->ofp);
350 >                        sop = getostream(mp->outspec, mp->modname, mp->bin0+j, 0);
351 >                        put_contrib(mcbin(mp,j), sop->ofp);
352                  }
353 +        }
354   }
355  
356  
# Line 341 | Line 377 | void
377   end_record()
378   {
379          --waitflush;
380 <        lu_doall(&ofiletab, puteol, NULL);
380 >        lu_doall(&ofiletab, &puteol, NULL);
381          if (using_stdout & (outfmt == 'a'))
382                  putc('\n', stdout);
383          if (!waitflush) {
# Line 355 | Line 391 | end_record()
391  
392   /* Get ray contribution from previous file */
393   static int
394 < get_contrib(DCOLOR cnt, FILE *finp)
394 > get_contrib(DCOLORV *cnt, FILE *finp)
395   {
396 <        COLOR   fv;
397 <        COLR    cv;
396 >        SCOLOR  fv;
397 >        SCOLR   cv;
398 >        int     i;
399  
400          switch (outfmt) {
401          case 'a':
402 <                return(fscanf(finp,"%lf %lf %lf",&cnt[0],&cnt[1],&cnt[2]) == 3);
403 <        case 'f':
404 <                if (fread(fv, sizeof(fv[0]), 3, finp) != 3)
368 <                        return(0);
369 <                copycolor(cnt, fv);
402 >                for (i = 0; i < NCSAMP; i++)
403 >                        if (fscanf(finp, "%lf", &cnt[i]) != 1)
404 >                                return(0);
405                  return(1);
406          case 'd':
407 <                return(fread(cnt, sizeof(cnt[0]), 3, finp) == 3);
407 >                return(getbinary(cnt, sizeof(DCOLORV), NCSAMP, finp) == NCSAMP);
408 >        case 'f':
409 >                if (getbinary(fv, sizeof(COLORV), NCSAMP, finp) != NCSAMP)
410 >                        return(0);
411 >                break;
412          case 'c':
413 <                if (fread(cv, sizeof(cv), 1, finp) != 1)
413 >                if (getbinary(cv, 1, LSCOLR, finp) != LSCOLR)
414                          return(0);
415 <                colr_color(fv, cv);
416 <                copycolor(cnt, fv);
378 <                return(1);
415 >                scolr_scolor(fv, cv);
416 >                break;
417          default:
418                  error(INTERNAL, "botched output format");
419          }
420 <        return(0);      /* pro forma return */
420 >                        /* copy result from SCOLOR */
421 >        for (i = NCSAMP; i-- > 0; )
422 >                cnt[i] = fv[i];
423 >        return(1);
424   }
425  
426  
# Line 409 | Line 450 | reload_output()
450          char            *outvfmt;
451          LUENT           *oent;
452          int             xr, yr;
453 <        STREAMOUT       sout;
454 <        DCOLOR          rgbv;
453 >        STREAMOUT       *sop;
454 >        DCOLORV         contr[MAXCSAMP];
455  
456          if (outfmt == 'a')
457                  fmode = "r";
458 <        outvfmt = formstr(outfmt);
458 >        outvfmt = (char *)formstr(outfmt);
459                                                  /* reload modifier values */
460          for (i = 0; i < nmods; i++) {
461                  mp = (MODCONT *)lu_find(&modconttab,modname[i])->data;
# Line 422 | Line 463 | reload_output()
463                          error(USER, "cannot reload from stdout");
464                  if (mp->outspec[0] == '!')
465                          error(USER, "cannot reload from command");
466 <                for (j = 0; ; j++) {            /* load each modifier bin */
467 <                        ofl = ofname(oname, mp->outspec, mp->modname, j);
466 >                for (j = 0; j < mp->nbins; j++) { /* load each modifier bin */
467 >                        ofl = ofname(oname, mp->outspec, mp->modname, mp->bin0+j);
468                          if (ofl < 0)
469                                  error(USER, "bad output file specification");
470                          oent = lu_find(&ofiletab, oname);
471 <                        if (oent->data != NULL) {
472 <                                sout = *(STREAMOUT *)oent->data;
473 <                        } else {
474 <                                sout.reclen = 0;
475 <                                sout.outpipe = 0;
476 <                                sout.xr = xres; sout.yr = yres;
436 <                                sout.ofp = NULL;
437 <                        }
438 <                        if (sout.ofp == NULL) { /* open output as input */
439 <                                sout.ofp = fopen(oname, fmode);
440 <                                if (sout.ofp == NULL) {
441 <                                        if (j == mp->nbins)
442 <                                                break;  /* assume end of modifier */
471 >                        if (oent->data == NULL)
472 >                                error(INTERNAL, "unallocated stream in reload_output()");
473 >                        sop = (STREAMOUT *)oent->data;
474 >                        if (sop->ofp == NULL) { /* open output as input */
475 >                                sop->ofp = fopen(oname, fmode);
476 >                                if (sop->ofp == NULL) {
477                                          sprintf(errmsg, "missing reload file '%s'",
478                                                          oname);
479                                          error(WARNING, errmsg);
480                                          break;
481                                  }
482   #ifdef getc_unlocked
483 <                                flockfile(sout.ofp);
483 >                                flockfile(sop->ofp);
484   #endif
485 <                                if (header && checkheader(sout.ofp, outvfmt, NULL) != 1) {
485 >                                if (header && checkheader(sop->ofp, outvfmt, NULL) != 1) {
486                                          sprintf(errmsg, "format mismatch for '%s'",
487                                                          oname);
488                                          error(USER, errmsg);
489                                  }
490 <                                if ((sout.xr > 0) & (sout.yr > 0) &&
491 <                                                (!fscnresolu(&xr, &yr, sout.ofp) ||
492 <                                                        (xr != sout.xr) |
493 <                                                        (yr != sout.yr))) {
490 >                                if ((sop->reclen == 1) & (sop->xr > 0) & (sop->yr > 0) &&
491 >                                                (!fscnresolu(&xr, &yr, sop->ofp) ||
492 >                                                        (xr != sop->xr) |
493 >                                                        (yr != sop->yr))) {
494                                          sprintf(errmsg, "resolution mismatch for '%s'",
495                                                          oname);
496                                          error(USER, errmsg);
497                                  }
498                          }
499 <                                                        /* read in RGB value */
500 <                        if (!get_contrib(rgbv, sout.ofp)) {
499 >                                                        /* read in spectral value */
500 >                        if (!get_contrib(contr, sop->ofp)) {
501                                  if (!j) {
502 <                                        fclose(sout.ofp);
502 >                                        fclose(sop->ofp);
503                                          break;          /* ignore empty file */
504                                  }
505                                  if (j < mp->nbins) {
# Line 475 | Line 509 | reload_output()
509                                  }
510                                  break;
511                          }
512 <                        if (j >= mp->nbins) {           /* check modifier size */
479 <                                sprintf(errmsg,
480 <                                "mismatched -bn setting for reloading '%s'",
481 <                                                modname[i]);
482 <                                error(USER, errmsg);
483 <                        }
484 <                                
485 <                        copycolor(mp->cbin[j], rgbv);
486 <                        if (oent->key == NULL)          /* new file entry */
487 <                                oent->key = strcpy((char *)
488 <                                                malloc(strlen(oname)+1), oname);
489 <                        if (oent->data == NULL)
490 <                                oent->data = (char *)malloc(sizeof(STREAMOUT));
491 <                        *(STREAMOUT *)oent->data = sout;
512 >                        memcpy(mcbin(mp,j), contr, DCOLORSIZ);
513                  }
514          }
515 <        lu_doall(&ofiletab, myclose, NULL);     /* close all files */
515 >        lu_doall(&ofiletab, &myclose, NULL);    /* close all files */
516   }
517  
518  
# Line 503 | Line 524 | myseeko(const LUENT *e, void *p)
524          off_t           nbytes = *(off_t *)p;
525          
526          if (sop->reclen > 1)
527 <                nbytes = nbytes * sop->reclen;
527 >                nbytes *= (off_t)sop->reclen;
528          if (fseeko(sop->ofp, nbytes, SEEK_CUR) < 0) {
529                  sprintf(errmsg, "seek error on file '%s'", e->key);
530                  error(SYSTEM, errmsg);
# Line 524 | Line 545 | recover_output()
545          int             ofl;
546          char            oname[1024];
547          LUENT           *oent;
548 <        STREAMOUT       sout;
548 >        STREAMOUT       *sop;
549          off_t           nvals;
550          int             xr, yr;
551  
# Line 533 | Line 554 | recover_output()
554                  error(USER, "cannot recover ASCII output");
555                  return;
556          case 'f':
557 <                outvsiz = sizeof(float)*3;
557 >                outvsiz = sizeof(float)*NCSAMP;
558                  break;
559          case 'd':
560 <                outvsiz = sizeof(double)*3;
560 >                outvsiz = sizeof(double)*NCSAMP;
561                  break;
562          case 'c':
563 <                outvsiz = sizeof(COLR);
563 >                outvsiz = LSCOLR;
564                  break;
565          default:
566                  error(INTERNAL, "botched output format");
567                  return;
568          }
569 <        outvfmt = formstr(outfmt);
569 >        outvfmt = (char *)formstr(outfmt);
570                                                  /* check modifier outputs */
571          for (i = 0; i < nmods; i++) {
572                  mp = (MODCONT *)lu_find(&modconttab,modname[i])->data;
# Line 553 | Line 574 | recover_output()
574                          error(USER, "cannot recover from stdout");
575                  if (mp->outspec[0] == '!')
576                          error(USER, "cannot recover from command");
577 <                for (j = 0; ; j++) {            /* check each bin's file */
578 <                        ofl = ofname(oname, mp->outspec, mp->modname, j);
577 >                for (j = 0; j < mp->nbins; j++) { /* check each bin's file */
578 >                        ofl = ofname(oname, mp->outspec, mp->modname, mp->bin0+j);
579                          if (ofl < 0)
580                                  error(USER, "bad output file specification");
581                          oent = lu_find(&ofiletab, oname);
582 <                        if (oent->data != NULL) {
583 <                                sout = *(STREAMOUT *)oent->data;
584 <                        } else {
585 <                                sout.reclen = 0;
565 <                                sout.outpipe = 0;
566 <                                sout.ofp = NULL;
567 <                        }
568 <                        if (sout.ofp != NULL) { /* already open? */
582 >                        if (oent->data == NULL)
583 >                                error(INTERNAL, "unallocated stream in recover_output()");
584 >                        sop = (STREAMOUT *)oent->data;
585 >                        if (sop->ofp != NULL) { /* already open? */
586                                  if (ofl & OF_BIN)
587                                          continue;
588                                  break;
589                          }
590                                                  /* open output */
591 <                        sout.ofp = fopen(oname, "rb+");
592 <                        if (sout.ofp == NULL) {
576 <                                if (j == mp->nbins)
577 <                                        break;  /* assume end of modifier */
591 >                        sop->ofp = fopen(oname, "rb+");
592 >                        if (sop->ofp == NULL) {
593                                  sprintf(errmsg, "missing recover file '%s'",
594                                                  oname);
595                                  error(WARNING, errmsg);
596 +                                lastout = 0;
597                                  break;
598                          }
599 <                        nvals = lseek(fileno(sout.ofp), 0, SEEK_END);
599 >                        nvals = lseek(fileno(sop->ofp), 0, SEEK_END);
600                          if (nvals <= 0) {
601                                  lastout = 0;    /* empty output, quit here */
602 <                                fclose(sout.ofp);
602 >                                fclose(sop->ofp);
603                                  break;
604                          }
605 <                        if (!sout.reclen) {
590 <                                if (!(ofl & OF_BIN)) {
591 <                                        sprintf(errmsg,
592 <                                                "need -bn to recover file '%s'",
593 <                                                        oname);
594 <                                        error(USER, errmsg);
595 <                                }
596 <                                recsiz = outvsiz;
597 <                        } else
598 <                                recsiz = outvsiz * sout.reclen;
605 >                        recsiz = outvsiz * sop->reclen;
606  
607 <                        lseek(fileno(sout.ofp), 0, SEEK_SET);
608 <                        if (header && checkheader(sout.ofp, outvfmt, NULL) != 1) {
607 >                        lseek(fileno(sop->ofp), 0, SEEK_SET);
608 >                        if (header && checkheader(sop->ofp, outvfmt, NULL) != 1) {
609                                  sprintf(errmsg, "format mismatch for '%s'",
610                                                  oname);
611                                  error(USER, errmsg);
612                          }
613 <                        sout.xr = xres; sout.yr = yres;
614 <                        if ((sout.xr > 0) & (sout.yr > 0) &&
615 <                                        (!fscnresolu(&xr, &yr, sout.ofp) ||
616 <                                                (xr != sout.xr) |
610 <                                                (yr != sout.yr))) {
613 >                        if ((sop->reclen == 1) & (sop->xr > 0) & (sop->yr > 0) &&
614 >                                        (!fscnresolu(&xr, &yr, sop->ofp) ||
615 >                                                (xr != sop->xr) |
616 >                                                (yr != sop->yr))) {
617                                  sprintf(errmsg, "resolution mismatch for '%s'",
618                                                  oname);
619                                  error(USER, errmsg);
620                          }
621 <                        nvals = (nvals - (off_t)ftell(sout.ofp)) / recsiz;
621 >                        nvals = (nvals - (off_t)ftell(sop->ofp)) / recsiz;
622                          if ((lastout < 0) | (nvals < lastout))
623                                  lastout = nvals;
618 –                        if (oent->key == NULL)  /* new entry */
619 –                                oent->key = strcpy((char *)
620 –                                                malloc(strlen(oname)+1), oname);
621 –                        if (oent->data == NULL)
622 –                                oent->data = (char *)malloc(sizeof(STREAMOUT));
623 –                        *(STREAMOUT *)oent->data = sout;
624                          if (!(ofl & OF_BIN))
625                                  break;          /* no bin separation */
626                  }
627                  if (!lastout) {                 /* empty output */
628                          error(WARNING, "no previous data to recover");
629 <                        lu_done(&ofiletab);     /* reclose all outputs */
629 >                                                /* reclose all outputs */
630 >                        lu_doall(&ofiletab, &myclose, NULL);
631                          return;
632                  }
632 –                if (j > mp->nbins) {            /* check modifier size */
633 –                        sprintf(errmsg,
634 –                                "mismatched -bn setting for recovering '%s'",
635 –                                        modname[i]);
636 –                        error(USER, errmsg);
637 –                }
633          }
634          if (lastout < 0) {
635                  error(WARNING, "no output files to recover");
# Line 647 | Line 642 | recover_output()
642          }
643                                                  /* seek on all files */
644          nvals = lastout * outvsiz;
645 <        lu_doall(&ofiletab, myseeko, &nvals);
645 >        lu_doall(&ofiletab, &myseeko, &nvals);
646                                                  /* skip repeated input */
647 +        lastout *= accumulate;
648          for (nvals = 0; nvals < lastout; nvals++) {
649                  FVECT   vdummy;
650                  if (getvec(vdummy) < 0 || getvec(vdummy) < 0)
651                          error(USER, "unexpected EOF on input");
652          }
653 <        lastray = lastdone = lastout * accumulate;
653 >        lastray = lastdone = (RNUMBER)lastout;
654          if (raysleft)
655                  raysleft -= lastray;
656   }

Diff Legend

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